消息队列RocketMQ版客户端如何设置消费线程数_云消息队列 RocketMQ 版(RocketMQ)-阿里云帮助中心

云消息队列 RocketMQ 版所提供的TCP Java SDK支持多线程消费，且适用于所有消息类型，本文介绍如何设置消费线程数的方法。

在启动Consumer时，设置一个ConsumeThreadNums属性即可。具体示例如下所示。

public static void main(String[] args) {
    Properties properties = new Properties();
    properties.put(PropertyKeyConst.GROUP_ID, "GID_001");
    properties.put(PropertyKeyConst.AccessKey, "xxxxxxxxxxxx");
    properties.put(PropertyKeyConst.SecretKey, "xxxxxxxxxxxx");
    /**
     * 设置消费端线程数固定为20
     */
    properties.setProperty(PropertyKeyConst.ConsumeThreadNums,"20");
    Consumer consumer =ONSFactory.createConsumer(properties);
    consumer.subscribe("TestTopic", "*", new MessageListener() {
        public Action consume(Message message, ConsumeContext context) {
            System.out.println("Receive: " + message);
            return Action.CommitMessage;
        }
    });
    consumer.start();
    System.out.println("Consumer Started");
}