node-zookeeper-dubbo-plus

node-zookeeper-dubbo年久失修，无法支持dubbo 2.6.3+协议，错误如下：

Unknown result flag, expect '0' '1' '2', get 3
Unknown result flag, expect '0' '1' '2', get 4
Unknown result flag, expect '0' '1' '2', get 5

修改内容

• 增加对dubbo 2.6.3+协议的支持，方法比较粗暴，直接忽略了attachments信息。
• 消除DEP0005警告，替换Buffer() => Buffer.from()。

其他使用方法同原包，变更包名即可。以下为原文：

node-zookeeper-dubbo

nodejs通过dubbo默认协议通信

3.0版本发布，使用长连接进行通信，同时重构了大量代码，性能几乎翻倍。

用法

1const nzd=require('node-zookeeper-dubbo');
2const app=require('express')();
3const opt={
4  application:{name:'fxxk'},
5  registry:'www.cctv.com:2181',
6  dubboVer:'2.5.3.6',
7  root:'dubbo',
8  dependencies:{
9    Foo:{
10      interface:'com.service.Foo',
11      version:'LATEST',
12      timeout:6000,
13      group:'isis',
14      methodSignature: { // optional
15        findById : (id) => [ {'$class': 'java.lang.Long', '$': id} ],
16        findByName : (name) => [ java.String(name) ],
17      }
18    },
19    Bar:{
20      interface:'com.service.Bar',
21      version:'LATEST',
22      timeout:6000,
23      group:'gcd'
24    }
25  }
26}
27
28const Dubbo=new nzd(opt);
29
30Dubbo.on("service:changed", (event)=>console.log(event))
31
32const customerObj = {
33  $class: 'com.xxx.XXXDTO',
34  $: {
35    a: 1,
36    b: 'test',
37    c: {$class: 'java.lang.Long', $: 123}
38  }
39};
40
41app.get('/foo',(req,res)=>{
42  Dubbo.Foo
43    .xxMethod({'$class': 'java.lang.Long', '$': '10000000'},customerObj)
44    .then(data=>res.send(data))
45    .catch(err=>res.send(err))
46})
47
48app.get('/foo/findById',(req,res)=>{
49  Dubbo.Foo
50    .findById(10000)
51    .then(data=>res.send(data))
52    .catch(err=>res.send(err))
53})
54
55app.listen(9090)
56

注意

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

参数配置说明

• application
  • name - 项目名称，必填
• registry - zookeeper服务地址，必填
• dubboVer - dubbo版本，必填
• root - 注册到zookeeper上的根节点名称
• dependencies - 依赖的服务集，必填
  • Foo - 自定义名称，这里方便起见用Foo作为示例，必填
    • interface - 服务地址，必填
    • version - 注册的服务版本
    • timeout - 超时时间，默认6000
    • group - 分组
    • methodSignature - 方法签名

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

1const java = require('js-to-java');
2const arg = {$class:'int',$:123};
3//等同于
4const arg = java('int',123);

感谢为这个项目作出过贡献的每个人，感谢为我提供思路和指导的 @caomu，感谢 js-to-java, hessian.js 的作者们。