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 回答