ActiveMQ：消费者/生产者为同一个队列实现不同的协议？
我最近开始使用消息队列（使用ActiveMQ)，并进行了试验。
-
null
谢谢你的建议，
共有1个答案
您的问题的答案可能已经作为MOM标准记录在Oracle的JMS中：
需要注意的是，JMS是一个API标准，而不是协议标准。因为所有JMS客户机实现相同的接口，所以很容易将一个供应商的clinet移植到另一个供应商的JMS提供实现。但是不同的JMS供应商通常不能直接相互通信。
-
我有一个使用ActiveMQ的消息队列。web请求用persistency=true将消息放入队列。现在，我有两个消费者，它们都作为单独的会话连接到这个队列。使用者1总是确认消息，但使用者2从不这样做。 JMS队列实现负载平衡器语义。一条消息将被一个使用者接收。如果在发送消息时没有可用的使用者，它将被保留，直到有可以处理消息的使用者可用为止。如果使用者接收到一条消息，但在关闭之前没有确认它，那么该
-
我们使用activemq作为Java独立应用程序的消息队列。我的问题是，基于activemq web控制台，队列有一定数量的消息排队和出列。但是，根据我在代码中添加的sysout语句，应用程序消耗的消息数似乎少于activemq web控制台上显示的消息数。例如，在activemq控制台上，没有。排队和出列的消息约为1800条。但是，在控制台上显示的出列消息数（我每接收一条消息就增加一个计数器）只
-
我有一个生产者/消费者场景，我不希望一个生产者交付产品，多个消费者消费这些产品。然而，常见的情况是，交付的产品只被一个消费者消费，而其他消费者从未看到过这个特定的产品。我不想实现的是，一个产品被每个消费者消费一次，而没有任何形式的阻碍。 我的第一个想法是使用多个BlockingQueue，每个消费者使用一个，并使生产者将每个产品按顺序放入所有可用的BlockingQueues中。但是，如果其中一个
-
下面我用一篇关于临时排队的文章来解释我的想法，我只想知道我对还是错。 参考链接：如何使用JMS实现请求响应 “创建临时目的地、消费者、生产者和连接都是与代理同步的请求-响应操作，因此在处理每个请求时应避免，因为它会导致与JMS代理进行大量聊天。” 我不明白这句话在咒骂什么？在不同的线程中我们可以访问临时队列吗？一点道理都没有？有人能解释一下吗
-
我有三根线。线程1(T1)是生成器，它生成数据。线程2和线程3(T2和T3)分别等待T1的数据在单独的循环中处理。我正在考虑在线程之间共享BlockingQueue,并通过调用“Take”让T2和T3等待。
-
问题内容： 我想创建某种线程应用程序。但是我不确定在两者之间实现队列的最佳方法是什么。 因此，我提出了两个想法（这两个想法可能都是完全错误的）。我想知道哪种更好，如果它们都烂了，那么实现队列的最佳方法是什么。我关心的主要是这些示例中队列的实现。我正在扩展一个内部类的Queue类，它是线程安全的。下面是两个示例，每个示例有4个类。 主班 消费阶层 生产者类别 队列类 要么 主班 消费阶层 生产者类别