Spring Cloud 마이크로서비스에서의 비동기 메시지 통신

클라우드 컴퓨팅과 빅데이터의 등장으로 마이크로서비스 아키텍처는 엔터프라이즈 시스템에서 널리 사용됩니다. 마이크로서비스 아키텍처의 중요한 구현 도구인 Spring Cloud는 마이크로서비스 아키텍처에서 통신을 구현하기 위한 다양한 솔루션을 제공합니다. 이 기사에서는 Spring Cloud 마이크로서비스의 비동기 메시지 통신 솔루션에 중점을 두고 모든 사람이 마이크로서비스 아키텍처의 메시지 통신 문제를 해결할 수 있는 몇 가지 아이디어와 참조를 제공하고자 합니다.

1. 마이크로서비스 비동기 메시지 통신의 배경

마이크로서비스 아키텍처에서는 서비스가 독립적인 개발, 독립적인 배포 및 독립적인 유지 관리를 위해 여러 마이크로서비스로 분할됩니다. 기존 RPC 호출 또는 HTTP 요청은 높은 동시성 및 빅 데이터 시나리오에서 긴 응답 시간으로 인해 시스템 성능을 저하시킵니다. 따라서 비동기 메시지 통신은 서로 다른 마이크로 서비스 간의 통신을 효율적으로 지원하는 탁월한 솔루션으로 마이크로 서비스에서 널리 사용됩니다.

2. Spring Cloud의 비동기 메시지 통신 방식

Spring Cloud에는 일반적으로 사용되는 두 가지 비동기 메시지 통신 방식인 Spring Cloud Stream과 Spring Cloud Bus가 있습니다.

1. Spring Cloud Stream

Spring Cloud Stream은 메시지 기반 마이크로서비스 구축을 위해 Spring Cloud에서 제공하는 프레임워크입니다. Spring Boot와 Spring Integration을 기반으로 구축되어 다양한 메시지 브로커 서비스를 쉽게 연결할 수 있습니다. Spring Cloud Stream은 게시/구독 모델(Publish/Subscribe)을 기반으로 비동기 메시지 통신을 구현합니다.

Spring Cloud Stream 작업 흐름은 다음과 같습니다.

① 생산자는 메시지를 생성하여 Spring Cloud Stream에 게시합니다.
② Spring Cloud Stream은 메시지를 중간 브로커(Message Broker)로 보냅니다.
3 소비자는 정보를 구독합니다. 중간 브로커로부터 메시지가 수신되면 Spring Cloud Stream에 통보되고, Spring Cloud Stream은 해당 Consumer에게 메시지를 전달합니다.

Spring Cloud Stream은 높은 신뢰성, 높은 동시성 및 높은 확장성을 특징으로 하는 Apache Kafka 및 RabbitMQ와 같은 메시지 브로커 서비스를 사용합니다. 사용 프로세스는 매우 간단합니다. 해당 종속성을 도입하고 사용하는 메시지 에이전트를 구성하기만 하면 됩니다. 메시지 서비스를 구현하는 샘플 코드는 다음과 같습니다.

// 引入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

2. Spring Cloud Bus

Spring Cloud Bus는 분산 시스템에서 상태 변경을 전파하는 메커니즘으로, 시스템을 구성하는 다양한 마이크로서비스 간 메시지 전달을 가능하게 합니다. . Spring Cloud Bus는 메시지 브로커를 사용하여 다양한 마이크로서비스를 연결하고 경량 메시지 유형을 사용하여 이벤트 상태 전송을 완료합니다. Spring Cloud Stream과 달리 Spring Cloud Bus는 시스템 내 메시징 및 상태 공유에 더 많이 사용됩니다.

Spring Cloud Bus 워크플로는 다음과 같습니다.

① HTTP/HTTPS 요청을 통해 Spring Cloud Bus의 상태에 영향을 줄 수 있는 이벤트를 트리거합니다(예: POST 메서드, PATCH 메서드 또는 DELETE 메서드).
② Spring Cloud Bus가 이벤트를 수신합니다. 이벤트 내용을 요청하고 저장합니다.
③ 메시지 에이전트를 통해 Spring Cloud Bus의 이벤트 상태를 전체 분산 시스템에 방송합니다.
④ 각 마이크로서비스는 이벤트가 발생하면 메시지 에이전트에서 이벤트 상태를 모니터링하고 실시간으로 동기화합니다. 상태 변경 상태를 변경합니다.

Spring Cloud Bus는 높은 확장성과 높은 신뢰성을 특징으로 하는 RabbitMQ 또는 Kafka를 메시지 브로커 서버로 사용합니다. Spring Cloud Bus는 사용이 매우 간단합니다. 애플리케이션 속성 파일에 해당 구성을 추가하기만 하면 됩니다. 메시지 서비스를 구현하기 위한 샘플 코드는 다음과 같습니다.

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

Spring Cloud는 현재 마이크로서비스 아키텍처에서 가장 널리 사용되는 구현 솔루션 중 하나입니다. Spring Cloud를 사용하여 비동기 메시지 통신을 구현하면 많은 장점이 있습니다. 본 글에서는 Spring Cloud에서 흔히 사용되는 비동기 메시지 통신 솔루션인 Spring Cloud Stream과 Spring Cloud Bus를 소개하고, 간단한 코드 예제를 통해 이를 애플리케이션에서 사용하는 방법을 소개합니다. 이 글이 모든 사람이 마이크로서비스 아키텍처를 실제로 더 잘 적용하고 시스템의 성능과 안정성을 향상시키는 데 도움이 되기를 바랍니다.

위 내용은 Spring Cloud 마이크로서비스에서의 비동기 메시지 통신의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!