README
注:该项目已经不再维护, 如果有需要可以尝试新的组件 node-dubbo-client
dubbo-node-consumer-client
dubbo的node消费者端.暂时只提供注册消费者的功能.
Install
npm install --save dubbo-node-consumer-client
Usage
* 项目启动的时候先对dubbo进行配置.
var dubboClient = require('dubbo-node-consumer-client');
dubboClient.init({
application: {
'application': '', //node应用的名称
'application.version': '', //node应用的版本
'category': 'consumers', //指定类型为消费者
'dubbo': '', //注册在dubbo上显示的名称
'side': 'consumer', //消费者端
'pid': process.pid, //node进程id
'version': '' //dubbo版本
},
dubbo: {
providerTimeout: 10 //jsonrpc超时时间,默认为45秒
},
registry: '192.168.0.102:2181', //zookeeper注册地址
loadbalance: 'random', //接口调用算法,random-权重/round-轮调,默认round
portfilter: [] //过滤端口
});
* 配置完成之后,对所有使用到的服务进行注册
注意:如果注册的服务不存在于zookeeper上,会在zookeeper上创建服务文件夹,等待服务注册.
var interfaces = [
{
"service": "", //服务名称
"version": "", //服务版本
"group": "" //服务所属的分组
},{
"service": "",
"version": "",
"group": ""
}
];
dubboClient.registry(interfaces);
* 以上配置完成即可调用服务
/**
* 这里的data是数组类型,严格按照服务提供者的参数接收顺序.
*
* 如果提供者的方法是形参接收,数组内的数据顺序就是形参的顺序.
* 例: 服务提供者方法 test(int a,int b);
* data拼接方式[a,b]
* 如果服务提供者的方法是对象接收,数组直接放入对象.
* 例: 服务提供者方法 test(User user)
* data拼接方式[{user object}]
**/
var data = [];
dubboClient.getService(serviceName, version, group)
.then(function(_promise){
//methodName --- 服务中具体的某个方法
return _promise(methodName,data);
})
.then(function(result){
//这里的result即为服务返回的数据
})
.catch(function(err){
//捕获服务调用中的异常
});
API
init(options[,logger])
options.application ---当前应用的dubbo描述信息
options.registry ---zookeeper注册地址
options.loadbalance ---服务调用算法,random-权重/round-轮调,默认round
options.portfilter ---过滤指定的端口
logger ---日志记录器,可选 ---提供外部日志记录,目前只支持log4js,外部注册完成的logger对象即可logger.getLogger('dubbo') ---默认使用console输出日志
registry(interfaces)
interfaces ---服务描述信息
interface.service ---服务在dobbo上注册的名称
interface.version ---服务的版本
interface.group ---服务的分组
getService(serviceName, version, group)
这里的三个参数和registry方法中三个描述信息相同