GoWebRPC

Go 程序之间可以使用 net/rpc 包实现相互通信&＃xff0c;这是另一种客户端-服务器应用场景。它提供了一种方便的途径&＃xff0c;通过网络连接调用远程函数。当然&＃xff0c;仅当程序运行在不同机器上时&＃xff0c;这项技术才实用。rpc 包建立在 gob 包之上&＃xff0c;实现了自动编码/解码传输的跨网络方法调用。

服务器端需要注册一个对象实例&＃xff0c;与其类型名一起&＃xff0c;使之成为一项可见的服务&＃xff1a;它允许远程客户端跨越网络或其他 I/O 连接访问此对象已导出的方法。总之就是在网络上暴露类型的方法。

rpc 包使用了 http 和 tcp 协议&＃xff0c;以及用于数据传输的 gob 包。服务器端可以注册多个不同类型的对象&＃xff08;服务&＃xff09;&＃xff0c;但同一类型的多个对象会产生错误。

小结:

• Golang 提供RPC标准包&＃xff0c;支持开发 RPC 服务端和客户端&＃xff0c;采用 gob 编码。
• 支持三种请求方式&＃xff1a;HTTP、TCP 和 JSONRPC
• Golang RPC 函数必须特定的格式写法才能被远程调用&＃xff0c;格式如下&＃xff1a;

func (t *T) MethodName(argType T1, replyType *T2) error


T1 和 T2 必须能被 encoding/gob 包编码和解码

实例演示

服务端:

• 新增rpc服务 func (p *HelloService) Hello(request string, reply *string) error{}
• 注册rpc服务 rpc.Register(HelloService)
• 开启服务监听 net.Listen(“tcp”, “:5200”)

package mainimport ("fmt""log""net""net/rpc"
)type HelloService struct{}func (p *HelloService) Hello(request string, reply *string) error {*reply &＃61; "hello: " &＃43; requestfmt.Println("hello方法被调用,返回给客户端的结果为: ", *reply)return nil
}func main() {rpc.RegisterName("HelloService", new(HelloService))listener, err :&＃61; net.Listen("tcp", ":5200")if err !&＃61; nil {log.Fatal(err)}conn, err :&＃61; listener.Accept()if err !&＃61; nil {log.Fatal(err)}rpc.ServeConn(conn)
}

客户端:

• 连接rpc服务器 rpc.Dail(“tcp”, “localhost:5200”)
• 调用rpc服务 client.Call(“HelloService.Hello”, “chloe”, &reply)

package mainimport ("fmt""log""net/rpc"
)func main() {client, err :&＃61; rpc.Dial("tcp", "localhost:5200")if err !&＃61; nil {log.Fatal(err)}var reply stringerr &＃61; client.Call("HelloService.Hello", "chloe", &reply)if err !&＃61; nil {log.Fatal(err)}fmt.Println("远程调用,响应结果为: " &＃43; reply)
}

更多go rpc细节可以参考此文