2024年3月24日发(作者：)

defaultmqpushconsumer 参数详解

一、概述

defaultmqpushconsumer 是 Apache ActiveMQ 中的一个重要

组件，用于从消息队列中消费消息。在使用

defaultmqpushconsumer 之前，我们需要了解其常用参数及其含

义，以便更好地配置和使用它。本文将详细介绍

defaultmqpushconsumer 的常用参数，帮助您更好地了解和掌握这

个组件。

二、参数详解

1. consumerID（字符串类型，可选）

指定 consumer 的唯一标识符，用于区分不同的 consumer 实

例。默认为自动生成。

2. maxRedeliverCount（整数类型，可选）

指定消费者重播消息的上限次数。默认值为 0，表示没有限制。

当消息被重播时，该参数用于控制重播次数的计数器递增。

3. consumerName（字符串类型，可选）

指定 consumer 的名称，用于区分不同的 consumer 实例。默认

为空字符串，表示使用自动生成的名称。

第 1 页 共 4 页

4. subscriptionName（字符串类型，可选）

指定消费者订阅的消息的主题或队列名称。默认值为空字符串，

表示不指定订阅主题或队列。

5. prefetchCount（整数类型，可选）

指定消费者从队列中获取消息的次数限制。默认值为 0，表示不

限制获取消息的次数。该参数可用于控制消费者对队列的消费速度。

6. exclusive（布尔类型，可选）

指定消费者是否为独占型消费者。默认值为 false，表示消费者不

是独占型消费者。当设置为 true 时，其他应用程序将无法消费相同的

消息。

7. durableSubscriptionName（字符串类型，可选）

指定持久型消费者订阅的消息名称。默认值为空字符串，表示不

指定订阅名称。当消费者是持久型时，需要指定此参数。

8. filterType（字符串类型，可选）

指定消费者过滤器的类型，用于筛选要消费的消息。默认为空字

符串，表示不使用过滤器。常见的过滤器类型包括

JMSMessageKeySelector、JMSTypeSelector 等。

9. filterString（字符串类型，可选）

第 2 页 共 4 页

在指定的过滤器类型下使用特定的过滤条件来筛选要消费的消

息。默认为空字符串，表示不使用过滤条件。可以与 filterType 参数

联合使用，根据消息的属性进行筛选。

10. clientID（字符串类型，可选）

为 consumer 分配一个唯一的标识符，通常用于标识特定的客户

端应用程序。默认值为自动生成。该参数有助于在分布式环境中识别

不同的客户端实例。

三、示例配置

```java

DefaultMQPushConsumer consumer = new

DefaultMQPushConsumer("consumerGroup");

sumerID("myConsumer"); // 设置唯一标识符

ibe("Topic", "mySelector"); // 订阅主题并设置

过滤器条件

ableSubscriptionName("mySubscription");

// 设置持久型订阅名称

fetchCount(3); // 设置获取消息的次数限制为 3

次

第 3 页 共 4 页

```

上述示例中，我们创建了一个名为 "myConsumer" 的 consumer

实例，并设置了唯一的标识符、订阅主题和获取消息的次数限制等参

数。可以根据实际需求调整这些参数的值。

第 4 页 共 4 页