在您的代码里面,每次发送消息的单位是一个MessageEntity,可不可以将这个MessageEntity理解为一个Partition,存取数据的一个基本单元。
public class MessageEntity {
private String title;
private String body;
@Override
public String toString() {
return "MessageEntity{" +
"title='" + title + '\'' +
", body='" + body + '\'' +
'}';
}
}