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，重新整理多次看下接口傳回資訊，能夠看到輪詢效果：