2.8. MicroProfile Reactive Messaging

JBoss EAP XP 5.0.0으로 업그레이드하면 reactive messaging extensions 및 subsystems를 포함하는 MicroProfile Reactive Messaging의 최신 버전을 활성화할 수 있습니다.

"반복 스트림"은 처리 프로토콜 및 표준과 함께 이벤트 데이터의 연속으로, 버퍼링 없이 비동기 경계(예: 스케줄러)에 푸시됩니다. 예를 들어, "이벤트"가 예정된 일 수 있으며, 예를 들어, 환경 앱에서 온도 검사를 반복할 수 있습니다. 반응 스트림의 주요 이점은 다양한 애플리케이션 및 구현의 원활한 상호 운용성입니다.

반응형 메시징은 이벤트 중심, 데이터 스트리밍 및 이벤트 소싱 애플리케이션을 빌드하기 위한 프레임워크를 제공합니다. 반응성 메시징은 한 앱에서 다른 앱으로 이벤트 데이터, 반응 스트림의 일정 및 원활한 교환을 초래합니다. 예를 들어 애플리케이션이 Apache Kafka와 같은 다른 사용자와 상호 작용할 수 있도록 반응 스트림을 통해 비동기 메시징에 MicroProfile Reactive Messaging을 사용할 수 있습니다.

MicroProfile Reactive Messaging 인스턴스를 최신 버전으로 업그레이드한 후 다음을 수행할 수 있습니다.

커넥터를 사용하여 MicroProfile Reactive Messaging을 여러 외부 메시징 시스템과 통합할 수 있습니다. JBoss EAP용 MicroProfile에는 Apache Kafka 커넥터와 AMQP(Advanced Message Queuing Protocol) 커넥터가 포함되어 있습니다. Eclipse MicroProfile Config 사양을 사용하여 커넥터를 구성합니다.

MicroProfile Reactive Messaging 커넥터 및 통합 계층

MicroProfile Reactive Messaging에는 다음과 같은 커넥터가 포함되어 있습니다.

두 커넥터 계층 모두 microprofile-reactive-messaging Galleon 계층을 포함합니다. microprofile-reactive-messaging 계층은 핵심 MicroProfile Reactive Messaging 기능을 제공합니다.

Apache Kafka는 실시간으로 레코드 스트림을 게시, 구독, 저장 및 처리할 수 있는 오픈 소스 분산 이벤트(데이터) 스트리밍 플랫폼입니다. 여러 소스의 이벤트 스트림을 처리하고 여러 소비자에 전달하여 대량의 데이터를 A에서 Z로 이동하고 다른 모든 위치에서 동시에 이동합니다. MicroProfile Reactive Messaging은 Apache Kafka를 사용하여 이러한 이벤트 레코드를 2 마이크로초 미만으로 제공하여 분산된 내결함성 클러스터에 안전하게 저장하고 모든 팀 정의 영역 또는 지역 리전에서 사용할 수 있도록 합니다.