Пример балансировки нагрузки с Zuul и Eureka

1. Обзор

В этой статье мы рассмотрим, как работает балансировка нагрузки с Zuul и Eureka.

Мы будем направлять запросы к службе REST, обнаруженной Spring Cloud Eureka, через Zuul Proxy .

2. Первоначальная настройка

Нам нужно настроить сервер/клиент Eureka, как показано в статье Spring Cloud Netflix-Eureka .

3. Настройка Зуула

Zuul, среди прочего, получает данные из сервисных центров Eureka и выполняет балансировку нагрузки на стороне сервера.

3.1. Конфигурация Maven

Во- первых, мы добавим зависимость Zuul Server и Eureka в наш pom.xml:

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-zuul</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>

3.2. Общение с Эврикой

Во-вторых, мы добавим необходимые свойства в файл application.properties Zuul :

server.port=8762
spring.application.name=zuul-server
eureka.instance.preferIpAddress=true
eureka.client.registerWithEureka=true
eureka.client.fetchRegistry=true
eureka.client.serviceUrl.defaultZone=${EUREKA_URI:http://localhost:8761/eureka}

Здесь мы говорим Zuul зарегистрироваться как служба в Eureka и работать на порту 8762.

Далее мы реализуем основной класс с @EnableZuulProxy и @EnableDiscoveryClient. @EnableZuulProxy указывает, что это сервер Zuul, а @EnableDiscoveryClient указывает, что это клиент Eureka:

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

Мы укажем наш браузер на http://localhost:8762/routes . Это должно показать все маршруты, доступные для Зуула , обнаруженные Эврикой:

{"/spring-cloud-eureka-client/**":"spring-cloud-eureka-client"}

Теперь мы будем общаться с клиентом Eureka, используя полученный маршрут Zuul Proxy. Указание нашему браузеру на http://localhost:8762/spring-cloud-eureka-client/greeting должно генерировать примерно такой ответ:

Hello from 'SPRING-CLOUD-EUREKA-CLIENT with Port Number 8081'!

4. Балансировка нагрузки с Zuul

Когда Zuul получает запрос, он выбирает одно из доступных физических местоположений и перенаправляет запросы фактическому экземпляру службы. Весь процесс кэширования местоположения экземпляров службы и перенаправления запроса в фактическое местоположение предоставляется из коробки без необходимости дополнительных настроек.

Здесь мы видим, как Zuul инкапсулирует три разных экземпляра одного и того же сервиса:

Внутри Zuul использует ленту Netflix для поиска всех экземпляров службы из службы обнаружения (Eureka Server).

Давайте проследим за этим поведением при вызове нескольких экземпляров.

4.1. Регистрация нескольких экземпляров

Начнем с запуска двух экземпляров (порты 8081 и 8082).

После того, как все экземпляры запущены, мы можем наблюдать в журналах, что физическое расположение экземпляров регистрируется в DynamicServerListLoadBalancer, а маршрут сопоставляется с контроллером Zuul , который заботится о пересылке запросов к фактическому экземпляру:

Mapped URL path [/spring-cloud-eureka-client/**] onto handler of type [class org.springframework.cloud.netflix.zuul.web.ZuulController]
Client:spring-cloud-eureka-client instantiated a LoadBalancer:
  DynamicServerListLoadBalancer:{NFLoadBalancer:name=spring-cloud-eureka-client,
  current list of Servers=[],Load balancer stats=Zone stats: {},Server stats: []}ServerList:null
Using serverListUpdater PollingServerListUpdater
DynamicServerListLoadBalancer for client spring-cloud-eureka-client initialized: 
  DynamicServerListLoadBalancer:{NFLoadBalancer:name=spring-cloud-eureka-client,
  current list of Servers=[0.0.0.0:8081, 0.0.0.0:8082],
  Load balancer stats=Zone stats: {defaultzone=[Zone:defaultzone;   Instance count:2;   
  Active connections count: 0;  Circuit breaker tripped count: 0;   
  Active connections per server: 0.0;]},
  Server stats: 
    [[Server:0.0.0.0:8080;  Zone:defaultZone;......],
    [Server:0.0.0.0:8081;   Zone:defaultZone; ......],

Примечание: журналы были отформатированы для лучшей читабельности.

4.2. Пример балансировки нагрузки

Давайте перейдем в нашем браузере на http://localhost:8762/spring-cloud-eureka-client/greeting несколько раз.

Каждый раз мы должны видеть немного другой результат:

Hello from 'SPRING-CLOUD-EUREKA-CLIENT with Port Number 8081'!

Hello from 'SPRING-CLOUD-EUREKA-CLIENT with Port Number 8082'!

Hello from 'SPRING-CLOUD-EUREKA-CLIENT with Port Number 8081'!

Каждый запрос, полученный Zuul, пересылается другому экземпляру в циклическом режиме.

Если мы запустим другой инстанс и зарегистрируем его в Eureka, Zuul зарегистрирует его автоматически и начнет пересылать ему запросы:

Hello from 'SPRING-CLOUD-EUREKA-CLIENT with Port Number 8083'!

Мы также можем изменить стратегию балансировки нагрузки Zuul на любую другую стратегию ленты Netflix — подробнее об этом можно прочитать в нашей статье о ленте .

5. Вывод

Как мы видели, Zuul предоставляет один URL-адрес для всех экземпляров Rest Service и выполняет балансировку нагрузки для пересылки запросов одному из экземпляров в циклическом режиме.

Как всегда, полный код для этой статьи можно найти на GitHub .