首页 > 解决方案 > grpc压缩不在nodejs上压缩

问题描述

我正在运行 grpc 使用的节点示例:greeter_server 和客户端:

服务器

var PROTO_PATH = __dirname + '/../../protos/helloworld.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).helloworld;

/**
 * Implements the SayHello RPC method.
 */
function sayHello(call, callback) {
  callback(null, {message: 'Hello ' + call.request.name});
}

/**
 * Starts an RPC server that receives requests for the Greeter service at the
 * sample server port
 */
function main() {
  var server = new grpc.Server();
  server.addService(hello_proto.Greeter.service, {sayHello: sayHello});
  server.bind('[::]:50051', grpc.ServerCredentials.createInsecure());
  server.start();
}

main();

客户:


var PROTO_PATH = __dirname + '/../../protos/helloworld.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).helloworld;

function main() {
  var client = new hello_proto.Greeter('localhost:50051',
                                       grpc.credentials.createInsecure(), 
                                       {"grpc.default_compression_algorithm": "grpc.default_compression_level": 2}
                                       );

  var user;
  if (process.argv.length >= 3) {
    user = process.argv[2];
  } else {
    user = 'world';
  }
  client.sayHello({name: user}, function(err, response) {
    console.log('Greeting:' + JSON.stringify(response));
    if (response) {
      console.log('Greeting:', response.message);
    }
  });
}

main();


对于节点 mudels,我使用以下配置:

{
  "name": "grpc-examples",
  "version": "0.1.0",
  "dependencies": {
    "@grpc/proto-loader": "^0.1.0",
    "async": "^1.5.2",
    "google-protobuf": "^3.0.0",
    "grpc": "1.24.4",
    "lodash": "^4.6.1",
    "minimist": "^1.2.0"
  }
}

根据https://github.com/grpc/grpc-node/blob/master/doc/compression.md 来自客户端的所有消息都应该被压缩。但是当我用wireshark检查时,没有应用压缩。似乎客户端默默地忽略了设置。这让我想到了一些问题:

  1. 我究竟做错了什么?
  2. 如何让它发挥作用?
  3. 是否有任何编程方式来确保成功应用提供的设置?
  4. 还有有什么方法可以在 grpc 模块中启用日志记录,这样我就可以调试这样的东西了?

标签: node.jscompressiongrpc

解决方案


推荐阅读