折腾了好长时间才写这篇文章，顺序消费，看上去挺好理解的，就是消费的时候按照队列中的顺序一个一个消费；而并发消费，则是消费者同时从队列中取消息，同时消费，没有先后顺序。RocketMQ也有这两种方式的实现，但是在实践的过程中，就是不能顺序消费，好不容易能够实

前面的章节，我们已经把RocketMQ的环境搭建起来了，是一个两主两从的异步集群。接下来，我们就看看怎么去使用RocketMQ，在使用之前，先要在NameServer中创建Topic，我们知道RocketMQ是基于Topic的消息队列，在生产者发送消息的时

我觉得这个问题问得很频繁，而且非常经典，在这里我就以 Kafka 为例子，说说我对 Kafka 顺序消息的一些理解吧，如有理解不对的地方麻烦留言指点一下。针对以上第二点，下面盘点一下 Kafka 集群中有哪些意外情况会打乱消息的顺序。

message queue是无限长的数组，一条消息进来下标就会涨1，下标就是offset，消息在某个MessageQueue里的位置，通过offset的值可以定位到这条消息，或者指示Consumer从这条消息开始向后处理。message queue中的ma

说说HaspMap底层原理？再说说它跟HaspTable和ConcurrentHashMap他们之间的相同点和不同点？讲讲jdk1.7和1.8的区别？Redis缓存雪崩、缓存穿透以及如何解决？CMS收集器和G1收集器最大的区别在哪里？有实际的JVM性能优化

commitLog 删除文件的策略指定时间到了，磁盘不足，人工删除，满足任一条件，判断文件是否过期或者磁盘不足，是则删除，一批次最多删除 10 个文件。commitLog 尾部是有空洞的，当一个消息在当前文件放不下时，rocketmq 认为下一个文件一定能

　　消息重试只针对集群消费方式生效；广播方式不提供失败重试特性，即消费失败后，失败消息不再重试，继续消费新的消息。　　每次重试后，消息ID都不一致，所以不能使用消息ID判断幂等。

package com.zn;public static void main(String[] args) throws MQClientException {. DefaultMQProducer producer=new DefaultMQProduc

启动 Broker 的时候，本地环境建议开启自动创建 Topic，生产环境建议关闭自动化创建 Topic。建议先手工创建 Topic，如果靠程序自动创

本文是根据平时面试以及网上资源进行的整理。希望对小伙伴们面试有帮助。使用消息队列会带来哪些问题？rocketmq不支持队列层面的广播，kafka的consumer group支持组间广播，组内负载均衡。partition：一个topic可以包含一个或多个p

rocketmq 基本使用可以看官网和官网给的demo.

public static void main(String[] args) throws Exception {. DefaultMQProducer producer = new DefaultMQProducer("producerGrou

上一篇 源码分析 RocketMQ DLedger(多副本) 之日志复制(传播) ，可能有不少读者朋友们觉得源码阅读较为枯燥，看的有点云里雾里，本篇将首先梳理一下 RocketMQ DLedger 多副本关于日志复制的三个核心流程图，然后再思考一下在异常情

RocketMQ的Consumer都是从Broker拉消息来消费，但是为了能做到实时收消息，RocketMQ使用长轮询方式，可以保证消息实时性同Push方式一致。这里需要注意的是，长轮询与长连接是两个不同的概念。长轮询表示，当客户端的一个请求达到服务端时，

半消息: 在原有队列消息执行后的逻辑，如果后面的本地逻辑出错，则不发送该消息，如果通过则告知rocketmq发送

MQ组件是系统架构里必不可少的一门利器，设计层面可以降低系统耦合度，高并发场景又可以起到削峰填谷的作用，从单体应用到集群部署方案，再到现在的微服务架构，MQ凭借其优秀的性能和高可靠性，得到了广泛的认可。这个其实就是数据库事务与MQ消息的一致性问题，简单来讲

消息队列

/opt/ali-rocketmq/devenv 是安装 rocketmq 的目录。注意 多个nameserver使用分号 分割。执行命令后 可以模拟主或从挂掉来测试一下。

前面两篇RocketMQ消息消费（一）/（二）篇，主要从Push/Pull两种消费模式的简要流程、长轮询机制和Consumer端负载均衡这几点内容出发，介绍了RocketMQ消息消费的正常流程和细节内容，本篇内容将主要介绍Consumer端消费失败的异常流

在首届阿里巴巴中间件峰会上，来自阿里的中间件架构师，Apache RocketMQ创始人冯嘉分享了《万亿级数据洪峰下的分布式消息引擎》。他主要从阿里消息引擎家族史、消息引擎面临的挑战，未来展望三个方面进行了分享。在分享中，他从可用性&可靠性