手把手教你用golang撸rpc
引言
"微服务"这个概念想必不用我说大家都知道，就算没接触过也听说过。简单来说就是以前系统中的，用户，搜索，内容，等等模块都在一起，这样会导致代码「越来越冗余，越来越难维护」，所以往往需要拆分这些服务，微服务在拆分的时候，会根据业务功能模块把一个单体的应用拆分成许多个独立的项目，每个项目完成一部分的业务功能，然后独立开发和部署。这些独立的项目就成为一个微服务。进而构成一个「服务集群」。看下面两张图可能会对微服务的概念更加直观
单体服务
单体服务
微服务
微服务
RPC介绍
微服务中很重要的一个内容就是「RPC」远程过程调用（Remote Procedure Call，缩写为 RPC）是一个计算机通信协议，他的主要作用是「允许运行于一台计算机的程序调用另一台计算机的子程序，而程序员无需额外地为这个交互作用编程」
那么RPC是如何实现的呢？今天咱们就以golang为工具，给大家实现一个简单的用rpc输出helloWorld
RPC实现步骤
其实RPC的实现和网络编程有点像，A服务需要远程调用B服务的某个方法，在这种情况下我们就把B服务称为「服务端」，A称为「客户端」
具体实现步骤如下图：
RPC实现步骤
服务端
1:注册服务对象，绑定类方法
rpc.ResisterName("服务名","回调对象")
ResisterName函数解释
func RegisterName(name string, rcvr interface{}) error
//参数解释
//name 服务名(自己随便取)，字符串类型
//rcvr 对应的RPC对象，该对象绑定的方法需要满足如下条件
1)方法必须是导出的(包外可见)，在golang中的体现为，方法名首字母大写
2)方法必须有两个参数，都是导出类型，内建类型
3) 方法的第二个参数(也就是客户端调用远程函数中的传出参数)，必须指针(传出参数)
4) 该方法只有一个返回值，就是error接口类型的返回值
下面我们针对参数2举个例子,比如下面这个方法TestMethod 就是符合条件的
type Test struct{
}
//这是符合RegisterName的参数2的方法名
func (this *Test) TestMethod(name string, resp *string)error{
return nil
}
rpc.RegisterName("test", new(Test)) //注册rpc服务对象
2:创建监听器
listener, err := net.Listen()
3:启动监听，建立链接
conn, err := listener.Accept()
4:将链接绑定RPC服务
rpc.ServerConn(conn)
ServerConn函数解释
func (server *Server) ServeConn(conn io.ReadWriteCloser)
//参数conn为成功建立好连接的socket，也就是前面的conn
客户端
1:用RPC连接服务器(服务端)
conn, err := rpc.Dail()
2:调用远程函数
conn.Call("服务名.方法名", "传入参数", "传出参数")
func (client *Client) Call(serviceMethod string, args interface{}, reply interface{}) error
//参数含义
//serviceMethod "服务名"."方法名"
//args "传入参数" 调用方法需要的参数
//reply "传出参数" 定义一个变量，对变量名取地址 &变量，完成传参
代码示例
服务端代码
server.go
package main
import (
"fmt"
"net"
"net/rpc"
)
type Hello struct {
}
func (this *Hello) HelloWorld(name string, resp *string) (err error) {
*resp = name + "您好！"
return err
}
func main() {
//注册rpc服务，指定对象和方法
err := rpc.RegisterName("hello", new(Hello))
if err != nil {
fmt.Println("注册 err:", err)
return
}
//设置监听
listener, err := net.Listen("tcp", "127.0.0.1:8088")
if err != nil {
fmt.Println("listen err:", err)
return
}
defer listener.Close()
//建立连接
conn, err := listener.Accept()
if err != nil {
fmt.Println("accept err:", err)
return
}
defer conn.Close()
//绑定服务
rpc.ServeConn(conn)
}
客户端代码
client.go
package main
import (
"fmt"
"net/rpc"
)
func main() {
//用rpc链接服务器
conn, err := rpc.Dial("tcp", "127.0.0.1:8088")
if err != nil {
fmt.Println("Dial err:", err)
return
}
defer conn.Close()
var resp *string
conn.Call("hello.HelloWorld", "小饭", &resp)
fmt.Println(*resp)
}
完
本文参与 腾讯云自媒体分享计划，分享自微信公众号。
原始发表：2022-10-12，如有侵权请联系 cloudcommunity@tencent.com 删除
评论
登录后参与评论
推荐阅读
目录