RocketMQ–生产者自定义消息发送规则

MessageQueueSelector

SendResult sr = producer.send(message, new MessageQueueSelector() { @Override public MessageQueue select(List<MessageQueue> mqs, Message msg, Object arg) { Integer queueNumber = (Integer)arg; return mqs.get(queueNumber); } }, 2); //发送同一topic第二个队列里面 System.err.println(sr);

本章小结