Spring Cloud Bus: шина сообщений

Java
Spring Cloud Bus: шина сообщений

Адрес фактического проекта электронной коммерции SpringBoot (20k+star):GitHub.com/macro-positive/…

Резюме

Spring Cloud Bus использует упрощенный брокер сообщений для подключения различных сервисов в архитектуре микросервисов, который можно использовать для широковещательной передачи изменений состояния (например, изменений конфигурации центра конфигурации) или других инструкций по управлению, и в этой статье подробно описывается его использование.

Введение в Spring Cloud Bus

Обычно мы используем брокер сообщений для создания темы, а затем подключаем к этой теме все сервисы в микросервисной архитектуре.Когда мы отправляем сообщение в тему, все службы, подписанные на тему, получают сообщение и потребляют его. Этот механизм можно легко построить с помощью Spring Cloud Bus, поэтому Spring Cloud Bus также называют шиной сообщений. Spring Cloud Bus можно использовать с Spring Cloud Config для динамического обновления конфигурации. В настоящее время Spring Cloud Bus поддерживает два брокера сообщений: RabbitMQ и Kafka.В качестве примера возьмем RabbitMQ, чтобы продемонстрировать функцию динамического обновления конфигурации с помощью Spring Cloud Bus.

Установка RabbitMQ

  • После завершения установки перейдите в каталог sbin в каталоге установки RabbitMQ:

  • Введите cmd в адресной строке и нажмите Enter, чтобы запустить командную строку, а затем введите следующую команду, чтобы запустить функцию управления:
rabbitmq-plugins enable rabbitmq_management

  • Посетите адрес, чтобы убедиться, что установка прошла успешно:http://localhost:15672/

  • Введите пароль учетной записи и войдите в систему: гость гость

Конфигурация динамического обновления

Используя Spring Cloud Bus для динамического обновления конфигурации, которую необходимо использовать вместе с Spring Cloud Config, мы используемпредыдущий разделМодули config-server и config-client в модуле демонстрируют эту функцию.

Добавить поддержку шины сообщений в config-server

  • Добавьте связанные зависимости в pom.xml:
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-bus-amqp</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
  • Добавьте файл конфигурации application-amqp.yml, в основном для добавления конфигурации RabbitMQ и предоставления конечной точки Actuator конфигурации обновления;
server:
  port: 8904
spring:
  application:
    name: config-server
  cloud:
    config:
      server:
        git:
          uri: https://gitee.com/macrozheng/springcloud-config.git
          username: macro
          password: 123456
          clone-on-start: true # 开启启动时直接从git获取配置
  rabbitmq: #rabbitmq相关配置
    host: localhost
    port: 5672
    username: guest
    password: guest
eureka:
  client:
    service-url:
      defaultZone: http://localhost:8001/eureka/
management:
  endpoints: #暴露bus刷新配置的端点
    web:
      exposure:
        include: 'bus-refresh'

Добавить поддержку шины сообщений в config-client

  • Добавьте связанные зависимости в pom.xml:
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-bus-amqp</artifactId>
</dependency>
  • Добавьте файлы конфигурации bootstrap-amqp1.yml и bootstrap-amqp2.yml, чтобы запустить два разных клиента конфигурации, и два файла конфигурации имеют только разные номера портов;
server:
  port: 9004
spring:
  application:
    name: config-client
  cloud:
    config:
      profile: dev #启用环境名称
      label: dev #分支名称
      name: config #配置文件名称
      discovery:
        enabled: true
        service-id: config-server
  rabbitmq: #rabbitmq相关配置
    host: localhost
    port: 5672
    username: guest
    password: guest
eureka:
  client:
    service-url:
      defaultZone: http://localhost:8001/eureka/
management:
  endpoints:
    web:
      exposure:
        include: 'refresh'

Демонстрация конфигурации динамического обновления

  • Сначала мы запускаем связанные службы, запускаем eureka-server, запускаем config-server с application-amqp.yml в качестве конфигурации, запускаем config-client с bootstrap-amqp1.yml в качестве конфигурации, запускаем config-client с bootstrap-amqp2.yml как клиент конфигурации, после запуска реестр выглядит следующим образом:

  • После запуска всех сервисов логинимся в консоль RabbitMQ и обнаруживаем, что Spring Cloud Bus создал обмен с именем springCloudBus и три очереди, начинающиеся с springCloudBus.anonymous:

  • Давайте сначала изменим файл конфигурации config-dev.yml в ветке dev в репозитории Git:
# 修改前信息
config:
  info: "config info for dev(dev)"
# 修改后信息
config:
  info: "update config info for dev(dev)"  


update config info for dev(dev)

Используйте с веб-хуками

WebHooks эквивалентен функции ловушки. Мы можем настроить эту функцию ловушки так, чтобы она запускалась, когда код помещается в репозиторий Git. Здесь Gitee используется в качестве примера, чтобы представить ее использование. Здесь, когда мы помещаем код в конфигурацию репозиторий, конфигурация службы будет автоматически обновлена.

используемые модули

springcloud-learning
├── eureka-server -- eureka注册中心
├── config-server -- 配置中心服务
└── config-client -- 获取配置的客户端服务

Адрес исходного кода проекта

GitHub.com/macro-positive/…

публика

проект торгового центраПолный набор учебных пособий сериализуется,Обратите внимание на публичный аккаунтПолучите это прямо сейчас.

公众号图片

Категории