Spring Cloud Stream Binder para Azure Event Hubs ya está disponible con carácter general. Es fácil crear aplicaciones de Java controladas por eventos muy escalables con Spring Cloud Stream con Event Hubs, un servicio de ingesta de datos en tiempo real totalmente administrado en Azure que es resistente y confiable para cualquier situación. Esto incluye emergencias, gracias a las características de recuperación ante desastres geográfica y replicación geográfica.
Spring Cloud Stream proporciona una abstracción de enlazador para implementaciones de agentes de mensajería populares. Proporciona un modelo de programación flexible basado en expresiones de Spring y procedimientos recomendados ya establecidos y conocidos, como la compatibilidad con la semántica persistente de publicación/suscripción, grupos de consumidores y particiones con estado. Ahora los desarrolladores pueden usar los mismos modelos para crear aplicaciones de Java con Event Hubs.
Introducción
Eche un vistazo al tutorial “Cómo crear una aplicación de Spring Cloud Stream Binder con Azure Event Hubs” y cree una aplicación de Spring Cloud Stream Binder basada en Java usando el inicializador de arranque de Spring (Spring Initializr) con Azure Event Hubs. Vaya a Azure Portal y cree un nuevo espacio de nombres de Event Hubs. Agregue la siguiente dependencia de Maven al proyecto de Java.
<dependency>
<groupId>com.microsoft.azure</groupId>
<artifactId>spring-cloud-azure-eventhubs-stream-binder</artifactId>
<version>1.1.0.RC4</version>
</dependency>
Publicación de mensajes
Utilice @EnableBinding(Source.class) para anotar una clase de origen y publicar mensajes en Event Hubs con modelos de Spring Cloud Stream. Puede personalizar el canal de salida para el origen con opciones de configuración.
- Destination (Destino): especifique qué instancia de Event Hubs debe conectarse al canal de salida.
- Sync/Async (Sincrónico/asincrónico): especifique el modo para producir los mensajes.
Suscripción a mensajes
Use @EnableBinding(Sink.class) para anotar una clase de receptor y consumir mensajes de Event Hubs. También puede personalizar el canal de entrada con opciones de configuración. Para ver la lista completa, consulte “Cómo crear una aplicación de Spring Cloud Stream Binder con Azure Event Hubs”.
- Destination (Destino): especifique una instancia de Event Hubs para enlazarla con el canal de entrada.
- Customer Group (Grupo de clientes): especifique un grupo de clientes para recibir mensajes.
Pruebe la creación de aplicaciones de Java controladas por eventos usando Spring Cloud Stream Binder para Event Hubs
Pruebe una aplicación de Java con Spring Cloud Stream Binder en Azure Event Hubs y denos su opinión por correo electrónico o en la sección de comentarios al final de la página.