Rocketmq-client 中 MessageListenerOrderly和MessageListenerConcurrently的区别
在消费者设置并发线程和单次最大拉取消息数量为1时，当消息拉取失败
MessageListenerOrderly会一直重试当前消息阻塞后面消息的消费。而MessageListenerConcurrently则会把消息挂起先消费后面的消息，在达到消息重试间隔时间后重新消费失败的消息。
例如下面的代码和控制台输出
MessageListenerOrderly示例：
@Test
public void receiveFIFOMsg() throws InterruptedException, MQClientException, MQBrokerException, RemotingException, UnknownHostException {
String topic = "TestTopic";
String tag = "tagA";
//顺序消费
MessageListenerOrderly messageListenerOrderly = new MessageListenerOrderly() {
@Override
public ConsumeOrderlyStatus consumeMessage(List<MessageExt> msgs, ConsumeOrderlyContext context) {
System.out.println("msgs："+JSON.toJSONString(msgs));
if("msgIdA0".equals(msgs.get(0).getKeys())){
System.out.println("消费失败");
return ConsumeOrderlyStatus.SUSPEND_CURRENT_QUEUE_A_MOMENT;
}else {
System.out.println("消费成功");
return ConsumeOrderlyStatus.SUCCESS;
}
}
};
DefaultMQPushConsumer normal = RocketMqUtil.getConsume("NORMAL", topic, tag, messageListenerConcurrently);
Thread.sleep(Long.MAX_VALUE);
normal.shutdown();
}msgs：[{"body":"VGhpcyBpcyBhIG5vcm1hbCBtZXNzYWdlIGZvciBBcGFjaGUgUm9ja2V0TVEj5bqP5Y+377yaMA==","bodyCRC":842783038,"bornHost":{"address":"192.168.183.1","port":20161},"bornHostBytes":{"array":"wKi3AQAATsE=","limit":8,"position":0},"bornHostNameString":"192.168.183.1","bornHostString":"192.168.183.1","bornTimestamp":1729613042189,"brokerName":"broker-a","commitLogOffset":182937,"delayTimeLevel":5,"delayTimeMs":0,"delayTimeSec":0,"deliverTimeMs":0,"flag":0,"keys":"msgIdA0","msgId":"A9FE0699679418B4AAC2714F9A0C0000","offsetMsgId":"C0A8B78100002A9F000000000002CA99","preparedTransactionOffset":0,"properties":{"ORIGIN_MESSAGE_ID":"C0A8B78100002A9F000000000002B709","RETRY_TOPIC":"TestTopic","MSG_REGION":"DefaultRegion","UNIQ_KEY":"A9FE0699679418B4AAC2714F9A0C0000","CLUSTER":"DefaultCluster","MIN_OFFSET":"0","DELAY":"5","TAGS":"tagA","KEYS":"msgIdA0","WAIT":"false","TRACE_ON":"true","REAL_TOPIC":"%RETRY%NORMAL","MAX_OFFSET":"159","REAL_QID":"0"},"queueId":0,"queueOffset":158,"reconsumeTimes":3,"storeHost":{"address":"192.168.183.129","port":10911},"storeHostBytes":{"array":"wKi3gQAAKp8=","limit":8,"position":0},"storeSize":414,"storeTimestamp":1729613193577,"sysFlag":0,"tags":"tagA","topic":"TestTopic","waitStoreMsgOK":false}]
消费失败
msgs：[{"body":"VGhpcyBpcyBhIG5vcm1hbCBtZXNzYWdlIGZvciBBcGFjaGUgUm9ja2V0TVEj5bqP5Y+377yaMA==","bodyCRC":842783038,"bornHost":{"address":"192.168.183.1","port":20161},"bornHostBytes":{"array":"wKi3AQAATsE=","limit":8,"position":0},"bornHostNameString":"192.168.183.1","bornHostString":"192.168.183.1","bornTimestamp":1729613042189,"brokerName":"broker-a","commitLogOffset":182937,"delayTimeLevel":5,"delayTimeMs":0,"delayTimeSec":0,"deliverTimeMs":0,"flag":0,"keys":"msgIdA0","msgId":"A9FE0699679418B4AAC2714F9A0C0000","offsetMsgId":"C0A8B78100002A9F000000000002CA99","preparedTransactionOffset":0,"properties":{"ORIGIN_MESSAGE_ID":"C0A8B78100002A9F000000000002B709","RETRY_TOPIC":"TestTopic","MSG_REGION":"DefaultRegion","UNIQ_KEY":"A9FE0699679418B4AAC2714F9A0C0000","CLUSTER":"DefaultCluster","MIN_OFFSET":"0","DELAY":"5","TAGS":"tagA","KEYS":"msgIdA0","WAIT":"false","TRACE_ON":"true","REAL_TOPIC":"%RETRY%NORMAL","MAX_OFFSET":"159","REAL_QID":"0"},"queueId":0,"queueOffset":158,"reconsumeTimes":4,"storeHost":{"address":"192.168.183.129","port":10911},"storeHostBytes":{"array":"wKi3gQAAKp8=","limit":8,"position":0},"storeSize":414,"storeTimestamp":1729613193577,"sysFlag":0,"tags":"tagA","topic":"TestTopic","waitStoreMsgOK":false}]
消费失败
msgs：[{"body":"VGhpcyBpcyBhIG5vcm1hbCBtZXNzYWdlIGZvciBBcGFjaGUgUm9ja2V0TVEj5bqP5Y+377yaMA==","bodyCRC":842783038,"bornHost":{"address":"192.168.183.1","port":20161},"bornHostBytes":{"array":"wKi3AQAATsE=","limit":8,"position":0},"bornHostNameString":"192.168.183.1","bornHostString":"192.168.183.1","bornTimestamp":1729613042189,"brokerName":"broker-a","commitLogOffset":182937,"delayTimeLevel":5,"delayTimeMs":0,"delayTimeSec":0,"deliverTimeMs":0,"flag":0,"keys":"msgIdA0","msgId":"A9FE0699679418B4AAC2714F9A0C0000","offsetMsgId":"C0A8B78100002A9F000000000002CA99","preparedTransactionOffset":0,"properties":{"ORIGIN_MESSAGE_ID":"C0A8B78100002A9F000000000002B709","RETRY_TOPIC":"TestTopic","MSG_REGION":"DefaultRegion","UNIQ_KEY":"A9FE0699679418B4AAC2714F9A0C0000","CLUSTER":"DefaultCluster","MIN_OFFSET":"0","DELAY":"5","TAGS":"tagA","KEYS":"msgIdA0","WAIT":"false","TRACE_ON":"true","REAL_TOPIC":"%RETRY%NORMAL","MAX_OFFSET":"159","REAL_QID":"0"},"queueId":0,"queueOffset":158,"reconsumeTimes":5,"storeHost":{"address":"192.168.183.129","port":10911},"storeHostBytes":{"array":"wKi3gQAAKp8=","limit":8,"position":0},"storeSize":414,"storeTimestamp":1729613193577,"sysFlag":0,"tags":"tagA","topic":"TestTopic","waitStoreMsgOK":false}]
消费失败
msgs：[{"body":"VGhpcyBpcyBhIG5vcm1hbCBtZXNzYWdlIGZvciBBcGFjaGUgUm9ja2V0TVEj5bqP5Y+377yaMA==","bodyCRC":842783038,"bornHost":{"address":"192.168.183.1","port":20161},"bornHostBytes":{"array":"wKi3AQAATsE=","limit":8,"position":0},"bornHostNameString":"192.168.183.1","bornHostString":"192.168.183.1","bornTimestamp":1729613042189,"brokerName":"broker-a","commitLogOffset":182937,"delayTimeLevel":5,"delayTimeMs":0,"delayTimeSec":0,"deliverTimeMs":0,"flag":0,"keys":"msgIdA0","msgId":"A9FE0699679418B4AAC2714F9A0C0000","offsetMsgId":"C0A8B78100002A9F000000000002CA99","preparedTransactionOffset":0,"properties":{"ORIGIN_MESSAGE_ID":"C0A8B78100002A9F000000000002B709","RETRY_TOPIC":"TestTopic","MSG_REGION":"DefaultRegion","UNIQ_KEY":"A9FE0699679418B4AAC2714F9A0C0000","CLUSTER":"DefaultCluster","MIN_OFFSET":"0","DELAY":"5","TAGS":"tagA","KEYS":"msgIdA0","WAIT":"false","TRACE_ON":"true","REAL_TOPIC":"%RETRY%NORMAL","MAX_OFFSET":"159","REAL_QID":"0"},"queueId":0,"queueOffset":158,"reconsumeTimes":6,"storeHost":{"address":"192.168.183.129","port":10911},"storeHostBytes":{"array":"wKi3gQAAKp8=","limit":8,"position":0},"storeSize":414,"storeTimestamp":1729613193577,"sysFlag":0,"tags":"tagA","topic":"TestTopic","waitStoreMsgOK":false}]
消费失败
msgs：[{"body":"VGhpcyBpcyBhIG5vcm1hbCBtZXNzYWdlIGZvciBBcGFjaGUgUm9ja2V0TVEj5bqP5Y+377yaMA==","bodyCRC":842783038,"bornHost":{"address":"192.168.183.1","port":20161},"bornHostBytes":{"array":"wKi3AQAATsE=","limit":8,"position":0},"bornHostNameString":"192.168.183.1","bornHostString":"192.168.183.1","bornTimestamp":1729613042189,"brokerName":"broker-a","commitLogOffset":182937,"delayTimeLevel":5,"delayTimeMs":0,"delayTimeSec":0,"deliverTimeMs":0,"flag":0,"keys":"msgIdA0","msgId":"A9FE0699679418B4AAC2714F9A0C0000","offsetMsgId":"C0A8B78100002A9F000000000002CA99","preparedTransactionOffset":0,"properties":{"ORIGIN_MESSAGE_ID":"C0A8B78100002A9F000000000002B709","RETRY_TOPIC":"TestTopic","MSG_REGION":"DefaultRegion","UNIQ_KEY":"A9FE0699679418B4AAC2714F9A0C0000","CLUSTER":"DefaultCluster","MIN_OFFSET":"0","DELAY":"5","TAGS":"tagA","KEYS":"msgIdA0","WAIT":"false","TRACE_ON":"true","REAL_TOPIC":"%RETRY%NORMAL","MAX_OFFSET":"159","REAL_QID":"0"},"queueId":0,"queueOffset":158,"reconsumeTimes":7,"storeHost":{"address":"192.168.183.129","port":10911},"storeHostBytes":{"array":"wKi3gQAAKp8=","limit":8,"position":0},"storeSize":414,"storeTimestamp":1729613193577,"sysFlag":0,"tags":"tagA","topic":"TestTopic","waitStoreMsgOK":false}]
消费失败
msgs：[{"body":"VGhpcyBpcyBhIG5vcm1hbCBtZXNzYWdlIGZvciBBcGFjaGUgUm9ja2V0TVEj5bqP5Y+377yaMA==","bodyCRC":842783038,"bornHost":{"address":"192.168.183.1","port":20161},"bornHostBytes":{"array":"wKi3AQAATsE=","limit":8,"position":0},"bornHostNameString":"192.168.183.1","bornHostString":"192.168.183.1","bornTimestamp":1729613042189,"brokerName":"broker-a","commitLogOffset":182937,"delayTimeLevel":5,"delayTimeMs":0,"delayTimeSec":0,"deliverTimeMs":0,"flag":0,"keys":"msgIdA0","msgId":"A9FE0699679418B4AAC2714F9A0C0000","offsetMsgId":"C0A8B78100002A9F000000000002CA99","preparedTransactionOffset":0,"properties":{"ORIGIN_MESSAGE_ID":"C0A8B78100002A9F000000000002B709","RETRY_TOPIC":"TestTopic","MSG_REGION":"DefaultRegion","UNIQ_KEY":"A9FE0699679418B4AAC2714F9A0C0000","CLUSTER":"DefaultCluster","MIN_OFFSET":"0","DELAY":"5","TAGS":"tagA","KEYS":"msgIdA0","WAIT":"false","TRACE_ON":"true","REAL_TOPIC":"%RETRY%NORMAL","MAX_OFFSET":"159","REAL_QID":"0"},"queueId":0,"queueOffset":158,"reconsumeTimes":8,"storeHost":{"address":"192.168.183.129","port":10911},"storeHostBytes":{"array":"wKi3gQAAKp8=","limit":8,"position":0},"storeSize":414,"storeTimestamp":1729613193577,"sysFlag":0,"tags":"tagA","topic":"TestTopic","waitStoreMsgOK":false}]
消费失败
msgs：[{"body":"VGhpcyBpcyBhIG5vcm1hbCBtZXNzYWdlIGZvciBBcGFjaGUgUm9ja2V0TVEj5bqP5Y+377yaMA==","bodyCRC":842783038,"bornHost":{"address":"192.168.183.1","port":20161},"bornHostBytes":{"array":"wKi3AQAATsE=","limit":8,"position":0},"bornHostNameString":"192.168.183.1","bornHostString":"192.168.183.1","bornTimestamp":1729613042189,"brokerName":"broker-a","commitLogOffset":182937,"delayTimeLevel":5,"delayTimeMs":0,"delayTimeSec":0,"deliverTimeMs":0,"flag":0,"keys":"msgIdA0","msgId":"A9FE0699679418B4AAC2714F9A0C0000","offsetMsgId":"C0A8B78100002A9F000000000002CA99","preparedTransactionOffset":0,"properties":{"ORIGIN_MESSAGE_ID":"C0A8B78100002A9F000000000002B709","RETRY_TOPIC":"TestTopic","MSG_REGION":"DefaultRegion","UNIQ_KEY":"A9FE0699679418B4AAC2714F9A0C0000","CLUSTER":"DefaultCluster","MIN_OFFSET":"0","DELAY":"5","TAGS":"tagA","KEYS":"msgIdA0","WAIT":"false","TRACE_ON":"true","REAL_TOPIC":"%RETRY%NORMAL","MAX_OFFSET":"159","REAL_QID":"0"},"queueId":0,"queueOffset":158,"reconsumeTimes":9,"storeHost":{"address":"192.168.183.129","port":10911},"storeHostBytes":{"array":"wKi3gQAAKp8=","limit":8,"position":0},"storeSize":414,"storeTimestamp":1729613193577,"sysFlag":0,"tags":"tagA","topic":"TestTopic","waitStoreMsgOK":false}]
消费失败
msgs：[{"body":"VGhpcyBpcyBhIG5vcm1hbCBtZXNzYWdlIGZvciBBcGFjaGUgUm9ja2V0TVEj5bqP5Y+377yaMA==","bodyCRC":842783038,"bornHost":{"address":"192.168.183.1","port":20161},"bornHostBytes":{"array":"wKi3AQAATsE=","limit":8,"position":0},"bornHostNameString":"192.168.183.1","bornHostString":"192.168.183.1","bornTimestamp":1729613042189,"brokerName":"broker-a","commitLogOffset":182937,"delayTimeLevel":5,"delayTimeMs":0,"delayTimeSec":0,"deliverTimeMs":0,"flag":0,"keys":"msgIdA0","msgId":"A9FE0699679418B4AAC2714F9A0C0000","offsetMsgId":"C0A8B78100002A9F000000000002CA99","preparedTransactionOffset":0,"properties":{"ORIGIN_MESSAGE_ID":"C0A8B78100002A9F000000000002B709","RETRY_TOPIC":"TestTopic","MSG_REGION":"DefaultRegion","UNIQ_KEY":"A9FE0699679418B4AAC2714F9A0C0000","CLUSTER":"DefaultCluster","MIN_OFFSET":"0","DELAY":"5","TAGS":"tagA","KEYS":"msgIdA0","WAIT":"false","TRACE_ON":"true","REAL_TOPIC":"%RETRY%NORMAL","MAX_OFFSET":"159","REAL_QID":"0"},"queueId":0,"queueOffset":158,"reconsumeTimes":10,"storeHost":{"address":"192.168.183.129","port":10911},"storeHostBytes":{"array":"wKi3gQAAKp8=","limit":8,"position":0},"storeSize":414,"storeTimestamp":1729613193577,"sysFlag":0,"tags":"tagA","topic":"TestTopic","waitStoreMsgOK":false}]
消费失败
MessageListenerConcurrently示例：
@Test
public void receiveFIFOMsg() throws InterruptedException, MQClientException, MQBrokerException, RemotingException, UnknownHostException {
String topic = "TestTopic";
String tag = "tagA";
//并发接收消息
MessageListenerConcurrently messageListenerConcurrently = new MessageListenerConcurrently() {
@Override
public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) {
System.out.println("msgs：" + JSON.toJSONString(msgs));
// System.out.println("context：" + JSON.toJSONString(context));
if("msgIdA0".equals(msgs.get(0).getKeys())){
System.out.println("消费失败");
return ConsumeConcurrentlyStatus.RECONSUME_LATER;
}else {
System.out.println("消费成功");
return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
}
}
};
DefaultMQPushConsumer normal = RocketMqUtil.getConsume("NORMAL", topic, tag, messageListenerConcurrently);
Thread.sleep(Long.MAX_VALUE);
normal.shutdown();
}msgs：[{"body":"VGhpcyBpcyBhIG5vcm1hbCBtZXNzYWdlIGZvciBBcGFjaGUgUm9ja2V0TVEj5bqP5Y+377yaMA==","bodyCRC":842783038,"bornHost":{"address":"192.168.183.1","port":20161},"bornHostBytes":{"array":"wKi3AQAATsE=","limit":8,"position":0},"bornHostNameString":"192.168.183.1","bornHostString":"192.168.183.1","bornTimestamp":1729613042189,"brokerName":"broker-a","commitLogOffset":177929,"delayTimeLevel":0,"delayTimeMs":0,"delayTimeSec":0,"deliverTimeMs":0,"flag":0,"keys":"msgIdA0","msgId":"A9FE0699679418B4AAC2714F9A0C0000","offsetMsgId":"C0A8B78100002A9F000000000002B709","preparedTransactionOffset":0,"properties":{"CONSUME_START_TIME":"1729613091622","MSG_REGION":"DefaultRegion","UNIQ_KEY":"A9FE0699679418B4AAC2714F9A0C0000","CLUSTER":"DefaultCluster","MIN_OFFSET":"0","TAGS":"tagA","KEYS":"msgIdA0","WAIT":"true","TRACE_ON":"true","MAX_OFFSET":"63"},"queueId":0,"queueOffset":53,"reconsumeTimes":0,"storeHost":{"address":"192.168.183.129","port":10911},"storeHostBytes":{"array":"wKi3gQAAKp8=","limit":8,"position":0},"storeSize":292,"storeTimestamp":1729613041945,"sysFlag":0,"tags":"tagA","topic":"TestTopic","waitStoreMsgOK":true}]
消费失败
msgs：[{"body":"VGhpcyBpcyBhIG5vcm1hbCBtZXNzYWdlIGZvciBBcGFjaGUgUm9ja2V0TVEj5bqP5Y+377yaMQ==","bodyCRC":1161619880,"bornHost":{"address":"192.168.183.1","port":20161},"bornHostBytes":{"array":"wKi3AQAATsE=","limit":8,"position":0},"bornHostNameString":"192.168.183.1","bornHostString":"192.168.183.1","bornTimestamp":1729613042195,"brokerName":"broker-a","commitLogOffset":178221,"delayTimeLevel":0,"delayTimeMs":0,"delayTimeSec":0,"deliverTimeMs":0,"flag":0,"keys":"msgIdA1","msgId":"A9FE0699679418B4AAC2714F9A130001","offsetMsgId":"C0A8B78100002A9F000000000002B82D","preparedTransactionOffset":0,"properties":{"CONSUME_START_TIME":"1729613093735","MSG_REGION":"DefaultRegion","UNIQ_KEY":"A9FE0699679418B4AAC2714F9A130001","CLUSTER":"DefaultCluster","MIN_OFFSET":"0","TAGS":"tagA","KEYS":"msgIdA1","WAIT":"true","TRACE_ON":"true","MAX_OFFSET":"63"},"queueId":0,"queueOffset":54,"reconsumeTimes":0,"storeHost":{"address":"192.168.183.129","port":10911},"storeHostBytes":{"array":"wKi3gQAAKp8=","limit":8,"position":0},"storeSize":292,"storeTimestamp":1729613041949,"sysFlag":0,"tags":"tagA","topic":"TestTopic","waitStoreMsgOK":true}]
消费成功
msgs：[{"body":"VGhpcyBpcyBhIG5vcm1hbCBtZXNzYWdlIGZvciBBcGFjaGUgUm9ja2V0TVEj5bqP5Y+377yaMg==","bodyCRC":1547024402,"bornHost":{"address":"192.168.183.1","port":20161},"bornHostBytes":{"array":"wKi3AQAATsE=","limit":8,"position":0},"bornHostNameString":"192.168.183.1","bornHostString":"192.168.183.1","bornTimestamp":1729613042198,"brokerName":"broker-a","commitLogOffset":178513,"delayTimeLevel":0,"delayTimeMs":0,"delayTimeSec":0,"deliverTimeMs":0,"flag":0,"keys":"msgIdA2","msgId":"A9FE0699679418B4AAC2714F9A160002","offsetMsgId":"C0A8B78100002A9F000000000002B951","preparedTransactionOffset":0,"properties":{"CONSUME_START_TIME":"1729613093735","MSG_REGION":"DefaultRegion","UNIQ_KEY":"A9FE0699679418B4AAC2714F9A160002","CLUSTER":"DefaultCluster","MIN_OFFSET":"0","TAGS":"tagA","KEYS":"msgIdA2","WAIT":"true","TRACE_ON":"true","MAX_OFFSET":"63"},"queueId":0,"queueOffset":55,"reconsumeTimes":0,"storeHost":{"address":"192.168.183.129","port":10911},"storeHostBytes":{"array":"wKi3gQAAKp8=","limit":8,"position":0},"storeSize":292,"storeTimestamp":1729613041951,"sysFlag":0,"tags":"tagA","topic":"TestTopic","waitStoreMsgOK":true}]
消费成功
msgs：[{"body":"VGhpcyBpcyBhIG5vcm1hbCBtZXNzYWdlIGZvciBBcGFjaGUgUm9ja2V0TVEj5bqP5Y+377yaMw==","bodyCRC":724732036,"bornHost":{"address":"192.168.183.1","port":20161},"bornHostBytes":{"array":"wKi3AQAATsE=","limit":8,"position":0},"bornHostNameString":"192.168.183.1","bornHostString":"192.168.183.1","bornTimestamp":1729613042200,"brokerName":"broker-a","commitLogOffset":178805,"delayTimeLevel":0,"delayTimeMs":0,"delayTimeSec":0,"deliverTimeMs":0,"flag":0,"keys":"msgIdA3","msgId":"A9FE0699679418B4AAC2714F9A180003","offsetMsgId":"C0A8B78100002A9F000000000002BA75","preparedTransactionOffset":0,"properties":{"CONSUME_START_TIME":"1729613093735","MSG_REGION":"DefaultRegion","UNIQ_KEY":"A9FE0699679418B4AAC2714F9A180003","CLUSTER":"DefaultCluster","MIN_OFFSET":"0","TAGS":"tagA","KEYS":"msgIdA3","WAIT":"true","TRACE_ON":"true","MAX_OFFSET":"63"},"queueId":0,"queueOffset":56,"reconsumeTimes":0,"storeHost":{"address":"192.168.183.129","port":10911},"storeHostBytes":{"array":"wKi3gQAAKp8=","limit":8,"position":0},"storeSize":292,"storeTimestamp":1729613041953,"sysFlag":0,"tags":"tagA","topic":"TestTopic","waitStoreMsgOK":true}]
消费成功
msgs：[{"body":"VGhpcyBpcyBhIG5vcm1hbCBtZXNzYWdlIGZvciBBcGFjaGUgUm9ja2V0TVEj5bqP5Y+377yaNA==","bodyCRC":894836007,"bornHost":{"address":"192.168.183.1","port":20161},"bornHostBytes":{"array":"wKi3AQAATsE=","limit":8,"position":0},"bornHostNameString":"192.168.183.1","bornHostString":"192.168.183.1","bornTimestamp":1729613042202,"brokerName":"broker-a","commitLogOffset":179097,"delayTimeLevel":0,"delayTimeMs":0,"delayTimeSec":0,"deliverTimeMs":0,"flag":0,"keys":"msgIdA4","msgId":"A9FE0699679418B4AAC2714F9A1A0004","offsetMsgId":"C0A8B78100002A9F000000000002BB99","preparedTransactionOffset":0,"properties":{"CONSUME_START_TIME":"1729613093735","MSG_REGION":"DefaultRegion","UNIQ_KEY":"A9FE0699679418B4AAC2714F9A1A0004","CLUSTER":"DefaultCluster","MIN_OFFSET":"0","TAGS":"tagA","KEYS":"msgIdA4","WAIT":"true","TRACE_ON":"true","MAX_OFFSET":"63"},"queueId":0,"queueOffset":57,"reconsumeTimes":0,"storeHost":{"address":"192.168.183.129","port":10911},"storeHostBytes":{"array":"wKi3gQAAKp8=","limit":8,"position":0},"storeSize":292,"storeTimestamp":1729613041955,"sysFlag":0,"tags":"tagA","topic":"TestTopic","waitStoreMsgOK":true}]
消费成功
msgs：[{"body":"VGhpcyBpcyBhIG5vcm1hbCBtZXNzYWdlIGZvciBBcGFjaGUgUm9ja2V0TVEj5bqP5Y+377yaNQ==","bodyCRC":1112616369,"bornHost":{"address":"192.168.183.1","port":20161},"bornHostBytes":{"array":"wKi3AQAATsE=","limit":8,"position":0},"bornHostNameString":"192.168.183.1","bornHostString":"192.168.183.1","bornTimestamp":1729613042204,"brokerName":"broker-a","commitLogOffset":179389,"delayTimeLevel":0,"delayTimeMs":0,"delayTimeSec":0,"deliverTimeMs":0,"flag":0,"keys":"msgIdA5","msgId":"A9FE0699679418B4AAC2714F9A1C0005","offsetMsgId":"C0A8B78100002A9F000000000002BCBD","preparedTransactionOffset":0,"properties":{"CONSUME_START_TIME":"1729613093736","MSG_REGION":"DefaultRegion","UNIQ_KEY":"A9FE0699679418B4AAC2714F9A1C0005","CLUSTER":"DefaultCluster","MIN_OFFSET":"0","TAGS":"tagA","KEYS":"msgIdA5","WAIT":"true","TRACE_ON":"true","MAX_OFFSET":"63"},"queueId":0,"queueOffset":58,"reconsumeTimes":0,"storeHost":{"address":"192.168.183.129","port":10911},"storeHostBytes":{"array":"wKi3gQAAKp8=","limit":8,"position":0},"storeSize":292,"storeTimestamp":1729613041957,"sysFlag":0,"tags":"tagA","topic":"TestTopic","waitStoreMsgOK":true}]
消费成功
msgs：[{"body":"VGhpcyBpcyBhIG5vcm1hbCBtZXNzYWdlIGZvciBBcGFjaGUgUm9ja2V0TVEj5bqP5Y+377yaNg==","bodyCRC":1532525579,"bornHost":{"address":"192.168.183.1","port":20161},"bornHostBytes":{"array":"wKi3AQAATsE=","limit":8,"position":0},"bornHostNameString":"192.168.183.1","bornHostString":"192.168.183.1","bornTimestamp":1729613042206,"brokerName":"broker-a","commitLogOffset":179681,"delayTimeLevel":0,"delayTimeMs":0,"delayTimeSec":0,"deliverTimeMs":0,"flag":0,"keys":"msgIdA6","msgId":"A9FE0699679418B4AAC2714F9A1E0006","offsetMsgId":"C0A8B78100002A9F000000000002BDE1","preparedTransactionOffset":0,"properties":{"CONSUME_START_TIME":"1729613093736","MSG_REGION":"DefaultRegion","UNIQ_KEY":"A9FE0699679418B4AAC2714F9A1E0006","CLUSTER":"DefaultCluster","MIN_OFFSET":"0","TAGS":"tagA","KEYS":"msgIdA6","WAIT":"true","TRACE_ON":"true","MAX_OFFSET":"63"},"queueId":0,"queueOffset":59,"reconsumeTimes":0,"storeHost":{"address":"192.168.183.129","port":10911},"storeHostBytes":{"array":"wKi3gQAAKp8=","limit":8,"position":0},"storeSize":292,"storeTimestamp":1729613041959,"sysFlag":0,"tags":"tagA","topic":"TestTopic","waitStoreMsgOK":true}]
消费成功
msgs：[{"body":"VGhpcyBpcyBhIG5vcm1hbCBtZXNzYWdlIGZvciBBcGFjaGUgUm9ja2V0TVEj5bqP5Y+377yaNw==","bodyCRC":744443037,"bornHost":{"address":"192.168.183.1","port":20161},"bornHostBytes":{"array":"wKi3AQAATsE=","limit":8,"position":0},"bornHostNameString":"192.168.183.1","bornHostString":"192.168.183.1","bornTimestamp":1729613042207,"brokerName":"broker-a","commitLogOffset":179973,"delayTimeLevel":0,"delayTimeMs":0,"delayTimeSec":0,"deliverTimeMs":0,"flag":0,"keys":"msgIdA7","msgId":"A9FE0699679418B4AAC2714F9A1F0007","offsetMsgId":"C0A8B78100002A9F000000000002BF05","preparedTransactionOffset":0,"properties":{"CONSUME_START_TIME":"1729613093736","MSG_REGION":"DefaultRegion","UNIQ_KEY":"A9FE0699679418B4AAC2714F9A1F0007","CLUSTER":"DefaultCluster","MIN_OFFSET":"0","TAGS":"tagA","KEYS":"msgIdA7","WAIT":"true","TRACE_ON":"true","MAX_OFFSET":"63"},"queueId":0,"queueOffset":60,"reconsumeTimes":0,"storeHost":{"address":"192.168.183.129","port":10911},"storeHostBytes":{"array":"wKi3gQAAKp8=","limit":8,"position":0},"storeSize":292,"storeTimestamp":1729613041961,"sysFlag":0,"tags":"tagA","topic":"TestTopic","waitStoreMsgOK":true}]
消费成功
msgs：[{"body":"VGhpcyBpcyBhIG5vcm1hbCBtZXNzYWdlIGZvciBBcGFjaGUgUm9ja2V0TVEj5bqP5Y+377yaOA==","bodyCRC":1021333772,"bornHost":{"address":"192.168.183.1","port":20161},"bornHostBytes":{"array":"wKi3AQAATsE=","limit":8,"position":0},"bornHostNameString":"192.168.183.1","bornHostString":"192.168.183.1","bornTimestamp":1729613042209,"brokerName":"broker-a","commitLogOffset":180265,"delayTimeLevel":0,"delayTimeMs":0,"delayTimeSec":0,"deliverTimeMs":0,"flag":0,"keys":"msgIdA8","msgId":"A9FE0699679418B4AAC2714F9A210008","offsetMsgId":"C0A8B78100002A9F000000000002C029","preparedTransactionOffset":0,"properties":{"CONSUME_START_TIME":"1729613093736","MSG_REGION":"DefaultRegion","UNIQ_KEY":"A9FE0699679418B4AAC2714F9A210008","CLUSTER":"DefaultCluster","MIN_OFFSET":"0","TAGS":"tagA","KEYS":"msgIdA8","WAIT":"true","TRACE_ON":"true","MAX_OFFSET":"63"},"queueId":0,"queueOffset":61,"reconsumeTimes":0,"storeHost":{"address":"192.168.183.129","port":10911},"storeHostBytes":{"array":"wKi3gQAAKp8=","limit":8,"position":0},"storeSize":292,"storeTimestamp":1729613041963,"sysFlag":0,"tags":"tagA","topic":"TestTopic","waitStoreMsgOK":true}]
消费成功
msgs：[{"body":"VGhpcyBpcyBhIG5vcm1hbCBtZXNzYWdlIGZvciBBcGFjaGUgUm9ja2V0TVEj5bqP5Y+377yaOQ==","bodyCRC":1273455002,"bornHost":{"address":"192.168.183.1","port":20161},"bornHostBytes":{"array":"wKi3AQAATsE=","limit":8,"position":0},"bornHostNameString":"192.168.183.1","bornHostString":"192.168.183.1","bornTimestamp":1729613042212,"brokerName":"broker-a","commitLogOffset":180557,"delayTimeLevel":0,"delayTimeMs":0,"delayTimeSec":0,"deliverTimeMs":0,"flag":0,"keys":"msgIdA9","msgId":"A9FE0699679418B4AAC2714F9A240009","offsetMsgId":"C0A8B78100002A9F000000000002C14D","preparedTransactionOffset":0,"properties":{"CONSUME_START_TIME":"1729613093736","MSG_REGION":"DefaultRegion","UNIQ_KEY":"A9FE0699679418B4AAC2714F9A240009","CLUSTER":"DefaultCluster","MIN_OFFSET":"0","TAGS":"tagA","KEYS":"msgIdA9","WAIT":"true","TRACE_ON":"true","MAX_OFFSET":"63"},"queueId":0,"queueOffset":62,"reconsumeTimes":0,"storeHost":{"address":"192.168.183.129","port":10911},"storeHostBytes":{"array":"wKi3gQAAKp8=","limit":8,"position":0},"storeSize":292,"storeTimestamp":1729613041966,"sysFlag":0,"tags":"tagA","topic":"TestTopic","waitStoreMsgOK":true}]
消费成功
msgs：[{"body":"VGhpcyBpcyBhIG5vcm1hbCBtZXNzYWdlIGZvciBBcGFjaGUgUm9ja2V0TVEj5bqP5Y+377yaMA==","bodyCRC":842783038,"bornHost":{"address":"192.168.183.1","port":20161},"bornHostBytes":{"array":"wKi3AQAATsE=","limit":8,"position":0},"bornHostNameString":"192.168.183.1","bornHostString":"192.168.183.1","bornTimestamp":1729613042189,"brokerName":"broker-a","commitLogOffset":181269,"delayTimeLevel":3,"delayTimeMs":0,"delayTimeSec":0,"deliverTimeMs":0,"flag":0,"keys":"msgIdA0","msgId":"A9FE0699679418B4AAC2714F9A0C0000","offsetMsgId":"C0A8B78100002A9F000000000002C415","preparedTransactionOffset":0,"properties":{"CONSUME_START_TIME":"1729613103793","ORIGIN_MESSAGE_ID":"C0A8B78100002A9F000000000002B709","RETRY_TOPIC":"TestTopic","MSG_REGION":"DefaultRegion","UNIQ_KEY":"A9FE0699679418B4AAC2714F9A0C0000","CLUSTER":"DefaultCluster","MIN_OFFSET":"0","DELAY":"3","TAGS":"tagA","KEYS":"msgIdA0","WAIT":"false","TRACE_ON":"true","REAL_TOPIC":"%RETRY%NORMAL","MAX_OFFSET":"157","REAL_QID":"0"},"queueId":0,"queueOffset":156,"reconsumeTimes":1,"storeHost":{"address":"192.168.183.129","port":10911},"storeHostBytes":{"array":"wKi3gQAAKp8=","limit":8,"position":0},"storeSize":414,"storeTimestamp":1729613103543,"sysFlag":0,"tags":"tagA","topic":"TestTopic","waitStoreMsgOK":false}]
消费失败
msgs：[{"body":"VGhpcyBpcyBhIG5vcm1hbCBtZXNzYWdlIGZvciBBcGFjaGUgUm9ja2V0TVEj5bqP5Y+377yaMA==","bodyCRC":842783038,"bornHost":{"address":"192.168.183.1","port":20161},"bornHostBytes":{"array":"wKi3AQAATsE=","limit":8,"position":0},"bornHostNameString":"192.168.183.1","bornHostString":"192.168.183.1","bornTimestamp":1729613042189,"brokerName":"broker-a","commitLogOffset":182103,"delayTimeLevel":4,"delayTimeMs":0,"delayTimeSec":0,"deliverTimeMs":0,"flag":0,"keys":"msgIdA0","msgId":"A9FE0699679418B4AAC2714F9A0C0000","offsetMsgId":"C0A8B78100002A9F000000000002C757","preparedTransactionOffset":0,"properties":{"CONSUME_START_TIME":"1729613133800","ORIGIN_MESSAGE_ID":"C0A8B78100002A9F000000000002B709","RETRY_TOPIC":"TestTopic","MSG_REGION":"DefaultRegion","UNIQ_KEY":"A9FE0699679418B4AAC2714F9A0C0000","CLUSTER":"DefaultCluster","MIN_OFFSET":"0","DELAY":"4","TAGS":"tagA","KEYS":"msgIdA0","WAIT":"false","TRACE_ON":"true","REAL_TOPIC":"%RETRY%NORMAL","MAX_OFFSET":"158","REAL_QID":"0"},"queueId":0,"queueOffset":157,"reconsumeTimes":2,"storeHost":{"address":"192.168.183.129","port":10911},"storeHostBytes":{"array":"wKi3gQAAKp8=","limit":8,"position":0},"storeSize":414,"storeTimestamp":1729613133551,"sysFlag":0,"tags":"tagA","topic":"TestTopic","waitStoreMsgOK":false}]
消费失败
本文是原创文章，采用 CC BY-NC-ND 4.0 协议，完整转载请注明来自 程序员流动的零一
阅读建议
评论
匿名评论
隐私政策
你无需删除空行，直接评论以获取最佳展示效果