单个ActiveMQ会话上的多个消费者

作者: v-star*위위
发布时间: 2024-03-29 11:53:54 (20天前)
转自：

2 条回复

0#
回复此人
那月静好 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 假设你喜欢当前的设计并且你只关心实现，那么我在这里关注的唯一原因是任何可能的并发访问 <code> javax.jms.Session </code> 。该 <code> Session </code> 不是线程安全的，因此它不应该同时被多个线程访问。一个 <code> javax.jms.Connection </code> 是线程安全的，所以这不是一个问题。为每个消费者创建一个会话可能更安全/更简单。会话非常轻量级，所以我不希望任何真正的性能下降。 </p> <P> 为避免会话并发问题，您甚至可以考虑使用连接池（例如 <a href="https://github.com/messaginghub/pooled-jms" rel="nofollow noreferrer"> PooledJMS </A> 它基于ActiveMQ的连接池实现）。 </p> <P> 您的预取大小 <EM> 威力 </EM> 如果您开始遇到消费者饥饿问题，那么这是一个问题，但是您没有说明您的消息量将会是什么，因此很难说这是否会成为一个问题。要记住两件事： </p> <UL> <LI> 消息量越大，消费者挨饿的可能性就越小。 </LI> <LI> 消费者处理消息所花费的时间越长，其预取大小就越低。 </LI> </UL> <P> 相应地调整预取大小。 </p> <P> 关于整体设计，我不禁想到了 <code> javax.jms.MessageListener </code> 这里的实施会更好。单个MessageListener可以获取消息并将其移交给线程进行处理。这将避免Quartz依赖以及轮询。 </p> </DIV>

编辑

登录后才能参与评论