springcloud之服務注冊與發現(zookeeper注冊中心)-Finchley.SR2版springcloud版本說明docker快速啟動一個zookeeper服務zk-server服務提供者zk-client服務消費者啟動多個zk-server服務提供者

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

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

由于市面上其版本比較多，版本不一可能造成了讀者嘗試時版本問題，是以這裡指明目前作者寫文章時使用的cloud版本

springboot版本：

<parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.7.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>           

springcloud版本：

<properties>
        <java.version>1.8</java.version>
        <spring-cloud.version>Finchley.SR2</spring-cloud.version>
    </properties>           

就我個人而言通常使用docker來運作啟動一些第三方的服務，這裡也用她來啟動zk，首先pull鏡像：

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

一般采用預設鏡像的配置即可啟動，這裡來看下啟動後logs日志的部分截圖：

能夠看到鏡像啟動時讀取了内置的zoo.cfg配置檔案，并且zookeeper目前版本是3.4

我們使用可視化工具ZooInspector連接配接zookeeper，能夠直覺的看到如下預設節點資訊：

目前看我們隻有一個node節點，試想一下如果用zk作為注冊中心，這裡應該會有至少兩個大節點，一個服務提供這節點，一個消費者注冊的節點，下面會通過程式來建立。

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

<!--zk-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
        </dependency>
        <!--zk工具包-->
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.13</version>
            <exclusions>
                <exclusion>
                    <groupId>org.slf4j</groupId>
                    <artifactId>slf4j-log4j12</artifactId>
                </exclusion>
                <exclusion>
                    <groupId>log4j</groupId>
                    <artifactId>log4j</artifactId>
                </exclusion>
            </exclusions>
        </dependency>           

上面pom分了兩步，第一個是springcloud使用zk做服務注冊發現用的，第二個相當于連接配接zk服務的用戶端包；然後在程式啟動入口出增加注解 @EnableDiscoveryClient

值得注意的是這裡指定了zk服務的版本号3.4.13，就目前個人遇到的情況看，連接配接zk的用戶端盡量和zk服務端版本保持一緻，避免造成版本問題

作為一個服務提供端(server)，我們還需要有一個暴露出去的接口服務，我這裡定義如下接口：

@RestController
public class UserController {

    @Value("${server.port}")
    private int port;

    @GetMapping("/list")
    public List<MoUser> getList() {

        return new ArrayList<MoUser>() {
            {
                add(new MoUser(1, "shenniu001_" + port));
                add(new MoUser(2, "shenniu002_" + port));
                add(new MoUser(3, "shenniu003_" + port));
            }
        };
    }
}           

通過接口把服務啟動的端口傳回出去，來達到區分不同接口的作用。有了接口代碼後，還剩下連接配接zk服務的一些列配置，application.yml中的配置資訊如：

spring:
  application:
    name: zk-server
  cloud:
    zookeeper:
      connect-string: localhost:2081
      discovery:
        register: true
        enabled: true
        instance-id: 1
        root: /shenniu
server:
  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工程中，服務消費者的pom配置與生産者很像，這裡為了友善用了feign來通路服務端，如下pom配置：

<dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-feign</artifactId>
            <version>1.4.6.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
        </dependency>
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.13</version>
            <exclusions>
                <exclusion>
                    <groupId>org.slf4j</groupId>
                    <artifactId>slf4j-log4j12</artifactId>
                </exclusion>
                <exclusion>
                    <groupId>log4j</groupId>
                    <artifactId>log4j</artifactId>
                </exclusion>
            </exclusions>
        </dependency>           

同樣需要執行具體的zk服務端的版本，以及排除沖突的log包；因為用了feign工具來通路，是以需要在程式入口出增加如下注解：

@SpringBootApplication
@EnableDiscoveryClient
@EnableFeignClients
public class ZkClientApplication {
    public static void main(String[] args) {
        SpringApplication.run(ZkClientApplication.class, args);
    }
}           

然後建立一個service層并建立接口IUserService，通過@FeignClient注解的實作通路服務提供者的接口：

@Service
@FeignClient("zk-server")
public interface IUserService {
    @GetMapping("/list")
    List<MoUser> getList();
}           

zk-client端我想把服務提供端zk-server傳回的資訊直接輸出到浏覽器上，如下代碼：

@RestController
public class UserController {

    @Autowired
    protected IUserService userService;

    @GetMapping("/list")
    public List<MoUser> getList() {
        return userService.getList();
    }
}           

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

spring:
  application:
    name: zk-client
  cloud:
    zookeeper:
      connect-string: localhost:2081
      discovery:
        register: true
        enabled: true
        instance-id: 1
        root: /shenniu
server:
  port: 7061           

如果細心能夠發現zk-client和zk-server的zk服務配置資訊基本一緻，其實不管是服務提供者還是服務消費者，都是作為zk服務的用戶端來使用，并且都把自己的服務通路資訊上傳注冊給zookeeper注冊中心的

啟動zk-client項目，通路接口能夠成功響應出zk-server接口傳回的資訊：

上面一個zk-server(服務提供者)，一個zk-client(服務消費者)在實際場景中很少見，一般服務提供者都是部署在多台機子或虛拟機中(當然zk服務叢集不在本次考慮範圍)，是以這裡通過idea啟動多個不同端口的zk-server來實驗下并測試feign的負載均衡是否可用。

分别啟動6061，6062，6063的zk-server端口服務，這裡我注釋了instance-id: 1節點，采用自動生成的id：

然後在浏覽器中通路zk-client，重新整理多次看下接口傳回資訊，能夠看到輪詢效果：