RocketMQ - 消费者启动机制

package org.apache.rocketmq.common.consumer;
/**
 * 一个枚举，表示从什么位点开始消费。
 */
public enum ConsumeFromWhere {
    //从上次消费的位点开始消费，相当于断点继续
    CONSUME_FROM_LAST_OFFSET,
    //4.2.0不支持，处理同 CONSUME_FROM_LAST_OFFSET
    @Deprecated
    CONSUME_FROM_LAST_OFFSET_AND_FROM_MIN_WHEN_BOOT_FIRST,
    //4.2.0 不支持，处理同 CONSUME_FROM_LAST_OFFSET
    @Deprecated
    CONSUME_FROM_MIN_OFFSET,
    //4.2.0 不支持，处理同 CONSUME_FROM_LAST_OFFSET
    @Deprecated
    CONSUME_FROM_MAX_OFFSET,
    //从ConsumeQueue的最小位点开始消费
    CONSUME_FROM_FIRST_OFFSET,
    //从指定时间开始消费
    CONSUME_FROM_TIMESTAMP,
}

public class DefaultMQPushConsumer extends ClientConfig implements MQPushConsumer {
    private final InternalLogger log = ClientLogger.getLog();
    /**
     * 默认的Push消费者具体实现类
     */
    protected final transient DefaultMQPushConsumerImpl defaultMQPushConsumerImpl;
    /**
     * 消费者组名字
     */
    private String consumerGroup;
    /**
     * 消费模式，现在支持集群模式消费和广播模式消费
     */
    private MessageModel messageModel = MessageModel.CLUSTERING;
    /**
     * 一个枚举，表示从什么位点开始消费
     */
    private ConsumeFromWhere consumeFromWhere = ConsumeFromWhere.CONSUME_FROM_LAST_OFFSET;
    /**
     * 表示从哪一时刻开始消费，格式为*yyyyMMDDHHmmss，默认为半小时前。
     * 当*consumeFromWhere=CONSUME_FROM_TIMESTAMP时，consumeTimestamp设*置的值才生效
     */
    private String consumeTimestamp = UtilAll.timeMillisToHumanString3(System.currentTimeMillis() - (1000 * 60 * 30));
    /**
     * 消费者订阅topic-queue策略
     */
    private AllocateMessageQueueStrategy allocateMessageQueueStrategy;
    /**
     * 订阅关系，表示当前消费者订阅了哪些Topic的哪些 Tag
     */
    private Map<String /* topic */, String /* sub expression */> subscription = new HashMap<String, String>();
    /**
     * 消息Push回调监听器
     */
    private MessageListener messageListener;
    /**
     * Offset Storage
     */
    private OffsetStore offsetStore;
    /**
     *  最小消费线程数，必须小于consumeThreadMax
     */
    private int consumeThreadMin = 20;
    /**
     * 最大线程数，必须大于consumeThreadMin
     */
    private int consumeThreadMax = 20;
    /**
     * 动态调整消费线程池的线程数大小，开源版本不支持该功能
     */
    private long adjustThreadPoolNumsThreshold = 100000;
    /**
     * 并发消息的最大位点差。如果Pull消息的位点差超过该值，拉取变慢
     */
    private int consumeConcurrentlyMaxSpan = 2000;
    /**
     * 一个 Queue 能缓存的最大消息数。超过该值则采取拉取流控措施。
     */
    private int pullThresholdForQueue = 1000;
    /**
     * 一个Queue最大能缓存的消息字节数，单位是MB
     */
    private int pullThresholdSizeForQueue = 100;
    /**
     * 一个Topic最大能缓存的消息数。超过该值则采取拉取流控措施。
     * 该字段默认值是-1，该值根据pullThresholdForQueue的配置决定是否生效，pullThresholdForTopic的优先级低于pullThresholdForQueue
     */
    private int pullThresholdForTopic = -1;
    /**
     * 一个Topic最大能缓存的消息字节数，单位是MB。
     * 默认为-1，结合 pullThresholdSizeForQueue 配置项生效，该配置项的优先级低于pullThresholdSizeForQueue
     */
    private int pullThresholdSizeForTopic = -1;
    /**
     * 拉取间隔，单位为ms
     */
    private long pullInterval = 0;
    /**
     * 消费者每次批量消费时，最多消费多少条消息
     */
    private int consumeMessageBatchMaxSize = 1;
    /**
     * 一次最多拉取多少条消息
     */
    private int pullBatchSize = 32;
    /**
     * 每次拉取消息时是否更新订阅关系，该方法的返回值默认为False
     */
    private boolean postSubscriptionWhenPull = false;
    /**
     * Whether the unit of subscription group
     */
    private boolean unitMode = false;
    /**
     * 最大重试次数，该函数返回值默认为-1，表示默认最大重试次数为16
     */
    private int maxReconsumeTimes = -1;
    /**
     * 为短轮询场景设置的挂起时间，比如顺序消息场景
     */
    private long suspendCurrentQueueTimeMillis = 1000;
    /**
     * 消费超时时间，单位为min，默认值为15min
     */
    private long consumeTimeout = 15;
    /**
     * Maximum time to await message consuming when shutdown consumer, 0 indicates no await.
     */
    private long awaitTerminationMillisWhenShutdown = 0;
    /**
     * Interface of asynchronous transfer data
     */
    private TraceDispatcher traceDispatcher = null;
}