dubbo-node-zookeeper

NodeJS与dubbo RPC通信, zookeeper协同，提供了CLI从Java Interface一键生成services并引用。

内部使用了Socket连接池重用连接，以提高性能。

Install

1npm install dubbo-node-zookeeper -g

或

1yarn global add dubbo-node-zookeeper

Usage

CLI生成services

1dubbo2ts -i DemoService.java -o services -g dubbo -r LATEST -t 6000

use dubbo2ts -h for more details.

生成示例 - DemoService.ts(CLI generated)

1import Dubbo from "dubbo-node-zookeeper";
2
3export const ServiceHead = {
4    interfac: "com.alibaba.dubbo.demo.DemoService",
5    version: "LATEST",
6    timeout: 6000,
7    group: "dubbo",
8    methods: {
9        sayHello: name => [{ $class: "java.lang.String", $: name }],
10        sayHello2: req => [{ $class: "com.alibaba.dubbo.demo.DemoReq", $: req }]
11    }
12};
13
14export function sayHello(name: string) {
15    return Dubbo.exec<string>("DemoService.sayHello", name);
16}
17
18export function sayHello2(req: any) {
19    return Dubbo.exec<string>("DemoService.sayHello2", req);
20}
21
22export default {
23    sayHello,
24    sayHello2
25};

生成示例 - index.ts(引入所有的Services)(CLI generated)

1import { ServiceHead as DemoService } from "./DemoService";
2
3export default {
4    DemoService
5};

使用services

1import Dubbo from "dubbo-node-zookeeper";
2import services from "./services";
3import { sayHello } from "./services/DemoService";
4import express from "express";
5
6new Dubbo({
7    application: { name: "demo-provider" },
8    register: "127.0.0.1:2181",
9    dubboVer: "2.5.7",
10    root: "dubbo",
11    services
12});
13
14setInterval(function() {
15    sayHello("Jack")
16        .then(data => console.log(data))
17        .catch(err => console.log(err));
18}, 5000);
19
20//或者中转http请求至RPC
21const app = express();
22app.get("/hello", (req, res) => {
23    sayHello("Jack")
24    .then(data => res.send(data))
25    .catch(err => res.send(err))
26})

Demo

查看Demo工程

License

Dubbo-node-zookeeper is freely distributable under the terms of the MIT license.