dubbo客户端, 基于node-zookeeper-dub

node-dubbo-client-pool

nodejs通过dubbo默认协议通信，基于node-zookeeper-dubbo， 实现连接池。 每一个接口有多个provider提供服务，针对于每个provider建立（多个）长链接。

Usage

const nzd=require('node-dubbo-client-pool'); const app=require('express')(); const opt={ application:{name:'fxxk'}, register:'www.cctv.com:2181', dubboVer:'2.5.3.6', root:'dubbo', maxConn: 10, minConn: 2, dependencies:{ Foo:{ interface:'com.service.Foo', version:'LATEST', timeout:6000, group:'isis', methodSignature: { findById : (id) => [ {'$class': 'java.lang.Long', '$': id} ], findByName : (name) => (java) => [ java.String(name) ], } }, Bar:{ interface:'com.service.Bar', version:'LATEST', timeout:6000, group:'gcd' } } } opt.java = require('js-to-java') const Dubbo=new nzd(opt); const customerObj = { $class: 'com.xxx.XXXDTO', $: { a: 1, b: 'test', c: {$class: 'java.lang.Long', $: 123} } }; app.get('/foo',(req,res)=>{ Dubbo.Foo .xxMethod({'$class': 'java.lang.Long', '$': '10000000'},customerObj) .then(data=>res.send(data)) .catch(err=>res.send(err)) }) app.get('/foo/findById',(req,res)=>{ Dubbo.Foo .findById(10000) .then(data=>res.send(data)) .catch(err=>res.send(err)) }) app.listen(9090) 注意

须等待初始化完毕才能正常使用，标志：Dubbo service init done

如果要和1.x版本共存的话试试这个，niv.

参数配置说明 application name - 项目名称，必填 register - zookeeper服务地址，必填 dubboVer - dubbo版本，必填 root - 注册到zookeeper上的根节点名称 maxConn - 连接到每一个provider的链接的最大个数，默认10个。 minConn - 连接到每一个provider的链接的最小个数，默认2个。 dependencies - 依赖的服务集，必填 Foo - 自定义名称，这里方便起见用Foo作为事例，必填 interface - 服务地址，必填 version - 注册的服务版本 timeout - 超时时间，默认6000 group - 分组 methodSignature - 方法签名

可以选择使用 js-to-java， 能极大提高效率

var arg={$class:'int',$:123}; //等同于 var arg=java('int',123);