activemq topic消息没有被消费，activemq有消费者不消费

activemq消息队列当消费一定数量的消息后就停止消费了?

1、ActiveMQ队列消息过多产生的原因 若某一个消息消费端消费速度比较慢，然后生产者就认为没有发送成功，然后重新发送，这样才会产生消息的积压。注：ActiveMQ有ack机制，来确认消息是否发送成功并被消费端消费。

2、最近在项目中使用了 activemq 进行消息的异步传递，只有一个消费者时，系统可以正常运行，但当增加多个消费者时，却只有一个消费者进行消费，其他的消费者不消费。

3、只有MQ接到系统B成功收到信息的确认之后，它才从传输队列中真正将该信息删除。如果通讯线路不通，或系统B不在运行，信息会留在传输队列中，直到被成功地传送到目的地。

4、这就导致资源没有充分利用，而且降低了消息的处理速度。 为了避免这种情况，ActiveMQ使用预取极限（prefetch limit）来限制一次性分发给单个消费者的最大消息个数。

5、Broker：概念来自与Apache ActiveMQ，指MQ的服务端，帮你把消息从发送端传送到接收端。消息队列Queue：一个先进先出的消息存储区域。消息按照顺序发送接收，一旦消息被消费处理，该消息将从队列中删除。

6、例如：不能直接给用户提示订单提交成功，京东上提示：“您提交了订单，请等待系统确认”再由消息队列的消费者进程从消息队列中获取数据，异步写入数据库。

系统时间变化导致ActiveMQ消费者僵死的问题

问题 最近在项目中使用了 activemq 进行消息的异步传递，只有一个消费者时，系统可以正常运行，但当增加多个消费者时，却只有一个消费者进行消费，其他的消费者不消费。

消息队列概述\x0d\x0a 消息队列中间件是分布式系统中重要的组件，主要解决应用耦合，异步消息，流量削锋等问题。实现高性能，高可用，可伸缩和最终一致性架构。是大型分布式系统不可缺少的中间件。

首先，你确定重启MQ之后，pending中没有了的消息是被发送而不是丢失了么？其次，你有没有试过重启MQ之后再重启下消费者的应用？有时候MQ和消费者的连接丢失之后，重启MQ并不能重新建立连接。

消息队列中间件是分布式系统中重要的组件，主要解决应用耦合，异步消息，流量削锋等问题。实现高性能，高可用，可伸缩和最终一致性架构。是大型分布式系统不可缺少的中间件。

上述提到的非理性消费和驾驶技术不行的车辆，这些车辆可能长期闲置，成为僵尸车。 一些企业或个人购买的二手车，由于车况较差或者其他原因，很难转手，只能长期闲置。

当然，我也可以定义两个producer：AP和BP，AP发A消息，BP发B消息，那我的新问题是：---解决方案---一个统一的接收者从activemq上接收消息，接受者收到消息后，根据类型判断，转发给不同的消费者。

activemq消费者消费时异常会怎样

由于环境中有部分服务器每天都会定时重新设置系统时间，ActiveMQ的连接常常出现僵死的情况。现象为Agent不再输出日志，根据现有日志判断线程卡在consumer.receive(60000)这一个语句上。今天下定决心研究了一下源码。

然而，如果不限制每次push给消费者的消息个数将会是危险的，过多的消息会导致消费者客户端资源耗尽。尤其是当消息的消费速度显著慢于消息的分发速度时。

activemq 有一个机制，叫消息预读取，这个机制默认会读取 1000 条消息发往一个消费者中，当超过 1000 消息堆积时，才会继续读取剩下的消息发往另一个消费者中。

mq中如何保证消费者顺序消费

mq顺序消费的使用场景：强校验场景：如与金钱相关的支付等关键消息，必须强校验。基于数据库的唯一键来保证重复数据不会被插入多条。

RabbitMQ使用过程中，有些业务场景需要我们保证顺序消费，例如：业务上产生三条消息，分别是对数据的增加、修改、删除操作，如果没有保证顺序消费，执行顺序可能变成删除、修改、增加，这就乱了。

创建消费者时，设置消息模式为集群模式，并设置消费模式为顺序消费。在消费者中，通过设置消息队列的选择器来选择特定的消息队列。

我们使用RocketMQ顺序消息来模拟一下订单的场景，顺序消息分为两部分：顺序发送、顺序消费。 顺序发消息 上面代码模拟了按顺序依次发送创建、支付、退款消息到TopicTest中。

RabbitMQ的消息顺序问题，需要分三个环节看待，发送消息的顺序、队列中消息的顺序、消费消息的顺序。

activemq部分消息无法取走

首先，你确定重启MQ之后，pending中没有了的消息是被发送而不是丢失了么？其次，你有没有试过重启MQ之后再重启下消费者的应用？有时候MQ和消费者的连接丢失之后，重启MQ并不能重新建立连接。

我们建立一条从系统A到系统B的消息通道，消息通道代理将从传输队列中读取消息，并传递这条信息到系统B，然后等待确认。只有MQ接到系统B成功收到信息的确认之后，它才从传输队列中真正将该信息删除。

消费者则使用预取极限（prefetch limit）来设置其消息缓冲区的大小。