时间戳

首页 > 解决方案 > GRPC双向流配置

node.js - GRPC双向流配置

问题描述

我正在按照这个 GRPC 介绍视频在客户端和服务器之间实现一个简单的双向流

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

错误：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

我错过了什么还是有什么问题？

谢谢您的帮助！

标签： node.jsstreamgrpcbidi

解决方案

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

推荐阅读