因爲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...