Go微服务:基于net/rpc模块实现微服务远程调用

基于RPC协议实现微服务

基于rpc实现跨语言调用，不限定服务提供方使用的语言
在微服务架构中，每个微服务都被封装成了进程，相互独立
在这里提供了客户端和服务端演示调用示例

1 ）服务端

新建 server/msg 目录，后执行 $ go mod init msg

编辑 server/msg/main.go 文件

package main// net 模块是go内置模块
import ("fmt""net""net/rpc"
)// 定义一个可供远程调用的struct
type Msg struct {}// 为Msg这个struct添加被调用函数 GetReplay
func (this Msg) GetReplay(req string, res *string) error {fmt.Println(req) // 服务端输出日志：请求参数*res = "这是服务端返回的信息：已收到客户端的请求参数，参数为：" + req // 这是返回信息return nil
}func main() {// 1. 注册RPC服务err1 := rpc.RegisterName("msg", new(Msg))// 错误处理if err1 != nil {fmt.Println(err1)}// 2、监听端口listener, err2 := net.Listen("tcp", "127.0.0.1:3000")if err2 != nil {fmt.Println(err2)}// 3、应用退出的时候关闭监听端口defer listener.Close()for {// 4、建立链接conn, err3 := listener.Accept()// 错误处理if err3 != nil {fmt.Println(err3)}fmt.Print("客户端参数为: ");// 5. 绑定服务rpc.ServeConn(conn)}
}

net包是一个 go 内置的一个模块
准备调用函数 Msg.GetReplay
- 此方法只能有两个可序列化的参数，注意第二个参数是指针类型
  - req 表示获取客户端传过来的数据
  - res 表示给客户端返回数据 (指针类型)
- 方法要返回一个 error 类型，同时必须是公开的方法
- req 和 res的类型不能是 channel（通道）、func（函数）
- 因为它们均不能进行序列化
整个流程如下:
- 1 ）通过 rpc.RegisterName 注册 rpc 服务，注意这里的 name 后期被客户端调用
- 2 ）通过 net.Listen 监听rpc服务，得到 listener 对象
- 3 ）通过 defer listener.Close() 应用退出时关闭监听端口
- 4 ）基于无限循环做响应处理，这里有两个环节
  - 4.1 ）通过 listener.Accept() 接收连接信息，得到 conn 连接对象
  - 4.2 ）通过 rpc.ServeConn(conn) 绑定服务

3 ）客户端

新建 client 目录，后执行 $ go mod init client
这里在 client 项目目录中，新建一个 main.go 文件

编辑 client/main.go 文件

package mainimport ("fmt""net/rpc"
)func main() {// 1. 用 rpc.Dial和rpc微服务端建立连接conn, err1 := rpc.Dial("tcp", "127.0.0.1:3000")// 错误处理if err1 != nil {fmt.Println(err1)}// 2、当客户端退出的时候关闭连接defer conn.Close()// 3. 调用远程函数var reply stringerr2 := conn.Call("msg.GetReplay", "滴滴滴", &reply)// 错误处理if err2 != nil {fmt.Println(err2)}// 4、获取微服务返回的数据fmt.Println(reply)
}

这里是客户端，需要经过以下几个步骤：
1 ）要连接的话，首先要建立连接 rpc.Dial 得到 conn 连接对象
2 ）添加客户端退出时的关闭连接处理 defer conn.Close()
3 ）基于 conn.Call 调用远程函数
- 第一个参数，服务名.远程方法 的字符串形式
- 第二个参数，给服务端的参数
- 第三个参数，服务端返回的数据地址