1. 程式人生 > >RocketMQ系列(六)批量傳送與過濾

RocketMQ系列(六)批量傳送與過濾

今天我們再來看看RocketMQ的另外兩個小功能,訊息的批量傳送和過濾。這兩個小功能提升了我們使用RocketMQ的效率。 ## 批量傳送 以前我們傳送訊息的時候,都是一個一個的傳送,這樣效率比較低下。能不能一次傳送多個訊息呢?當然是可以的,RocketMQ為我們提供了這樣的功能。但是它也有一些使用的條件: * 同一批發送的訊息的Topic必須相同; * 同一批訊息的waitStoreMsgOK 必須相同; * 批量傳送的訊息不支援延遲,就是上一節說的延遲訊息; * 同一批次的訊息,大小不能超過1MiB; 好了,只要我們滿足上面的這些限制,就可以使用批量傳送了,我們來看看傳送端的程式碼吧, ```java @Test public void producerBatch() throws Exception {