在 gRPC 中捕获请求/响应 |如何在node.js中使用gRPC服务器拦截器？

Question

我是 gRPC 新手，我正在寻找一种在调用服务器函数之前捕获 gRPC 中的请求的方法。这可能也是响应所需要的。换句话说，我试图在请求/响应到达控制器之前对其进行操作。

我发现了一个名为 interceptor 的功能，但据我了解，此功能仅随 gRPC-web 一起提供！

那么我该怎么做呢？拦截器只能用于客户端吗？

例如，我想用某种能力（也许是拦截器）记录 gRPC 中的每个请求，我该怎么做？

服务器.js

const grpc = require('@grpc/grpc-js');
const PROTO_PATH = './news.proto';
const protoLoader = require('@grpc/proto-loader');

const options = {
  keepCase: true,
  longs: String,
  enums: String,
  defaults: true,
  oneofs: true,
};
var packageDefinition = protoLoader.loadSync(PROTO_PATH, options);
const newsProto = grpc.loadPackageDefinition(packageDefinition);

const server = new grpc.Server();
let news = [
  { id: '1', title: 'Note 1', body: 'Content 1', postImage: 'Post image 1' },
  { id: '2', title: 'Note 2', body: 'Content 2', postImage: 'Post image 2' },
];


server.addService(newsProto.NewsService.service, {
  getAllNews: (call, callback) => {
    return callback(null, { news });
  }
});

server.bindAsync(
  '127.0.0.1:50051',
  grpc.ServerCredentials.createInsecure(),
  (error, port) => {
    if (error) {
      throw new Error(error);
    }

    console.log('Server at port:', port);
    console.log('Server running at http://127.0.0.1:50051');
    server.start();
  }
);

客户端.js

const grpc = require('@grpc/grpc-js');
const protoLoader = require('@grpc/proto-loader');
const PROTO_PATH = './news.proto';

const options = {
  keepCase: true,
  longs: String,
  enums: String,
  defaults: true,
  oneofs: true,
};

var packageDefinition = protoLoader.loadSync(PROTO_PATH, options);

const NewsService = grpc.loadPackageDefinition(packageDefinition).NewsService;

const client = new NewsService(
  'localhost:50051',
  grpc.credentials.createInsecure()
);

client.getAllNews({}, (error, news) => {
  if (error) throw error
  console.log(news);
});

Answer 1

如何使用服务器拦截器的描述可以在本文档中找到。简而言之，您创建一个或多个拦截器函数，它们接受一个

ServerInterceptingCall

并生成另一个

ServerInterceptingCall

。然后，将选项参数的

interceptors

字段中的数组中的这些函数传递给

Server

构造函数。