??分布式理論

??分布式系統(tǒng)

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

        分布式系統(tǒng)（distributed system）是建立在網(wǎng)絡之上的軟件系統(tǒng)。

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

??Dubbo框架

        隨著互聯(lián)網(wǎng)的發(fā)展，網(wǎng)站應用的規(guī)模不斷擴大，常規(guī)的垂直應用架構已無法應對，分布式服務架構以及 流動計算架構勢在必行，急需一個治理系統(tǒng)確保架構有條不紊的演進。

??單一應用架構

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

        適用于小型網(wǎng)站，小型管理系統(tǒng)，將所有功能都部署到一個功能里，簡單易用。 

缺點：

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

??垂直應用架構

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

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

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

??分布式服務架構

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

??流動計算架構

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

??什么是RPC？

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

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

??RPC基本原理

??Dubbo

??什么是dubbo？

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

?dubbo基本概念

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

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

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

監(jiān)控中心**（Monitor）**：服務消費者和提供者，在內(nèi)存中累計調(diào)用次數(shù)和調(diào)用時間，定時每分鐘發(fā) 送一次統(tǒng)計數(shù)據(jù)到監(jiān)控中

?調(diào)用關系說明

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

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

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

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

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

??window下安裝zookeeper

1、下載zookeeper ；

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

可能遇到問題：閃退 !

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

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

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

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

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

create –e /kuangshen 123：創(chuàng)建一個kuangshen節(jié)點，值為123

get /kuangshen：獲取/kuangshen節(jié)點的值

再來查看一下節(jié)點

??SpringBoot + Dubbo + zookeeper

??框架搭建

1. 啟動zookeeper ！

2. IDEA創(chuàng)建一個空項目；

3.創(chuàng)建一個模塊，實現(xiàn)服務提供者：provider-server ， 選擇web依賴即可

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

5.創(chuàng)建一個模塊，實現(xiàn)服務消費者：consumer-server ， 選擇web依賴即可

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

??服務提供者

1、將服務提供者注冊到注冊中心，我們需要整合Dubbo和zookeeper，所以需要導包 我們從dubbo官網(wǎng)進入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的實現(xiàn)類中配置服務注解，發(fā)布服務！注意導包問題

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

??消費者

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

配置參數(shù)

#當前應用名字
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();
    }
 }

到此這篇關于SpringBoot+Dubbo+Zookeeper知識整合的文章就介紹到這了,更多相關SpringBoot+Dubbo+Zookeeper知識整合內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

最新評論