grpc-client

node版本基于服务端提供protos快速建立连接的客户端中间件.

api api(中文) github

Installation

Install with npm

npm install @fxs0819/grpc-client

⚠️ 请确保您的系统/容器上已经安装了' openssl '

Examples

const config = {
    uri: '0.0.0.0:50051',
    ssl: {
        isOpen: false
        // rootCertPath: path.join(__dirname, './certs/cacert.pem'),
        // clientStorePath: path.join(__dirname, './certs/client.pfx'),
        // pfxCode: 'qianxin.quick.50843197',
        // authority: 'quickservice'
    },
    config: {
        PROTO_PATH: path.join(__dirname, './protos/Hello.proto'),
        PACKAGE_NAME: 'hello',
        SERVE_NAME: 'MainGreeter'
    }
};
const client:Client = await new Client(config);
const res = await client.myProxy('sayHello', { 'name': 'Tom' });
console.log(res);
client.close();

import { PassThrough } from 'stream';
import * as lodash from 'lodash';
import * as async from 'async';

const stream = new PassThrough({ objectMode: true });
const sayMultiHelloCall = client.myProxy('sayMultiHello', stream);

const senders: any[] = [];
for (var i = 0; i < 10; i++) {
  senders[i] = (function(i) {
    return (callback:any)=>{
      stream.write({ name: `name${i}` });
      lodash.delay(callback, 1000);
    };
  }(i));
}
async.series(senders, () => {
  stream.end();
});
const sayMultiHello = await sayMultiHelloCall;

License

MIT