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")