Node.js經過Dubbo2.js調用Java

1. Dubbo 是啥？

Dubbo 是一個由阿里開源的 RPC 框架。

簡單說下RPC框架的背景。

Dubbo 是一種 RPC 框架，應用在分佈式服務。

2. 使用 Dubbo 實現 Java 互調

​ 首先咱們能夠先嚐試下同語言下的 Dubbo 調用，從容易開始。

​ 能夠參考下 dubbo 官方文檔 http://dubbo.apache.org/zh-cn/docs/user/quick-start.html

​ 這邊簡單嘗試下，主要有兩步：

1. 首先創建一個服務提供方， 也就是上圖 Provider 的角色；

2. 接下來創建一個服務消費者， 也如同上圖的 Consumer 的角色；

服務提供方創建 Provider

1.0 使用Spring Boot 創建一個Spring 微服務 (能夠參考)https://yuchenzhen.github.io/2018/08/24/SpringBoot-IDE-initial/

**1.1. 創建一個 Interface **

// TestProviderService.java

package com.dubbo.learn.dubbo;

public interface TestProviderService {
    String Hello (String who);
}

1.2 實現這個TestProviderServiceImpl

// TestProviderServiceImpl
package com.dubbo.learn.dubbo.impl;

import com.dubbo.learn.dubbo.TestProviderService;
import com.alibaba.dubbo.config.annotation.Service;

@Service(version="1.0.0")
public class TestProviderServiceImpl implements TestProviderService  {
    public String Hello(String who) {
        return "Hello world ! Dear Programer " + who ;
    }
}

1.3 啓動程序主入口添加@EnableDubbo註解

// ProviderApplication.java
package com.dubbo.learn;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;

@SpringBootApplication
@EnableDubbo
public class ProviderApplication {

    public static void main(String[] args) {
        SpringApplication.run(ProviderApplication.class, args);
    }

}

​ 爲了引入這個@EnableDubbo註解，須要咱們引入com.alibaba的包

<!--pom.xml-->
<dependency>
  <groupId>com.alibaba.boot</groupId>
  <artifactId>dubbo-spring-boot-starter</artifactId> 
  <version>0.2.1.RELEASE</version>
</dependency>
<dependency>
  <groupId>com.alibaba</groupId>
  <artifactId>dubbo</artifactId>
  <version>2.6.5</version>
</dependency>
<dependency>
  <groupId>org.apache.curator</groupId>
  <artifactId>curator-framework</artifactId>
  <version>2.11.1</version>
</dependency>

​ curator-framework是dubbo所使用的消息中心Zookeeper所須要的包
​ dubbo-spring-boot-starter是 dubbo spring 的配置包

1.4 最後咱們把dubbo 的啓動配置寫到application.properties裏面

# application.properties
server.port = 8829
#
dubbo.application.name=provider
dubbo.registry.protocol=zookeeper
dubbo.registry.address=zookeeper://127.0.0.1:2181
dubbo.scan.base-packages=com.dubboo.learn
dubbo.protocol.name=dubbo
dubbo.protocol.port=20880
dubbo.consumer.check=false

整個項目結構如圖：

而後，啓動就好。

啓動以後，經過 dubbo Admin 網頁客戶端能夠看見Provider的接口在 Regitry 裏面註冊成功。

服務消費者Consumer

1.0 使用Spring Boot 創建一個Spring 消費者的微服務

1.1 定義接口，這裏的接口路徑位置和包名最好一致 （否則要本身調整）

// TestProviderService.java
package com.dubbo.learn.dubbo;
public interface TestProviderService {
    String Hello (String who);
}

1.2 定義一個 Service調用該dubbo 接口

// TestConsumerService.java
package com.dubbo.learn;

import com.alibaba.dubbo.config.annotation.Reference;
import com.dubbo.learn.dubbo.TestProviderService;
import org.springframework.stereotype.Component;

@Component
public class TestConsumerService {
    @Reference(version = "1.0.0")
    TestProviderService testProviderService;

    public void consumer (String who) {
        String res = testProviderService.Hello(who);
        System.out.println("consumer : provider says " + res);
    }
}

在主程序函數調用該Service 的函數

// DubboConsumerApplication.java
package com.dubbo.learn;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.ConfigurableApplicationContext;
import com.dubbo.learn.TestConsumerService;

@SpringBootApplication
public class DubboConsumerApplication {

    public static void main(String[] args) {
        ConfigurableApplicationContext run = SpringApplication.run(DubboConsumerApplication.class, args);
        TestConsumerService testConsumer = run.getBean(TestConsumerService.class);
        testConsumer.consumer("White");
    }

}

@Reference這個註解就是用來調用 dubbo 對應的接口的。因此也是要引入跟服務端的那幾個包

<!--pom.xml-->
<dependency>
  <groupId>com.alibaba.boot</groupId>
  <artifactId>dubbo-spring-boot-starter</artifactId> 
  <version>0.2.1.RELEASE</version>
</dependency>
<dependency>
  <groupId>com.alibaba</groupId>
  <artifactId>dubbo</artifactId>
  <version>2.6.5</version>
</dependency>
<dependency>
  <groupId>org.apache.curator</groupId>
  <artifactId>curator-framework</artifactId>
  <version>2.11.1</version>
</dependency>

1.3 最後咱們把dubbo 的啓動配置寫到application.properties裏面

#application.properties
server.port=8830
dubbo.application.name=consumer
#註冊中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181

dubbo.scan.base-packages=com.dubboo.learn.dubbo
dubbo.protocol.port=20880

項目目錄結構以下：

啓動後效果以下：

3. Node.js 如何經過 Dubbo 調用 Java

Node 這邊經過 dubbo調用 Java 的 provider 的接口，咱們嘗試調用了幾個包：sofa-rpc-node，node-zookeeper-dubbo，和dubbo2.js 。
其中 sofa-rpc-node 的對使用 egg.js框架的比較友好，node-zookeeper-dubbo 使用起來跟 sofa-rpc-node 差很少；可是有點麻煩的就是這兩個包都須要寫 proto3的接口定義。
而 dubbo2.js則比較方便，如下是使用 dubbo2.js 的示列

const { Dubbo, java, setting } = require('dubbo2.js')
const interfaceName = 'com.dubbo.learn.dubbo.TestProviderService'
const interfaceVersion = '1.0.0'
const dubboSetting = setting.match(
  interfaceName, { version: interfaceVersion }
)
const dubboService = dubbo => dubbo.proxyService({
  dubboInterface: interfaceName,
  version: '1.0.0',
  methods: {
    Hello (who) {
      return [
        java.String(who)
      ]
    }
  }
})
const service = {dubboService}
// 實例化Dubbo， 入參主要是名稱和 dubbo 接口的設置
const dubbo = new Dubbo({
  application: {name: 'dubbo-node-test'},
  register: '127.0.0.1:2181',
  dubboSetting,
  service
})

module.exports = dubbo

代碼就是這麼簡單， 把 Java 服務裏面經過 dubbo 提供出來的接口(包括接口名，接口版本信息，接口方法) 註冊一下。
獲得Dubbo 實例以後，調用對應的 service就可使用。
以下：

await dubbo.service.dubboService.Hello(who)

咱們簡單寫了一個接口：

const KoaRouter = require('koa-router')
const dubbo = require('./dubbo')
const router = new KoaRouter({prefix: '/api/v1'})

router.use('/')

router.get('/testNodeDubbo', async (ctx, next) => {
  console.info(`[testNodeDubbo]:==:> start`)
  let {who} = ctx.request.query
  const res = await dubbo.service.dubboService.Hello(who)
  ctx.body = res
})

module.exports = router

調用結果：

這樣就完成了 node 做爲消費者經過 dubbo 去調用 java 的接口了。

4. Node.js 經過接口調用 Java 與 經過 Dubbo 調用 Java 的對比

這邊嘗試使用了調用了一樣邏輯的 dubbo 和 http 接口， 對比了一下兩個實現的返回時間。
其中紅色的是 dubbo 接口， 藍色的是 http 接口。

其餘：

項目地址：
https://github.com/yuchenzhen/Java-dubbo-provider
https://github.com/yuchenzhen/Java-dubbo-client
https://github.com/yuchenzhen/node-dubbo2-consumer/tree/master