JBoss Fuse - Apache AMQ

在本章中，我们将了解 ActiveMQ 以及它如何充当消息代理，允许应用程序相互通信。

什么是 AMQ？

ActiveMQ 是一个用 Java 编写的开源消息代理。它完全符合 JMS 1.1 标准。

JMS 是一种允许开发基于消息的系统的规范。ActiveMQ 充当消息代理，位于应用程序之间，并允许它们以异步和可靠的方式进行通信。

消息类型

为了更好地理解，下面解释了两种消息传递选项。

点对点

在这种类型的通信中，代理仅将消息发送给一个消费者，而其他消费者将等待直到他们从代理获取消息。没有消费者会收到相同的消息。

如果没有消费者，代理将保存消息，直到它获得一个消费者。这种类型的通信也称为**基于队列的通信**，其中生产者将消息发送到队列，并且只有一个消费者从队列获取一条消息。如果有多个消费者，他们可能会获取下一条消息，但他们不会获取与其他消费者相同的消息。

发布/订阅

在这种类型的通信中，代理将相同的消息副本发送给所有活动的消费者。这种类型的通信也称为**基于主题的通信**，其中代理将相同的消息发送给已订阅特定主题的所有活动消费者。此模型支持单向通信，其中不期望对传输的消息进行验证。

创建队列和主题

Fuse 与 ActiveMQ 捆绑在一起。我们可以使用 FMC 控制台（基于浏览器的 AMQ 工作界面）访问 ActiveMQ。

使用**localhost:8181**登录 FMC 并选择**ActiveMQ**选项卡。

• 点击+创建
• 输入队列/主题名称
• 从单选按钮中选择队列/主题
• 点击创建队列/创建主题

现在您应该能够在根 → 队列 → 下看到已创建的**TestQ**。

要检查创建的主题，请按照根 → 主题操作。

浏览/删除队列内容

• 使用**localhost:8181**登录 FMC

• 选择 ActiveMQ 选项卡

• 根 → 队列 → TestQ <选择要浏览的队列> → 浏览

• 要检查此消息的内容，请点击该特定消息。

• 您可以通过点击右上角显示的删除按钮来删除特定消息