rocketMq設置消費者單線程消費

consumer.setConsumeThreadMax(1); consumer.setConsumeThreadMin(1); // 一個應用建立一個Consumer，由應用來維護此對象，能夠設置爲全局對象或者單例,ConsumerGroupName須要由應用來保證惟一 final DefaultMQPushConsumer consumer = new DefaultMQPushConsum

>>阅读原文<<