Go微服务

RPC协议

Remote Procedure Call Protocol，远程过程调用协议，IPC是进程间通信，RPC是远程进程通信。

服务端和客户端编码实现

服务端：

package main

import (
  "fmt"
  "net"
  "net/rpc"
)

// 定义类对象
type World struct {
}

// 绑定类方法
func (this *World) SayHello(name string, resp *string) error {
  *resp = name + " 你好！"
  return nil
}

func main() {
  // 1. 注册RPC服务，绑定对象方法
  err := rpc.RegisterName("hello", new(World))
  if err != nil {
    fmt.Println("注册RPC服务失败:", err)
    return
  }

  // 2. 创建RPC服务器，监听端口
  listen, err := net.Listen("tcp", "127.0.0.1:8080")
  if err != nil {
    fmt.Println("net.Listen err:", err)
  }
  defer listen.Close()
  fmt.Println("开始监听...")

  // 3. 建立连接
  conn, err := listen.Accept()
  if err != nil {
    fmt.Println("Accept err:", err)
  }
  defer conn.Close()
  fmt.Println("连接成功...")

  // 4. 绑定服务
  rpc.ServeConn(conn)
}

客户端：

package main

import (
  "fmt"
  "net/rpc"
)

func main() {
  // 1. 用RPC连接服务器
  conn, err := rpc.Dial("tcp", "127.0.0.1:8080")
  if err != nil {
    fmt.Println("Dial err:", err)
    return
  }
  defer conn.Close()

  // 2. 调用远程函数
  var reply string
  err = conn.Call("hello.SayHello", "张三", &reply)
  if err != nil {
    fmt.Println("Call err:", err)
    return
  }

  fmt.Println("Reply:", reply)
}

JSON版RPC

修改服务端代码：jsonrpc.ServeConn(conn)

修改客户端代码：conn, err := jsonrpc.Dial("tcp", "127.0.0.1:8080")