Node 使用 dubbo 协议与 java 进行互相调用

时间 2020-03-19

标签 node 使用 dubbo 协议 java 进行互相调用栏目 Dubbo 繁體版

原文原文链接

前言

随着 BFF 的普及，愈来愈多的应用使用 Nodejs 做为中间层来提供 SSR、WEB API聚合等能力，而相似 Java 等后端更加偏向于服务下沉，而 node 和 java 之间的调用若是走 http 的话，性能没有 rpc 来的高效，在这里介绍一下 node 和 java 以前使用 dubbo 协议的实例（后续还会有 ws / grpc 等）java

安装

在这里使用 daze.js 框架提供的 dubbo-provider 扩展来提供 dubbo 通讯能力node

生成项目:

$ npx @dazejs/cli create dubbo_project
复制代码

安装扩展:

$ cd dubbo_project
$ npm install --save-dev @dazejs/dubbo-provider
复制代码

注册扩展

将扩展加入到 daze.js 配置文件中，配置文件位于 src/config/app.tsgit

import { DubboServiceProvider } from '@dazejs/dubbo-provider'

export default {
  // ...
  providers: [
      // ...
      DubboServiceProvider  
  ]
};
复制代码

添加 dubbo 配置文件

直接在 src/config/ 目录下建立 dubbo.ts, 能够在其中定义须要用到的注册中心地址:github

export default {
    default: { // 字段名即为注册中心命名
      type: 'zookeeper', // 注册中心类型，目前只支持 zookeeper
      host: '127.0.0.1:2181', // zookeeper host地址，hostname+port
      port: 20880 // 对外提供的 dubbo 服务端口
    }
  };
复制代码

建立消费者

在 src/app/ 目录下建立 exmple-consumer.ts （框架会自动读取该目录下的文件进行加载）npm

import { DubboConsumer, dubbo } from '@dazejs/dubbo-provider';
  
  @dubbo.registry('default') // 上面 dubbo.ts 提供的注册中心地址
  @dubbo.interface('com.alibaba.dubbo.demo.DemoProvider', '1.0.0') // 提供者接口地址， 1.0.0 为接口版本号
  export class ExampleConsumer extends DubboConsumer {
      // ...
  }
复制代码

ExampleConsumer 必须继承自 DubboConsumer 才能被框架识别为一个 dubbo 消费者后端

使用消费者调用 java 方法

在 src/app 下建立一个控制器，咱们在控制器方法里面消费 java 数据api

import { Controller, http, inject } from '@dazejs/framework';
   import DemoConsumer from '../dubbo/consumers/demo';
   
   export class ExampleController extends Controller {
   
     @inject(DemoConsumer) demoConsumer: DemoConsumer; // 注入消费者实例
   
     @http.get()
     async index() {
       // 消费方法，参数使用数组的形式传入
       // 调用 java com.alibaba.dubbo.demo.DemoProvider 类的 sayHello 方法
       const res = await this.demoConsumer.invoke('sayHello', ['world']);
       return res;
     }
   }
复制代码

框架会转换简单的参数的类型为 java 类型，推荐使用 java.String('world') 进行手动转换数组

建立提供者

咱们也能够建立提供者来供其余方来调用bash

import { DubboProvider, dubbo } from '@dazejs/dubbo-provider';
   
   @dubbo.registry('default')
   @dubbo.interface('com.alibaba.dubbo.demo.NodeDemoProvider', '1.0.0')
   export default class extends DubboProvider {
     @dubbo.method()
     sayHello(name: string) {
       return `Hello ${name}`;
     }
   }
复制代码

java 调用, 这里省略了 api 与 xml 的定义app

NodeDemoProvider demoService = (NodeDemoProvider) context.getBean("demoProvider"); // 获取远程服务代理
String hello = demoService.sayHello("world"); // 执行远程方法 hello = 'Hello world'
复制代码