2.9. MicroProfile Reactive Messaging
2.9.1. MicroProfile 被动消息传递 复制链接链接已复制到粘贴板!
当您升级到 JBoss EAP XP 4.0.0 时,您可以启用最新版本的 MicroProfile Reactive 消息传递,其中包括被动消息传递扩展和子系统。
"主动流"是事件数据的成功,以及处理协议和标准,并在没有缓冲区的异步边界(如调度程序)间推送。"事件"可能是调度,并在 hwlatdetect 应用中重复温度检查,例如:被动流的主要优点是您的各种应用程序和实现的无缝互操作性。
被动消息传递为构建事件驱动的、数据流和事件源应用程序提供了一个框架。被动消息传递导致事件数据的持续和平稳交换(从被动流到另一个应用程序)。您可以使用 MicroProfile Reactive Messaging 通过被动流进行异步消息传递,以便应用程序可以与其他流(如 Apache Kafka)进行交互。
在将 MicroProfile Reactive Messaging 实例升级到最新版本后,您可以执行以下操作:
- 为 Apache Kafka 数据流平台置备带有 MicroProfile Reactive Messaging 的服务器。
- 与被动消息传递 in-memory 交互,并通过最新的被动消息传递 API 支持 Apache Kafka 主题。
- 使用 MicroProfile 指标查找在给定频道上流出多少消息。
2.9.2. MicroProfile 被动消息传递连接器 复制链接链接已复制到粘贴板!
您可以使用连接器将 MicroProfile 被动消息传递与多个外部消息传递系统集成。用于 JBoss EAP 的 MicroProfile 附带 Apache Kafka 连接器。使用 Eclipse MicroProfile Config 规范配置您的连接器。
Apache Kafka 连接器并融合了层
MicroProfile Reactive Messaging 包括 Kafka 连接器,您可以使用 MicroProfile 配置进行配置。Kafka 连接器融合了 microprofile-reactive-messaging-kafka 和 microprofile-reactive-messaging Galleon 层。microprofile-reactive-messaging 层提供核心 MicroProfile 主动消息功能。
| layer | 定义 |
|---|---|
|
|
|
|
|
|
|
|
|
2.9.3. Apache Kafka 事件流平台 复制链接链接已复制到粘贴板!
Apache Kafka 是一个开源分布式事件(数据)流平台,可以实时发布、订阅、存储和处理记录流。它处理来自多个源的事件流,并将其提供给多个消费者,将大量数据从 A 移到 Z 和其他地方,并同时将其处理。MicroProfile Reactive 消息传递使用 Apache Kafka 在几微秒内提供这些事件记录,将其安全存储在分布式、容错集群中,同时将其在任何团队定义区域或地理区域中可用。