RocketMq消息隊(duì)列之削峰詳解
RocketMq削峰
MQ的主要特點(diǎn)為解耦、異步、削峰,本篇博客只是簡單的記錄RocketMQ削峰用法,用于減少數(shù)據(jù)庫壓力的業(yè)務(wù)場景。
生產(chǎn)者,消費(fèi)者的配置可以參考以前的文章,這里只列出消費(fèi)者新增的兩個(gè)配置:
@Bean(initMethod = "start", destroyMethod = "shutdown") public DefaultMQPushConsumer BatchConsumer() { DefaultMQPushConsumer consumer = new DefaultMQPushConsumer(consumerBatchGroupName); consumer.setNamesrvAddr(nameServerAddress); consumer.setMaxReconsumeTimes(0); consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET); consumer.registerMessageListener(messageListener); //consumer.setMessageModel(MessageModel.CLUSTERING);集群模式(默認(rèn)) //consumer.setMessageModel(MessageModel.BROADCASTING);//廣播模式 // 每次拉取的間隔,單位為毫秒 consumer.setPullInterval(10000); // 設(shè)置每次從隊(duì)列中拉取的消息數(shù)為16 consumer.setPullBatchSize(1); try { consumer.subscribe(batchTopic, "*"); } catch (MQClientException e) { e.printStackTrace(); } return consumer; }
pullInterval:每次從Broker拉取消息的間隔,單位為毫秒
pullBatchSize:每次從Broker隊(duì)列拉取到的消息數(shù),該參數(shù)很容易讓人誤解,一開始我以為是每次拉取的消息總數(shù),但測試過幾次后確認(rèn)了實(shí)質(zhì)上是從每個(gè)隊(duì)列的拉取數(shù),即Consume每次拉取的消息總數(shù)如下:
EachPullTotal=所有Broker上的讀/寫隊(duì)列數(shù)(broker數(shù)量*writeQueueNums或者readQueueNums) * pullBatchSize,這里我們簡單演示所以只有一個(gè)Broker,Broker上的writeQueueNums=readQueueNums=16,pullBatchSize=1,所以每10秒拉取的數(shù)量為1*1*16=16條。
好了,我們現(xiàn)在往MQ中發(fā)送消息,觀察單位時(shí)間間隔內(nèi)的消費(fèi)情況。
2020-06-06 10:15:07.145 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4880040, offsetMsgId=C0A8BE8300002A9F00000000000BCB7B, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=9], queueOffset=75]
2020-06-06 10:15:07.147 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F48A0041, offsetMsgId=C0A8BE8300002A9F00000000000BCC44, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=10], queueOffset=75]
2020-06-06 10:15:07.149 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F48B0042, offsetMsgId=C0A8BE8300002A9F00000000000BCD0D, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=11], queueOffset=77]
2020-06-06 10:15:07.150 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F48D0043, offsetMsgId=C0A8BE8300002A9F00000000000BCDD6, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=12], queueOffset=75]
2020-06-06 10:15:07.153 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F48E0044, offsetMsgId=C0A8BE8300002A9F00000000000BCE9F, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=13], queueOffset=76]
2020-06-06 10:15:07.154 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4910045, offsetMsgId=C0A8BE8300002A9F00000000000BCF68, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=14], queueOffset=77]
2020-06-06 10:15:07.157 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4930046, offsetMsgId=C0A8BE8300002A9F00000000000BD031, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=15], queueOffset=76]
2020-06-06 10:15:07.159 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4950047, offsetMsgId=C0A8BE8300002A9F00000000000BD0FA, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=0], queueOffset=76]
2020-06-06 10:15:07.160 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4970048, offsetMsgId=C0A8BE8300002A9F00000000000BD1C3, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=1], queueOffset=77]
2020-06-06 10:15:07.163 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4990049, offsetMsgId=C0A8BE8300002A9F00000000000BD28C, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=2], queueOffset=77]
2020-06-06 10:15:07.165 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F49B004A, offsetMsgId=C0A8BE8300002A9F00000000000BD358, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=3], queueOffset=76]
2020-06-06 10:15:07.167 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F49D004B, offsetMsgId=C0A8BE8300002A9F00000000000BD424, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=4], queueOffset=77]
2020-06-06 10:15:07.170 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4A0004C, offsetMsgId=C0A8BE8300002A9F00000000000BD4F0, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=5], queueOffset=77]
2020-06-06 10:15:07.174 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4A3004D, offsetMsgId=C0A8BE8300002A9F00000000000BD5BC, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=6], queueOffset=76]
2020-06-06 10:15:07.176 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4A6004E, offsetMsgId=C0A8BE8300002A9F00000000000BD688, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=7], queueOffset=75]
2020-06-06 10:15:07.178 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4A8004F, offsetMsgId=C0A8BE8300002A9F00000000000BD754, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=8], queueOffset=76]
2020-06-06 10:15:07.180 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4AB0050, offsetMsgId=C0A8BE8300002A9F00000000000BD820, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=9], queueOffset=76]
2020-06-06 10:15:07.182 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4AC0051, offsetMsgId=C0A8BE8300002A9F00000000000BD8EC, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=10], queueOffset=76]
2020-06-06 10:15:07.184 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4AF0052, offsetMsgId=C0A8BE8300002A9F00000000000BD9B8, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=11], queueOffset=78]
2020-06-06 10:15:07.187 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4B10053, offsetMsgId=C0A8BE8300002A9F00000000000BDA84, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=12], queueOffset=76]
2020-06-06 10:15:07.188 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4B30054, offsetMsgId=C0A8BE8300002A9F00000000000BDB50, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=13], queueOffset=77]
2020-06-06 10:15:07.189 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4B40055, offsetMsgId=C0A8BE8300002A9F00000000000BDC1C, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=14], queueOffset=78]
2020-06-06 10:15:07.191 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4B60056, offsetMsgId=C0A8BE8300002A9F00000000000BDCE8, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=15], queueOffset=77]
2020-06-06 10:15:07.192 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4B70057, offsetMsgId=C0A8BE8300002A9F00000000000BDDB4, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=0], queueOffset=77]
2020-06-06 10:15:07.194 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4B90058, offsetMsgId=C0A8BE8300002A9F00000000000BDE80, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=1], queueOffset=78]
2020-06-06 10:15:07.195 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4BA0059, offsetMsgId=C0A8BE8300002A9F00000000000BDF4C, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=2], queueOffset=78]
2020-06-06 10:15:07.196 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4BB005A, offsetMsgId=C0A8BE8300002A9F00000000000BE018, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=3], queueOffset=77]
2020-06-06 10:15:07.197 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4BC005B, offsetMsgId=C0A8BE8300002A9F00000000000BE0E4, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=4], queueOffset=78]
2020-06-06 10:15:07.198 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4BD005C, offsetMsgId=C0A8BE8300002A9F00000000000BE1B0, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=5], queueOffset=78]
2020-06-06 10:15:07.199 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4BE005D, offsetMsgId=C0A8BE8300002A9F00000000000BE27C, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=6], queueOffset=77]
2020-06-06 10:15:07.200 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4BF005E, offsetMsgId=C0A8BE8300002A9F00000000000BE348, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=7], queueOffset=76]
2020-06-06 10:15:07.201 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4C0005F, offsetMsgId=C0A8BE8300002A9F00000000000BE414, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=8], queueOffset=77]
2020-06-06 10:15:07.202 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4C10060, offsetMsgId=C0A8BE8300002A9F00000000000BE4E0, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=9], queueOffset=77]
2020-06-06 10:15:07.202 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4C20061, offsetMsgId=C0A8BE8300002A9F00000000000BE5AC, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=10], queueOffset=77]
2020-06-06 10:15:07.203 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4C20062, offsetMsgId=C0A8BE8300002A9F00000000000BE678, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=11], queueOffset=79]
2020-06-06 10:15:07.204 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4C30063, offsetMsgId=C0A8BE8300002A9F00000000000BE744, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=12], queueOffset=77]
2020-06-06 10:15:07.205 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4C40064, offsetMsgId=C0A8BE8300002A9F00000000000BE810, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=13], queueOffset=78]
2020-06-06 10:15:07.206 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4C50065, offsetMsgId=C0A8BE8300002A9F00000000000BE8DC, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=14], queueOffset=79]
2020-06-06 10:15:07.207 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4C60066, offsetMsgId=C0A8BE8300002A9F00000000000BE9A8, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=15], queueOffset=78]
2020-06-06 10:15:07.209 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4C70067, offsetMsgId=C0A8BE8300002A9F00000000000BEA74, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=0], queueOffset=78]
2020-06-06 10:15:07.210 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4C90068, offsetMsgId=C0A8BE8300002A9F00000000000BEB40, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=1], queueOffset=79]
2020-06-06 10:15:07.211 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4CA0069, offsetMsgId=C0A8BE8300002A9F00000000000BEC0C, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=2], queueOffset=79]
2020-06-06 10:15:07.212 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4CB006A, offsetMsgId=C0A8BE8300002A9F00000000000BECD8, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=3], queueOffset=78]
2020-06-06 10:15:07.212 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4CC006B, offsetMsgId=C0A8BE8300002A9F00000000000BEDA4, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=4], queueOffset=79]
2020-06-06 10:15:07.213 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4CC006C, offsetMsgId=C0A8BE8300002A9F00000000000BEE70, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=5], queueOffset=79]
2020-06-06 10:15:07.215 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4CD006D, offsetMsgId=C0A8BE8300002A9F00000000000BEF3C, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=6], queueOffset=78]
2020-06-06 10:15:07.215 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4CF006E, offsetMsgId=C0A8BE8300002A9F00000000000BF008, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=7], queueOffset=77]
2020-06-06 10:15:07.215 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4CF006F, offsetMsgId=C0A8BE8300002A9F00000000000BF0D4, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=8], queueOffset=78]
2020-06-06 10:15:07.216 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4CF0070, offsetMsgId=C0A8BE8300002A9F00000000000BF1A0, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=9], queueOffset=78]
2020-06-06 10:15:07.216 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4D00071, offsetMsgId=C0A8BE8300002A9F00000000000BF26C, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=10], queueOffset=78]
2020-06-06 10:15:07.218 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4D00072, offsetMsgId=C0A8BE8300002A9F00000000000BF338, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=11], queueOffset=80]
2020-06-06 10:15:07.219 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4D20073, offsetMsgId=C0A8BE8300002A9F00000000000BF404, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=12], queueOffset=78]
2020-06-06 10:15:07.219 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4D30074, offsetMsgId=C0A8BE8300002A9F00000000000BF4D0, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=13], queueOffset=79]
2020-06-06 10:15:07.219 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4D30075, offsetMsgId=C0A8BE8300002A9F00000000000BF59C, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=14], queueOffset=80]
2020-06-06 10:15:07.221 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4D30076, offsetMsgId=C0A8BE8300002A9F00000000000BF668, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=15], queueOffset=79]
2020-06-06 10:15:07.221 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4D50077, offsetMsgId=C0A8BE8300002A9F00000000000BF734, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=0], queueOffset=79]
2020-06-06 10:15:07.222 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4D50078, offsetMsgId=C0A8BE8300002A9F00000000000BF800, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=1], queueOffset=80]
2020-06-06 10:15:07.222 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4D60079, offsetMsgId=C0A8BE8300002A9F00000000000BF8CC, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=2], queueOffset=80]
2020-06-06 10:15:07.223 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4D6007A, offsetMsgId=C0A8BE8300002A9F00000000000BF998, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=3], queueOffset=79]
2020-06-06 10:15:07.224 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4D7007B, offsetMsgId=C0A8BE8300002A9F00000000000BFA64, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=4], queueOffset=80]
2020-06-06 10:15:07.226 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4D8007C, offsetMsgId=C0A8BE8300002A9F00000000000BFB30, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=5], queueOffset=80]
2020-06-06 10:15:07.229 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4DA007D, offsetMsgId=C0A8BE8300002A9F00000000000BFBFC, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=6], queueOffset=79]
2020-06-06 10:15:07.230 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4DD007E, offsetMsgId=C0A8BE8300002A9F00000000000BFCC8, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=7], queueOffset=78]
2020-06-06 10:15:07.231 INFO 15268 --- [nio-9001-exec-3] com.yj.mq.controller.MQController : SendResult:SendResult [sendStatus=SEND_OK, msgId=C0A8006B3BA4764C12B61BF2F4DE007F, offsetMsgId=C0A8BE8300002A9F00000000000BFD94, messageQueue=MessageQueue [topic=BATCH_CSDN, brokerName=localhost.localdomain, queueId=8], queueOffset=79]
2020-06-06 10:15:09.518 INFO 15268 --- [MessageThread_5] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:1_tag,body:{"desc":"1","orderId":1}
2020-06-06 10:15:09.518 INFO 15268 --- [MessageThread_3] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:2_tag,body:{"desc":"2","orderId":2}
2020-06-06 10:15:09.518 INFO 15268 --- [MessageThread_4] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:3_tag,body:{"desc":"3","orderId":3}
2020-06-06 10:15:09.519 INFO 15268 --- [MessageThread_8] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:4_tag,body:{"desc":"4","orderId":4}
2020-06-06 10:15:09.519 INFO 15268 --- [MessageThread_9] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:5_tag,body:{"desc":"5","orderId":5}
2020-06-06 10:15:09.538 INFO 15268 --- [essageThread_10] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:6_tag,body:{"desc":"6","orderId":6}
2020-06-06 10:15:09.538 INFO 15268 --- [essageThread_11] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:7_tag,body:{"desc":"7","orderId":7}
2020-06-06 10:15:09.573 INFO 15268 --- [essageThread_12] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:11_tag,body:{"desc":"11","orderId":11}
2020-06-06 10:15:09.573 INFO 15268 --- [MessageThread_2] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:13_tag,body:{"desc":"13","orderId":13}
2020-06-06 10:15:09.573 INFO 15268 --- [essageThread_13] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:9_tag,body:{"desc":"9","orderId":9}
2020-06-06 10:15:09.573 INFO 15268 --- [essageThread_14] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:12_tag,body:{"desc":"12","orderId":12}
2020-06-06 10:15:09.573 INFO 15268 --- [essageThread_15] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:8_tag,body:{"desc":"8","orderId":8}
2020-06-06 10:15:09.573 INFO 15268 --- [essageThread_16] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:10_tag,body:{"desc":"10","orderId":10}
2020-06-06 10:15:09.573 INFO 15268 --- [essageThread_18] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:14_tag,body:{"desc":"14","orderId":14}
2020-06-06 10:15:09.573 INFO 15268 --- [essageThread_19] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:16_tag,body:{"desc":"16","orderId":16}
2020-06-06 10:15:09.573 INFO 15268 --- [essageThread_17] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:15_tag,body:{"desc":"15","orderId":15}
2020-06-06 10:15:19.520 INFO 15268 --- [MessageThread_1] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:18_tag,body:{"desc":"18","orderId":18}
2020-06-06 10:15:19.520 INFO 15268 --- [essageThread_20] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:19_tag,body:{"desc":"19","orderId":19}
2020-06-06 10:15:19.520 INFO 15268 --- [MessageThread_6] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:17_tag,body:{"desc":"17","orderId":17}
2020-06-06 10:15:19.522 INFO 15268 --- [MessageThread_7] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:20_tag,body:{"desc":"20","orderId":20}
2020-06-06 10:15:19.522 INFO 15268 --- [MessageThread_5] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:21_tag,body:{"desc":"21","orderId":21}
2020-06-06 10:15:19.541 INFO 15268 --- [MessageThread_3] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:22_tag,body:{"desc":"22","orderId":22}
2020-06-06 10:15:19.541 INFO 15268 --- [MessageThread_4] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:23_tag,body:{"desc":"23","orderId":23}
2020-06-06 10:15:19.578 INFO 15268 --- [MessageThread_8] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:25_tag,body:{"desc":"25","orderId":25}
2020-06-06 10:15:19.578 INFO 15268 --- [essageThread_11] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:24_tag,body:{"desc":"24","orderId":24}
2020-06-06 10:15:19.578 INFO 15268 --- [essageThread_12] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:26_tag,body:{"desc":"26","orderId":26}
2020-06-06 10:15:19.578 INFO 15268 --- [MessageThread_8] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:30_tag,body:{"desc":"30","orderId":30}
2020-06-06 10:15:19.578 INFO 15268 --- [essageThread_12] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:32_tag,body:{"desc":"32","orderId":32}
2020-06-06 10:15:19.578 INFO 15268 --- [MessageThread_9] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:28_tag,body:{"desc":"28","orderId":28}
2020-06-06 10:15:19.579 INFO 15268 --- [essageThread_12] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:31_tag,body:{"desc":"31","orderId":31}
2020-06-06 10:15:19.578 INFO 15268 --- [essageThread_10] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:27_tag,body:{"desc":"27","orderId":27}
2020-06-06 10:15:19.578 INFO 15268 --- [essageThread_11] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:29_tag,body:{"desc":"29","orderId":29}
2020-06-06 10:15:29.526 INFO 15268 --- [essageThread_16] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:33_tag,body:{"desc":"33","orderId":33}
2020-06-06 10:15:29.526 INFO 15268 --- [essageThread_18] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:35_tag,body:{"desc":"35","orderId":35}
2020-06-06 10:15:29.527 INFO 15268 --- [essageThread_19] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:34_tag,body:{"desc":"34","orderId":34}
2020-06-06 10:15:29.527 INFO 15268 --- [essageThread_19] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:36_tag,body:{"desc":"36","orderId":36}
2020-06-06 10:15:29.527 INFO 15268 --- [MessageThread_1] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:37_tag,body:{"desc":"37","orderId":37}
2020-06-06 10:15:29.545 INFO 15268 --- [essageThread_20] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:38_tag,body:{"desc":"38","orderId":38}
2020-06-06 10:15:29.545 INFO 15268 --- [MessageThread_6] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:39_tag,body:{"desc":"39","orderId":39}
2020-06-06 10:15:29.585 INFO 15268 --- [MessageThread_7] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:41_tag,body:{"desc":"41","orderId":41}
2020-06-06 10:15:29.585 INFO 15268 --- [MessageThread_8] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:45_tag,body:{"desc":"45","orderId":45}
2020-06-06 10:15:29.585 INFO 15268 --- [MessageThread_5] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:43_tag,body:{"desc":"43","orderId":43}
2020-06-06 10:15:29.585 INFO 15268 --- [MessageThread_3] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:44_tag,body:{"desc":"44","orderId":44}
2020-06-06 10:15:29.585 INFO 15268 --- [MessageThread_4] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:40_tag,body:{"desc":"40","orderId":40}
2020-06-06 10:15:29.585 INFO 15268 --- [MessageThread_2] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:46_tag,body:{"desc":"46","orderId":46}
2020-06-06 10:15:29.585 INFO 15268 --- [essageThread_13] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:42_tag,body:{"desc":"42","orderId":42}
2020-06-06 10:15:29.585 INFO 15268 --- [essageThread_14] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:48_tag,body:{"desc":"48","orderId":48}
2020-06-06 10:15:29.585 INFO 15268 --- [essageThread_15] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:47_tag,body:{"desc":"47","orderId":47}
2020-06-06 10:15:39.528 INFO 15268 --- [MessageThread_9] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:49_tag,body:{"desc":"49","orderId":49}
2020-06-06 10:15:39.528 INFO 15268 --- [essageThread_10] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:51_tag,body:{"desc":"51","orderId":51}
2020-06-06 10:15:39.528 INFO 15268 --- [essageThread_12] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:50_tag,body:{"desc":"50","orderId":50}
2020-06-06 10:15:39.529 INFO 15268 --- [essageThread_11] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:52_tag,body:{"desc":"52","orderId":52}
2020-06-06 10:15:39.530 INFO 15268 --- [essageThread_16] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:53_tag,body:{"desc":"53","orderId":53}
2020-06-06 10:15:39.546 INFO 15268 --- [essageThread_18] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:54_tag,body:{"desc":"54","orderId":54}
2020-06-06 10:15:39.546 INFO 15268 --- [essageThread_17] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:55_tag,body:{"desc":"55","orderId":55}
2020-06-06 10:15:39.588 INFO 15268 --- [essageThread_19] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:57_tag,body:{"desc":"57","orderId":57}
2020-06-06 10:15:39.588 INFO 15268 --- [MessageThread_1] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:59_tag,body:{"desc":"59","orderId":59}
2020-06-06 10:15:39.588 INFO 15268 --- [essageThread_20] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:56_tag,body:{"desc":"56","orderId":56}
2020-06-06 10:15:39.588 INFO 15268 --- [essageThread_19] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:62_tag,body:{"desc":"62","orderId":62}
2020-06-06 10:15:39.588 INFO 15268 --- [MessageThread_1] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:64_tag,body:{"desc":"64","orderId":64}
2020-06-06 10:15:39.588 INFO 15268 --- [MessageThread_6] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:58_tag,body:{"desc":"58","orderId":58}
2020-06-06 10:15:39.588 INFO 15268 --- [essageThread_20] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:60_tag,body:{"desc":"60","orderId":60}
2020-06-06 10:15:39.588 INFO 15268 --- [MessageThread_5] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:63_tag,body:{"desc":"63","orderId":63}
2020-06-06 10:15:39.588 INFO 15268 --- [MessageThread_7] com.yj.mq.consumer.MessageProcessor : port:9001,消費(fèi)Tag:61_tag,body:{"desc":"61","orderId":61}
我們一共發(fā)送了64條消息,發(fā)現(xiàn)每間隔10秒,每次消費(fèi)16條數(shù)據(jù)。
到此這篇關(guān)于RocketMq消息隊(duì)列之削峰詳解的文章就介紹到這了,更多相關(guān)RocketMq削峰內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
學(xué)習(xí)Java之Java中的異常處理機(jī)制詳解
在本文中,小編將帶領(lǐng)大家來學(xué)習(xí)Java的異常處理機(jī)制,包括異常機(jī)制、異常類型、如何捕獲異常、如何拋出異常以及如何創(chuàng)建自定義異常等核心內(nèi)容,感興趣的同學(xué)跟著小編一起來看看吧2023-08-08Maven實(shí)現(xiàn)自己的starter依賴
本文主要介紹了Maven實(shí)現(xiàn)自己的starter依賴,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2023-04-04Java設(shè)計(jì)模式之23種設(shè)計(jì)模式詳解
這篇文章主要介紹了Java設(shè)計(jì)模式之23種設(shè)計(jì)模式詳解,設(shè)計(jì)模式使代碼編制真正工程化,設(shè)計(jì)模式是軟件工程的基石,項(xiàng)目中合理的運(yùn)用設(shè)計(jì)模式可以完美的解決很多問題,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-07-07關(guān)于@JsonProperty,@NotNull,@JsonIgnore的具體使用
這篇文章主要介紹了關(guān)于@JsonProperty,@NotNull,@JsonIgnore的具體使用,具有很好的參考價(jià)值,希望對大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2022-08-08Java用itextpdf導(dǎo)出PDF方法(通俗易懂)
因?yàn)轫?xiàng)目需要導(dǎo)出PDF文件,所以去找了一下能夠生成PDF的java工具,這篇文章主要給大家介紹了關(guān)于Java用itextpdf導(dǎo)出PDF的相關(guān)資料,文中介紹的方法通俗易懂,需要的朋友可以參考下2023-07-07基于Springboot實(shí)現(xiàn)送水公司信息管理系統(tǒng)
這篇文章主要介紹了基于Springboot實(shí)現(xiàn)送水公司信息管理,本文通過實(shí)例代碼給大家介紹的非常詳細(xì),對大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2022-01-01