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