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