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

什么是AMQ？

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

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

讯息类型

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

点对点

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

如果没有消费者，则代理将保留消息，直到获得消费者为止。这种通信方式也称为基于队列的通信，其中生产者将消息发送到队列，只有一个使用者从队列中获得一条消息。如果有一个以上的消费者，他们可能会收到下一条消息，但不会获得与另一消费者相同的消息。

发布/订阅

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

创建队列和主题

保险丝与ActiveMQ捆绑在一起。我们可以使用FMC控制台(与AMQ一起使用的基于浏览器的界面)访问ActiveMQ。

使用localhost：8181登录到FMC，然后选择ActiveMQ选项卡。

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

现在您应该能够看到在root→Queue→下创建的TestQ。

要检查创建的主题，请遵循root→主题。

浏览/删除队列内容

• 使用localhost：8181登录到FMC
• 选择ActiveMQ选项卡
• 根→队列→TestQ <选择要浏览的队列>→浏览

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

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