/
srv.go
55 lines (44 loc) · 868 Bytes
/
srv.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
package main
import (
"fmt"
codec "github.com/ugorji/go/codec"
"log"
"net"
"net/rpc"
)
type Echo struct{}
func (e *Echo) Echo123(args []string, response *string) error {
log.Printf("args=%#v\n", args)
*response = fmt.Sprintf("%#v", args)
return nil
}
// dup'd in cli.go
type EchoArgument struct {
A string
B string
C string
}
func (e *Echo) EchoStruct(arg EchoArgument, response *string) error {
log.Printf("args=%#v\n", arg)
*response = fmt.Sprintf("%#v", arg)
return nil
}
func main() {
echo := &Echo{}
rpc.Register(echo)
ln, e := net.Listen("tcp", ":9000")
if e != nil {
log.Fatal("listen error:", e)
}
log.Println("rpc server starting")
for {
conn, err := ln.Accept()
if err != nil {
log.Println(err)
continue
}
var h codec.MsgpackHandle
c := codec.MsgpackSpecRpc.ServerCodec(conn, &h)
go rpc.ServeCodec(c)
}
}