发送消息的时候可以指定一个Key,这个Key通常就是消息对应的某种业务的主键。RocketMQ没有限制它必须是唯一的。下面代码中一共发送了10条消息,对应的Key分别是0-9。
@Test public void testSendWithKeys() throws Exception { DefaultMQProducer producer = new DefaultMQProducer("group1"); producer
京公网安备 11010502049817号