Использование Azure Event Grid в Spring

В этой статье показано, как использовать Azure Event Grid для отправки события в тему и использования очереди Service Bus в качестве Event Handler для принятия в приложении Spring Boot.

Служба Azure Event Grid — это высокомасштабируемая полностью управляемая служба распространения сообщений pub Sub, которая предлагает гибкие шаблоны потребления сообщений с помощью протоколов MQTT и HTTP.

Необходимые условия

• Подписка Azure — создать бесплатно.

• Java Development Kit (JDK) версии 8 или более поздней.

• Apache Maven версии 3.0 или более поздней.

• Экземпляр темы сетки событий. Если у вас его нет, см. Создание настраиваемой темы или домена в Azure Event Grid.

• Экземпляр очереди Service Bus. Если у вас его нет, см. Создать очередь в портале Azure.

• Приложение Spring Boot. Если у вас его нет, создайте проект Maven, используя Spring Initializr. Обязательно выберите Maven Project и выберите Java версии 8 или более поздней.

Подписка на настраиваемую тему

Выполните следующие действия, чтобы создать подписку на события и настроить Event Grid для отправки событий в очередь Service Bus:

1. В портале Azure перейдите к своему экземпляру темы Event Grid.
2. Выберите подписки на события на панели инструментов.
3. На странице "Создание подписки на событие" введите значение имени для подписки на события.
4. Для Endpoint Type выберите очередь Service Bus.
5. Выберите конечную точку и затем выберите созданный ранее экземпляр очереди Service Bus.

Отправка события с помощью Azure Event Grid и получение через очередь Azure Service Bus

С помощью ресурса Azure Event Grid можно отправить событие с помощью Spring Cloud Azure Event Grid. Используя ресурс очереди Azure Service Bus в роли обработчика событий, можно получить событие через Spring Cloud Azure Stream Binder для Service Bus.

Чтобы установить модуль Spring Cloud Azure Event Grid Starter и модуль Spring Cloud Azure Stream Binder Service Bus, добавьте следующие зависимости в файл pom.xml:

• Список компонентов (BOM) Spring Cloud для Azure

  <dependencyManagement>
    <dependencies>
      <dependency>
        <groupId>com.azure.spring</groupId>
        <artifactId>spring-cloud-azure-dependencies</artifactId>
        <version>7.1.0</version>
        <type>pom</type>
        <scope>import</scope>
      </dependency>
    </dependencies>
  </dependencyManagement>
  

  Заметка

  Если вы используете Spring Boot 4.0.x, обязательно установите версию, указанную в spring-cloud-azure-dependencies, на значение 7.1.0.

  Если вы используете Spring Boot 3.5.x, обязательно задайте версию spring-cloud-azure-dependencies на 6.1.0.

  Если вы используете Spring Boot 3.1.x-3.5.x, обязательно установите для нее версию spring-cloud-azure-dependencies на 5.25.0.

  Если вы используете Spring Boot 2.x, обязательно установите версию spring-cloud-azure-dependencies на 4.20.0.

  Эта ведомость материалов (BOM) должна быть сконфигурирована в <dependencyManagement> разделе файла pom.xml. Это гарантирует, что все зависимости Spring Cloud Azure используют одну и ту же версию.

  Дополнительные сведения о версии, используемой для этого BOM, можно найти в разделе Какую версию Spring Cloud Azure мне следует использовать?.

• Артефакт Spring Cloud Azure Event Grid Starter:

  <dependency>
    <groupId>com.azure.spring</groupId>
    <artifactId>spring-cloud-azure-starter-eventgrid</artifactId>
  </dependency>
  

• Артефакт Service Bus Stream Binder Spring Cloud Azure:

  <dependency>
    <groupId>com.azure.spring</groupId>
    <artifactId>spring-cloud-azure-stream-binder-servicebus</artifactId>
  </dependency>
  

Код приложения

Выполните следующие действия, чтобы настроить приложение для отправки события с помощью сетки событий и получения с помощью очереди Service Bus.

1. Настройте учетные данные Azure Event Grid и Service Bus в файле конфигурации application.yaml, как показано в следующем примере:

   spring:
     cloud:
       azure:
         eventgrid:
           endpoint: ${AZURE_EVENTGRID_ENDPOINT}
           key: ${AZURE_EVENTGRID_KEY}
         servicebus:
           connection-string: ${AZURE_SERVICEBUS_CONNECTION_STRING}
       function:
         definition: consume
       stream:
         bindings:
           consume-in-0:
             destination: ${AZURE_SERVICEBUS_QUEUE_NAME}
         servicebus:
           bindings:
             consume-in-0:
               consumer:
                 auto-complete: false
   

   Заметка

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

2. Измените файл класса запуска, чтобы отобразить следующее содержимое. Этот код генерирует автодополнения.

   import com.azure.core.util.BinaryData;
   import com.azure.messaging.eventgrid.EventGridEvent;
   import com.azure.messaging.eventgrid.EventGridPublisherClient;
   import org.slf4j.Logger;
   import org.slf4j.LoggerFactory;
   import org.springframework.beans.factory.annotation.Autowired;
   import org.springframework.boot.CommandLineRunner;
   import org.springframework.boot.SpringApplication;
   import org.springframework.boot.autoconfigure.SpringBootApplication;
   import org.springframework.context.annotation.Bean;
   import org.springframework.messaging.Message;
   
   import java.util.List;
   import java.util.function.Consumer;
   
   @SpringBootApplication
   public class EventGridSampleApplication implements CommandLineRunner {
   
       private static final Logger LOGGER = LoggerFactory.getLogger(EventGridSampleApplication.class);
   
       @Autowired
       EventGridPublisherClient<EventGridEvent> client;
   
       public static void main(String[] args) {
           SpringApplication.run(EventGridSampleApplication.class, args);
       }
   
       @Bean
       public Consumer<Message<String>> consume() {
           return message -> {
               List<EventGridEvent> eventData = EventGridEvent.fromString(message.getPayload());
               eventData.forEach(event -> {
                   LOGGER.info("New event received: '{}'", event.getData());
               });
           };
       }
   
       @Override
       public void run(String... args) throws Exception {
           String str = "FirstName: John, LastName: James";
           EventGridEvent event = new EventGridEvent("A user is created", "User.Created.Text", BinaryData.fromObject(str), "0.1");
   
           client.sendEvent(event);
           LOGGER.info("New event published: '{}'", event.getData());
       }
   }
   
   

3. Запустите приложение. После запуска приложение создает журналы, аналогичные следующему примеру:

   New event published: '"FirstName: John, LastName: James"'
   ...
   New event received: '"FirstName: John, LastName: James"'
   

Развертывание в Azure Spring Apps

Теперь, когда у вас есть приложение Spring Boot, работающее локально, пришло время переместить его в рабочую среду. Azure Spring Apps упрощает развертывание приложений Spring Boot для Azure без каких-либо изменений кода. Служба управляет инфраструктурой приложений Spring, чтобы разработчики могли сосредоточиться на коде. Azure Spring Apps обеспечивает управление жизненным циклом с помощью комплексного мониторинга и диагностики, управления конфигурацией, обнаружения служб, интеграции CI/CD, развертывания по схеме blue-green и многого другого. Чтобы развернуть ваше приложение в Azure Spring Apps, см. статью Развертывание первого приложения в Azure Spring Apps.

Дальнейшие действия

Чтобы узнать больше о Spring и Azure, перейдите в Центр документации по Spring на Azure.

Azure для разработчиков на SpringПримеры Spring Cloud Azure Event Grid