dubbo.js

简介

nodeJs下dubbo 客户端工具

特性支持

• 连接复用，同时支持hessian、jsonrpc 协议

• 支持配置长连接池大小，调用dubbo服务的链接可控。

• 可配的服务熔断机制，调用失败降级，更加可靠

• TODO：可拓展的传输编码协议

安装使用

$ npm install dubbo.js -S

主要方法

createRegistry

新建registry仓库

createRegistry({
    logger,         // logger对象，默认为 console
    zookeeper,      // zk源处理，默认使用 ‘zookeeper-cluster-client’ 包
    root,           // zk连接root，默认为 ‘dubbo’
    zkHosts         // zk连接地址
});

// 对象主要提供3个方法：
subscribe(config: Object {interfaceName}, listener: function)     // 订阅服务，watch可用的服务地址
unSubscribe(config, listener)   // 取消订阅
close()                         // 关闭该registry，断开zk连接

示例：

import { createRegistry } from 'dubbo.js';
async function launch() {
    const registry = createRegistry({
        logger: console,
        zkHosts: '127.0.0.1:2181'
    });

    await registry.ready();

    registry.subscribe({
        interfaceName: 'com.xxx.yyy'
    }, addressList => {
        console.log(addressList)
    })
}
launch()
    .catch(console.error);

createConsumer

使用单个registry获得一个消费者实例。

import { createConsumer, createRegistry } from 'dubbo.js';
async function launch() {
    const registry = createRegistry({
        logger: console,
        zkHosts: '127.0.0.1:2181'
    });

    await registry.ready();

    const consumer = createConsumer({
        registry,
        interfaceName: 'com.xxx.yyy'
    });

    await consumer.ready();
}

launch()
    .catch(console.error);

详细消费者配置见下面文档。

createRpcClient

interfaceName的服务对应产生的rpc客户端实例，可直接产生其消费者实例

    createRpcClient({
        registry,
        interfaceName
    })
    参数说明：
    interfaceName：
    代表 dubbo 暴露的接口服务，根据 interface 字段会找到对应接口的 provider，与 Java 开发约定即可。
    registry：
    使用createRegistry创建的实例
    

使用示例

以下是一次使用jsonrpc协议调用dubbo服务的操作

import { createRpcClient, createRegistry } from 'dubbo.js';
async function launch() {
    const registry = createRegistry({
        logger: console,
        zkHosts: '127.0.0.1:2181'
    });

    await registry.ready();

    const rpcClient = createRpcClient({
        registry,
        interfaceName: 'com.user.client.consumer'
    });
    
    const config = {
        dubboVersion: '3.0.6-SNAPSHOT',
        version: '1.0',
        contextPath: 'dubbo',                 // 默认可不填
        group: 'performance',
        protocol: 'jsonrpc',                  //jsonrpc or dubbo，需要看服务端支持情况
        timeout: 3000,
        loadBalance: 'roundRobin',            //连接池中负载均衡方式，默认 ‘random’，可选 ‘random’，‘roundRobin’
        pool: {
            min: 2,                             //连接池最小连接数， 默认 2
            max: 4,                             //连接池最大连接数， 默认 4
            maxWaitingClients: 10,           
            evictionRunIntervalMillis: 10000,   //轮询清理空闲太久未使用的连接的时间间隔，默认 10000ms
            idleTimeoutMillis: 180000,          //这段时间内连接未被使用会被当作空闲连接，然后被上述evict流程清理，默认 180000ms
            keepAlive: true
        },
        circuitBreaker: {                   // 熔断器配置
            openTimeout: 10000,               // 默认 10s，熔断时间窗口，熔断的连接等待10s后会尝试半开等待探活
            failLimit: 10,                    // 默认 10次，连接连续异常处理请求10次后被熔断
            succLimit: 5                      // 默认 3次， 连续成功处理请求3次后连接被打开
        }
    };
    
    const consumer = rpcClient.createConsumer(config);

    await consumer.ready();
    // 发起调用
    consumer.invoke('getUser', [{
        id: 1
    }], ['Dubbo-Attachments: key1=1,key2=2'], {
        retry: 3,
        mock: {
            id: 1,
            name: 'sysuser'
        },
        timeout: 3000
    });
}

launch()
    .catch(console.error);

createConsumer配置解释（标*为必填字段）：

* config.protocol

目前支持的 rpc 调用方式有：

jsonrpc

dubbo

获取，默认为 dubbo(hessian协议)

config.dubboVersion

dubbo暴露的接口对应的dubbo版本，用来筛选接口，默认为 '2.8.0'版本

config.jsonRpcVersion

jsonrpc协议暴露的接口对应的版本，用来调用接口， 默认为 '2.0'版本

config.httpclient

jsonrpc支持用户传入自己的httpclient，否则采用默认

config.contextPath

contextPath是java后端定义的区分服务调用路经的，业务上需与后端确认是否有该参数，默认为空

config.agent

jsonrpc支持用户传入自定义agent，否则采用默认http.Agent

config.version

version 字段用来对找到的 provider 进行删选，不填或填写 '*' 则不做删选。

config.group

group 字段用来对找到的 provider 进一步删选，不填或填写 '*' 则不做删选。

config.methods

=支持启动时检查 Provider 是否提供出合法的方法，配置 methods 属性即可

config.loadBalance

连接池中选取连接的负载均衡方式，默认 ‘random’，可选 ‘random’，‘roundRobin’

调用方法 （invoke）

调用对应的远程服务方法

invoke(method, params, headers?, opts?)

method: String          调用的远程方法名
params: Object          与服务端约定好的传参格式的对象
headers: Array(String)  请求头，如Dubbo-Attachments信息
opts: Object        其他参数，现支持：{
                                rpcMsgId: 1,
                                timeout: 3000, //请求超时时间，超过该时间当作错误走重试
                                retry: 1,      //失败重试次数
                                mock: xxxx     //重试失败后兜底返回的数据,可为任何类型
                            }
'注： opts.rpcMsgId 是jsonrpc协议下的调用标识符。为整型数字，服务端返回调用结果时会带
回该字段用来标示为该次调用的返回。默认为 1'

熔断机制

客户端中连接池中的一个连接遇到若干次连续的请求异常，原因可能很多：例如 服务端断开连接、服务暂时不可用、请求超时等。

由于连接还是在连接池中的说明它还是处于合法的provider列表中的，这种情况这个连接我们可能需要等待服务端的服务恢复才能去使用。

极端情况，所有连接都不可用了，从客户端角度考虑是不应该继续无止境的请求的，因此引入熔断机制。dubbo.js中的熔断器逻辑如下：

额外参数详解

连接池配置：

// dubbo调用连接池配置，可以按照项目需要修改配置
config.pool = {
    min: 2,                             //连接池最小连接数， 默认 2
    max: 4,                             //连接池最大连接数， 默认 4
    maxWaitingClients: 10,           
    evictionRunIntervalMillis: 10000,   //轮询清理空闲太久未使用的连接的时间间隔，默认 10000ms
    idleTimeoutMillis: 180000,          //这段时间内连接未被使用会被当作空闲连接，然后被上述evict流程清理，默认 180000ms
    keepAlive: true
};

熔断器配置：

    config.circuitBreaker = {                   //可选配置，熔断器配置
        openTimeout: 10000,               // 默认 10s，熔断时间窗口，熔断的连接等待10s后会尝试半开等待探活
        failLimit: 10,                    // 默认 10次，连接连续异常处理请求10次后被熔断
        succLimit: 5                      // 默认 3次， 连续成功处理请求3次后连接被打开
    }

Todo

• 支持协议可拓展

LICENSE

MIT