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