理论部分在https://www.jianshu.com/p/453c6e7ff81c中的 “三、事务消息”。下面从代码层面看一下rockemq的事务消息 一、事务消费端。 　　从代码中看到跟其他模式的消费端没有什么两样。 二、本地事务的执行器，实现 ...

broker过期文件删除机制 RocketMQ会每隔10秒执行文件清理任务 主要是删除commitlog和consumequeue文件 commitlog文件删除 触发过期文件删除的条件： 1）达到配置的时间点 2）磁盘用了超过85% 3）手动执行 ...

　　RocketMQ作为消息中间件，经常会被用来和其他消息中间件做比较，比对rabbitmq, kafka... 但个人觉得它一直对标的，都是kafka。因为它们面对的场景往往都是超高并发，超高性能要求的场景。 　　所以，有必要深挖下其实现高性能，高并发的原因。实际上，这是非常大的话题 ...

参考： https://blog.csdn.net/zhaoming19870124/article/details/90900808 https://blog.csdn.net/hosaos/a ...

RocketMQ日志 RocketMQ提供了一个日志模块，实现自定义的Appender，目的是为了将日志发送到MQ中。 可以参考文章https://blog.csdn.net/wanbf123/article/details/77988801 在RocketMQ的client模块中中 ...

　　看了https://www.jianshu.com/p/453c6e7ff81c这篇博客，得出顺序消费的结论。“要实现严格的顺序消息，简单且可行的办法就是：保证生产者 - MQServer - 消费者是一对一的关系”。 我们下面通过几个实例来学习RocketMQ的顺序消费。 一、单节点 ...

一、准备环境 1.系统：Centos7.3（无硬性要求） 2. jdk：1.8 3.maven：3.5（无硬性要求） 4.git 5.rocketmq 4.2 二、环境部署 1.jdk1.8以及maven可以在另一篇文章查看【http://www.cnblogs.com ...

参考： https://blog.csdn.net/u010277958/article/details/88647281 https://blog.csdn.net/u010634288/art ...