NodeJS 实现一个简单的gRPC demo

syntax = "proto3";

package pet;

// 服务名为 Adopt 
// 方法为 AdoptPet
service Adopt {
  rpc AdoptPet(PetRequest) returns (PetReply) {}
}

// 请求时 需传递type
message PetRequest {
  string type = 1;
}

// 返回体只包含name属性
message PetReply {
  string name = 1;
}

const PROTO_PATH = __dirname + '/pet.proto'

var grpc = require('@grpc/grpc-js') // 用于创建服务的的核心库
var protoLoader = require('@grpc/proto-loader') // 用于加载，解析，序列化 proto文件的库
var packageDefinition = protoLoader.loadSync(
  PROTO_PATH,
  {
    keepCase: true,
    longs: String,
    enums: String,
    defaults: true,
    oneofs: true
  }
)

var pet_proto = grpc.loadPackageDefinition(packageDefinition).pet;

function AdoptPet(call, callback) {
  callback(null, { name: 'Tom' })
}

function start() {
  var server = new grpc.Server();
  server.addService(pet_proto.Adopt.service, { AdoptPet })

  server.bindAsync('0.0.0.0:50052', grpc.ServerCredentials.createInsecure(), () => {
    server.start();
  })

}

start()

var PROTO_PATH = __dirname + '/pet.proto'

var grpc = require('@grpc/grpc-js')
var protoLoader = require('@grpc/proto-loader')
var packageDefinition = protoLoader.loadSync(
  PROTO_PATH,
  {
    keepCase: true,
    longs: String,
    enume: String,
    defaults: true,
    oneofs: true,
  }
)

var pet_proto = grpc.loadPackageDefinition(packageDefinition).pet;

function main() {
  var target = 'localhost:50052'
  var client = new pet_proto.Adopt(target, grpc.credentials.createInsecure())

  client.AdoptPet({ type: 'dog' }, function (error, res) {
    console.log('pet name:', res.name)
  })
}

main()