目錄

🎯分佈式理論

🎃分佈式系統

🎃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 {
    @Override
    public 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)
 @SpringBootTest
 public class ConsumerServerApplicationTests {
    @Autowired
    UserService userService;
    @Test
    public void contextLoads() {
        userService.bugTicket();
    }
 }