Compatibilidad de Spring Cloud Azure con las colas de Spring Messaging Azure Storage

Honi aplikatzen zaio: ✅ Version 4.20.0, ✅ Version 5.25.0, ✅ Version 6.5.0, ✅ Version 7.4.0

En este artículo se describe cómo puede utilizar Spring Cloud Azure y Spring Messaging Azure Storage Queue. Spring Framework proporciona una amplia compatibilidad con la integración con sistemas de mensajería.

Azure Storage Queue en Spring Messaging

Conceptos clave

Azure Queue Storage es un servicio para almacenar un gran número de mensajes. Puede acceder a los mensajes desde cualquier lugar del mundo a través de llamadas autenticadas mediante HTTP o HTTPS. Un mensaje de cola puede tener un tamaño de hasta 64 KB. Una cola puede contener millones de mensajes, hasta el límite de capacidad total de una cuenta de almacenamiento. Las colas se usan normalmente para crear un trabajo pendiente para procesar de forma asincrónica. El proyecto Spring Messaging para Azure Queue Storage aplica conceptos básicos de Spring al desarrollo de soluciones de mensajería basadas en Bus de servicio. Proporciona una plantilla de como una abstracción de alto nivel para enviar y recibir mensajes. Estas bibliotecas promueven el uso de la inserción de dependencias y la configuración declarativa.

Configuración de dependencias

<dependency>
  <groupId>com.azure.spring</groupId>
  <artifactId>spring-cloud-azure-starter</artifactId>
</dependency>
<dependency>
  <groupId>com.azure.spring</groupId>
  <artifactId>spring-messaging-azure-storage-queue</artifactId>
</dependency>

Configuración

La biblioteca proporciona las siguientes opciones de configuración para StorageQueueTemplate:

Propiedad	Tipo	Descripción
`spring.cloud.azure.message-converter.isolated-object-mapper`	booleano	Si se usa un bean de ObjectMapper aislado para el convertidor de mensajes de Storage Queue. Habilitado de forma predeterminada.
`spring.cloud.azure.storage.queue.enabled`	booleano	Si una cola de Azure Storage está habilitada.
`spring.cloud.azure.storage.queue.connection-string`	Cuerda	Valor de la cadena de conexión del espacio de nombres de la cola de almacenamiento.
`spring.cloud.azure.storage.queue.accountName`	Cuerda	Nombre de la cuenta de cola de Storage.
`spring.cloud.azure.storage.queue.accountKey`	Cuerda	Clave de cuenta de Storage Queue.

Uso básico

Convertidor de mensajes de cola de almacenamiento personalizado

Hay dos formas de configurar el convertidor de mensajes de Storage Queue:

Configure la siguiente propiedad para que el convertidor de mensajes predeterminado de Storage Queue use un bean ObjectMapper, que puede ser su bean ObjectMapper personalizado o uno administrado por Spring Boot:
```
spring:
  cloud:
    azure:
      message-converter:
        isolated-object-mapper: false
```

Defina directamente el bean del convertidor de mensajes de Storage Queue:

@Bean
AzureMessageConverter<QueueMessageItem, QueueMessageItem> storageQueueMessageConverter() {
    JsonMapper jsonMapper = JsonMapper.builder().addModule(new JavaTimeModule()).build();
    return new ServiceBusMessageConverter(jsonMapper);
}

Envío y recepción de mensajes a la cola de Azure Storage

Siga estos pasos para enviar y recibir mensajes:

Rellene las opciones de configuración de credenciales mediante uno de los métodos siguientes:

Para las credenciales como DefaultAzureCredential, configure las siguientes propiedades en el archivo application.yml:

spring:
  cloud:
    azure:
      storage:
        queue:
          account-name: ${AZURE_STORAGE_QUEUE_ACCOUNT_NAME}

Para las credenciales como cadena de conexión, configure las siguientes propiedades en el archivo application.yml:

spring:
  cloud:
    azure:
      storage:
        queue:
          connection-string: ${AZURE_STORAGE_QUEUE_CONNECTION_STRING}

Para las credenciales como identidades administradas, configure las siguientes propiedades en el archivo application.yml:

spring:
  cloud:
    azure:
      credential:
        managed-identity-enabled: true
        client-id: ${AZURE_CLIENT_ID}
      profile:
        tenant-id: <tenant>
      storage:
        queue:
          account-name: ${AZURE_STORAGE_QUEUE_ACCOUNT_NAME}

Nota:

Se permiten los siguientes valores para tenant-id: common, organizations, consumerso el identificador de inquilino. Para obtener más información sobre estos valores, consulte la sección Uso del punto de conexión incorrecto (cuentas personales y de organización) de Error AADSTS50020: la cuenta de usuario del proveedor de identidades no existe en el inquilino. Para obtener información sobre cómo convertir su aplicación de un solo inquilino a multiinquilino, consulte Convertir aplicación de un solo inquilino a multiinquilino en Microsoft Entra ID.

Para las credenciales como principal de servicio, configure las siguientes propiedades en su archivo application.yml:

spring:
  cloud:
    azure:
      credential:
        client-id: ${AZURE_CLIENT_ID}
        client-secret: ${AZURE_CLIENT_SECRET}
      profile:
        tenant-id: <tenant>
      storage:
        queue:
          account-name: ${AZURE_STORAGE_QUEUE_ACCOUNT_NAME}

Nota:

StorageQueueTemplate está configurado automáticamente. Puede conectarse automáticamente directamente a sus propios frijoles para enviar o recibir mensajes, como se muestra en el ejemplo siguiente:

@Component
public class MyBean {

    private final StorageQueueTemplate storageQueueTemplate;

    public MyBean(StorageQueueTemplate storageQueueTemplate) {
        this.storageQueueTemplate = storageQueueTemplate;
    }

    public void someMethod() {
        this.serviceBusTemplate.sendAsync('STORAGE_QUEUE_NAME', MessageBuilder.withPayload("Hello world").build()).subscribe();
    }

    public void processMessage() {
        Message<?> message = storageQueueTemplate.receiveAsync('STORAGE_QUEUE_NAME', Duration.ofSeconds(30)).block();
        // ...
    }

}

Muestras

Para obtener más información, consulte el azure-spring-boot-samples repositorio en GitHub.

Oharrak

Lagungarria al da orri hau?

Last updated on 2026-09-21