RocketMQ怎么保证消息不丢失？A.从Producer的视角来看：如果消息未能正确的存储在MQ中，或者消费者未能正确的消费到这条消息，都是消息丢失。B.从Broker的视角来看：如果消息已经存在Broker里面了，如何保证不会丢失呢（宕机、磁盘崩溃）。C.从Consumer的视角来看：如果消息已经完成持久化了，但是Consumer取了，但是未消费成功且没有反馈，就是消息丢失。D.从Producer分析：如何确保消息正确的发送到了Broker?默认情况下，可以通过同步的方式阻塞式的发送，checkSendStatus，状态是OK，表示消息一定成功的投递到了Broker，状态超时或者失败，则会

RocketMQ怎么保证消息不丢失？A.从Producer的视角来看：如果消息未能正确的存储在MQ中，或者消费者未能正确的消费到这条消息，都是消息丢失。B.从Broker的视角来看：如果消息已经存在Broker里面了，如何保证不会丢失呢（宕机、磁盘崩溃）。C.从Consumer的视角来看：如果消息已经完成持久化了，但是Consumer取了，但是未消费成功且没有反馈，就是消息丢失。D.从Producer分析：如何确保消息正确的发送到了Broker?默认情况下，可以通过同步的方式阻塞式的发送，checkSendStatus，状态是OK，表示消息一定成功的投递到了Broker，状态超时或者失败，则会

镜像下载、域名解析、时间同步请点击阿里云开源镜像站部署rocketmq和可视化客户端一、服务器资源服务名称：Linux服务器IP：[请查看资源分配文档]操作系统：CentOS7.8x64二、rocketmq安装2.1下载下载地址：rocketmq.apache.org/dowloading/…这里，咋们下载4.8.0版本2.2、将压缩包放到tools目录下并解压把rocketmq-all-4.8.0-bin-release.zip上传到/opt/tools目录下并解压并重命名# cd/opt/tools#unzip-d/opt/apps/rocketmq-all-4.8.0-bin-relea

镜像下载、域名解析、时间同步请点击阿里云开源镜像站部署rocketmq和可视化客户端一、服务器资源服务名称：Linux服务器IP：[请查看资源分配文档]操作系统：CentOS7.8x64二、rocketmq安装2.1下载下载地址：rocketmq.apache.org/dowloading/…这里，咋们下载4.8.0版本2.2、将压缩包放到tools目录下并解压把rocketmq-all-4.8.0-bin-release.zip上传到/opt/tools目录下并解压并重命名# cd/opt/tools#unzip-d/opt/apps/rocketmq-all-4.8.0-bin-relea

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

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

vivo互联网服务器团队-LiKui一、简介1.1RocketMQ简介RocketMQ是由阿里巴巴开源的分布式消息中间件，支持顺序消息、定时消息、自定义过滤器、负载均衡、pull/push消息等功能。RocketMQ主要由Producer、Broker、Consumer、NameServer四部分组成，其中Producer负责生产消息，Consumer负责消费消息，Broker负责存储消息。NameServer充当名字路由服务，整体架构图如下所示：Producer：负责生产消息，一般由业务系统生产消息，可通过集群方式部署。RocketMQ提供多种发送方式，同步发送、异步发送、顺序发送、单向发送

vivo互联网服务器团队-LiKui一、简介1.1RocketMQ简介RocketMQ是由阿里巴巴开源的分布式消息中间件，支持顺序消息、定时消息、自定义过滤器、负载均衡、pull/push消息等功能。RocketMQ主要由Producer、Broker、Consumer、NameServer四部分组成，其中Producer负责生产消息，Consumer负责消费消息，Broker负责存储消息。NameServer充当名字路由服务，整体架构图如下所示：Producer：负责生产消息，一般由业务系统生产消息，可通过集群方式部署。RocketMQ提供多种发送方式，同步发送、异步发送、顺序发送、单向发送

作者：老Z，云原生爱好者，目前专注于云原生运维，KubeSphereAmbassador。SpringCloudAlibaba全家桶之RocketMQ是一款典型的分布式架构下的消息中间件产品，使用异步通信方式和发布订阅的消息传输模型。很多基于SpringCloud开发的项目都喜欢采用RocketMQ作为消息中间件。RocketMQ常用的部署模式如下：单Master模式多Master无Slave模式多Master多Slave模式-异步复制多Master多Slave模式-同步双写更多的部署方案详细信息可以参考官方文档。本文重点介绍单Master模式和多Master多Slave-异步复制模式在K8s

作者：老Z，云原生爱好者，目前专注于云原生运维，KubeSphereAmbassador。SpringCloudAlibaba全家桶之RocketMQ是一款典型的分布式架构下的消息中间件产品，使用异步通信方式和发布订阅的消息传输模型。很多基于SpringCloud开发的项目都喜欢采用RocketMQ作为消息中间件。RocketMQ常用的部署模式如下：单Master模式多Master无Slave模式多Master多Slave模式-异步复制多Master多Slave模式-同步双写更多的部署方案详细信息可以参考官方文档。本文重点介绍单Master模式和多Master多Slave-异步复制模式在K8s