欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

RocketMq消息隊列之削峰詳解

 更新時間：2023年09月15日 10:01:56   作者：獵戶星座。  
這篇文章主要介紹了RocketMq消息隊列之削峰詳解,MQ的主要特點為解耦、異步、削峰,本篇博客只是簡單的記錄RocketMQ削峰用法,用于減少數(shù)據(jù)庫壓力的業(yè)務場景,需要的朋友可以參考下

RocketMq削峰

MQ的主要特點為解耦、異步、削峰，本篇博客只是簡單的記錄RocketMQ削峰用法，用于減少數(shù)據(jù)庫壓力的業(yè)務場景。

生產者，消費者的配置可以參考以前的文章，這里只列出消費者新增的兩個配置：

    @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);集群模式(默認)
        //consumer.setMessageModel(MessageModel.BROADCASTING);//廣播模式
        // 每次拉取的間隔，單位為毫秒
        consumer.setPullInterval(10000);
        // 設置每次從隊列中拉取的消息數(shù)為16
        consumer.setPullBatchSize(1);
        try {
            consumer.subscribe(batchTopic, "*");
        } catch (MQClientException e) {
            e.printStackTrace();
        }
        return consumer;
    }

pullInterval：每次從Broker拉取消息的間隔，單位為毫秒

pullBatchSize：每次從Broker隊列拉取到的消息數(shù)，該參數(shù)很容易讓人誤解，一開始我以為是每次拉取的消息總數(shù)，但測試過幾次后確認了實質上是從每個隊列的拉取數(shù)，即Consume每次拉取的消息總數(shù)如下：

EachPullTotal=所有Broker上的讀/寫隊列數(shù)(broker數(shù)量*writeQueueNums或者readQueueNums) * pullBatchSize，這里我們簡單演示所以只有一個Broker,Broker上的writeQueueNums=readQueueNums=16，pullBatchSize=1,所以每10秒拉取的數(shù)量為1*1*16=16條。

好了，我們現(xiàn)在往MQ中發(fā)送消息，觀察單位時間間隔內的消費情況。

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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費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,消費Tag:61_tag,body:{"desc":"61","orderId":61}

我們一共發(fā)送了64條消息，發(fā)現(xiàn)每間隔10秒，每次消費16條數(shù)據(jù)。

到此這篇關于RocketMq消息隊列之削峰詳解的文章就介紹到這了,更多相關RocketMq削峰內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

相關文章

  • Java?輕松入門使用Fiddler抓包工具教程

    Java?輕松入門使用Fiddler抓包工具教程

    超文本傳輸協(xié)議（HTTP）是一個簡單的請求-響應協(xié)議,其主要是基于TCP來實現(xiàn)的，可以通過Chrome開發(fā)者工具或者Wireshark或者Fiddler抓包，以便分析?HTTP?請求/響應的細節(jié)，本篇博客主要談論如何使用Fiddler抓取HTTP，當然也可以抓取HTTPS
    2022-02-02
  • 學習Java之Java中的異常處理機制詳解

    學習Java之Java中的異常處理機制詳解

    在本文中,小編將帶領大家來學習Java的異常處理機制,包括異常機制、異常類型、如何捕獲異常、如何拋出異常以及如何創(chuàng)建自定義異常等核心內容,感興趣的同學跟著小編一起來看看吧
    2023-08-08
  • Maven實現(xiàn)自己的starter依賴

    Maven實現(xiàn)自己的starter依賴

    本文主要介紹了Maven實現(xiàn)自己的starter依賴，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧
    2023-04-04
  • Java設計模式之23種設計模式詳解

    Java設計模式之23種設計模式詳解

    這篇文章主要介紹了Java設計模式之23種設計模式詳解，設計模式使代碼編制真正工程化，設計模式是軟件工程的基石，項目中合理的運用設計模式可以完美的解決很多問題，需要的朋友們下面隨著小編來一起學習學習吧
    2020-07-07
  • Mybatis中攔截器的簡單實現(xiàn)方法

    Mybatis中攔截器的簡單實現(xiàn)方法

    這篇文章主要給大家介紹了關于Mybatis中攔截器的簡單實現(xiàn)方法，文中通過示例代碼介紹的非常詳細，對大家學習或者使用Mybatis具有一定的參考學習價值，需要的朋友們下面來一起學習學習吧
    2019-08-08
  • 關于@JsonProperty,@NotNull,@JsonIgnore的具體使用

    關于@JsonProperty,@NotNull,@JsonIgnore的具體使用

    這篇文章主要介紹了關于@JsonProperty,@NotNull,@JsonIgnore的具體使用，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教
    2022-08-08
  • Java用itextpdf導出PDF方法(通俗易懂)

    Java用itextpdf導出PDF方法(通俗易懂)

    因為項目需要導出PDF文件,所以去找了一下能夠生成PDF的java工具,這篇文章主要給大家介紹了關于Java用itextpdf導出PDF的相關資料,文中介紹的方法通俗易懂,需要的朋友可以參考下
    2023-07-07
  • Java中的==使用方法詳解

    Java中的==使用方法詳解

    這篇文章主要給大家介紹了關于Java中的==使用方法的相關資料，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧
    2021-09-09
  • java項目中的絕對路徑和相對路徑用法說明

    java項目中的絕對路徑和相對路徑用法說明

    這篇文章主要介紹了java項目中的絕對路徑和相對路徑用法說明，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧
    2020-08-08
  • 基于Springboot實現(xiàn)送水公司信息管理系統(tǒng)

    基于Springboot實現(xiàn)送水公司信息管理系統(tǒng)

    這篇文章主要介紹了基于Springboot實現(xiàn)送水公司信息管理,本文通過實例代碼給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下
    2022-01-01

最新評論