js-remoting-for-apache-dubbo

dubbo remoting

Introduction

Dubbo Protocol Nodejs Implement

• Common Exchange Packet

 0      1      2             4             6             8            10            12
 +------+------+------+------+------+------+------+------+------+------+------+------+
 |    MAGIC    | flag |status|                        packet id                      |
 +-------------+-------------+-------------+-------------+-------------+-------------+
 |        body length        |                          body                         |
 +---------------------------+                                                       +
 |                                     ... ...                                       |
 +-----------------------------------------------------------------------------------+

• Dubbo Request Packet

 0      1      2             4             6             8            10            12
 +------+------+------+------+------+------+------+------+------+------+------+------+
 |    MAGIC    | flag |      |                        packet id                      |
 +-------------+-------------+-----------------+-------------------+-----------------+
 |        body length        |  dubbo version  |   service path    | service version |
 +---------------+-----------+-----------+-----+-------------------+-----------------+
 |  method name  | arguments description |                                           |
 +---------------+-----------------------+                arguments                  +
 |                                        ...  ...                                   |
 +-----------------------------------------------------------------------------------+
 |                                   attachments                                     |
 +-----------------------------------------------------------------------------------+

• Dubbo Response Packet

packet status ok

 0      1      2             4             6             8            10            12
 +------+------+------+------+------+------+------+------+------+------+------+------+
 |    MAGIC    | flag |status|                        packet id                      |
 +-------------+-------------+---------------------------+---------------------------+
 |        body length        |        result flag        |                           |
 +---------------------------+---------------------------+                           +
 |                             result or exception ...                               |
 +-----------------------------------------------------------------------------------+

packet status not ok

 0      1      2             4             6             8            10            12
 +------+------+------+------+------+------+------+------+------+------+------+------+
 |    MAGIC    | flag |status|                        packet id                      |
 +-------------+-------------+---------------------------+---------------------------+
 |        body length        |                   error message                       |
 +---------------------------+-------------------------------------------------------+

Install

1$ npm install dubbo-remoting --save

Usage

You can use this dubbo protocol implementation with the sofa-rpc-node

1. Install & Launch zk

1$ brew install zookeeper
2
3$ zkServer start
4ZooKeeper JMX enabled by default
5Using config: /usr/local/etc/zookeeper/zoo.cfg
6Starting zookeeper ... STARTED

2. Expose a dubbo service

1'use strict';
2
3const { RpcServer } = require('sofa-rpc-node').server;
4const { ZookeeperRegistry } = require('sofa-rpc-node').registry;
5const protocol = require('dubbo-remoting');
6
7const logger = console;
8
9// 1. create zk registry client
10const registry = new ZookeeperRegistry({
11  logger,
12  address: '127.0.0.1:2181',
13});
14
15// 2. create rpc server
16const server = new RpcServer({
17  logger,
18  registry,
19  port: 12200,
20  protocol,
21});
22
23// 3. add service
24server.addService({
25  interfaceName: 'com.nodejs.test.TestService',
26}, {
27  async plus(a, b) {
28    return a + b;
29  },
30});
31
32// 4. launch the server
33server.start()
34  .then(() => {
35    server.publish();
36  });

3. Call the dubbo service

1'use strict';
2
3const { RpcClient } = require('sofa-rpc-node').client;
4const { ZookeeperRegistry } = require('sofa-rpc-node').registry;
5const protocol = require('dubbo-remoting');
6const logger = console;
7
8// 1. create zk registry client
9const registry = new ZookeeperRegistry({
10  logger,
11  address: '127.0.0.1:2181',
12});
13
14async function invoke() {
15  // 2. create rpc client with dubbo protocol
16  const client = new RpcClient({
17    logger,
18    registry,
19    protocol,
20  });
21  // 3. create rpc service consumer
22  const consumer = client.createConsumer({
23    interfaceName: 'com.nodejs.test.TestService',
24  });
25  // 4. wait consumer ready
26  await consumer.ready();
27
28  // 5. call the service
29  const result = await consumer.invoke('plus', [1, 2], { responseTimeout: 3000 });
30  console.log('1 + 2 = ' + result);
31}
32
33invoke().catch(console.error);