Analytics, Announcements, Azure Spring Cloud, Event Hubs, Web
Java basé sur des événements avec Spring Cloud Stream Binder pour Azure Event Hubs
Posted on
1 min read
Spring Cloud Stream Binder pour Azure Event Hubs est désormais généralement disponible. La création d'applications hautement évolutives en Java basé sur des événements est désormais un jeu d'enfant à l'aide de Spring Cloud Stream avec Event Hubs, un service d'ingestion de données en temps réel et complètement managé disponible sur Azure. Il s'agit d'un service résilient et fiable en toutes circonstances. Cela inclut les situations d'urgence, grâce à des fonctionnalités de géo-reprise d'activité après sinistre et de géoréplication.
L'infrastructure Spring Cloud Stream fournit une abstraction de Binder pour les implémentations populaires de répartiteurs de messages. Elle fournit un modèle de programmation flexible basé sur les idiomes et les meilleures pratiques Spring déjà établis et familiers, notamment la prise en charge de la sémantique pub/sub persistante, des groupes de consommateurs et des partitions avec état. Les développeurs peuvent à présent utiliser les mêmes modèles pour créer des applications Java avec Event Hubs.
Prise en main
Consultez le tutoriel « Comment créer une application Spring Cloud Stream Binder avec Azure Event Hubs », et créez une application Spring Cloud Stream Binder basée sur Java à l'aide de l'initialiseur de démarrage Spring Boot Initializer avec Azure Event Hubs. Accédez au portail Azure et créez un espace de noms Event Hubs. Ajoutez la dépendance Maven suivante à votre projet Java.
<dependency>
<groupId>com.microsoft.azure</groupId>
<artifactId>spring-cloud-azure-eventhubs-stream-binder</artifactId>
<version>1.1.0.RC4</version>
</dependency>
Publier des messages
Utilisez @EnableBinding(Source.class) pour annoter une classe source et publier des messages dans Event Hubs avec des modèles Spring Cloud Stream. Vous pouvez personnaliser le canal de sortie de la source à l'aide de configurations.
- Destination : spécifiez le hub d'événements à connecter au canal de sortie.
- Sync/Async : spécifiez le mode de production des messages.
S'abonner à des messages
Utilisez @EnableBinding(Sink.class) pour annoter une classe de récepteurs et utiliser les messages des hubs d'événements. Vous pouvez également personnaliser le canal d'entrée à l'aide de configurations. Pour obtenir la liste complète, consultez la documentation « Comment créer une application Spring Cloud Stream Binder avec Azure Event Hubs ».
- Destination : spécifiez le hub d'événements à lier au canal d'entrée.
- Groupe de clients : spécifiez le Groupe de clients qui recevra les messages.
Essayer de créer des applications en Java basé sur des événements à l'aide de Spring Cloud Stream Binder pour Event Hubs
Essayez une application Java en utilisant Spring Cloud Stream Binder sur Azure Event Hubs et faites-nous savoir ce que vous en pensez par e-mail ou en déposant un commentaire ci-dessous.