GRPC 双向流配置

Question

我正在关注这个 GRPC 介绍 video 以在客户端和服务器之间实现一个简单的 bidi 流

可能我在实现中遗漏了一些东西，实际上我收到了这个错误：

错误：14 不可用：已收到 GOAWAY

这是我的代码：

-原型：

syntax = "proto3";
package nbsb;

message EchoMessage {
  string value = 1;
  int32 value2 = 2;
}

service EchoService {
  rpc Echo (EchoMessage) returns (EchoMessage);

  rpc EchoClientStream (stream EchoMessage) returns (EchoMessage);

  rpc EchoServerStream (EchoMessage) returns (stream EchoMessage);

  rpc EchoBidiStream (stream EchoMessage) returns (stream EchoMessage);
}

-服务器

var PROTO_PATH = __dirname + '/echo.proto';

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

var hello_proto = grpc.loadPackageDefinition(packageDefinition).nbsb;
const { Server } = require('grpc-server-js');

function main() {
    const server = new Server();
    server.addService(hello_proto.EchoService.service, {
        EchoBidiStream(stream){
            stream.on('error', console.error);
            stream.on('data', (data)=>{stream.write(data)});
            stream.on('end',()=>stream.end());
            }

    });


      server.bind('localhost:55555');
  }

  main();

-客户：

var PROTO_PATH = __dirname + '/echo.proto';

var grpc = require('grpc');
var protoLoader = require('@grpc/proto-loader');
var packageDefinition = protoLoader.loadSync(PROTO_PATH, {keepCase: true, longs: String, enums: String, defaults: true, oneofs: true});
var hello_proto = grpc.loadPackageDefinition(packageDefinition).nbsb;

function main() {
  var client = new hello_proto.EchoService('localhost:55555',grpc.credentials.createInsecure());

    const stream = client.EchoBidiStream();

    stream.on('error', console.error);
    stream.on('data',console.log);
    stream.on('end',()=>client.close());


    stream.write({data:{value: "hello", value2:1}});
    stream.end({});

}

main()

服务器实现是grpc-server-js

我是漏掉了什么还是哪里出了问题？？

感谢您的帮助！

Answer 1

绑定端口成功后需要调用server.start()才能真正开始处理请求。 server.bind returns 一个承诺，因此您应该 await 该承诺或使用 promise.then 知道绑定何时成功。

GRPC 双向流配置

GRPC bidi stream configuration

stream

bidi

node.js

grpc