ActiveMQ - 教程
-
简述
ActiveMQ 是一个用 Java 编写的开源消息代理。它完全符合 JMS 1.1 标准。JMS 是一种允许开发基于消息的系统的规范。ActiveMQ 充当位于应用程序之间的消息代理,并允许它们以异步和可靠的方式进行通信。在本教程中,我们将介绍使用 ActiveMQ 的所有方法,这有助于解决开发人员/用户在基于 activeMQ 的应用程序中面临的常见问题。本教程专为需要详细了解 ActiveMQ 及其体系结构和实际用法的 Java 程序员而设计。本教程将带您进入中级专业知识水平,您可以从中获得更高水平的专业知识。在继续学习本教程之前,您应该对 Java 编程语言有很好的了解。 -
消息类型
为了更好地理解,下面解释了两种类型的消息传递选项。点对点
在这种类型的通信中,代理只向一个消费者发送消息,而其他消费者将等待,直到他们从代理那里收到消息。没有消费者会收到相同的消息。如果没有消费者,Broker 将保留消息直到它获得消费者。这种类型的通信也称为Queue based communication生产者将消息发送到队列,只有一个消费者从队列中获取一条消息。如果有多个消费者,他们可能会收到下一条消息,但不会收到与另一个消费者相同的消息。发布/订阅
在这种类型的通信中,Broker 向所有活跃的消费者发送相同的消息副本。这种类型的通信也称为Topic based communication经纪人向所有订阅了特定主题的活跃消费者发送相同的消息。该模型支持单向通信,其中不需要对传输的消息进行验证。