创建/关闭客户端

create

  1. let pegasusClient = require('pegasus-nodejs-client');
  2. /**
  3.  * Create a client instance
  4.  * @param   {Object}  configs
  5.  *          {Array}   configs.metaServers          required
  6.  *          {String}  configs.metaServers[i]       required
  7.  *          {Number}  configs.operationTimeout(ms) optional
  8.  *          {Object}  configs.log                  optional
  9.  * @return  {Client}  client instance
  10.  * @throws  {InvalidParamException}
  11.  */
  12. client = pegasusClient.create({
  13.     metaServers: ['127.0.0.1:34601', '127.0.0.1:34602', '127.0.0.1:34603'],
  14.     operationTimeout : 5000,
  15.     log : log,
  16. });
  • metaServers为meta server地址列表，为必填项
  • operationTimeout为本次操作的超时时间，单位是毫秒，默认是1000ms
  • log为日志库实例
  • 我们使用日志库 log4js
  • 默认使用的日志配置在log_config.js文件中，配置如下：
  1. let filename = "./logs/"+process.pid+"/pegasus-nodejs-client.log";
  2. let logConfig = {
  3.    appenders: { 
  4.      pegasus: {
  5.        type: "file", 
  6.        filename: filename, 
  7.        maxLogSize: 104857600, 
  8.        backups: 10
  9.      } 
  10.    },
  11.    categories: { 
  12.      default: { appenders: ["pegasus"], level: "INFO" } 
  13.    }
  14. };

上述配置表示，会将错误级别等于及高于INFO级别的日志存储在文件中，每个日志文件最大100M，最多保留10个日志文件

  • 若不想使用默认配置，则需要重新定义如上的logConfig对象，作为创建客户端时的log对象
  • 当参数有误时，会抛出异常，停止后续操作

close

  1. // close client when you do not need to use it
  2. client.close();