Spring Cloud использует zookeeper в качестве сервисного реестра и центра конфигурации

задняя часть Spring Cloud

Довольно популярно строить микросервисы с помощью облачного фреймворка Spring, в конце концов, это фреймворк, предоставляемый Spring, который можно использовать с Spring Boot, микросервис можно построить в ближайшее время, что значительно снижает рабочую нагрузку.
Поговорим о том, как звонить друг другу между микросервисами. Для этого требуется сервис с функциями регистрации и обнаружения сервисов. Все микросервисы зарегистрированы в этом сервисе. В этом случае все микросервисы будут звонить друг другу клиентами.
В настоящее время существует две формы регистрации и обнаружения служб: одна из них — обнаружение на стороне клиента (eureka), которая более популярна. Другой — обнаружение на стороне сервера (zookeeper или consul).
Здесь мы в основном говорим об использовании zookeeper в качестве сервисного реестра и центра конфигурации.

1. Центр регистрации услуг

1. Установите зоопарк

Разархивировать зоопарк:

tar -xvf zookeeper-3.4.10.tar.gz

Запуск зоопарка:

cd zookeeper-3.4.10
cd conf
cp zoo_sample.cfg zoo.cfg 
cd ../bin
sh zkServer.sh start

2. Введите зависимости

<dependency>
   <groupId>org.springframework.cloud</groupId>
   <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
</dependency>

3. Создайте микросервис и используйте zookeeper в качестве реестра сервиса.

package com.garlic.springcloudzookeeperclientapp;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

/**
 * zookeeper作为服务注册中心，应用启动类
 * @author llsydn
 */
@SpringBootApplication
@EnableDiscoveryClient
public class SpringCloudZookeeperClientAppApplication {
    public static void main(String[] args) {
        SpringApplication.run(SpringCloudZookeeperClientAppApplication.class, args);
    }
}

Соответствующее application.properties

## 配置应用名称
spring.application.name=spring-cloud-zookeeper-client-app
## 配置服务端口
server.port=8080
## 关闭安全控制
management.security.enabled=false
## 配置zookeeper地址
spring.cloud.zookeeper.connect-string=localhost:2181

Используйте DiscoveryClient для получения списка зарегистрированных сервисов.

package com.garlic.springcloudzookeeperclientapp.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.discovery.DiscoveryClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.ArrayList;
import java.util.List;

/**
 * 提供Rest Api，根据实例名称获取注册服务列表
 *
 * @author llsydn
 * @create 2018-5-11 20:47
 */
@RestController
@RequestMapping("/zookeeper")
public class ZookeeperController {
    @Value("${spring.application.name}")
    private String instanceName;
    private final DiscoveryClient discoveryClient;
    @Autowired
    public ZookeeperController(DiscoveryClient discoveryClient) {
        this.discoveryClient = discoveryClient;
    }
    @GetMapping
    public String hello() {
        return "Hello,Zookeeper.";
    }
    @GetMapping("/services")
    public List<String> serviceUrl() {
        List<ServiceInstance> list = discoveryClient.getInstances(instanceName);
        List<String> services = new ArrayList<>();
        if (list != null && list.size() > 0 ) {
            list.forEach(serviceInstance -> {
                services.add(serviceInstance.getUri().toString());
            });
        }
        return services;
    }
}

Примечание: могут быть запущены разные экземпляры, здесь я запустил порт8080и8081два экземпляра, затем используйтеконечная точкаСписок зарегистрированных сервисов можно запросить. Список зарегистрированных служб также можно запросить с помощью команд, связанных с zookeeper.

sh zkCli.sh
[services, zookeeper]
[zk: localhost:2181(CONNECTED) 1] ls /
[services, zookeeper]
[zk: localhost:2181(CONNECTED) 2] ls /services
[spring-cloud-zookeeper-client-app]
[zk: localhost:2181(CONNECTED) 3] ls /services/spring-cloud-zookeeper-client-app
[be61af3d-ffc2-4ffc-932c-26bc0f94971c, bcf21ece-e9e1-4a91-b985-8828688370b8]
[zk: localhost:2181(CONNECTED) 4]

2. Центр конфигурации

1. Используйте zkCli для создания информации о конфигурации

[zk: localhost:2181(CONNECTED) 27] create /config ""
Created /config
[zk: localhost:2181(CONNECTED) 28] create /config ""
Created /config/garlic
[zk: localhost:2181(CONNECTED) 29] create /config/garlic/name "default"
Created /config/garlic/name
[zk: localhost:2181(CONNECTED) 30] set /config/garlic-dev/name "dev"
Node does not exist: /config/garlic-dev/name
[zk: localhost:2181(CONNECTED) 31] create /config/garlic-dev/name "dev"
Created /config/garlic-dev/name
[zk: localhost:2181(CONNECTED) 32] create /config/garlic-test/name "test"
Created /config/garlic-test/name
[zk: localhost:2181(CONNECTED) 33] create /config/garlic-prod/name "prod"

2. Используйте контроллер для динамического получения данных центра конфигурации zookeeper.

2.1зависимости maven

<dependency>
   <groupId>org.springframework.cloud</groupId>
   <artifactId>spring-cloud-starter-zookeeper-config</artifactId>
</dependency>

2.2bootstrap.properties

## 启用zookeeper作为配置中心
spring.cloud.zookeeper.config.enabled = true
## 配置根路径
spring.cloud.zookeeper.config.root = config
## 配置默认上下文
spring.cloud.zookeeper.config.defaultContext = garlic
## 配置profile分隔符
spring.cloud.zookeeper.config.profileSeparator = -

spring.cloud.zookeeper.config.rootсоответствоватьzkCliсозданныйconfigсодержание,defaultContextсоздан соответственноgarlicилиgarlic-* Каталог, в соответствии с профилем, чтобы определить, следует ли получить конфигурацию dev или test или prod

2.3application.properties

## 配置应用名称
spring.application.name=spring-cloud-zookeeper-config-app
## 配置服务端口
server.port=10000
## 关闭安全控制
management.security.enabled=false
spring.profiles.active=dev

2.4 Используйте контроллер для динамического получения данных центра конфигурации zookeeper.

package com.garlic.springcloudzookeeperconfigapp.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.core.env.Environment;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * 提供Rest Api，获取配置在zookeeper中的配置信息
 *
 * @author llsydn
 * @create 2018-5-11 20:50
 */
@RestController
@RequestMapping("/zookeeper")
@RefreshScope // 必须添加，否则不会自动刷新name的值
public class ZookeeperController {
    @Autowired
    private Environment environment;
    @Value("${name}")
    private String name;
    @GetMapping
    public String hello() {
        return "Hello, " + name;
    }
    @GetMapping("/env")
    public String test() {
        String name = environment.getProperty("name");
        System.out.println(name);
        return "Hello," + name;
    }
}

После запуска экземпляра конфигурации вы можете использоватьzkCliИсправлятьgarlicВнизnameзначение, а затем получить доступ кконечная точкачтобы увидеть, изменится ли значение. Пока что используйтеzookeeperПо мере завершения работы центра регистрации услуг и центра конфигурации мы можем использоватьzookeeperв качестве центра конфигурации, затем используйтеzuulВ качестве шлюза API настройте динамическую маршрутизацию, в качестве поставщика услуг настройте информацию, связанную с подключением к базе данных.

Категории