🎼個人主頁：【Y小夜】

😎作者簡介：一位雙非學校的大二學生，編程愛好者，

專注于基礎和實戰分享，歡迎私信咨詢！

🎆入門專欄：🎇【MySQL，Java基礎，Rust】

🎈熱門專欄：🎊【Python，Javaweb，Vue框架】

感謝您的點贊、關注、評論、收藏、是對我最大的認可和支持！??

目錄

🎯分布式理論

🎃分布式系統

🎃Dubbo框架

🎃單一應用架構

🎃垂直應用架構

🎃分布式服務架構

🎃流動計算架構

🎯什么是RPC？

🎃RPC基本原理

🎯Dubbo

🎃什么是dubbo？

?dubbo基本概念

?調用關系說明

🎃window下安裝zookeeper

🎯SpringBoot + Dubbo + zookeeper

🎃框架搭建

🎃服務提供者

🎃消費者

5. 測試類編寫；

---

🎯分布式理論

🎃分布式系統

“分布式系統是若干獨立計算機的集合，這些計算機對 于用戶來說就像單個相關系統”

????????分布式系統（distributed system）是建立在網絡之上的軟件系統。

????????首先需要明確的是，只有當單個節點的處理能力無法滿足日益增長的計算、存儲任務的時候，且硬件的 提升（加內存、加磁盤、使用更好的CPU）高昂到得不償失的時候，應用程序也不能進一步優化的時 候，我們才需要考慮分布式系統。因為，分布式系統要解決的問題本身就是和單機系統一樣的，而由于 分布式系統多節點、通過網絡通信的拓撲結構，會引入很多單機系統沒有的問題，為了解決這些問題又 會引入更多的機制、協議，帶來更多的問題。

🎃Dubbo框架

????????隨著互聯網的發展，網站應用的規模不斷擴大，常規的垂直應用架構已無法應對，分布式服務架構以及 流動計算架構勢在必行，急需一個治理系統確保架構有條不紊的演進。

🎃單一應用架構

????????當網站流量很小時，只需一個應用，將所有功能都部署在一起，以減少部署節點和成本。此時，用于簡化增刪改查工作量的數據訪問框架(ORM)是關鍵。

????????適用于小型網站，小型管理系統，將所有功能都部署到一個功能里，簡單易用。?

缺點：

• 1、性能擴展比較難
• 2、協同開發問題
• 3、不利于升級維護

🎃垂直應用架構

????????當訪問量逐漸增大，單一應用增加機器帶來的加速度越來越小，將應用拆成互不相干的幾個應用，以提 升效率。此時，用于加速前端頁面開發的Web框架(MVC)是關鍵

????????通過切分業務來實現各個模塊獨立部署，降低了維護和部署的難度，團隊各司其職更易管理，性能擴展 也更方便，更有針對性。

缺點： 公用模塊無法重復利用，開發性的浪費

🎃分布式服務架構

????????當垂直應用越來越多，應用之間交互不可避免，將核心業務抽取出來，作為獨立的服務，逐漸形成穩定 的服務中心，使前端應用能更快速的響應多變的市場需求。此時，用于提高業務復用及整合的分布式服務框架(RPC)是關鍵。

🎃流動計算架構

????????當服務越來越多，容量的評估，小服務資源的浪費等問題逐漸顯現，此時需增加一個調度中心基于訪問 壓力實時管理集群容量，提高集群利用率。此時，用于提高機器利用率的資源調度和治理中心**(SOA)[ Service Oriented Architecture]是關鍵**

🎯什么是RPC？

????????RPC【Remote Procedure Call】是指遠程過程調用，是一種進程間通信方式，他是一種技術的思想，而 不是規范。它允許程序調用另一個地址空間（通常是共享網絡的另一臺機器上）的過程或函數，而不用 程序員顯式編碼這個遠程調用的細節。即程序員無論是調用本地的還是遠程的函數，本質上編寫的調用 代碼基本相同。????????

????????也就是說兩臺服務器A，B，一個應用部署在A服務器上，想要調用B服務器上應用提供的函數/方法，由 于不在一個內存空間，不能直接調用，需要通過網絡來表達調用的語義和傳達調用的數據。為什么要用 RPC呢？就是無法在一個進程內，甚至一個計算機內通過本地調用的方式完成的需求，比如不同的系統 間的通訊，甚至不同的組織間的通訊，由于計算能力需要橫向擴展，需要在多臺機器組成的集群上部署 應用。RPC就是要像調用本地的函數一樣去調遠程函數；

🎃RPC基本原理

🎯Dubbo

🎃什么是dubbo？

Apache Dubbo |?d?b??| 是一款高性能、輕量級的開源Java RPC框架，它提供了三大核心能力：面向 接口的遠程方法調用，智能容錯和負載均衡，以及服務自動注冊和發現

?dubbo基本概念

服務提供者**（Provider）**：暴露服務的服務提供方，服務提供者在啟動時，向注冊中心注冊自己提 供的服務。

服務消費者**（Consumer）**: 調用遠程服務的服務消費方，服務消費者在啟動時，向注冊中心訂閱自 己所需的服務，服務消費者，從提供者地址列表中，基于軟負載均衡算法，選一臺提供者進行調用，如 果調用失敗，再選另一臺調用。

注冊中心**（Registry）**：注冊中心返回服務提供者地址列表給消費者，如果有變更，注冊中心將基 于長連接推送變更數據給消費者

監控中心**（Monitor）**：服務消費者和提供者，在內存中累計調用次數和調用時間，定時每分鐘發 送一次統計數據到監控中

?調用關系說明

l 服務容器負責啟動，加載，運行服務提供者。 l 服務提供者在啟動時，向注冊中心注冊自己提供的服務。

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

l 注冊中心返回服務提供者地址列表給消費者，如果有變更，注冊中心將基于長連接推送變更數據給消費 者。

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

l 服務消費者和提供者，在內存中累計調用次數和調用時間，定時每分鐘發送一次統計數據到監控中心。

🎃window下安裝zookeeper

1、下載zookeeper ；

2、運行/bin/zkServer.cmd ，初次運行會報錯，沒有zoo.cfg配置文件；

可能遇到問題：閃退 !

解決方案：編輯zkServer.cmd文件末尾添加 pause 。這樣運行出錯就不會退出，會提示錯誤信息， 方便找到原因

3、修改zoo.cfg配置文件 將conf文件夾下面的zoo_sample.cfg復制一份改名為zoo.cfg即可

注意幾個重要位置： dataDir=./ 臨時數據存儲的目錄（可寫相對路徑） clientPort=2181 zookeeper的端口號 修改完成后再次啟動zookeeper

?4、使用zkCli.cmd測試 ls /：列出zookeeper根下保存的所有節點

[zk: 127.0.0.1:2181(CONNECTED) 4] ls /[zookeeper]

create –e /kuangshen 123：創建一個kuangshen節點，值為123

get /kuangshen：獲取/kuangshen節點的值

再來查看一下節點

🎯SpringBoot + Dubbo + zookeeper

🎃框架搭建

1. 啟動zookeeper ！

2. IDEA創建一個空項目；

3.創建一個模塊，實現服務提供者：provider-server ， 選擇web依賴即可

4.項目創建完畢，我們寫一個服務，比如賣票的服務；

5.創建一個模塊，實現服務消費者：consumer-server ， 選擇web依賴即可

6.項目創建完畢，我們寫一個服務，比如用戶的服務；

🎃服務提供者

1、將服務提供者注冊到注冊中心，我們需要整合Dubbo和zookeeper，所以需要導包 我們從dubbo官網進入github，看下方的幫助文檔，找到dubbo-springboot，找到依賴包

<!-- Dubbo Spring Boot Starter --><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-spring-boot-starter</artifactId><version>2.7.3</version></dependency>    

2、在springboot配置文件中配置dubbo相關屬性

#當前應用名字
dubbo.application.name=provider-server#注冊中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181#掃描指定包下服務
dubbo.scan.base-packages=com.kuang.provider.service

3.在service的實現類中配置服務注解，發布服務！注意導包問題

import org.apache.dubbo.config.annotation.Service;import org.springframework.stereotype.Component;@Service //將服務發布出去
@Component //放在容器中
public class TicketServiceImpl implements TicketService {@Overridepublic String getTicket() {return "aaqa";}}

🎃消費者

1、導入依賴，和之前的依賴一樣；

配置參數

#當前應用名字
dubbo.application.name=consumer-server#注冊中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181

3. 本來正常步驟是需要將服務提供者的接口打包，然后用pom文件導入，我們這里使用簡單的方式，直 接將服務的接口拿過來，路徑必須保證正確，即和服務提供者相同；

4.完善消費者的服務類

package com.kuang.consumer.service;import com.kuang.provider.service.TicketService;import org.apache.dubbo.config.annotation.Reference;import org.springframework.stereotype.Service;@Service //注入到容器中
public class UserService {@Reference //遠程引用指定的服務，他會按照全類名進行匹配，看誰給注冊中心注冊了這個全
類名TicketService ticketService;public void bugTicket(){String ticket = ticketService.getTicket();System.out.println("在注冊中心買到"+ticket);}}

5. 測試類編寫；

@RunWith(SpringRunner.class)@SpringBootTestpublic class ConsumerServerApplicationTests {@AutowiredUserService userService;@Testpublic void contextLoads() {userService.bugTicket();}}