jsonrpc

定义rpc方法：

  1. type DemoService struct{}
  3. type Args struct {
  4.     A, B int
  5. }
  7. // go要求的RPC调用方法必须为两个参数：一个args， 一个result。返回error
  8. func (DemoService) Div(args Args, result *float64) error {
  9.     if args.B == 0 {
  10.         return errors.New("division by zero")
  11.     }
  13.     *result = float64(args.A) / float64(args.B)
  14.     return nil
  15. }

server

  1. func main() {
  3.     // 登记rpc接收方的方法
  4.     rpc.Register(rpcdemo.DemoService{})
  6.     // 创建一个tcp socket来监听1234端口，该端口用来监听rpc请求
  7.     listener, err := net.Listen("tcp", ":1234")
  8.     if err != nil {
  9.         panic(err)
  10.     }
  11.     defer listener.Close()
  13.     for {
  14.         // 接收rpc
  15.         conn, err := listener.Accept()
  16.         if err != nil {
  17.             log.Printf("accept error: %v", err)
  18.             continue
  19.         }
  21.         // 处理当前rpc
  22.         go jsonrpc.ServeConn(conn)
  23.     }
  24. }

client

  1. func main() {
  3.     // 建立tcp连接
  4.     conn, err := net.Dial("tcp", ":1234")
  5.     if err != nil {
  6.         panic(err)
  7.     }
  9.     client := jsonrpc.NewClient(conn)
  11.     var result float64
  12.     err = client.Call("DemoService.Div", rpcdemo.Args{10, 3}, &result)
  13.     if err != nil {
  14.         fmt.Println(err)
  15.     } else {
  16.         fmt.Println(result)
  17.     }
  19.     err = client.Call("DemoService.Div", rpcdemo.Args{10, 0}, &result)
  20.     if err != nil {
  21.         fmt.Println(err)
  22.     } else {
  23.         fmt.Println(result)
  24.     }
  25. }

rpc序列化和反序列化

image.png