RocketMQ是以consumer group+queue为单位是管理消费进度的，以一个consumer offset标记这个这个消费组在这条queue上的消费进度。 如果某已存在的消费组出现了新消费实例的时候，依靠这个组的消费进度，就可以判断第一次是...

本文梳理笔者的MQ知识，从消息中间件的基础知识讲起，在有了基础知识后，对市面上各主流的消息中间件进行详细的解析，包括 RabbitMQ、RocketMQ、Kafka、Pulsar，最后再横向对比这几款主流的消息中间件。...

内存映射是在内核中维护用户空间虚拟地址与文件偏移的映射关系，可以让用户态向操作数组一样读写文件，当对应页数据未读入内存时就会触发缺页中断，再由CPU响应中断根据映射关系读取文件中指定位置的数据并添加用户页表项...

RocketMQ是一个分布式消息队列系统，它最初由阿里巴巴开发并开源。RocketMQ具有高可靠性、高吞吐量、高扩展性和良好的可维护性等特点，被广泛应用于金融、电商、物流、游戏等领域。...

日前拜读阿牛老师的大作 领导：谁再用定时任务实现关闭订单，立马滚蛋！发现其方案有若干瑕疵，特此抛砖引玉讨论一二。

最开始的mqnamesrv.sh脚本获取环境变量的部分看不懂其实没啥影响，大略有个印象即可，当然可以截取部分的命令到Linux运行测试一下就明白了，比如准备环境变量等等，最后一句话比较关键。...

kafka不支持延迟消息，rocketmq支持的延迟消息粒度有限，pulsar（https://github.com/apache/pulsar）采用优先队列的方式实现，支持任意粒度的延迟消息，不过，对于大量延迟比较久的消息，内存消耗会比较严重。本文学习下如何在mac上...

RocketMq3.X的版本和Kafka一样是基于Zookeeper进行路由管理的，但是这意味着运维需要多部署一套Zookeeper集群，后来RocketMq选择去ZK最终出现了NameServ。NameServ作为RocketMq源码阅读的切入点非常不错，本文将会介绍Ver ...

CountDownLatch 是一个同步工具类，用来协调多个线程之间的同步，它能够使一个线程在等待另外一些线程完成各自工作之后，再继续执行。

RocketMQ最佳实践https://github.com/apache/rocketmq/blob/master/docs/cn/best_practice.md