go语言微服务之RPC协议[通俗易懂]

func(server *Server) RegistName(name string ,rcvr interface{}) error

参数1 ：服务名，字符串类型

参数2 ：对应rpc对象，该对象绑定方法要满足以下条件：

方法必须是导出的 –包外可见。首字母大写

方法必须两个参数，都是导出类型，内建类型

方法的第二个参数必须是“指针”（传出参数）

方法只有一个error 接口类型的返回值

如:

type World struct {

}

方法：

s *Wofunc(thirld) HelloWorld (name string,resp *string) error {

}

rpc.RegisterName(“服务名”,new(World))

2,绑定rpc服务

func (server *Server) ServerConn(conn io.ReadWriteCloser)

conn:成功建立好连接的：socket — conn

3,调用远程函数

func (client *Client) Call(serviceMethod string, args interface{}, reply interface{}) error
serviceMethod：“服务名.方法名”

args:传入参数。方法需要的数据。

reply:传出参数。定义 var 变量，&变量名完成传参。

4 代码实现

4.1 服务端代码实现

package main

import (
	"fmt"
	"net"
	"net/rpc"
)

type World struct {
}

//绑定类方法

func (this *World) HelloWorld(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，设置监听
	listener, err := net.Listen("tcp", "127.0.0.1:8800")
	if err != nil {
		fmt.Println("net.Listen err:", err)
		return
	}
	defer listener.Close()

	fmt.Println("开始监听...")

	//3，建立连接
	conn, err := listener.Accept()
	if err != nil {
		fmt.Println("listener.Accept err:", err)
		return
	}
	defer conn.Close()
	fmt.Println("连接成功！")
	//4，绑定服务
	rpc.ServeConn(conn)

}

4 .2客户端代码实现

package main

import (
	"fmt"
	"net/rpc"
)

func main() {
	//1，用rpc连接服务器--Dial()
	conn, err := rpc.Dial("tcp", "127.0.0.1:8800")
	if err != nil {
		fmt.Println("rpc.Dial err:", err)
		return
	}
	defer conn.Close()
	fmt.Println("建立连接成功")
	//2，调用远程函数
	var reply string //接收函数返回值
	err = conn.Call("hello.HelloWorld", "李白", &reply)
	if err != nil {
		fmt.Println("conn.Call err:", err)
		return
	}
	fmt.Println(reply)
}