GO语言微服务（1）原生RPC-EW帮帮网

提到微服务，老生常谈的就是服务间的通信，主要有两种方式

同步调用：rpc 远程过程调用

rpc协议：主要包括

1、传输协议（http1.1、http2.0、wensocket协议、http3.0）

2、传输格式（JSON、Protobuf、xml）

异步调用：消息队列 kafka，activeMQ，rocketMQ

net/rpc包

先来了解socket通信

server端伪代码

listener :=net.listen() //获取监听器对象

conn :=listener.Accept() //等待连接

conn.read() //读到客户端发送的数据

conn.write() //向客户端发送数据

conn.close() //关闭连接

listener.close //关闭监听器

client端伪代码

conn :=net.Dial() //连接服务端

conn.write() //发送数据

conn.read() // 接收返回数据

conn.close() // 关闭连接

RPC使用

server端

//注册rpc服务对象

rpc.RegisterName("服务名"，回调函数）

//创建监听器

listener，err := net.Listen()

//建立连接

conn ，err := listener.Accept()

//绑定rpc服务到连接上

rpc.ServeConn(conn)

client端

//连接rpc服务端

conn，err ;=rpc.Dial()

//调用服务

conn.Call("服务名.方法名"，传入参数，传出参数）

贴一下代码

server端

package main

import (
	"log"
	"net"
	"net/rpc"
	"strconv"
	"time"
)

// 定义服务
type Order struct{}

func (this *Order) GetOrder(req string, resp *string) error {
	*resp = req + strconv.Itoa(int(time.Now().UnixNano()))
	return nil
}
func main() {
	//注册rpc服务
	rpc.RegisterName("order", new(Order))
	//设置监听
	listener, err := net.Listen("tcp", "127.0.0.1:80")
	if err != nil {
		log.Fatal("监听错误")
	}
	defer listener.Close()
	//获取链接
	accept, err := listener.Accept()
	if err != nil {
		log.Fatal("获取连接错误")
	}
	defer accept.Close()
	//绑定服务与链接
	rpc.ServeConn(accept)
}

client端

package main

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

func main() {
	//连接客户端
	client, err := rpc.Dial("tcp", "127.0.0.1:80")
	if err != nil {
		log.Fatal("连接服务的错误")
	}
	defer client.Close()
	//调用服务
	var resp string
	err = client.Call("order.GetOrder", "lijialin", &resp)
	fmt.Println(err)
	fmt.Println(resp)
}

了解了原始RPC，我们可以对原始RPC进行封装，为后面学习GRPC做铺垫

先来说一下为什么要封装：如下图所示，Order结构体绑定的方法是有一定限制条件的，如果写错了，那么在编译时是不会报错的，但是在运行时会报错，本着报错宜早不宜迟的原则，我们可以是由接口对服务实现类进行限制。