乐趣区

关于程序员:手把手教你用golang撸rpc

jiezi

引言

“ 微服务 ” 这个概念想必不必我说大家都晓得，就算没接触过也据说过。简略来说就是以前零碎中的，用户，搜寻，内容，等等模块都在一起，这样会导致代码 越来越冗余，越来越难保护 ，所以往往须要拆分这些服务，微服务在拆分的时候，会依据业务功能模块把一个单体的利用拆分成许多个独立的我的项目，每个我的项目实现一部分的业务性能，而后独立开发和部署。这些独立的我的项目就成为一个微服务。进而形成一个 服务集群。看上面两张图可能会对微服务的概念更加直观

单体服务
微服务

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 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)
}

本文由 mdnice 多平台公布

退出移动版