grpc + protocol/buf 打通 node 和 golang 服务

aside section ._1OhGeD · · 540 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

一. 安装 protocol/buf 编译器

  • wget "https://github.com/protocolbuffers/protobuf/releases/download/v3.9.1/protobuf-all-3.9.1.tar.gz"

  • tar zxvf protobuf-all-3.9.1.tar.gz

  • cd protobuf-3.9.1

  • ./configure

  • make && sudo make install

如果 protoc --version ; 则说明安装成功

二. 在 Golang 和 Node 服务器中同时配置相同的 .proto 文件

  syntax = "proto3";

  package message;

  service HelloService {
    rpc SayHello (HelloRequest) returns (HelloResponse);
  }

  message HelloRequest {
    string code = 1;
    string message = 2;
  }

  message HelloResponse {
    string code = 1;
    string message = 2;
  }

三. golang server 安装依赖

  • google.golang.org/grpc : grpc 框架

    • go get -u -v google.golang.org/grpc
  • go get -u github.com/golang/protobuf/protoc-gen-go

    **安转 golang protocol buffers plugin **

  • 编译项目中 .proto 文件

    • protoc -I message/ message/hello.proto --go_out=plugins=grpc:message

      • -I 源文件包, --go_out=plugins=grpc:(${packageName}), 将会生成 hello.pb.go 文件

      • 编译时可能会报错: protoc: error while loading shared libraries: libprotoc.so.9: cannot open shared obje

        • 解决: 在 bash 中添加环境变量 export LD_LIBRARY_PATH=/usr/local/lib;
  • Golang Server:

    package main
    
    import (
      "context"
      "fmt"
      "net"
    
      "mpa-dance-push/src/logger"
      pb "mpa-dance-push/src/message"
    
      "google.golang.org/grpc"
    )
    
    const port = ":50001"
    
    type server struct{}
    
    func (s *server) SayHello(ctx context.Context, in *pb.HelloRequest) (*pb.HelloResponse, error) {
      logger.Info.Printf("Received: %v", in.GetMessage())
      return &pb.HelloResponse{Message: "Hello " + in.GetMessage()}, nil
    }
    
    // InitRPCServer 初始化 rpc server
    func InitRPCServer() {
      lis, err := net.Listen("tcp", port)
      if err != nil {
        logger.Error.Println("fail")
        return
      }
      fmt.Printf("[Init Tcp Server: Port => %s] \n", port)
      s := grpc.NewServer()
      pb.RegisterHelloServiceServer(s, &server{})
      if err := s.Serve(lis); err != nil {
        logger.Error.Printf("failed to serve: %v", err)
      }
    }
    
    func main() {
      InitRPCServer()
    }
    

四. 创建 Node 客户端 koa + ts

  • 安装依赖 @grpc/proto-loader, grpc

    • yarn add @grpc/proto-loader grpc --save-dev
  • 代码如下:

  import { loadSync } from '@grpc/proto-loader'
  import { BaseService } from '@services/BaseService'
  import { credentials, loadPackageDefinition, PackageDefinition } from 'grpc'
  import { PROTO_PATH } from 'scretConfig'
  import { Server } from '../../server'
  import { WxProtoMessage } from './rpcMessageModel'

  export class GRPCService extends BaseService {

    private packageDefinition: PackageDefinition

    constructor(server: Server) {
      super(server)
      this.packageDefinition = loadSync(PROTO_PATH, {
        keepCase: true,
        longs: String,
        enums: String,
        defaults: true,
        oneofs: true
      })

      let message = loadPackageDefinition(this.packageDefinition).message as WxProtoMessage
      const client = new message.HelloService('localhost:50001', credentials.createInsecure())

      client.SayHello({ message: 'world' }, (_err: any, response: any) => {
        console.log(response.message)
      })
    }
  }

五, proto3 语法


有疑问加站长微信联系(非本文作者)

本文来自:简书

感谢作者:aside section ._1OhGeD

查看原文:grpc + protocol/buf 打通 node 和 golang 服务

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

540 次点击  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传