springboot-15-Dubbo和Zookeeper內建

文章目錄

• Dubbo和Zookeeper內建
• • 一、分布式理論
  • • 1.什麼是分布式系統？
    • 2.分布式服務架構
    • 3.什麼是RPC
  • 二、測試環境搭建
  • • 1.Dubbo
    • 2.window下安裝dubbo-admin
    • 3.Zookeeper
  • 三、SpringBoot 整合Dubbo + zookeeper

Dubbo和Zookeeper內建

一、分布式理論

1.什麼是分布式系統？

在《分布式系統原理與範型》一書中有如下定義：“分布式系統是若幹獨立計算機的集合，這些計算機對于使用者來說就像單個相關系統”；

分布式系統是由一組通過網絡進行通信、為了完成共同的任務而協調工作的計算機節點組成的系統。分布式系統的出現是為了用廉價的、普通的機器完成單個計算機無法完成的計算、存儲任務。其目的是利用更多的機器，處理更多的資料。

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

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

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

2.分布式服務架構

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

3.什麼是RPC

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

也就是說兩台伺服器A，B，一個應用部署在A伺服器上，想要調用B伺服器上應用提供的函數/方法，由于不在一個記憶體空間，不能直接調用，需要通過網絡來表達調用的語義和傳達調用的資料。為什麼要用RPC呢？就是無法在一個程序内，甚至一個計算機内通過本地調用的方式完成的需求，比如不同的系統間的通訊，甚至不同的組織間的通訊，由于計算能力需要橫向擴充，需要在多台機器組成的叢集上部署應用。RPC就是要像調用本地的函數一樣去調遠端函數；

推薦閱讀文章：https://www.jianshu.com/p/2accc2840a1b

RPC基本原理

步驟解析：

RPC兩個核心子產品：通訊，序列化。

二、測試環境搭建

1.Dubbo

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

dubbo官網 http://dubbo.apache.org/zh-cn/index.html

服務提供者（Provider）

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

服務消費者（Consumer）

：調用遠端服務的服務消費方，服務消費者在啟動時，向注冊中心訂閱自己所需的服務，服務消費者，從提供者位址清單中，基于軟負載均衡算法，選一台提供者進行調用，如果調用失敗，再選另一台調用。

注冊中心（Registry）

：注冊中心傳回服務提供者位址清單給消費者，如果有變更，注冊中心将基于長連接配接推送變更資料給消費者

監控中心（Monitor）

：服務消費者和提供者，在記憶體中累計調用次數和調用時間，定時每分鐘發送一次統計資料到監控中心

調用關系說明

• 服務容器負責啟動，加載，運作服務提供者。
• 服務提供者在啟動時，向注冊中心注冊自己提供的服務。
• 服務消費者在啟動時，向注冊中心訂閱自己所需的服務。
• 注冊中心傳回服務提供者位址清單給消費者，如果有變更，注冊中心将基于長連接配接推送變更資料給消費者。
• 服務消費者，從提供者位址清單中，基于軟負載均衡算法，選一台提供者進行調用，如果調用失敗，再選另一台調用。
• 服務消費者和提供者，在記憶體中累計調用次數和調用時間，定時每分鐘發送一次統計資料到監控中心。

2.window下安裝dubbo-admin

dubbo本身并不是一個服務軟體。它其實就是一個jar包，能夠幫你的java程式連接配接到zookeeper，并利用zookeeper消費、提供服務。

但是為了讓使用者更好的管理監控衆多的dubbo服務，官方提供了一個可視化的監控程式dubbo-admin，不過這個監控即使不裝也不影響使用。

下載下傳位址：https://github.com/apache/dubbo-admin/tree/master

解壓進入目錄

修改 dubbo-admin\src\main\resources \application.properties 指定zookeeper位址

server.port=7001
spring.velocity.cache=false
spring.velocity.charset=UTF-8
spring.velocity.layout-url=/templates/default.vm
spring.messages.fallback-to-system-locale=false
spring.messages.basename=i18n/message
spring.root.password=root
spring.guest.password=guest

dubbo.registry.address=zookeeper://127.0.0.1:2181
           

在項目目錄下打包dubbo-admin

mvn clean package -Dmaven.test.skip=true
           

執行 dubbo-admin\target 下的dubbo-admin-0.0.1-SNAPSHOT.jar

java -jar dubbo-admin-0.0.1-SNAPSHOT.jar
           

注意：執行jar包前要先執行zookeeper的服務端

執行完畢，我們去通路一下

http://localhost:7001/

， 這時候我們需要輸入登入賬戶和密碼，我們都是預設的root-root；

登入成功後，檢視界面

3.Zookeeper

ZooKeeper是一個分布式的，開放源碼的分布式應用程式協調服務，是Google的Chubby一個開源的實作，是Hadoop和Hbase的重要元件。它是一個為分布式應用提供一緻性服務的軟體，提供的功能包括：配置維護、域名服務、分布式同步、組服務等。

下載下傳Zookeeper：https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/zookeeper-3.7.0/

選擇

apache-zookeeper-3.7.0-bin.tar.gz

下載下傳，帶

x.x.x-bin

的是已編譯的，另一個運作會報錯。

運作

/bin/zkServer.cmd

，初次運作會報錯，沒有

zoo.cfg

配置檔案；

可能遇到問題：閃退 !

解決方案：編輯

zkServer.cmd

檔案末尾添加

pause

。這樣運作出錯就不會退出，會提示錯誤資訊，友善找到原因。

建立

zoo.cfg

配置檔案

将conf檔案夾下面的zoo_sample.cfg複制一份改名為zoo.cfg即可。

注意幾個重要位置：

• dataDir=./ 臨時資料存儲的目錄（可寫相對路徑）
• clientPort=2181 zookeeper的端口号

修改完成後再次啟動zookeeper

使用

zkCli.cmd

測試

• ls /

  ：列出zookeeper根下儲存的所有節點

• create –e /kuangshen 123

  ：建立一個kuangshen節點，值為123

• get /kuangshen

  ：擷取/kuangshen節點的值

三、SpringBoot 整合Dubbo + zookeeper

需要建立一個

服務提供者

和

一個服務消費者

1.導包

<!--dubbo-->
<!-- Dubbo Spring Boot Starter -->
<dependency>
   <groupId>org.apache.dubbo</groupId>
   <artifactId>dubbo-spring-boot-starter</artifactId>
   <version>2.7.3</version>
</dependency>
<!--zookeeper-->
<!-- https://mvnrepository.com/artifact/com.github.sgroschupf/zkclient -->
<dependency>
   <groupId>com.github.sgroschupf</groupId>
   <artifactId>zkclient</artifactId>
   <version>0.1</version>
</dependency>
<!-- 引入zookeeper -->
<dependency>
   <groupId>org.apache.curator</groupId>
   <artifactId>curator-framework</artifactId>
   <version>2.12.0</version>
</dependency>
<dependency>
   <groupId>org.apache.curator</groupId>
   <artifactId>curator-recipes</artifactId>
   <version>2.12.0</version>
</dependency>
<dependency>
   <groupId>org.apache.zookeeper</groupId>
   <artifactId>zookeeper</artifactId>
   <version>3.4.14</version>
   <!--排除這個slf4j-log4j12-->
   <exclusions>
       <exclusion>
           <groupId>org.slf4j</groupId>
           <artifactId>slf4j-log4j12</artifactId>
       </exclusion>
   </exclusions>
</dependency>
           

2.建立一個空項目，然後建立

服務提供者：provider-server

編寫接口

package com.kuang.provider.service;

public interface TicketService {
   public String getTicket();
}
           

編寫實作類

import org.apache.dubbo.config.annotation.Service;
import org.springframework.stereotype.Component;

@Service //将服務釋出出去
@Component //放在容器中
public class TicketServiceImpl implements TicketService {
   @Override
   public String getTicket() {
       return "《狂神說Java》";
  }
}
           

邏輯了解 ：應用啟動起來，dubbo就會掃描指定的包下帶有@component注解的服務，将它釋出在指定的注冊中心中！

在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.建立

服務消費者：consumer-server

消費者的服務類

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);
  }

}
           

配置參數

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

本來正常步驟是需要将服務提供者的接口打包，然後用pom檔案導入，我們這裡使用簡單的方式，直接将服務的接口拿過來，路徑必須保證正确，即和服務提供者相同

測試類編寫

@RunWith(SpringRunner.class)
@SpringBootTest
public class ConsumerServerApplicationTests {

   @Autowired
   UserService userService;

   @Test
   public void contextLoads() {

       userService.bugTicket();

  }

}
           

測試

1.啟動zookeeper服務端

2.運作dubbo的jar包

3.運作springboot項目（開啟服務者）

4.消費者消費測試，結果：

監控中心 ：

這就是

SpingBoot + dubbo + zookeeper

實作分布式開發的應用，其實就是一個服務拆分的思想。

問題：

啟動springboot項目後，zookeeper服務端直接強迫關閉連接配接，暫時無法解決。