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);