dubbox在企業(yè)中的應(yīng)用

我們摒棄其它教程粗陋的思路，當(dāng)你看到這篇文章之時(shí)，代表已經(jīng)做出選擇；這里只是做細(xì)微講解，demo請到
dubbo github：https://github.com/alibaba/dubbo
dubbox github：https://github.com/dangdangdotcom/dubbox
下載詳細(xì)代碼，查看事例

大綱

  • 官方文檔
  • 項(xiàng)目結(jié)構(gòu)
  • 環(huán)境配置
    • 提供者
    • 消費(fèi)者
  • dubbo協(xié)議
    • 默認(rèn)Hessian序列化
    • kyro序列化

一、官方文檔

dubbo：http://dubbo.io/

二、項(xiàng)目結(jié)構(gòu)

項(xiàng)目結(jié)構(gòu)圖
  • ems-***-api：包含model數(shù)據(jù)對象、service層接口
  • ems-***-provider：是對service接口的實(shí)現(xiàn)和dao層
  • ems--rest：restful協(xié)議實(shí)現(xiàn)層，引用了ems--api
為什么會是這樣的結(jié)構(gòu)？

項(xiàng)目中項(xiàng)目讓其它消費(fèi)端使用該接口，但是不想讓對方了解業(yè)務(wù)的具體實(shí)現(xiàn)；當(dāng)項(xiàng)目發(fā)布部署后，我們只需要把ems-***-api給消費(fèi)端使用，dubbo即可調(diào)用遠(yuǎn)程實(shí)現(xiàn)層；

項(xiàng)目架構(gòu)說明：dubbo進(jìn)入到我的項(xiàng)目

二、環(huán)境配置

提供者

ems-cic-provider的pom.xml中加和ems-cic-api的包


提供者結(jié)構(gòu)
  • src/main/java：java代碼
  • src/main/assembly：
    assembly.xml打包配置文件
    conf包含數(shù)據(jù)庫連接、dubbo、redis等相關(guān)參數(shù)（properties）文件
  • src/main/resources
    META-INF/spring/dubbo-provider.xml：dubbo配置文件
//dubbo-provider.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:jee="http://www.springframework.org/schema/jee"
    xmlns:tx="http://www.springframework.org/schema/tx" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
    xmlns:context="http://www.springframework.org/schema/context"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd
    http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.1.xsd
    http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-3.1.xsd
    http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd
    http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.1.xsd">
    
    <context:property-placeholder location="classpath:conf/*.properties"/>
    <import resource="spring-config-db.xml"/>
<!--應(yīng)用相關(guān)，name：應(yīng)用名稱、owner：所有者、organization：組織-->
    <dubbo:application name="ems-cic" owner="cic" organization="ems" />
<!--協(xié)議相關(guān)，name：協(xié)議名稱、serialization:序列化方式、host:提供者所在服務(wù)器ip、port：提供者端口號-->
    <dubbo:protocol name="dubbo" serialization="kryo" host="${dubbo.protocol.host}" port="${dubbo.protocol.port}" />
<!--對協(xié)議進(jìn)行設(shè)置，delay：延時(shí)、timeout：接口調(diào)用過期時(shí)間、retries:重度次數(shù)-->
    <dubbo:provider protocol="dubbo" delay="-1" timeout="20000" retries="0"  />
<!--注冊地址，一般情況下使用zookeeper，如：zookeeper://127.0.0.1:2181-->
    <dubbo:registry address="${dubbo.registry.address}" />
<!--接口暴露，interface：ems-***-api中所定義的java interface、ref：spring掃描的service實(shí)現(xiàn)別名、protocol：指定以什么協(xié)議暴露接口、validation：true表示驗(yàn)證接口參數(shù)-->
    <dubbo:service interface="net.slans.ems.cic.service.SignService" ref="signService" protocol="dubbo" validation="true" />
    <dubbo:service interface="net.slans.ems.cic.service.DepartmentService" ref="departmentService" protocol="dubbo" validation="true" />
    <dubbo:service interface="net.slans.ems.cic.service.UserService" ref="userService" protocol="dubbo" validation="true" />
    <dubbo:service interface="net.slans.ems.cic.service.RoleService" ref="roleService" protocol="dubbo" validation="true" />
    <dubbo:service interface="net.slans.ems.cic.manager.OmpCodeManager" ref="ompCodeManager" protocol="dubbo" validation="true" />
    <dubbo:service interface="net.slans.ems.cic.manager.OmpTokenManager" ref="ompTokenManager" protocol="dubbo" validation="true" /> 
    <dubbo:service interface="net.slans.ems.cic.manager.OmpRegCodeManager" ref="ompRegCodeManager" protocol="dubbo" validation="true" /> 

</beans>

//dubbo.properties
dubbo.application.name=ems-uic-provider
dubbo.protocol.host=127.0.0.1
dubbo.protocol.port=20810
dubbo.protocol.timeout=2000000
dubbo.registry.address=zookeeper://127.0.0.1:2181
dubbo.log4j.file=logs/dubbo.log
dubbo.log4j.level=WARN

這個(gè)地方我需要嘮叨一下，

  • dubbo.provider timeout：當(dāng)提供者沒有在指定時(shí)間內(nèi)返回?cái)?shù)據(jù)就會報(bào)錯(cuò)，當(dāng)數(shù)據(jù)源查詢數(shù)據(jù)比較慢就會出現(xiàn)此類問題
  • dubbo.provider retries：當(dāng)因指定時(shí)間內(nèi)未返回?cái)?shù)據(jù)，是否重復(fù)調(diào)用此接口，當(dāng)插入數(shù)據(jù)時(shí)，重復(fù)執(zhí)行會造成數(shù)據(jù)重復(fù)
  • dubbo.protocol host：在這里指定內(nèi)部ip在內(nèi)網(wǎng)才可以使用，最開始我們沒有指定此項(xiàng)，跨服務(wù)器消費(fèi)者啟動(dòng)會出現(xiàn)接口無法訪問

此處無法列舉出所有問題，有其它問題可以評論

消費(fèi)者
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:jee="http://www.springframework.org/schema/jee"
    xmlns:tx="http://www.springframework.org/schema/tx" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
    xmlns:context="http://www.springframework.org/schema/context"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd
    http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.1.xsd
    http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-3.1.xsd
    http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd
    http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.1.xsd">
    
    <context:property-placeholder location="classpath:conf/*.properties"/>
    <import resource="spring-config.xml"/>
    
    <dubbo:application name="ems-omp-rest" owner="uic" organization="ems" />

    <dubbo:registry address="zookeeper://127.0.0.1:2181" />
<!--注意：消費(fèi)者和提供者需要使用共同的序列化方法-->
    <dubbo:protocol name="dubbo" serialization="kryo" />
    
    <!-- 訪問的接口 -->
    <dubbo:reference id="snsCodeManager" interface="net.slans.ems.uic.manager.SnsCodeManager" protocol="dubbo" validation="true" />
    <dubbo:reference id="snsTokenManager" interface="net.slans.ems.uic.manager.SnsTokenManager" protocol="dubbo" validation="true" /> 
    <dubbo:reference id="ompCodeManager" interface="net.slans.ems.cic.manager.OmpCodeManager" protocol="dubbo" validation="true" />
    <dubbo:reference id="ompTokenManager" interface="net.slans.ems.cic.manager.OmpTokenManager" protocol="dubbo" validation="true" />
    <dubbo:reference id="ompRegCodeManager" interface="net.slans.ems.cic.manager.OmpRegCodeManager" protocol="dubbo" validation="true" /> 
    <dubbo:reference id="verifyManager" interface="net.slans.ems.uic.manager.VerifyManager" protocol="dubbo" validation="true" /> 
    <dubbo:reference id="signService" interface="net.slans.ems.cic.service.SignService" protocol="dubbo" validation="true" />
    <dubbo:reference id="departmentService" interface="net.slans.ems.cic.service.DepartmentService" protocol="dubbo" validation="true" />
    <dubbo:reference id="userService" interface="net.slans.ems.cic.service.UserService" protocol="dubbo" validation="true" />
    <dubbo:reference id="roleService" interface="net.slans.ems.cic.service.RoleService" protocol="dubbo" validation="true" />
    <dubbo:reference id="slansService" interface="net.slans.ems.uic.service.SlansService" protocol="dubbo" validation="true" /> 
    
</beans>

三、dubbo協(xié)議

  • 默認(rèn)Hessian序列化
//默認(rèn)是Hessian不指定即可
<dubbo:protocol name="dubbo" host="${dubbo.protocol.host}" port="${dubbo.protocol.port}" />
  • kyro序列化
//serialization="kryo"
<dubbo:protocol name="dubbo" serialization="kryo" host="${dubbo.protocol.host}" port="${dubbo.protocol.port}" />

接下來，會涉及到dubbox restful、mycat、jstorm、redis、mongodb、react+redux

很高興認(rèn)識你，我們都一樣，有過迷茫卻從未放棄；害怕孤獨(dú)可從不寂寞。

最后編輯于 ：
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時(shí)請結(jié)合常識與多方信息審慎甄別。
平臺聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點(diǎn)，簡書系信息發(fā)布平臺，僅提供信息存儲服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容