因为MVC中的M都是dubbo服务,因此须要一个插件来调用dubbo服务。我的推荐这个包node-zookeeper-dubbo 咱们所须要的只是把他封装成一个插件,使用方式则相似于httpClient.java
首先执行egg-init --type=plugin egg-dubbo-plugin
这样一个插件的大致框架就构造完成了(egg真的很方便,是否是?)node
而后安装依赖:git
npm i --save js-to-java npm i --save node-zookeeper-dubbo
完成这些后,咱们就开始开发工做了,主要内容就是app.js和app/extend/context.js这两个文件中。github
app.js:npm
const nzd = require("node-zookeeper-dubbo"); module.exports = app => { class DubboClient { constructor() { let config = app.config.dubboclient; config.java = require('js-to-java') this.dubboAgent=new nzd(config.dubboAgent); } request(className, method, javaParams) { try { return this.dubboAgent[className][method](...javaParams); }catch(e){ app.coreLogger.error('[egg:dubboAgent] call dubbo error'); app.coreLogger.error(e); } } } app.dubboClinent = new DubboClient(); };
能够看到,DubboClient只是一个封装,真正对工做委托给了 dubboAgent,也就是nzd。app
context.js框架
module.exports = { dubbo(className, method, ...javaParams) { const timeout = this.app.dubboClinent.dubboAgent.dependencies[className].dubboTimeout || this.app.dubboClinent.dubboTimeout || 30000; return Promise.race([ this.app.dubboClinent.request(className, method, javaParams), new Promise((_, reject) => setTimeout(() => reject(new Error('timeout')), timeout)) ]); }, };
在context.js里,咱们进行了dubbo方法的绑定,这样在controller里,就能够像调用ctx.curl方法同样,调用dubbo服务了。
这里要注意一个问题:dubbo服务可能会超时,因此咱们这里须要对超时进行了处理,经过Promise.race,让dubbo服务的调用和咱们的timeout进行竞争,若是超时,直接抛出错误。注意!!!不要catch,egg会统一对错误进行处理,因此咱们在底层不要catch错误,直接把错误往上抛出就好!curl
最后,看一下使用这个插件时的配置,在config.default.js中:ide
exports.dubboclient = { dubboAgent: { application:{name:'demo-provider'}, register:'localhost:2181', dubboVer:'2.5.4-SNAPSHOT', root:'dubbo', dependencies:{ Foo:{ interface:'com.alibaba.dubbo.demo.provider.DemoService', }, } } }
和node-zookeeper-dubbo对比下就能看出,咱们只是把配置移动到dubboAgent这个对象而已。单元测试
完成后,补齐单元测试,发布到npm库里就可。
git地址:https://github.com/Daniel1989...