RocketMQ入门到实战，你准备好了吗？

说实话，我第一次听说RocketMQ的时候，脑子里全是云和大数据的高大上。

哈哈，别怕，咱们慢慢聊。

先把概念掰开揉碎——

RocketMQ是阿里巴巴开源的分布式消息中间件。

它的定位啊，就是在海量业务之间传递“信”，让系统解耦、削峰、容错。

懂了吗？Ru果还有点懵，咱再来一遍。

Producer

负责把业务事件包装成Message发出去。

同步、异步、单向随你挑。

还有事务消息、顺序消息这些“花活”。

Broker

存储和转发，是整个系统的心脏。

内部结构用CommitLog + ConsumeQueue + IndexFile三层组合拳。

写入是顺序文件，读写分离，磁盘IO杠杠的。

NameServer

轻量级无状态服务，只负责注册和路由查询。

不搞选举，不用ZK，省了好多脑细胞的消耗。

Consumer

拉取并消费消息，维护Offset保证“只kan一次”。

集群模式下同一个Group里只会有一个实例真正消费每条消息。

其实啊，这个设计是想让NameServer保持极致的可用性。

ZK选举会有短暂不可用窗口，而NameServer要Zuo到“一拍即通”。

所以它用了无状态+Zui终一致性的思路，Broker心跳上报就行了。

先装JDK，确保java -versionNeng跑出来。

D:\rocketmq目录下解压包，注意别有中文空格——我之前踩过坑，那叫一个尴尬。.

tar -xvf rocketmq-all-4.9.2-bin-release.zip
cd rocketmq-all-4.9.2-bin-release
export JAVA_HOME=/path/to/jdk
sh bin/mqnamesrv &
sh bin/mqbroker -n localhost:9876 autoCreateTopicEnable=true &
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

启动完后用控制台或者自带工具kankantopic列表是不是Yi经冒出来了。

// Producer端
Message msg = new Message.getBytes);
SendResult result = producer.send;
System.out.println;

// Consumer端
consumer.subscribe;
consumer.registerMessageListener -> {
    for  {
        System.out.println));
    }
    return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
});
consumer.start;

C代码跑通之后你会发现控制台上弹出“收到：Hello RocketMQ”。哈哈，这感觉就像打开了新世界的大门。

sequenceDiagram
    participant P as Producer
    participant B as Broker
    P->B: . 发送半消息
    B-->P: 半消息发送成功
    P->P: . 执行本地事务
    alt 本地事务成功
        P->B: . 发送Commit
        B->B: 消息变为可见
    else 本地事务失败
        P->B: . 发送Rollback
        B->B: 删除消息
    else 未收到确认
        B->P: . 事务回查
        P-->B: 返回Commit/Rollback
    end

Aha，这段图说得挺清楚——先发半条信息，让Broker先占位；等本地业务成功再提交，否则撤回。这样就保证了“业务成功⇔消息必达”。

P1：Broker默认5秒回查，你Ke以在producer端配置transactionCheckListener来自定义处理逻辑；

P2：Ru果你的业务执行时间hen长，记得调大timeout或拆分成多个小事务；

P3：broke掉的broker恢复后会自动重新拉取未完成的事务进行回查——这点hen安心。

List batch = new ArrayList<>;
for  {
    batch.add.getBytes));
}
producer.send;
System.out.println;

C这招在双十一那种秒杀场景简直就是救命稻草——一次网络往返搞定百条，大幅降低IO开销。

有人问：“我写了个RocketMQ博客，为啥百度不收录？”

A：内容太技术化，没有自然语言描述导致搜索引擎难以抓取关键词；

B：P标签里缺少标题层级和meta信息；

C：站点没有备案或被墙，也会被屏蔽。

D："Robot.txt"误拦截。解决办法就是加点中文解释、补全、检查robots文件。你懂的，一点点改动就Neng爬进去啦！

C场景hen常见——用户下单后需要把订单信息同步到库存、支付、日志等子系统。

A方案是直接同步调用，好处是简单，但一旦某个服务挂掉，就会导致整体链路卡死。

B方案是使用RocketMQZuo异步解耦——订单服务只负责把订单事件发给MQ，然后各子系统各自消费。

// 订单服务 Producer 示例 
Message orderMsg = new Message.getBytes);
orderMsg.putUserProperty);
producer.send;
System.out.println);

// 库存服务 Consumer 示例 
consumer.subscribe;
consumer.registerMessageListener -> {
    for  {
        String json = new String);
        Order o = JSON.parseObject;
        // 执行库存扣减...
        System.out.println);
    }
    return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
});
consumer.start;

C这样一来即便库存系统临时宕机，订单仍然在MQ里等着重试，业务不会被卡住。害，这才是真正的高可用啊！

producer.send {
   @Override public MessageQueue select {
       String orderId = arg;
       int idx = Math.abs) % mqs.size;
       return mqs.get;
   }
}, orderId);
consumer.registerMessageListener {
   @Override public ConsumeOrderlyStatus consumeMessage(List msgs,
            ConsumeOrderlyContext ctx) {
       // 单线程消费，同一个queue里的msg顺序必然保持。
       return ConsumeOrderlyStatus.SUCCESS;
   }
});

B说实话，这段代码kan起来有点冗长，但核心思路就是：同一业务ID对应同一个队列，让消费者按队列顺序处理即可。咱就是说这招在支付流水这种必须严格顺序的场景里稳如老狗。

graph TB    
    P -->|设置delayLevel| B    
    B -->|写入DelayLog| S    
    S -->|时间到| B -->|恢复原Topic| C

.x版本加入时间轮+TimerLog，实现秒级任意延迟；Zui长支持40天；你想延迟多久dou行，只要配好level就好；

.x版本还引入Proxy层，把接入与存算彻底拆分，让边缘计算geng灵活；Ru果你要Zuo万级TPS，这层真的Neng帮忙减轻Broker压力。