如果一个broker正常退出,是会删除abort文件的。那么启动broker的时候发现abort文件还存在,那么说明上次是异常终止,会进入到commit-log的recoverAbnormally逻辑里面,因为所有其他的信息都是从commit-log获取到的,所以追根溯源只能从commit-log开 ...
分类:
其他好文 时间:
2019-12-08 22:49:36
阅读次数:
182
RocketMQ是阿里开源的分布式消息中间件,跟其它中间件相比,RocketMQ的特点是纯JAVA实现;集群和HA实现相对简单;在发生宕机和其它故障时消息丢失率更低。 一.RocketMQ专业术语 Producer(生产者) 消息生产者,位于用户的进程内,Producer通过NameServer获取 ...
分类:
其他好文 时间:
2019-12-07 23:06:19
阅读次数:
134
上一篇入门基础部分对rocketmq进行了一个基础知识的讲解说明,在正式使用前我们需要进行环境的搭建,今天就来说一说rockeketmq分布式集群环境的搭建 ...
分类:
其他好文 时间:
2019-12-07 14:23:16
阅读次数:
121
一、 推荐文章 1、以下来自OSChina的 mingxungu https://itzones.cn/ RocketMQ运维监控 RocketMQ刷盘策略 RocketMQ消息重试 RocketMQ内存映射 RocketMQ权限控制 RocketMQ主从同步 RocketMQ事务消息 Rocket ...
分类:
其他好文 时间:
2019-12-07 10:25:25
阅读次数:
118
其实Rocketmq的给第三方的插件已经全了,如果大家有兴趣的话请移步https://github.com/apache/rocketmq-externals。本文主要是结合笔者已有的rmq在spark中的应用经验对rocketmq做简单介绍以及经验总结,当然免不了会将rocketmq和如今特别火爆 ...
分类:
其他好文 时间:
2019-12-06 18:59:15
阅读次数:
409
一、安装 1、下载 下载地址:http://rocketmq.apache.org/release_notes/ 执行命令:wget http://mirrors.tuna.tsinghua.edu.cn/apache/rocketmq/4.6.0/rocketmq-all-4.6.0-bin-re ...
分类:
其他好文 时间:
2019-12-06 15:09:38
阅读次数:
113
Raft协议是分布式领域解决一致性的又一著名协议,主要包含Leader选举、日志复制两个部分。 温馨提示: 本文根据raft官方给出的raft动画进行学习,其动画展示地址:http://thesecretlivesofdata.com/raft/ @ "TOC" 1、Leader选举 1.1 一轮投 ...
分类:
其他好文 时间:
2019-12-05 21:47:36
阅读次数:
79
最近研究消息队列,发现好几个框架,搜罗一下进行对比,说一下选型说明: 1)中小型软件公司,建议选RabbitMQ。一方面,erlang语言天生具备高并发的特性,而且他的管理界面用起来十分方便。不考虑rocketmq和kafka的原因是,一方面中小型软件公司不如互联网公司,数据量没那么大,选消息中间件 ...
分类:
其他好文 时间:
2019-12-05 10:24:08
阅读次数:
157
环境 jdk: 8u22rocketmq: rocketmq-all-4.5.2-bin-releasespringboot: 2.1.6.RELEASErocketmq-springboot: 2.0.3 发送流程(事务消息) Rocket发送事务消息:1、由producer发送prepare(半 ...
分类:
编程语言 时间:
2019-12-04 18:32:23
阅读次数:
359
概念:半消息:在原有队列消息执行后的逻辑,如果后面的本地逻辑出错,则不发送该消息,如果通过则告知rocketmq发送
分类:
其他好文 时间:
2019-12-03 09:12:49
阅读次数:
607