新年第一篇博文，接著和大家分享springcloud相關內容；本次主要內容是使用cloud結合zookeeper作為註冊中心來搭建服務調用，前面幾篇文章有涉及到另外的eureka作為註冊中心，有興趣的朋友會回顧下上幾篇文章。 springcloud版本說明 docker快速啟動一個zookeeper ...

新年第一篇博文，接著和大家分享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

參數的簡單說明：

connect-string：連接zk服務的連接串
register: 是否啟動服務註冊
instance-id: zk唯一id的標識
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介面返回的信息：