你遇到的是ActiveMQ默认行为的问题：即使是非持久化（NON_PERSISTENT）消息，当消费者离线时，Broker依然会把消息保存在内存中，等待消费者上线后投递。要实现消费者离线时直接忽略这些消息，可以通过配置队列的特定属性来实现，以下是具体方案：

核心方案：配置队列的expireMessagesOnNoConsumers和purgeOnNoConsumers属性 #

这两个属性是ActiveMQ针对队列的扩展配置，组合起来可以完全满足你的需求：

• expireMessagesOnNoConsumers=true：当队列没有活跃消费者时，所有新发送的消息会被立即标记为过期，Broker直接丢弃，不会存储。
• purgeOnNoConsumers=true：当最后一个消费者断开连接时，自动清空队列中已有的所有消息（避免遗留之前未被消费的消息）。

具体设置方式 #

1. 通过ActiveMQ管理控制台配置

如果你已经创建了队列，可以直接通过管理控制台修改：

• 登录ActiveMQ管理后台（默认地址：http://localhost:8161/admin）
• 进入Queues页面，找到你的目标队列
• 点击队列名称进入详情页，在属性设置区域找到expireMessagesOnNoConsumers和purgeOnNoConsumers，将它们的值改为true并保存。

2. 在配置文件中预定义队列

如果你希望队列在Broker启动时就带有这些属性，可以修改activemq.xml配置文件：

<broker xmlns="http://activemq.apache.org/schema/core" brokerName="localhost" dataDirectory="${activemq.data}">
  <!-- 其他配置 -->
  <destinations>
    <queue name="your-target-queue">
      <properties>
        <property name="expireMessagesOnNoConsumers" value="true"/>
        <property name="purgeOnNoConsumers" value="true"/>
      </properties>
    </queue>
  </destinations>
  <!-- 其他配置 -->
</broker>

修改后重启ActiveMQ，队列就会自动应用这些属性。

3. 在代码中创建队列时设置属性

如果你的应用是通过代码动态创建队列，可以使用ActiveMQ的扩展类ActiveMQQueue来设置属性：

import org.apache.activemq.command.ActiveMQQueue;

// 创建队列并设置属性
ActiveMQQueue queue = new ActiveMQQueue("your-target-queue");
queue.setExpireMessagesOnNoConsumers(true);
queue.setPurgeOnNoConsumers(true);

// 后续使用这个队列创建生产者和消费者

备选方案：使用临时队列（Temporary Queue） #

如果你的场景是一对一的消费模式（比如请求-响应），可以使用临时队列：

• 临时队列与消费者的连接绑定，当消费者断开连接时，队列会被Broker自动删除。
• 消费者需要先创建临时队列，然后将队列名称告知生产者（比如通过另一个通知队列），生产者再将消息发送到这个临时队列。
• 这种方式的好处是完全不需要额外配置，但缺点是生产者需要动态获取队列名称，适合特定场景。

需要注意的是，以上方案都是针对非持久化消息的，如果你使用持久化消息，需要确保消息本身是非持久化的（通过producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT)设置），否则即使配置了上述属性，Broker依然会将消息持久化到磁盘。

内容的提问来源于stack exchange，提问作者xyzt