架构在金融行业用的比较多。 二、消息订阅模型 在 RocketMQ 的消息消费模式采用的是发布与订阅模式。 topic：一类消息的集合，消息发送者将一类消息发送到一个主题中，例如订单模块将 订单发送到 order_topic 中，而用户登录时，将登录事件发送到 user_login_topic 中。 consumegroup：消息消费组，一个消费单位的“群体”，消费组首先在启动时需要 订阅需要消费的 topic。一个 例如我们在开发一个订单系统，其中有一个子系统：order-service-app，在该项目 中会创建一个消费组 order_consumer 来订阅 order_topic，并且基于分布式部署， order-service-app 的部署情况如下： 本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 1.1 RocketMQ 核心概念扫盲篇 < 12 即 order-service-app 部署了 部署了 3 台服务器，每一个 jvm 进程可以看做是消费组 order_consumer 消费组的其中一个消费者。 1. 消费模式 那这三个消费者如何来分工来共同消费 order_topic 中的消息呢？ 在 RocketMQ 中支持广播模式与集群模式。 广播模式：一个消费组内的所有消费者每一个都会处理 topic 中的每一条消息，通常用 于刷新内存缓存。 集群模式：一个消费组内的所有消费者共同消费一个

0 1 7 A l i b a b a M i d d l e w a r e G r o u p $sh mqadmin querymsgbykey -k Query_Key -t ORDER_TOPIC #Message ID #QID o u p $sh mqadmin querymsgbyuniquekey -i 707C8CC435FE3FD00E77180D7FCB0B24 -t ORDER_TOPIC Topic: ORDER_TOPIC Tags: [ApacheCon] Keys: [Query_Key] Queue

............................................................................... 4 4.3 Message Order ................................................................................................. 适。如果要让 MQ 解决此问题，会对 MQ 的性能造成非常大的影响。返里要确保一点，业务上是否确实需 要返种严格的优兇级，如果将优兇级压缩成几个，对业务的影响有多大？ 4.3 Message Order 消息有序挃的是一类消息消费时，能挄照収送的顺序来消费。例如：一个订单产生了 3 条消息，分别是订单创 建，订单付款，订单完成。消费时，要挄照返个顺序消费才能有意丿。但是同时订单乀间是可以幵行消费的。 received will be the first discarded. d) PriorityOrder - Events should be discarded in priority order, such that lower priority 项目开源主页：https://github.com/alibaba/RocketMQ 8 events will be discarded

Scale based on events while preserve rich connection & processing semantics with event source (in order processing, retries, deadletter, checkpointing) - Some main logic - No message: scale to 0 read code,research architecture, make some modifications, test all examples with rocketmq queue(order, broadcast, schedule, batch, filter, logappender, openmessaging, transaction). Research about rocketmq

Service Apache RocketMQ SDK(Java/C++/.Net/PHP/Go) | Console | JMS | HTTP | Schedule Message Order Message File Service Aliware MQ Apache RocketMQ Replication DB Connector Third party partner

Service Apache RocketMQ SDK(Java/C++/.Net/PHP/Go) | Console | JMS | HTTP | Schedule Message Order Message File Service Aliware MQ Apache RocketMQ Replication DB Connector Third party partner