[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_11":-5},"routes/user.$name.replies",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":16},"replies",[34],"user",{"_20":21,"_13":14,"_22":23,"_24":14,"_25":26,"_27":28,"_29":30,"_31":16,"_32":33},"loginname","walkingOnAir","page",1,"limit",50,"total","id","22110","avatar_url","https://avatars.githubusercontent.com/u/12179762?v=4","githubUsername","create_at","2016-04-18 09:46:43.423","score",5,"topic_count",0,"reply_count","is_star",false,{"_20":35,"_36":37,"_38":39,"_40":41,"_42":43,"_44":45,"_46":33,"_47":33,"_31":48,"_49":50,"_25":51,"_52":53},"40206","author_id","6542","tab","share","content","## 1. Dubbo 是啥？\r\n\r\nDubbo 是一个由阿里开源的 RPC 框架。\r\n\r\n简单说下RPC框架的背景。\r\n\r\n![From dubbo.apache.org](http://ww1.sinaimg.cn/large/6026faa6ly1g1his3o33yj20p40p011i.jpg)\r\n\r\nDubbo 是一种 RPC 框架，应用在分布式服务。\r\n\r\n![](http://dubbo.apache.org/img/architecture.png) \r\n\r\n## 2. 使用 Dubbo 实现 Java 互调\r\n\r\n\t首先我们可以先尝试下同语言下的 Dubbo 调用，从容易开始。\r\n\r\n\t可以参考下 dubbo 官方文档 [http://dubbo.apache.org/zh-cn/docs/user/quick-start.html](http://dubbo.apache.org/zh-cn/docs/user/quick-start.html)\r\n\r\n\t这边简单尝试下，主要有两步： \r\n\r\n1. 首先建立一个服务提供方，也就是上图 Provider 的角色；\r\n\r\n2. 接下来建立一个服务消费者，也如同上图的 Consumer 的角色； \r\n\r\n### 服务提供方建立 Provider\r\n\r\n**1.0 使用Spring Boot 建立一个Spring 微服务** (可以参考)[https://yuchenzhen.github.io/2018/08/24/SpringBoot-IDE-initial/](http://https://yuchenzhen.github.io/2018/08/24/SpringBoot-IDE-initial/)\r\n\r\n**1.1. 建立一个 Interface **\r\n``` java\r\n// TestProviderService.java\r\n\r\npackage com.dubbo.learn.dubbo;\r\n\r\npublic interface TestProviderService {\r\n String Hello (String who);\r\n}\r\n```\r\n\r\n**1.2 实现这个TestProviderServiceImpl**\r\n\r\n``` java\r\n// TestProviderServiceImpl\r\npackage com.dubbo.learn.dubbo.impl;\r\n\r\nimport com.dubbo.learn.dubbo.TestProviderService;\r\nimport com.alibaba.dubbo.config.annotation.Service;\r\n\r\n@Service(version=\"1.0.0\")\r\npublic class TestProviderServiceImpl implements TestProviderService {\r\n public String Hello(String who) {\r\n return \"Hello world ! Dear Programer \" + who ;\r\n }\r\n}\r\n\r\n```\r\n\r\n**1.3 启动程序主入口添加`@EnableDubbo`注解**\r\n\r\n``` java\r\n// ProviderApplication.java\r\npackage com.dubbo.learn;\r\n\r\nimport org.springframework.boot.SpringApplication;\r\nimport org.springframework.boot.autoconfigure.SpringBootApplication;\r\nimport com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;\r\n\r\n@SpringBootApplication\r\n@EnableDubbo\r\npublic class ProviderApplication {\r\n\r\n public static void main(String[] args) {\r\n SpringApplication.run(ProviderApplication.class, args);\r\n }\r\n\r\n}\t\r\n``` \r\n\r\n\t为了引入这个`@EnableDubbo`注解，需要我们引入`com.alibaba`的包 \r\n\r\n```xml\r\n\r\n\r\n com.alibaba.boot\r\n dubbo-spring-boot-starter \r\n 0.2.1.RELEASE\r\n\r\n\r\n com.alibaba\r\n dubbo\r\n 2.6.5\r\n\r\n\r\n org.apache.curator\r\n curator-framework\r\n 2.11.1\r\n\r\n```\r\n\t`curator-framework`是dubbo所使用的消息中心`Zookeeper`所需要的包 \r\n\t`dubbo-spring-boot-starter`是 dubbo spring 的配置包 \r\n\r\n**1.4 最后我们把dubbo 的启动配置写到`application.properties`里面** \r\n\r\n```properties\r\n# application.properties\r\nserver.port = 8829\r\n#\r\ndubbo.application.name=provider\r\ndubbo.registry.protocol=zookeeper\r\ndubbo.registry.address=zookeeper://127.0.0.1:2181\r\ndubbo.scan.base-packages=com.dubboo.learn\r\ndubbo.protocol.name=dubbo\r\ndubbo.protocol.port=20880\r\ndubbo.consumer.check=false\r\n```\r\n整个项目结构如图： \r\n\r\n![](http://ww1.sinaimg.cn/large/6026faa6gy1g1ffq5j1mrj20a70jhab5.jpg)\r\n\r\n然后，启动就好。 \r\n\r\n启动之后，通过 dubbo Admin 网页客户端可以看见Provider的接口在 Regitry 里面注册成功。 \r\n![](http://ww1.sinaimg.cn/large/6026faa6gy1g1ffrs83ubj227m0n8djl.jpg)\r\n\r\n### 服务消费者Consumer\r\n**1.0 使用Spring Boot 建立一个Spring 消费者的微服务** \r\n\r\n**1.1 定义接口，这里的接口路径位置和包名最好一致（不然要自己调整）** \r\n```java\r\n// TestProviderService.java\r\npackage com.dubbo.learn.dubbo;\r\npublic interface TestProviderService {\r\n String Hello (String who);\r\n}\r\n``` \r\n\r\n**1.2 定义一个 Service调用该dubbo 接口**\r\n\r\n```java\r\n// TestConsumerService.java\r\npackage com.dubbo.learn;\r\n\r\nimport com.alibaba.dubbo.config.annotation.Reference;\r\nimport com.dubbo.learn.dubbo.TestProviderService;\r\nimport org.springframework.stereotype.Component;\r\n\r\n@Component\r\npublic class TestConsumerService {\r\n @Reference(version = \"1.0.0\")\r\n TestProviderService testProviderService;\r\n\r\n public void consumer (String who) {\r\n String res = testProviderService.Hello(who);\r\n System.out.println(\"consumer : provider says \" + res);\r\n }\r\n}\r\n```\r\n\r\n在主程序函数调用该Service 的函数 \r\n\r\n```java\r\n// DubboConsumerApplication.java\r\npackage com.dubbo.learn;\r\n\r\nimport org.springframework.boot.SpringApplication;\r\nimport org.springframework.boot.autoconfigure.SpringBootApplication;\r\nimport org.springframework.context.ConfigurableApplicationContext;\r\nimport com.dubbo.learn.TestConsumerService;\r\n\r\n@SpringBootApplication\r\npublic class DubboConsumerApplication {\r\n\r\n public static void main(String[] args) {\r\n ConfigurableApplicationContext run = SpringApplication.run(DubboConsumerApplication.class, args);\r\n TestConsumerService testConsumer = run.getBean(TestConsumerService.class);\r\n testConsumer.consumer(\"White\");\r\n }\r\n\r\n}\r\n```\r\n`@Reference`这个注解就是用来调用 dubbo 对应的接口的。所以也是要引入跟服务端的那几个包 \r\n\r\n```xml\r\n\r\n\r\n com.alibaba.boot\r\n dubbo-spring-boot-starter \r\n 0.2.1.RELEASE\r\n\r\n\r\n com.alibaba\r\n dubbo\r\n 2.6.5\r\n\r\n\r\n org.apache.curator\r\n curator-framework\r\n 2.11.1\r\n \r\n```\r\n\r\n**1.3 最后我们把dubbo 的启动配置写到application.properties里面**\r\n\r\n``` properties\r\n#application.properties\r\nserver.port=8830\r\ndubbo.application.name=consumer\r\n#注册中心地址\r\ndubbo.registry.address=zookeeper://127.0.0.1:2181\r\n\r\ndubbo.scan.base-packages=com.dubboo.learn.dubbo\r\ndubbo.protocol.port=20880\r\n```\r\n项目目录结构如下：\r\n![](http://ww1.sinaimg.cn/large/6026faa6gy1g1fgt0ik3aj20aa0irdgx.jpg)\r\n\r\n启动后效果如下：\r\n\r\n![](http://ww1.sinaimg.cn/large/6026faa6gy1g1fgfyr094j211l0e60yc.jpg)\r\n\r\n## 3. Node.js 如何通过 Dubbo 调用 Java\r\n\r\nNode 这边通过 dubbo调用 Java 的 provider 的接口，我们尝试调用了几个包：sofa-rpc-node，node-zookeeper-dubbo，和dubbo2.js 。 \r\n其中 sofa-rpc-node 的对使用 egg.js框架的比较友好，node-zookeeper-dubbo 使用起来跟 sofa-rpc-node 差不多；但是有点麻烦的就是这两个包都需要写 proto3的接口定义。 \r\n而 dubbo2.js则比较方便，以下是使用 dubbo2.js 的示列 \r\n```javascript\r\nconst { Dubbo, java, setting } = require('dubbo2.js')\r\nconst interfaceName = 'com.dubbo.learn.dubbo.TestProviderService'\r\nconst interfaceVersion = '1.0.0'\r\nconst dubboSetting = setting.match(\r\n interfaceName, { version: interfaceVersion }\r\n)\r\nconst dubboService = dubbo => dubbo.proxyService({\r\n dubboInterface: interfaceName,\r\n version: '1.0.0',\r\n methods: {\r\n Hello (who) {\r\n return [\r\n java.String(who)\r\n ]\r\n }\r\n }\r\n})\r\nconst service = {dubboService}\r\n// 实例化Dubbo，入参主要是名称和 dubbo 接口的设置\r\nconst dubbo = new Dubbo({\r\n application: {name: 'dubbo-node-test'},\r\n register: '127.0.0.1:2181',\r\n dubboSetting,\r\n service\r\n})\r\n\r\nmodule.exports = dubbo\r\n\r\n```\r\n代码就是这么简单，把 Java 服务里面通过 dubbo 提供出来的接口(包括接口名，接口版本信息，接口方法) 注册一下。 \r\n得到Dubbo 实例之后，调用对应的 service就可以使用。 \r\n如下： \r\n\r\n```javascript\r\nawait dubbo.service.dubboService.Hello(who)\r\n```\r\n我们简单写了一个接口： \r\n\r\n```javascript\r\nconst KoaRouter = require('koa-router')\r\nconst dubbo = require('./dubbo')\r\nconst router = new KoaRouter({prefix: '/api/v1'})\r\n\r\nrouter.use('/')\r\n\r\nrouter.get('/testNodeDubbo', async (ctx, next) => {\r\n console.info(`[testNodeDubbo]:==:> start`)\r\n let {who} = ctx.request.query\r\n const res = await dubbo.service.dubboService.Hello(who)\r\n ctx.body = res\r\n})\r\n\r\nmodule.exports = router\r\n\r\n```\r\n\r\n调用结果： \r\n\r\n![](http://ww1.sinaimg.cn/large/6026faa6gy1g1gidpequnj20zc0fyq45.jpg) \r\n这样就完成了 node 作为消费者通过 dubbo 去调用 java 的接口了。 \r\n## 4. Node.js 通过接口调用 Java 与通过 Dubbo 调用 Java 的对比\r\n![](http://ww1.sinaimg.cn/large/6026faa6gy1g1hbp8z51mj21fg0kaq7i.jpg) \r\n这边尝试使用了调用了同样逻辑的 dubbo 和 http 接口，对比了一下两个实现的返回时间。 \r\n其中红色的是 dubbo 接口，蓝色的是 http 接口。 \r\n#### 其他：\r\n项目地址： \r\n[https://github.com/yuchenzhen/Java-dubbo-provider](https://github.com/yuchenzhen/Java-dubbo-provider)\r\n[https://github.com/yuchenzhen/Java-dubbo-client](https://github.com/yuchenzhen/Java-dubbo-client)\r\n[https://github.com/yuchenzhen/node-dubbo2-consumer/tree/master](https://github.com/yuchenzhen/node-dubbo2-consumer/tree/master)","title","Node.js通过Dubbo2.js调用Java","last_reply_at","2021-08-11 15:38:02.594","good","top",2,"visit_count",4734,"2019-04-02 08:45:55.53","author",{"_13":54,"_22":55},"kalengo","https://avatars2.githubusercontent.com/u/8817810?v=4"]