Go微服务: 基于net/rpc/jsonrpc模块实现微服务跨语言调用

概述

• Golang 提供 net/rpc/jsonrpc 库来实现rpc方法
• ���用 json 方式进行数据编解码，支持跨语言调用

  这里实现跨语言示例

  1 ）go 服务端

  （）

  package main    import ( "log"  "net"  "net/rpc"  "net/rpc/jsonrpc")    // 定义服务接口  type Arith int    // 定义接口方法，参数和返回值都应该是指针类型  func (t *Arith) Multiply(args *Args, reply *int) error {*reply = args.A * args.Blog.Print("参数", args)return nil  }    // Args 是传递给服务的参数结构  type Args struct {  A, B int  }    func main() {  arith := new(Arith)  rpc.Register(arith)    l, err := net.Listen("tcp", ":1234")  if err != nil {  log.Fatal("listen error:", err)  }  defer l.Close()    for {  conn, err := l.Accept()  if err != nil {  log.Print("accept error:", err)  continue  }    // 使用 jsonrpc 包处理连接  go func() {  jsonrpc.ServeConn(conn)  conn.Close()  }()  }  }

  2 ）nodejs 客户端1

  const net = require('net');  const readline = require('readline');    // 创建一个 TCP 客户端  const client = new net.Socket();    // 连接到服务器  client.connect(1234, 'localhost', () => {    console.log('Connected to server!');      // 发送请求到服务器    const request = JSON.stringify({      jsonrpc: "2.0",      method: "Arith.Multiply",      params: [{ A: 7, B: 8 }],      id: 1    });      client.write(request + '\n');  });    // 处理从服务器返回的数据  const rl = readline.createInterface({    input: client,    output: process.stdout,    terminal: false  });    rl.on('line', (line) => {    const response = JSON.parse(line);    console.log('Server response:', response.result);    client.end();  });    client.on('error', (err) => {    console.error('Socket error:', err);  });    client.on('close', () => {    console.log('Connection closed');  });

  3 ）nodejs 客户端2

  （）

  const jayson = require('jayson');  const client = jayson.client.tcp({    port: 1234,    host: 'localhost'  });    // 定义要调用的方法以及参数  const request = {    jsonrpc: "2.0",    method: "Arith.Multiply",    params: [{ A: 7, B: 8 }],    id: 1  };    // 发送请求并处理响应  client.request(request, function(err, response) {    if (err) {      console.error('请求出错:', err);      return;    }        console.log('服务器响应:', response.result); // 输出乘法的结果  });

  4 ）go 客户端3

  package mainimport ("fmt""net""net/rpc""net/rpc/jsonrpc")type Args struct {  A int `json:"A"`  B int `json:"B"`  }  func main() {// 1. 用 net.Dial和rpc微服务端建立连接conn, err1 := net.Dial("tcp", "127.0.0.1:1234")if err1 != nil {fmt.Println(err1)}// 2. 当客户端退出的时候关闭连接defer conn.Close()// 3、建立基于json编解码的rpc服务client := rpc.NewClientWithCodec(jsonrpc.NewClientCodec(conn))// 4. 调用远程函数var reply interr2 := client.Call("Arith.Multiply", Args{A: 7, B: 8}, &reply)if err2 != nil {fmt.Println(err2)}// 5. 获取微服务返回的数据fmt.Println(reply)}

  总结

  • 这里演示了，基于go语言为服务端，nodejs 和 golang 为客户端的3种示范
  • 注意，上面 nodejs版本中的 params 的格式与 golang 中的区别
  • 标准库的RPC默认采用Go语言特有的gob编码，没法实现跨语言调用
  • golang官方还提供了 net/rpc/jsonrpc 库实现RPC方法
  • JSON RPC采用JSON进行数据编解码，因而支持跨语言调用
  • 但目前的jsonrpc库是基于tcp协议实现的，暂时不支持使用http进行数据传输
  • 另外，Mac环境，在没有服务端服务时，可用 nc 工具调试客户端
    • $ nc -l 127.0.0.1 1234
    • linux下需要安装, $ yum install -y nc
    • nc是netcat的简写，是一个功能强大的网络工具，有着网络界的瑞士军刀美誉
    • nc命令的主要作用如下：
      • 实现任意TCP/UDP端口的侦听，nc可以作为server以TCP或UDP方式侦听指定端口
      • 端口的扫描，nc可以作为client发起TCP或UDP连接
      • 机器之间传输文件
      • 机器之间网络测速