0

我有一个像这样运行的 gRPC 服务:

server.addService(PassportService, implementation);
server.bind(mfeConfig().grpc.passport, grpc.ServerCredentials.createInsecure());
server.start();

我可以像这样从客户端调用我的服务:

const request = new GetConsoleUserRequest();
const meta = new grpc.Metadata();
meta.add('__.grpc.exchanged-token', token);
this.client.getConsoleUser(
  request,
  meta,
  (err: grpc.ServiceError, val: GetConsoleUserResponse) => {

但我不知道如何在我的服务实现中读取元数据。现在不管我定义了哪些重载getConsoleUser,元数据从来都不是参数之一。这是getConsoleUser,它只返回一些假数据:

getConsoleUser: (_req: GetConsoleUserRequest, callback: Function) => {
  const response = new GetConsoleUserResponse();
  const user = new ConsoleUser();
  user.setName('Bob Loblaw');
  // Change me to userStatus.GUEST to simulate anonymous user access
  user.setState(userStatus.REGISTERED);
  user.setEmail('bob@loblaw.com');
  response.setConsoleUser(user);
  callback(null, response);
},

我已经尝试将该签名更改为:

getConsoleUser: (_req: GetConsoleUserRequest, meta: grpc.Metadata, callback: Function) => {

但是如果我这样做,第二个参数实际上是回调函数,第三个参数是未定义的。

有没有办法从我的服务实现中读取元数据?还是我必须将我的服务附加到其他一些类,以便我可以监听传入的元数据?

4

1 回答 1

2

传递给服务器方法的第一个参数不是消息对象。它是一个“调用”对象,具有多个不同的属性,包括call.metadata获取元数据,并且对于一元和服务器流方法,call.request具有实际的请求消息。对于流式请求,调用对象也是一个 Node.js Stream 对象,您可以写入和/或从中读取,无论哪个相关。

有关更多详细信息,请查看API 参考文档ServerUnaryCall中的和Server(Readable|Writable|Duplex)Stream类。

于 2020-03-03T23:35:13.630 回答