消息存储在【RocketMQ】消息的存储一文中提到，Broker收到消息后会调用CommitLog的asyncPutMessage方法写入消息，在DLedger模式下使用的是DLedgerCommitLog，进入asyncPutMessages方法，主要处理逻辑如下：调用serialize方法将消息数据序列化；构建批量消息追加请求BatchAppendEntryRequest，并设置上一步序列化的消息数据；调用handleAppend方法提交消息追加请求，进行消息写入；publicclassDLedgerCommitLogextendsCommitLog{@OverridepublicComp

消息存储在【RocketMQ】消息的存储一文中提到，Broker收到消息后会调用CommitLog的asyncPutMessage方法写入消息，在DLedger模式下使用的是DLedgerCommitLog，进入asyncPutMessages方法，主要处理逻辑如下：调用serialize方法将消息数据序列化；构建批量消息追加请求BatchAppendEntryRequest，并设置上一步序列化的消息数据；调用handleAppend方法提交消息追加请求，进行消息写入；publicclassDLedgerCommitLogextendsCommitLog{@OverridepublicComp