免费视频淫片aa毛片_日韩高清在线亚洲专区vr_日韩大片免费观看视频播放_亚洲欧美国产精品完整版

打開APP
userphoto
未登錄

開通VIP，暢享免費電子書等14項超值服

開通VIP

首頁

好書

留言交流

下載APP

聯(lián)系客服
【JAVA秒會技術之Dubbo入門】Dubbo在電商開發(fā)中的應用

Dubbo在電商開發(fā)中的應用

一、Dubbo背景

所謂背景介紹，就是“我們在什么情況下，基于什么原因開發(fā)了這樣一個中間件？”就博主來看，簡而言之，總結如下:

(1) 隨著服務的不斷增多，服務的URL配置管理變得非常困難。此時，我們需要找一個中介替我們管理。

(2) 服務間的依賴關系變得錯蹤復雜，相互調用混亂。此時，我們需要厘清誰是服務提供方，誰是服務的消費方。

(3) 服務間的調用量越來越大，服務的容量問題就暴露出來，這個服務需要多少機器支撐？什么時候該加機器？此時，我們需要有一個自動監(jiān)控系統(tǒng)，幫助我們監(jiān)控管理這一切。

基于以上三點，我們再做一個進一步提?。?/p>

我們需要一個管理眾多服務URL的中介 ——注冊中心；

我們需要搞清服務間復雜的依賴關系 ——服務提供方和服務消費方；

我們需要有一個自動監(jiān)控系統(tǒng)，監(jiān)管一切 ——監(jiān)控中心。

如此，我們Dubbo的模型就自然而然的出來了。

二、Dubbo簡介

Dubbo是Alibaba開源的分布式服務框架，它最大的特點是按照分層的方式來架構，使用這種方式可以使各個層之間解耦合（或者最大限度地松耦合），比如表現(xiàn)層和業(yè)務層就需要解耦合。

從面向服務的角度來看，Dubbo采用的是一種非常簡單的模型，要么是提供方提供服務，要么是消費方消費服務，所以基于這一點可以抽象出服務提供方（Provider）和服務消費方（Consumer）兩個角色。

除了以上兩個角色，它還有注冊中心和監(jiān)控中心。它可以通過注冊中心對服務進行注冊和訂閱，實現(xiàn)了軟負載均衡和Failover（故障切換），降低對F5硬件負載均衡器的依賴，也能減少部分成本。同事，還可以通過監(jiān)控中心對服務進行監(jiān)控，這樣的話，就可以知道哪些服務使用率高、哪些服務使用率低。對使用率高的服務增加機器，對使用率低的服務減少機器，達到合理分配資源的目的。


調用關系說明：

[0] 服務容器負責啟動，加載，運行服務提供者。

[1] 服務提供者在啟動時，向注冊中心注冊自己提供的服務。

[2] 服務消費者在啟動時，向注冊中心訂閱自己所需的服務。

[3] 注冊中心返回服務提供者地址列表給消費者，如果有變更，注冊中心將基于長連接推送變更數(shù)據(jù)給消費者。

[4] 服務消費者，從提供者地址列表中，基于軟負載均衡算法，選一臺提供者進行調用，如果調用失敗，再選另一臺調用。

[5] 服務消費者和提供者，在內存中累計調用次數(shù)和調用時間，定時每分鐘發(fā)送一次統(tǒng)計數(shù)據(jù)到監(jiān)控中心。

三、注冊中心

注冊中心負責服務地址的注冊與查找，相當于目錄服務，服務提供者和消費者只在啟動時與注冊中心交互，注冊中心不轉發(fā)請求，壓力較小。Dubbo目前支持4種注冊中心,（multicast、zookeeper、Redis、simple），但是對于dubbo-2.3.3以上版本，建議使用Zookeeper注冊中心。

（1）Zookeeper簡介

Zookeeper是Apacahe Hadoop的子項目，是一個樹型的目錄服務，支持變更推送，適合作為Dubbo服務的注冊中心，工業(yè)強度較高，可用于生產(chǎn)環(huán)境，并推薦使用。


流程說明：

①服務提供者啟動時：
    向/dubbo/com.foo.BarService/providers目錄下寫入自己的URL地址。
②服務消費者啟動時：
    訂閱/dubbo/com.foo.BarService/providers目錄下的提供者URL地址。
    并向/dubbo/com.foo.BarService/consumers目錄下寫入自己的URL地址。
③監(jiān)控中心啟動時：
    訂閱/dubbo/com.foo.BarService目錄下的所有提供者和消費者URL地址。

支持以下功能：

①當提供者出現(xiàn)斷電等異常停機時，注冊中心能自動刪除提供者信息。
②當注冊中心重啟時，能自動恢復注冊數(shù)據(jù)，以及訂閱請求。
③當會話過期時，能自動恢復注冊數(shù)據(jù)，以及訂閱請求。
④當設置<dubbo:registry check="false" />時，記錄失敗注冊和訂閱請求，后臺定時重試。
⑤可通過<dubbo:registry username="admin" password="1234" />設置zookeeper登錄信息。
⑥可通過<dubbo:registry group="dubbo" />設置zookeeper的根節(jié)點，不設置將使用無根樹。
⑦支持*號通配符<dubbo:reference group="*" version="*" />，可訂閱服務的所有分組和所有版本的提供者

（2）Zookeeper單機安裝

安裝環(huán)境：Linux centOS、JDK環(huán)境（Zookeeper是由Java開發(fā)的）

第一步：下載zookeeper的壓縮包，上傳到linux系統(tǒng)

[plain] view plain copy
  1. 下載Zookeeper-3.4.5.tar.gz 地址http://www.apache.org/dist/zookeeper/  

第二步：解壓縮

[plain] view plain copy
  1. tar -zxf zookeeper-3.4.5.tar.gz  

第三步：創(chuàng)建zoo.cfg文件，進入zookeeper-3.4.5/conf/目錄，修改zoo_sample.cfg 為zoo.cfg

[plain] view plain copy
  1. cp zoo_sample.cfg zoo.cfg  

第四步：配置zoo.cfg

[plain] view plain copy
  1. 主要配置dataDir和clientPort參數(shù)。例如：dataDir = /usr/local/zookeeper/data; clientPort = 2181。  
  2. 注意：datadir目錄中的data末級目錄如果不存在，也會自動生成。  

第五步：啟動zookeeper

[plain] view plain copy
  1. 啟動命令：./zkServer.sh start  
  2. 關閉命令：./zkServer.sh stop  
  3. 查看狀態(tài)命令：./zkServer.sh status  
第六步：關閉防火墻（可選）

[plain] view plain copy
  1. 暫時關閉：service iptables stop  
  2. 永久關閉：chkconfig iptables off</strong>  

四、Dubbo的配置

Dubbo采用全spring配置方式，透明化接入應用，對應用沒有任何API侵入，只需用Spring加載Dubbo的配置即可，Dubbo基于Spring的Schema擴展進行加載。

在Maven的pom.xml中配置如下

[plain] view plain copy
  1. <dependency>  
  2. <!-- 配置zookeeper的客戶端Curator支持Fluent風格的操作API -->  
  3.     <groupId>com.netflix.curator</groupId>  
  4.     <artifactId>curator-framework</artifactId>  
  5.     <version>${com.netflix.curator.version}</version>  
  6. </dependency>  
  7. <dependency>  
  8. <!-- 配置zookeeper的客戶端ZkClient -->  
  9. <!-- 可以解決常見問題：重復注冊watcher、session失效重連、異常處理。 -->  
  10.     <groupId>com.101tec</groupId>  
  11.     <artifactId>zkclient</artifactId>  
  12.     <version>${com.101tec.version}</version>  
  13.     <exclusions>  
  14.         <exclusion>  
  15.             <!-- 添加日志 -->  
  16.                 <groupId>org.slf4j</groupId>  
  17.                 <artifactId>slf4j-log4j12</artifactId>  
  18.         </exclusion>  
  19.     </exclusions>  
  20. </dependency>  
  21. <dependency>  
  22. <!-- 配置Zookeeper -->  
  23.     <groupId>org.apache.zookeeper</groupId>  
  24.     <artifactId>zookeeper</artifactId>  
  25.     <version>${org.apache.zookeeper.version}</version>  
  26.         <exclusions>  
  27.             <exclusion>  
  28.                 <!-- 添加日志 -->  
  29.                 <groupId>org.slf4j</groupId>  
  30.                 <artifactId>slf4j-log4j12</artifactId>  
  31.             </exclusion>  
  32.         </exclusions>  
  33. </dependency>  
  34. <dependency>  
  35. <!-- 配置Dubbo -->  
  36.     <groupId>com.alibaba</groupId>  
  37.     <artifactId>dubbo</artifactId>  
  38.     <version>${com.alibaba.version}</version>  
  39.         <exclusions>  
  40.             <exclusion>  
  41.                 <artifactId>spring</artifactId>  
  42.                 <groupId>org.springframework</groupId>  
  43.             </exclusion>  
  44.         </exclusions>  
  45. </dependency>  

在applicationContext.xml中添加如下配置

[plain] view plain copy
  1. <!-- 引入Dubbo相關的配置文件 -->  
  2.     <import resource="applicationContext-dubbo.xml"/>  
  3.     <import resource="service-provider.xml"/>  
  4.     <import resource="service-consumer.xml"/>  

在applicationContext-dubbo.xml中添加如下配置

[plain] view plain copy
  1. <?xml version="1.0" encoding="UTF-8"?>  
  2. <beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
  3.     xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"  
  4.     xmlns="http://www.springframework.org/schema/beans"  
  5.     xsi:schemaLocation="  
  6.     http://www.springframework.org/schema/beans   
  7.     http://www.springframework.org/schema/beans/spring-beans-2.5.xsd  
  8.     http://code.alibabatech.com/schema/dubbo   
  9.     http://code.alibabatech.com/schema/dubbo/dubbo.xsd">  
  10.     <!-- 注冊中心地址 -->  
  11.     <dubbo:registry protocol="zookeeper" address="${dubbo.protocol.zookeeper}"  
  12.         client="curator" file="docservice-query.properties" />   
  13.     <!-- 本地緩存文件（保留已注冊的服務） -->  
  14.     <!--<dubbo:registry address="multicast://224.5.96.10:1234" /> -->  
  15.     <!-- 提供方應用信息：application-計算依賴關系。name-應用名，owner-負責人 -->  
  16.     <dubbo:application name="${dubbo.application.name}"  
  17.         owner="${dubbo.application.owner}" logger="slf4j" />  
  18.     <!-- 注冊端口名字（接收器）-->  
  19.     <dubbo:protocol name="${dubbo.protocol.name}" port="${dubbo.protocol.port}" />  
  20.     <!-- 當前提供組名 -->  
  21.     <dubbo:provider group="${dubbo.registry.group}" />  
  22.     <!-- 需要消費的消費組名 -->  
  23.     <dubbo:consumer group="${dubbo.registry.group}" />  
  24. </beans>  

服務提供方service-provider.xml配置如下

[plain] view plain copy
  1. <?xml version="1.0" encoding="UTF-8"?>  
  2. <beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
  3.        xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"  
  4.        xmlns="http://www.springframework.org/schema/beans"  
  5.        xsi:schemaLocation="  
  6.    http://www.springframework.org/schema/beans  
  7.    http://www.springframework.org/schema/beans/spring-beans-2.5.xsd  
  8.    http://code.alibabatech.com/schema/dubbo  
  9.    http://code.alibabatech.com/schema/dubbo/dubbo.xsd">  
  10. <!-- 需要暴露的服務地址以及服務名 ，protocol接收器標識-->  
  11. <dubbo:service interface="com.xxx.XxxService" ref="xxxService"  
  12.     protocol="dubbo"  timeout="1000"/>  
  13. </beans>  

服務消費方service-consumer.xml配置如下

[plain] view plain copy
  1. <?xml version="1.0" encoding="UTF-8"?>  
  2. <beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
  3.        xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"  
  4.        xmlns="http://www.springframework.org/schema/beans"  
  5.        xsi:schemaLocation="  
  6.    http://www.springframework.org/schema/beans  
  7.    http://www.springframework.org/schema/beans/spring-beans-2.5.xsd  
  8.    http://code.alibabatech.com/schema/dubbo  
  9.    http://code.alibabatech.com/schema/dubbo/dubbo.xsd">  
  10. <!-- 需要暴露的服務地址以及服務名 ，protocol接收器標識-->  
  11. <dubbo:reference interface="com.xxx.XxxService" id="xxxService" protocol="dubbo"  
  12.      timeout="10000" init="true" group="${dubbo.registry.group}" check="false"/>  
dubbo.properties配置如下

[plain] view plain copy
  1. <strong>#注冊端口名字（接收器）  
  2. dubbo.application.name=service-query  
  3. dubbo.protocol.name=dubbo  
  4. dubbo.protocol.port=20020  
  5. #contarin conf  
  6. dubbo.container=logback,spring  
  7. dubbo.shutdown.hook=true  
  8. #log  
  9. dubbo.application.logger=slf4j  
  10. #spring container  
  11. dubbo.spring.config=classpath*:*spring/applicationContext.xml  
  12. dubbo.logback.level=debug  
  13. dubbo.logback.maxhistory=30</strong>  

 

 

 

 

本站僅提供存儲服務，所有內容均由用戶發(fā)布，如發(fā)現(xiàn)有害或侵權內容，請點擊舉報。
打開APP，閱讀全文并永久保存 查看更多類似文章
猜你喜歡
類似文章
微服務的一種開源實現(xiàn)方式
Dubbo和Zookeeper
零基礎都秒懂：手把手教你搭建一套微服務框架！
Dubbo+Zookeeper
SpringBoot集成Dubbo
Dubbo源碼分析：小白入門篇
更多類似文章 >>
生活服務
分享 收藏 導長圖 關注 下載文章
綁定賬號成功
后續(xù)可登錄賬號暢享VIP特權！
如果VIP功能使用有故障，
可點擊這里聯(lián)系客服！

聯(lián)系客服