用法

服务器初始化

s := wkrpc.New("tcp://127.0.0.1:10000")
defer s.Stop()

err = s.Start()

客户端初始化

cli := client.New("tcp://127.0.0.1:10000")
defer cli.Stop()

err = cli.Start()

用法一: Request/Response

server

s.Route("/hi", func(c *wkrpc.Context) {
	c.Write([]byte("reply"))
})

client

resp,_ := cli.Request("/hi", []byte("hi"))

fmt.Println(string(resp.Body)) // reply

用法二: Send/Receive

server

s.OnMessage(func(conn gnet.Conn, m *proto.Message) {
    fmt.Println(string(msg.Body)) // hi
})

client

err = cli.Send(&proto.Message{
	MsgType: 1,
	Content: []byte("hi"),
})