(request ziface.IRequest)
| 16 | } |
| 17 | |
| 18 | func (this *PositionClientRouter) Handle(request ziface.IRequest) { |
| 19 | fmt.Println("Handle....") |
| 20 | |
| 21 | msg := &pb.Position{} |
| 22 | err := proto.Unmarshal(request.GetData(), msg) |
| 23 | if err != nil { |
| 24 | fmt.Println("Position Unmarshal error ", err, " data = ", request.GetData()) |
| 25 | return |
| 26 | } |
| 27 | |
| 28 | fmt.Printf("recv from server : msgId=%+v, data=%+v\n", request.GetMsgID(), msg) |
| 29 | } |
| 30 | |
| 31 | // 客户端自定义业务 |
| 32 | func business(conn ziface.IConnection) { |