Batch Message Sending

In the case of certain requirements on throughput, Apache RocketMQ can send messages after grouping them into batches. The approach is able to increase throughput and decrease the times of API and network calls.

batch

  1. public class SimpleBatchProducer {
  3.     public static void main(String[] args) throws Exception {
  4.         DefaultMQProducer producer = new DefaultMQProducer("BatchProducerGroupName");
  5.         producer.start();
  7.         //If you just send messages of no more than 1MiB at a time, it is easy to use batch
  8.         //Messages of the same batch should have: same topic, same waitStoreMsgOK and no schedule support
  9.         String topic = "BatchTest";
  10.         List<Message> messages = new ArrayList<>();
  11.         messages.add(new Message(topic, "Tag", "OrderID001", "Hello world 0".getBytes()));
  12.         messages.add(new Message(topic, "Tag", "OrderID002", "Hello world 1".getBytes()));
  13.         messages.add(new Message(topic, "Tag", "OrderID003", "Hello world 2".getBytes()));
  15.         producer.send(messages);
  16.     }
  17. }

Batch Message Sending - 图2note

The call here is simple, where it packages the message as Collection<Message> msgs and passes it into the method as a parameter. There are two things to note here. First of all, the size of the batch message cannot exceed 1 MiB, otherwise, it needs to be split. Secondly, the message topic within the same batch must be identical.