首页
博客
源码
资源
博客
源码
写文章
发布博客
发布资源
登录
X
rocketmq
相关资讯
热门
最新
后端
01-01 08:00
后端
RocketMQ之事务消息
RocketMQ之事务消息,一理论RocketMQ的事务消息,是指发送消息事件和其他事件需要同时成功或同时失败。一个常见的场景:订单付款后给用户发优惠券,订单系统需要作为生产者发消息,优惠券系统作为消费者收消息。在这个场景下,发送“用户已付款”消息,要和“用户付款”这个操作同时成功或者同时失败。RocketMQ采用两阶段提交的方式实现事务消息。TransactionMQProducer处理上面情况
121
后端
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安装-单机版-windows+centos
RocketMQ安装-单机版-windows+centos windows版本 解压压缩包rocketmq-all-4.7.1-bin-release.zip并复制到本地软件安装目录 环境变量添加 NAMESRV_ADDR=localhost:9876 ROCKETMQ_HOME=D:\soft\rocketmq 修改bin目录下的runbroker.cmd和runserver.cmd中的虚拟机内存
117
后端
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源码部署)本文主要分析RocketMQ中如何保证消息有序的。RocketMQ的版本为:4.2.0 release。一.时序图还是老规矩,先把分析过程的时序图摆出来:1.Producer发送顺序消息 2.Consumer接收顺序消息(一) 3.Consumer接收顺序消息(二) 二.源码分析 – Producer发送顺序消息1 DefaultMQProducer#send:发送消息,入参中有
105
后端
01-01 08:00
后端
RocketMQ笔记:应用实践
原创文章,转载请注明原文章地址,谢谢! 普通消息 消息发送分类 Producer对于消息的发送方式也有多种选择,不同的方式会产生不同的系统效果。 同步发送消息 同步发送消息是指,Producer发出...
104
后端
01-01 08:00
后端
RocketMQ事务消息的实现流程分析(发送消息零丢失方案)
先分析在那些情况下可能造成消息的丢失 在日常使用MQ过程,我们来看下图,会发现很多环节会造成数据的丢失。 针对丢失的情况,如何通过RocketMQ的事务消息来解决 我们还是先来看一张图,根据这图,我...
104
后端
01-01 08:00
后端
RocketMQ
1 RocketMQ基本理论 1.1 发展历史 阿里巴巴消息中间件起源于2001年的五彩石项目,Notify在这期间应运而生,用于交易核心消息的流转。2010年,B2B开始大规模使用ActiveMQ...
103
后端
01-01 08:00
后端
RocketMQ源码学习(一)-NameServer启动
RocketMQ源码学习(一)-NameServer启动,关于NameServer前面已经介绍了很多。本章不做过多的叙述。直接围绕源码开展学习。启动类-NamesrvStartup位置:org.apache.rocketmq.namesrv.NamesrvStartup关键部分代码://创建核心处理器NamesrvController,类似web,用于接收各种挽网络请求NamesrvControl
100
«
1
2
3
4
5
»