首页
博客
源码
资源
博客
源码
写文章
发布博客
发布资源
登录
X
rocketmq
相关资讯
热门
最新
后端
01-01 08:00
后端
RocketMQ基于Dledger模式,平滑升级
RocketMQ基于Dledger模式,平滑升级,前置条件该方案并非所有case通用,其它部署模型仅供参考。集群模式:多主多从(比如,2主4从)支持主从切换:Dledger,不支持也可参考,满足上一条要求发送端与消费端在进行broker升级的过程中(broker重启),要求客户端不允许出现errror报错,绝对平滑,业务不受影响,客户端基本无感知场景MQ集群节点需要进行轮替式升级,或者修改brok
94
后端
01-01 08:00
后端
RocketMQ Producer重试机制,何时重试,何时不重试?
RocketMQ Producer重试机制,何时重试,何时不重试?,版本4.7.1,以下说明参照该版本实现功能特性官网说明Producer的send方法本身支持内部重试,重试逻辑如下:至多重试2次。如果同步模式发送失败,则轮转到下一个Broker,如果异步模式发送失败,则只会在当前Broker进行重试。这个方法的总耗时时间不超过sendMsgTimeout设置的值,默认10s。如果本身向broke
133
后端
01-01 08:00
后端
RocketMQ客户端修改默认日志配置【java版】
RocketMQ客户端修改默认日志配置【java版】,RocketMQ客户端日志默认配置内部日志初始化代码static{//是否使用项目配置的slf4j记录日志,默认不使用CLIENT_USE_SLF4J=Boolean.parseBoolean(System.getProperty(CLIENT_LOG_USESLF4J,"false"));if(!CLIENT_USE_SLF4J){Inter
119
后端
01-01 08:00
后端
RocketMQ消息轨迹,你了解多少
RocketMQ消息轨迹,你了解多少,开启消息轨迹broker端traceTopicEnable属性设置为true,默认值为false。设置为true,broker启动的时候会初始化存储轨迹数据的默认topic:RMQ_SYS_TRACE_TOPIC;traceOn属性设置为true,默认值也是true。该属性如果设置false,客户端不会发送轨迹数据到broker端producer构造produ
147
后端
01-01 08:00
后端
RocketMQ事务消息篇(三)之事务消息源码分析
RocketMQ事务消息篇(三)之事务消息源码分析,事务消息处理基本流程在介绍事务消息的时候,画了一个简单的流程图说明事务消息的整体处理流程:p.s.下面的序号(1、2、3...)表示顺序,与上图中的(1、2、3...)无关。事务生产者调用事务消息发送接口,发送消息开始预提交阶段,客户端发送预消息并在请求头标记这是一条事务消息。消息体就是我们实际要发送的消息内容broker接收到消息,发现这是一条
148
后端
01-01 08:00
后端
RocketMQ源码学习(一)-NameServer启动
RocketMQ源码学习(一)-NameServer启动,关于NameServer前面已经介绍了很多。本章不做过多的叙述。直接围绕源码开展学习。启动类-NamesrvStartup位置:org.apache.rocketmq.namesrv.NamesrvStartup关键部分代码://创建核心处理器NamesrvController,类似web,用于接收各种挽网络请求NamesrvControl
100
后端
01-01 08:00
后端
RocketMQ源码学习(二)-Broker启动
RocketMQ源码学习(二)-Broker启动,启动方法org.apache.rocketmq.broker.BrokerStartup#mainpublicstaticvoidmain(String[]args){start(createBrokerController(args));}复制代码核心组件BrokerController创建org.apache.rocketmq.broker.B
114
后端
01-01 08:00
后端
RocketMQ源码学习(三)-消息存储
RocketMQ源码学习(三)-消息存储,前面介绍了Producer把消息发到了Broker,接下来研究一下Broker是如何进行消息存储的,最终存储文件的有哪些?commitLog:消息存储目录;config:运行期间的配置信息;consumerqueue:消息消费队列存储目录;index:消息索引文件存储目录;abort:如果该文件存在,则表明Broker非正产关闭;checkpoint:文件
107
后端
01-01 08:00
后端
RocketMQ之事务消息
RocketMQ之事务消息,一理论RocketMQ的事务消息,是指发送消息事件和其他事件需要同时成功或同时失败。一个常见的场景:订单付款后给用户发优惠券,订单系统需要作为生产者发消息,优惠券系统作为消费者收消息。在这个场景下,发送“用户已付款”消息,要和“用户付款”这个操作同时成功或者同时失败。RocketMQ采用两阶段提交的方式实现事务消息。TransactionMQProducer处理上面情况
122
后端
01-01 08:00
后端
RocketMQ以及console安装过程遇到的坑
RocketMQ以及console安装过程遇到的坑,前两天我在本地(windows环境)安装了一个RocketMQ以及对应的Console可视化图形界面,遇到了一丢丢问题下面让我给你们总结一下。刚开始我是想在买的腾讯云上安装的,没想到老马的机器太垃圾了,内存不够,根本支持不起。后来同事说可以通过参数减小mq的运行内存来安装,确实可行rocketMq能起来了,但是broker还是起不来,无奈之下只能
528
«
1
2
3
4
5
»