Java controlado por eventos con Spring Cloud Stream Binder para Azure Event Hubs

Publicado el 3 abril, 2019

Principal Program Manager, Azure Developer Experience

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.

Gráfico de Azure Event Hubs y Spring Apps

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.

Recursos adicionales