rocketMq设置消费者单线程消费

consumer.setConsumeThreadMax(1); consumer.setConsumeThreadMin(1); // 一个应用建立一个Consumer，由应用来维护此对象，能够设置为全局对象或者单例,ConsumerGroupName须要由应用来保证惟一 final DefaultMQPushConsumer consumer = new DefaultMQPushConsum

>>阅读原文<<