Go日记——反向RPC

王者非凡

背景

通常的RPC是基于C/S结构，RPC的服务端对应网络的服务器，RPC的客户端也对应网络客户端。但是对于一些特殊场景，比如在公司内网提供一个RPC服务，但是在外网无法链接到内网的服务器。这种时候我们可以参考类似反向代理的技术，首先从内网主动链接到外网的TCP服务器，然后基于TCP链接向外网提供RPC服务。
声明接口

1. type HelloService struct {}
3. func (p *HelloService) Hello(request string, reply *string) error {
4.     *reply = "hello:" + request
5.     return nil
6. }

复制代码

反向RPC服务

1. func main() {
2.     rpc.Register(new(HelloService))
4.     for {
5.         conn, _ := net.Dial("tcp", "localhost:1234")
6.         if conn == nil {
7.             time.Sleep(time.Second)
8.             continue
9.         }
11.         rpc.ServeConn(conn)
12.         conn.Close()
13.     }
14. }

复制代码

反向RPC的内网服务将不再主动提供TCP监听服务，而是首先主动链接到对方的TCP服务器。然后基于每个建立的TCP链接向对方提供RPC服务。
RPC客户端

RPC客户端则需要在一个公共的地址提供一个TCP服务，用于接受RPC服务器的链接请求：
[code]func main() {    listener, err := net.Listen("tcp", ":1234")    if err != nil {        log.Fatal("ListenTCP error:", err)    }    clientChan := make(chan *rpc.Client)    go func() {        for {            conn, err := listener.Accept()            if err != nil {                log.Fatal("Accept error:", err)            }            clientChan