Communication de messages asynchrones sous les microservices Spring Cloud

Avec l'essor du cloud computing et du big data, l'architecture des microservices est largement utilisée dans les systèmes d'entreprise. En tant qu'outil de mise en œuvre important pour l'architecture de microservices, Spring Cloud fournit une variété de solutions pour réaliser la communication sous une architecture de microservices. Cet article se concentrera sur la solution de communication de messages asynchrone sous les microservices Spring Cloud, dans l'espoir de fournir à chacun quelques idées et références pour résoudre les problèmes de communication de messages dans le cadre de l'architecture de microservices.

1. Contexte de la communication de messages asynchrones par microservice

Dans l'architecture des microservices, les services sont divisés en plusieurs microservices pour un développement indépendant, un déploiement indépendant et une maintenance indépendante. Il doit y avoir une interaction et une communication entre chaque microservice. Les appels RPC traditionnels ou les requêtes HTTP dégraderont les performances du système en raison des longs temps de réponse dans les scénarios de forte concurrence et de Big Data. Par conséquent, la communication de messages asynchrones est largement utilisée dans les microservices comme une excellente solution, prenant en charge efficacement la communication entre différents microservices.

2. Schéma de communication de messages asynchrones sous Spring Cloud

Dans Spring Cloud, il existe deux schémas de communication de messages asynchrones couramment utilisés : Spring Cloud Stream et Spring Cloud Bus.

1. Spring Cloud Stream

Spring Cloud Stream est un framework fourni par Spring Cloud pour créer des microservices basés sur des messages. Il est construit sur Spring Boot et Spring Integration et peut facilement connecter divers services de courtier de messages. Spring Cloud Stream implémente une communication de messages asynchrone basée sur le modèle de publication/abonnement (Publish/Subscribe).

Le workflow de Spring Cloud Stream est le suivant :

① Le producteur génère des messages et les publie sur Spring Cloud Stream ;
② Spring Cloud Stream envoie les messages au courtier intermédiaire (Message Broker) ; du courtier intermédiaire, et Spring Cloud Stream est averti lorsqu'un message est reçu, et Spring Cloud Stream transmet le message au consommateur correspondant.

Spring Cloud Stream utilise des services de courtage de messages tels qu'Apache Kafka et RabbitMQ, qui présentent les caractéristiques d'une grande fiabilité, d'une simultanéité élevée et d'une évolutivité élevée. Son processus d'utilisation est très simple. Il vous suffit d'introduire les dépendances correspondantes et de configurer l'agent de messages qu'il utilise. L'exemple de code pour implémenter un service de messagerie est le suivant :

// 引入Spring Cloud Stream依赖
<dependency>
   <groupId>org.springframework.cloud</groupId>
   <artifactId>spring-cloud-starter-stream-kafka</artifactId>
</dependency>
 
// 在应用程序属性文件中设置连接的kafka代理
spring.cloud.stream.kafka.binder.brokers=kafka.example.com:9092
spring.cloud.stream.kafka.binder.zkNodes=zookeeper.example.com
spring.cloud.stream.kafka.binder.defaultBrokerPort=9092
spring.cloud.stream.kafka.binder.defaultZkPort=2181

Spring Cloud Bus

Spring Cloud Bus est un mécanisme de propagation des changements d'état dans un système distribué. Il permet la transmission de messages entre différents microservices qui composent le système. . Spring Cloud Bus utilise un courtier de messages pour connecter divers microservices et utilise un type de message léger pour terminer la transmission de l'état des événements. Différent de Spring Cloud Stream, Spring Cloud Bus est davantage utilisé pour la messagerie et le partage d'état au sein du système.

Le workflow de Spring Cloud Bus est le suivant :

① Déclencher des événements qui peuvent affecter l'état sur Spring Cloud Bus via des requêtes HTTP/HTTPS (par exemple : méthode POST, méthode PATCH ou méthode DELETE)

② Spring Cloud Bus reçoit un événement ; demande et stocke le contenu de l'événement ;
③ Diffusez l'état de l'événement dans Spring Cloud Bus à l'ensemble du système distribué via l'agent de message
④ Chaque microservice surveille l'état de l'événement dans l'agent de message et le synchronise en temps réel lorsque l'événement se produit ; changements de statut Changer son statut.

Spring Cloud Bus utilise RabbitMQ ou Kafka comme serveur de courtier de messages, qui présente les caractéristiques d'une grande évolutivité et d'une grande fiabilité. Spring Cloud Bus est très simple à utiliser. Il vous suffit d'ajouter la configuration correspondante dans le fichier de propriétés de l'application. L'exemple de code pour implémenter un service de messagerie est le suivant :

// 添加依赖
<dependency>
   <groupId>org.springframework.cloud</groupId>
   <artifactId>spring-cloud-starter-bus-amqp</artifactId>
</dependency>
 
// 在应用程序属性文件中设置RabbitMQ地址
spring.rabbitmq.host=localhost
spring.rabbitmq.virtual-host=/
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

3. Résumé

Spring Cloud est l'une des solutions d'implémentation les plus populaires dans l'architecture de microservice actuelle. L'utilisation de Spring Cloud pour implémenter une communication de messages asynchrone présente de nombreux avantages. Cet article présente les solutions de communication de messages asynchrones couramment utilisées sous Spring Cloud : Spring Cloud Stream et Spring Cloud Bus, et explique comment les utiliser dans les applications à l'aide d'exemples de code simples. J'espère que cet article pourra aider tout le monde à mieux appliquer l'architecture des microservices dans la pratique et à améliorer les performances et la stabilité du système.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!