Asynchrone Nachrichtenkommunikation unter Spring Cloud-Mikrodiensten

Mit dem Aufkommen von Cloud Computing und Big Data wird die Microservice-Architektur in Unternehmenssystemen häufig eingesetzt. Als wichtiges Implementierungstool für die Microservice-Architektur bietet Spring Cloud eine Vielzahl von Lösungen zur Realisierung der Kommunikation unter der Microservice-Architektur. Dieser Artikel konzentriert sich auf die asynchrone Nachrichtenkommunikationslösung unter Spring Cloud-Microservices und hofft, jedem einige Ideen und Referenzen zur Lösung der Nachrichtenkommunikationsprobleme unter der Microservice-Architektur zu bieten.

1. Hintergrund der asynchronen Nachrichtenkommunikation von Microservices: Unter der Microservice-Architektur werden Dienste in mehrere Microservices für unabhängige Entwicklung, unabhängige Bereitstellung und unabhängige Wartung aufgeteilt. Zwischen jedem Microservice muss eine Interaktion und Kommunikation stattfinden. Herkömmliche RPC-Aufrufe oder HTTP-Anfragen beeinträchtigen die Systemleistung aufgrund langer Antwortzeiten in Szenarien mit hoher Parallelität und großen Datenmengen. Daher wird die asynchrone Nachrichtenkommunikation häufig in Microservices als hervorragende Lösung eingesetzt, um die Kommunikation zwischen verschiedenen Microservices effizient zu unterstützen.

2. Asynchrone Nachrichtenkommunikationslösungen unter Spring Cloud

In Spring Cloud gibt es zwei häufig verwendete asynchrone Nachrichtenkommunikationslösungen: Spring Cloud Stream und Spring Cloud Bus.

Spring Cloud Stream

1. Spring Cloud Stream ist ein von Spring Cloud bereitgestelltes Framework zum Erstellen nachrichtengesteuerter Mikrodienste. Es basiert auf Spring Boot und Spring Integration und kann problemlos verschiedene Nachrichtenbrokerdienste verbinden. Spring Cloud Stream implementiert die asynchrone Nachrichtenkommunikation basierend auf dem Publish/Subscribe-Modell (Publish/Subscribe).

Spring Cloud Stream-Workflow ist wie folgt:

① Der Produzent generiert Nachrichten und veröffentlicht sie an Spring Cloud Stream;

② Spring Cloud Stream sendet die Nachrichten an den Zwischenbroker (Message Broker);

③ Der Verbraucher abonniert die Informationen vom Zwischenbroker, und Spring Cloud Stream wird benachrichtigt, wenn eine Nachricht empfangen wird, und Spring Cloud Stream übermittelt die Nachricht an den entsprechenden Verbraucher.

Spring Cloud Stream verwendet Nachrichtenbrokerdienste wie Apache Kafka und RabbitMQ, die sich durch hohe Zuverlässigkeit, hohe Parallelität und hohe Skalierbarkeit auszeichnen. Der Verwendungsprozess ist sehr einfach. Sie müssen lediglich die entsprechenden Abhängigkeiten einführen und den verwendeten Nachrichtenagenten konfigurieren. Der Beispielcode zum Implementieren eines Nachrichtendienstes lautet wie folgt:

// 引入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 ist ein Mechanismus zur Weitergabe von Zustandsänderungen in einem verteilten System. Er ermöglicht die Nachrichtenübermittlung zwischen verschiedenen Mikrodiensten, aus denen das System besteht. . Spring Cloud Bus verwendet einen Nachrichtenbroker, um verschiedene Mikrodienste zu verbinden, und verwendet einen einfachen Nachrichtentyp, um die Übertragung des Ereignisstatus abzuschließen. Anders als Spring Cloud Stream wird Spring Cloud Bus eher für die Nachrichtenübermittlung und den Statusaustausch innerhalb des Systems verwendet.

Spring Cloud Bus-Workflow ist wie folgt:

① Lösen Sie Ereignisse aus, die den Status auf Spring Cloud Bus über HTTP/HTTPS-Anfragen beeinflussen können (zum Beispiel: POST-Methode, PATCH-Methode oder DELETE-Methode);

② Spring Cloud Bus empfängt ein Ereignis fordert den Inhalt des Ereignisses an und speichert ihn;

③ Übertragen Sie den Ereignisstatus in Spring Cloud Bus über den Nachrichtenagenten an das gesamte verteilte System.
④ Jeder Mikrodienst überwacht den Ereignisstatus im Nachrichtenagenten und synchronisiert ihn in Echtzeit Statusänderungen Ändern Sie den Status.

Spring Cloud Bus verwendet RabbitMQ oder Kafka als Nachrichtenbrokerserver, der sich durch hohe Skalierbarkeit und hohe Zuverlässigkeit auszeichnet. Spring Cloud Bus ist sehr einfach zu verwenden. Sie müssen lediglich die entsprechende Konfiguration in der Anwendungseigenschaftendatei hinzufügen. Der Beispielcode zum Implementieren eines Nachrichtendienstes lautet wie folgt:

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

Spring Cloud ist eine der beliebtesten Implementierungslösungen in der aktuellen Microservice-Architektur. Die Verwendung von Spring Cloud zur Implementierung asynchroner Nachrichtenkommunikation bietet viele Vorteile. In diesem Artikel werden die unter Spring Cloud häufig verwendeten asynchronen Nachrichtenkommunikationslösungen vorgestellt: Spring Cloud Stream und Spring Cloud Bus. Außerdem wird anhand einfacher Codebeispiele erläutert, wie diese in Anwendungen verwendet werden. Ich hoffe, dass dieser Artikel allen dabei helfen kann, die Microservice-Architektur besser in die Praxis umzusetzen und die Leistung und Stabilität des Systems zu verbessern.

Das obige ist der detaillierte Inhalt vonAsynchrone Nachrichtenkommunikation unter Spring Cloud-Mikrodiensten. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!