在您的代码里面，每次发送消息的单位是一个MessageEntity,可不可以将这个MessageEntity理解为一个Partition,存取数据的一个基本单元。

public class MessageEntity {
    private String title;
    private String body;

    @Override
    public String toString() {
        return "MessageEntity{" +
                "title='" + title + '\'' +
                ", body='" + body + '\'' +
                '}';
    }
}