消息存储在【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
Broker对消息的处理BrokerController初始化的过程中，调用registerProcessor方法注册了处理器，在注册处理器的代码中可以看到创建了处理消息发送的处理器对象SendMessageProcessor，然后将其注册到远程服务中：publicclassBrokerController{//初始化publicbooleaninitialize()throwsCloneNotSupportedException{//...//注册处理器this.registerProcessor();//...}//注册处理器publicvoidregisterProcessor(){/*
Broker对消息的处理BrokerController初始化的过程中，调用registerProcessor方法注册了处理器，在注册处理器的代码中可以看到创建了处理消息发送的处理器对象SendMessageProcessor，然后将其注册到远程服务中：publicclassBrokerController{//初始化publicbooleaninitialize()throwsCloneNotSupportedException{//...//注册处理器this.registerProcessor();//...}//注册处理器publicvoidregisterProcessor(){/*
想要在HomeAssistant中通过智能遥控发送红外信号控制空调需有两个步骤： 一、智能遥控接入HomeAssistant； 二、HomeAssistant将红外信号数据发往智能遥控，智能遥控收到后发送对应红外信号； 下面将详细介绍这两个流程，为了减少字数以下HomeAssistant会简称为：HA；设备接入 将设备接入HA就是建立设备与HA平台的通讯能力，使之HA能够将数据发送到相应的设备；在HomeAssistant平台的如下路径：配置-》设备与服务-》添加新集成》 在搜索框中输入：Broadlink，添加博联设备， 从路由器或其他地方获取到智能遥控的IP地址；输入到C
想要在HomeAssistant中通过智能遥控发送红外信号控制空调需有两个步骤： 一、智能遥控接入HomeAssistant； 二、HomeAssistant将红外信号数据发往智能遥控，智能遥控收到后发送对应红外信号； 下面将详细介绍这两个流程，为了减少字数以下HomeAssistant会简称为：HA；设备接入 将设备接入HA就是建立设备与HA平台的通讯能力，使之HA能够将数据发送到相应的设备；在HomeAssistant平台的如下路径：配置-》设备与服务-》添加新集成》 在搜索框中输入：Broadlink，添加博联设备， 从路由器或其他地方获取到智能遥控的IP地址；输入到C
作者：vivo互联网中间件团队-LiuRunyun大量业务使用消息中间件进行系统间的解耦、异步化、削峰填谷设计实现。公司内部前期基于RabbitMQ实现了一套高可用的消息中间件平台。随着业务的持续增长，消息体量随之增大，对消息中间件平台提出了更高的要求，此外在运维过程中也遇到了高可用难以保障，功能特性不足等诸多问题。基于遇到的这些问题，决定引入RocketMQ进行替换。本文将介绍基于RocketMQ建设消息中间件平台并实现在线业务无感知的平滑迁移。一、背景说明vivo互联网中间件团队于2016年开始基于开源RabbitMQ向业务提供高可用消息中间件平台服务。为解决好业务流量快速增长的问题，我们
