写回答
-
详细信息 阿里云提醒您： 如果您对实例或数据有修改、变更等风险操作，务必注意实例的容灾、容错能力，确保数据安全。 如果您对实例（包括但不限于ECS、RDS）等进行配置与数据修改，建议提前创建快照或开启RDS日志备份等功能。 如果您在阿里云平台授权或者提交过登录账号、密码等安全信息，建议您及时修改。
在启动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.put(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"); }
适用于 消息队列 RocketMQ 版
2020-03-28 21:07:58赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系，全系产品 Serverless 化。RocketMQ 一站式学习：https://rocketmq.io/
热门讨论
热门文章
相关课程
更多
相关文章
相关电子书
更多
