在大規模服務化之前，應用可能只是通過 RMI 或 Hessian 等工具，簡單的暴露和引用遠程服務，通過配置服務的URL地址進行調用，通過 F5 等硬件進行負載均衡。
當服務越來越多時，服務 URL 配置管理變得非常困難，F5 硬件負載均衡器的單點壓力也越來越大。 此時需要一個服務注冊中心，動態地注冊和發現服務，使服務的位置透明。並通過在消費方獲取服務提供方地址列表，實現軟負載均衡和 Failover，降低對 F5 硬件負載均衡器的依賴，也能減少部分成本。
當進一步發展，服務間依賴關系變得錯蹤復雜，甚至分不清哪個應用要在哪個應用之前啟動，架構師都不能完整的描述應用的架構關系。 這時，需要自動畫出應用間的依賴關系圖，以幫助架構師理清關系。
接着，服務的調用量越來越大，服務的容量問題就暴露出來，這個服務需要多少機器支撐？什么時候該加機器？ 為了解決這些問題，第一步，要將服務現在每天的調用量，響應時間，都統計出來，作為容量規划的參考指標。其次，要可以動態調整權重，在線上，將某台機器的權重一直加大，並在加大的過程中記錄響應時間的變化，直到響應時間到達閾值，記錄此時的訪問量，再以此訪問量乘以機器數反推總容量。
以上是 Dubbo 最基本的幾個需求。
dubbo的架構：
節點角色說明
| 節點 | 角色說明 |
|---|---|
Provider |
暴露服務的服務提供方 |
Consumer |
調用遠程服務的服務消費方 |
Registry |
服務注冊與發現的注冊中心 |
Monitor |
統計服務的調用次數和調用時間的監控中心 |
Container |
服務運行容器 |
調用關系說明
- 服務容器負責啟動，加載，運行服務提供者。
- 服務提供者在啟動時，向注冊中心注冊自己提供的服務。
- 服務消費者在啟動時，向注冊中心訂閱自己所需的服務。
- 注冊中心返回服務提供者地址列表給消費者，如果有變更，注冊中心將基於長連接推送變更數據給消費者。
- 服務消費者，從提供者地址列表中，基於軟負載均衡算法，選一台提供者進行調用，如果調用失敗，再選另一台調用。
- 服務消費者和提供者，在內存中累計調用次數和調用時間，定時每分鍾發送一次統計數據到監控中心。
Dubbo 架構具有以下幾個特點，分別是連通性、健壯性、伸縮性、以及向未來架構的升級性。
連通性
- 注冊中心負責服務地址的注冊與查找，相當於目錄服務，服務提供者和消費者只在啟動時與注冊中心交互，注冊中心不轉發請求，壓力較小
- 監控中心負責統計各服務調用次數，調用時間等，統計先在內存匯總后每分鍾一次發送到監控中心服務器，並以報表展示
- 服務提供者向注冊中心注冊其提供的服務，並匯報調用時間到監控中心，此時間不包含網絡開銷
- 服務消費者向注冊中心獲取服務提供者地址列表，並根據負載算法直接調用提供者，同時匯報調用時間到監控中心，此時間包含網絡開銷
- 注冊中心，服務提供者，服務消費者三者之間均為長連接，監控中心除外
- 注冊中心通過長連接感知服務提供者的存在，服務提供者宕機，注冊中心將立即推送事件通知消費者
- 注冊中心和監控中心全部宕機，不影響已運行的提供者和消費者，消費者在本地緩存了提供者列表
- 注冊中心和監控中心都是可選的，服務消費者可以直連服務提供者
健壯性
- 監控中心宕掉不影響使用，只是丟失部分采樣數據
- 數據庫宕掉后，注冊中心仍能通過緩存提供服務列表查詢，但不能注冊新服務
- 注冊中心對等集群，任意一台宕掉后，將自動切換到另一台
- 注冊中心全部宕掉后，服務提供者和服務消費者仍能通過本地緩存通訊
- 服務提供者無狀態，任意一台宕掉后，不影響使用
- 服務提供者全部宕掉后，服務消費者應用將無法使用，並無限次重連等待服務提供者恢復
伸縮性
- 注冊中心為對等集群，可動態增加機器部署實例，所有客戶端將自動發現新的注冊中心
- 服務提供者無狀態，可動態增加機器部署實例，注冊中心將推送新的服務提供者信息給消費者
升級性
當服務集群規模進一步擴大，帶動IT治理結構進一步升級，需要實現動態部署，進行流動計算，現有分布式服務架構不會帶來阻力。下圖是未來可能的一種架構：
節點角色說明
| 節點 | 角色說明 |
|---|---|
Deployer |
自動部署服務的本地代理 |
Repository |
倉庫用於存儲服務應用發布包 |
Scheduler |
調度中心基於訪問壓力自動增減服務提供者 |
Admin |
統一管理控制台 |
Registry |
服務注冊與發現的注冊中心 |
Monitor |
統計服務的調用次數和調用時間的監控中心 |
以上內容都來自官網的說明，我只是摘抄過來，方便自己了解。
下面我們來做一個demo操作：在整合demo過程中遇到有比較多的坑，現做個記錄，主要步驟以下：
1、安裝zookeeper
這個過程，我主要放在：https://www.cnblogs.com/lxhaaron/articles/14117523.html這個地址做了說明，這里就不做過多描述
2、創建provider服務
主要步驟以下：
一、創建一個空項目，命名為：springboot-dubbo-zookeeper-pro
二、在這個項目中創建一個Model，項目我們從阿里雲：https://start.aliyun.com創建，這樣比從spring官網創建速度快很多：
三、輸入項目名稱和包名
四、選擇Springboot的web項目
五、完成項目創建
六、加入引用：
<!-- https://mvnrepository.com/artifact/org.apache.dubbo/dubbo-spring-boot-starter --> <dependency> <groupId>org.apache.dubbo</groupId> <artifactId>dubbo-spring-boot-starter</artifactId> <version>2.7.8</version> </dependency> <!-- https://mvnrepository.com/artifact/com.github.sgroschupf/zkclient --> <dependency> <groupId>com.github.sgroschupf</groupId> <artifactId>zkclient</artifactId> <version>0.1</version> </dependency> <!-- https://mvnrepository.com/artifact/org.apache.curator/curator-recipes --> <dependency> <groupId>org.apache.curator</groupId> <artifactId>curator-recipes</artifactId> <version>5.1.0</version> <exclusions> <exclusion> <groupId>org.apache.zookeeper</groupId> <artifactId>zookeeper</artifactId> </exclusion> </exclusions> </dependency> <!-- https://mvnrepository.com/artifact/org.apache.curator/curator-framework --> <dependency> <groupId>org.apache.curator</groupId> <artifactId>curator-framework</artifactId> <version>5.1.0</version> </dependency> <!-- https://mvnrepository.com/artifact/org.apache.zookeeper/zookeeper --> <dependency> <groupId>org.apache.zookeeper</groupId> <artifactId>zookeeper</artifactId> <version>3.6.2</version> </dependency>
七、創建一個接口服務：ITicketService，並定義一個方法sellTicket
package com.fengfang.services; /** * TODO * * @author liuxh * @date 2020/12/11 16:30 **/ public interface ITicketService { public String sellTicket(); }
八、定義這個接口服務的實現類：舊版本是使用：org.apache.dubbo.config.annotation.Service的@Service注解，這很容易與spring的注解混淆，
因為我現在用的dubbo是最新版本：2.7.8，寫代碼時提示這個服務過期了，就更新為@DubboService注解，沒有用以前的這個服務注解
package com.fengfang.services.impl; import com.fengfang.services.ITicketService; import org.apache.dubbo.config.annotation.DubboService; import org.springframework.stereotype.Component; /** * TODO * * @author liuxh * @date 2020/12/11 16:30 **/
@DubboService
//@Service
@Component public class TicketService implements ITicketService { @Override public String sellTicket() { System.out.println("正在執行提供者服務!"); return "我是提供者的服務--賣票服務！"; } }
九、配置dubbo的配置文件：application.yml
server:
port: 8081
#定義dubbo屬性
dubbo:
application:
name: TicketServiceProvider
registry:
address: zookeeper://192.168.31.47:2181
timeout: 100000
protocol:
port: 20880
name: dubbo
scan:
base-packages: com.fengfang.services
這樣服務器就完成了，可以啟動服務看下，也可以到zookeeper里面去看下，這里就介紹一個用於連接zookeeper的客戶端下載地址，https://www.cnblogs.com/xubao/p/10693932.html，自己下載下來可以用來測試zookeeper遠程是否正常。
遇到的坑有以下幾個：
-
dubbo啟動報錯：org.apache.dubbo.config.ProtocolConfig#0“ contains illegal character, only digit，原因是沒有設置：
dubbo.protocol.name=dubbo,設置了這個屬性后就正常了，這個錯誤是自己跟蹤源碼發現的。 - 出現以下這樣的錯誤：原因是沒有設置：
dubbo.registry.timeout=50000,最后增加了這個設置就沒有問題了，這個問題是根據網上說的，還有的說要設置：dubbo.config-center.timeout,這個設置我是沒有增加的。
- 出現這樣的錯誤：SpringBoot啟動dubbo出現com.alibaba.dubbo.common.bytecode.Wrapper12: inconsistent stack height -1異常，原因是：
出現以下錯誤：原因是: 定義服務接口方法的時候 不能已get開頭， 例如：getXXX()
換成別的方法名 例如selectXXX() 之后 錯誤消失。參考問題地址：https://blog.csdn.net/fly_miqiqi/article/details/107080377，這個問題自己在后面重新測試驗證時，好像又沒有這個問題了，即使用帶get的也正常了。
3、創建consumer服務，用於測試服務
一、再創建一個模塊：springboot-dubbo-zookeeper-consumer
這個圖片的包名沒有更改，我是創建后重命名和服務提供者一樣的
二、加入引用，和上面服務提供者一樣：
<!-- https://mvnrepository.com/artifact/com.github.sgroschupf/zkclient --> <dependency> <groupId>com.github.sgroschupf</groupId> <artifactId>zkclient</artifactId> <version>0.1</version> </dependency> <!-- https://mvnrepository.com/artifact/org.apache.curator/curator-recipes --> <dependency> <groupId>org.apache.curator</groupId> <artifactId>curator-recipes</artifactId> <version>5.1.0</version> <exclusions> <exclusion> <groupId>org.apache.zookeeper</groupId> <artifactId>zookeeper</artifactId> </exclusion> </exclusions> </dependency> <!-- https://mvnrepository.com/artifact/org.apache.curator/curator-framework --> <dependency> <groupId>org.apache.curator</groupId> <artifactId>curator-framework</artifactId> <version>5.1.0</version> </dependency> <!-- https://mvnrepository.com/artifact/org.apache.zookeeper/zookeeper --> <dependency> <groupId>org.apache.zookeeper</groupId> <artifactId>zookeeper</artifactId> <version>3.6.2</version> </dependency>
三、增加配置檔，application.yml
server:
port: 8082
dubbo:
registry:
address: zookeeper://192.168.31.47:2181
protocol: zookeeper
timeout: 50000
protocol:
name: dubbo
port: 20881
application:
name: TicketServiceConsumer
四、創建一個與服務提供者一樣的服務接口：
package com.fengfang.services; /** * TODO * * @author liuxh * @date 2020/12/11 19:16 **/ public interface ITicketService { public String sellTicket(); }
五、創建一個消費者程序 ：UserTicketService，這里舊版本dubbo是使用:org.apache.dubbo.config.annotation.Reference的@Reference注解的，新版本已更改為：@DubboReference
注解的，但新版本更改為：
package com.fengfang.services; import org.apache.dubbo.config.annotation.DubboReference; import org.springframework.stereotype.Service; /** * TODO * * @author liuxh * @date 2020/12/11 19:16 **/ @Service public class UserTicketService { @DubboReference ITicketService ticketService; public void userBuyTicket(){ System.out.println("開始執行消費者程序"); String ticket = ticketService.sellTicket(); System.out.println(ticket); System.out.println("完成執行消費者程序"); } }
六、定義一個單元測試方法，用於測試以上服務方法：以下紅色字體內容
package com.fengfang; import com.fengfang.services.UserTicketService; import org.junit.jupiter.api.Test; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; @SpringBootTest class SpringbootDubboZookeeperConsumerApplicationTests { @Autowired UserTicketService userTicketService; @Test void contextLoads() { } @Test public void testUserBuyTicket(){ userTicketService.userBuyTicket(); } }
以上操作完成后，一個dubbo服務提供者和一個dubbo消費者就完成了，另外zookeeper沒有在這里進行過多的說明，可以自己再網上查詢下資料
另外項目現在雖然能完成功能，但還是有一個日志沖突的問題未解決，我在網上找了好多帖子也沒有處理好，這個是個遺留問題待后續跟進處理。
會報以下這樣的錯誤：
