springcloud之服務註冊與發現(zookeeper註冊中心)-Finchley.SR2版

新年第一篇博文，接着和你們分享springcloud相關內容；本次主要內容是使用cloud結合zookeeper做爲註冊中心來搭建服務調用，前面幾篇文章有涉及到另外的eureka做爲註冊中心，有興趣的朋友會回顧下上幾篇文章。

• springcloud版本說明
• docker快速啓動一個zookeeper服務
• zk-server服務提供者
• zk-client服務消費者
• 啓動多個zk-server服務提供者
• git源碼地址：https://github.com/shenniubuxing3/springcloud-Finchley.SR2

springcloud版本說明

因爲市面上其版本比較多，版本不一可能形成了讀者嘗試時版本問題，因此這裏指明當前做者寫文章時使用的cloud版本

springboot版本：

1     <parent>
2         <groupId>org.springframework.boot</groupId>
3         <artifactId>spring-boot-starter-parent</artifactId>
4         <version>2.0.7.RELEASE</version>
5         <relativePath/> <!-- lookup parent from repository -->
6     </parent>

springcloud版本：

1     <properties>
2         <java.version>1.8</java.version>
3         <spring-cloud.version>Finchley.SR2</spring-cloud.version>
4     </properties>

docker快速啓動一個zookeeper服務

就我我的而言一般使用docker來運行啓動一些第三方的服務，這裏也用她來啓動zk，首先pull鏡像：

1 docker pull zookeeper
2 docker run --name zookeeper -p 2081:2181 -d zookeeper
3 docker logs dd51008f9f8f

通常採用默認鏡像的配置便可啓動，這裏來看下啓動後logs日誌的部分截圖：

可以看到鏡像啓動時讀取了內置的zoo.cfg配置文件，而且zookeeper當前版本是3.4，咱們使用可視化工具ZooInspector鏈接zookeeper，可以直觀的看到以下默認節點信息：

目前看咱們只有一個node節點，試想一下若是用zk做爲註冊中心，這裏應該會有至少兩個大節點，一個服務提供這節點，一個消費者註冊的節點，下面會經過程序來建立。

zk-server服務提供者

在zk-server工程中，這裏先建立zk的服務提供者節點，在pom工程中須要以下配置：

 1         <!--zk-->
 2         <dependency>
 3             <groupId>org.springframework.cloud</groupId>
 4             <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
 5         </dependency>
 6         <!--zk工具包-->
 7         <dependency>
 8             <groupId>org.apache.zookeeper</groupId>
 9             <artifactId>zookeeper</artifactId>
10             <version>3.4.13</version>
11             <exclusions>
12                 <exclusion>
13                     <groupId>org.slf4j</groupId>
14                     <artifactId>slf4j-log4j12</artifactId>
15                 </exclusion>
16                 <exclusion>
17                     <groupId>log4j</groupId>
18                     <artifactId>log4j</artifactId>
19                 </exclusion>
20             </exclusions>
21         </dependency>

上面pom分了兩步，第一個是springcloud使用zk作服務註冊發現用的，第二個至關於鏈接zk服務的客戶端包；而後在程序啓動入口出增長註解 @EnableDiscoveryClient

值得注意的是這裏指定了zk服務的版本號3.4.13，就目前我的遇到的狀況看，鏈接zk的客戶端儘可能和zk服務端版本保持一致，避免形成版本問題；做爲一個服務提供端(server)，咱們還須要有一個暴露出去的接口服務，我這裏定義以下接口：

 1 @RestController
 2 public class UserController {
 3 
 4     @Value("${server.port}")
 5     private int port;
 6 
 7     @GetMapping("/list")
 8     public List<MoUser> getList() {
 9 
10         return new ArrayList<MoUser>() {
11             {
12                 add(new MoUser(1, "shenniu001_" + port));
13                 add(new MoUser(2, "shenniu002_" + port));
14                 add(new MoUser(3, "shenniu003_" + port));
15             }
16         };
17     }
18 }

經過接口把服務啓動的端口返回出去，來達到區分不一樣接口的做用。有了接口代碼後，還剩下鏈接zk服務的一些列配置，application.yml中的配置信息如：

 1 spring:
 2   application:
 3     name: zk-server
 4   cloud:
 5     zookeeper:
 6       connect-string: localhost:2081
 7       discovery:
 8         register: true
 9         enabled: true
10         instance-id: 1
11         root: /shenniu
12 server:
13   port: 6061

參數的簡單說明：

1. connect-string：鏈接zk服務的鏈接串
2. register: 是否啓動服務註冊
3. instance-id: zk惟一id的標識
4. root: zk根節點名稱，默認/services

有了如上的配置，咱們就可以啓動zk-server程序了；首先訪問暴露的接口正常：

而後再查看可視化視圖工具ZooInsector有以下新增信息：

這個時候可以說明zk-server服務往zk服務端註冊成功了，zk服務端節點上包含了zk-server服務的一些基本信息，如：ip，端口，名稱；這些是服務註冊與發現的基本信息

zk-client服務消費者

在zk-client工程中，服務消費者的pom配置與生產者很像，這裏爲了方便用了feign來訪問服務端，以下pom配置：

 1         <dependency>
 2             <groupId>org.springframework.cloud</groupId>
 3             <artifactId>spring-cloud-starter-feign</artifactId>
 4             <version>1.4.6.RELEASE</version>
 5         </dependency>
 6         <dependency>
 7             <groupId>org.springframework.cloud</groupId>
 8             <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
 9         </dependency>
10         <dependency>
11             <groupId>org.apache.zookeeper</groupId>
12             <artifactId>zookeeper</artifactId>
13             <version>3.4.13</version>
14             <exclusions>
15                 <exclusion>
16                     <groupId>org.slf4j</groupId>
17                     <artifactId>slf4j-log4j12</artifactId>
18                 </exclusion>
19                 <exclusion>
20                     <groupId>log4j</groupId>
21                     <artifactId>log4j</artifactId>
22                 </exclusion>
23             </exclusions>
24         </dependency>

一樣須要執行具體的zk服務端的版本，以及排除衝突的log包；由於用了feign工具來訪問，因此須要在程序入口出增長以下註解：

1 @SpringBootApplication
2 @EnableDiscoveryClient
3 @EnableFeignClients
4 public class ZkClientApplication {
5     public static void main(String[] args) {
6         SpringApplication.run(ZkClientApplication.class, args);
7     }
8 }

而後建立一個service層並建立接口IUserService，經過@FeignClient註解的實現訪問服務提供者的接口：

1 @Service
2 @FeignClient("zk-server")
3 public interface IUserService {
4     @GetMapping("/list")
5     List<MoUser> getList();
6 }

zk-client端我想把服務提供端zk-server返回的信息直接輸出到瀏覽器上，以下代碼：

 1 @RestController
 2 public class UserController {
 3 
 4     @Autowired
 5     protected IUserService userService;
 6 
 7     @GetMapping("/list")
 8     public List<MoUser> getList() {
 9         return userService.getList();
10     }
11 }

來到這裏，剩餘的就是在application.yml中配置鏈接zk服務端的配置：

 1 spring:
 2   application:
 3     name: zk-client
 4   cloud:
 5     zookeeper:
 6       connect-string: localhost:2081
 7       discovery:
 8         register: true
 9         enabled: true
10         instance-id: 1
11         root: /shenniu
12 server:
13   port: 7061

若是細心可以發現zk-client和zk-server的zk服務配置信息基本一致，其實不論是服務提供者仍是服務消費者，都是做爲zk服務的客戶端來使用，而且都把本身的服務訪問信息上傳註冊給zookeeper註冊中心的；啓動zk-client項目，訪問接口可以成功響應出zk-server接口返回的信息：

啓動多個zk-server服務提供者

上面一個zk-server(服務提供者)，一個zk-client(服務消費者)在實際場景中不多見，通常服務提供者都是部署在多臺機子或虛擬機中(固然zk服務集羣不在本次考慮範圍)，所以這裏經過idea啓動多個不一樣端口的zk-server來實驗下並測試feign的負載均衡是否可用。

分別啓動6061，6062，6063的zk-server端口服務，這裏我註釋了instance-id: 1節點，採用自動生成的id：

而後在瀏覽器中訪問zk-client，刷新屢次看下接口返回信息，可以看到輪詢效果：