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依赖
<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 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.

// 添加依赖
<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

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!