引言
"微服务"这个概念想必不必我说大家都晓得，就算没接触过也据说过。简略来说就是以前零碎中的，用户，搜寻，内容，等等模块都在一起，这样会导致代码越来越冗余，越来越难保护，所以往往须要拆分这些服务，微服务在拆分的时候，会依据业务功能模块把一个单体的利用拆分成许多个独立的我的项目，每个我的项目实现一部分的业务性能，而后独立开发和部署。这些独立的我的项目就成为一个微服务。进而形成一个服务集群。看上面两张图可能会对微服务的概念更加直观
单体服务
微服务
RPC介绍
微服务中很重要的一个内容就是RPC
近程过程调用（Remote Procedure Call，缩写为 RPC）是一个计算机通信协议，他的次要作用是容许运行于一台计算机的程序调用另一台计算机的子程序，而程序员无需额定地为这个交互作用编程
那么RPC是如何实现的呢？明天咱们就以golang为工具，给大家实现一个简略的用rpc输入helloWorld
RPC实现步骤
其实RPC的实现和网络编程有点像，A服务须要近程调用B服务的某个办法，在这种状况下咱们就把B服务称为服务端，A称为客户端
具体实现步骤如下图：
服务端
注册服务对象，绑定类办法(定义类，绑定类办法)
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服务对象创立监听器
listener, err := net.Listen()启动监听，建设链接
conn, err := listener.Accept()将链接绑定RPC服务
rpc.ServerConn(conn)ServerConn函数解释
func (server *Server) ServeConn(conn io.ReadWriteCloser)//参数conn为胜利建设好连贯的socket，也就是后面的conn客户端
用RPC连贯服务器(服务端)
conn, err := rpc.Dail()调用近程函数
conn.Call("服务名.办法名", "传入参数", "传出参数")func (client *Client) Call(serviceMethod string, args interface{}, reply interface{}) error//参数含意//serviceMethod "服务名"."办法名"//args "传入参数" 调用办法须要的参数//reply "传出参数" 定义一个变量，对变量名取地址 &变量，实现传参代码示例
服务端代码
server.go
package mainimport ( "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 mainimport ( "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)}本文由mdnice多平台公布