key rocketmq 有什么用_rocketmq 介绍（一）

消息队列的作用

1.消峰：当业务处在高峰期时，将数据先暂存，利用这个缓冲机制，再慢慢处理。

2.解耦：低耦合的业务可以延后处理。解耦带来的好处就是：提高系统的可用性

3.消息分发：发送消息给多个接收端接收。

基本概念

主要由三块组成：生产者(发送消息)

消费者(接收处理消息)

broker(存储消息)

特性

发布与订阅：

发布：某个生产者向某个topic 发送消息，

订阅：某个消费者订阅某个topic带有某些tag的信息。从而消费生产者生产的信息。

消息顺序：

某些情况下需要保证消息的消费顺序，例如创建订单，付款，配送。消费要按照这种顺序才是合理。但是多个订单又能同时消费。

顺序消息分为全局顺序和分区顺序。

全局顺序：对于指定的一个 Topic，所有消息按照严格的先入先出(FIFO)的顺序进行发布和消费。适用场景：性能要求不高，所有的消息严格按照 FIFO 原则进行消息发布和消费的场景

分区顺序：对于指定的一个 Topic，所有消息根据 sharding key 进行区块分区。同一个分区内的消息按照严格的 FIFO 顺序进行发布和消费。 Sharding key 是顺序消息中用来区分不同分区的关键字段，和普通消息的 Key 是完全不同的概念。适用场景：性能要求高，以 sharding key 作为分区字段，在同一个区块中严格的按照 FIFO 原则进行消息发布和消费的场景。

key rocketmq 有什么用_rocketmq 介绍（一）相关推荐

key rocketmq 有什么用_RocketMQ原理介绍
分布式开放消息系统(RocketMQ)的原理与实践备注: 1.如果您此前未接触过RocketMQ,请先阅读附录部分,以便了解RocketMQ的整体架构和相关术语 2.文中的MQServer与Brok ...
RocketMQ工作原理高级功能介绍
1.1 消息存储分布式队列因为有高可靠性的要求,所以数据要进行持久化存储. 消息生成者发送消息 MQ收到消息,将消息进行持久化,在存储中新增一条记录返回ACK给生产者 MQ push 消息给对应的 ...
RocketMQ Web控制台监控界面介绍+部署
文章目录简介部署 Docker方式 SpringBootFatJar方式界面指南运维页驾驶舱集群页面主题页面消费者页面生产者页面消息查询页面消息轨迹页面其他 HTTPS 方式访 ...
rocketmq python消息堆积_RocketMQ消息存储和查询原理
前言 RocketMQ 作为一款优秀的分布式消息中间件,可以为业务方提供高性能低延迟的稳定可靠的消息服务.其核心优势是可靠的消费存储.消息发送的高性能和低延迟.强大的消息堆积能力和消息处理能力. 从存 ...
RocketMQ各种集群模式介绍
集群模式 1)单Master模式这种方式风险较大,一旦Broker重启或者宕机时,会导致整个服务不可用.不建议线上环境使用,可以用于本地测试. 2)多Master模式一个集群无Slave,全是Ma ...
一文读懂RocketMQ的存储机制
一.存储方式业界主流的 MQ 产品像 RabbitMQ.RocketMQ.ActiveMQ.Kafka 都是支持持久化存储的,而 ZeroMQ 不需要支持持久化存储.业务系统也确实需要 MQ 支持持 ...
「查缺补漏」巩固你的 RocketMQ 知识体系
本期带来的内容是 RocketMQ 核心知识点.建议收藏起来慢慢看~ Windows安装部署下载地址:https://www.apache.org/dyn/closer.cgi?path=rocke ...
MQ 之 RocketMQ
前些天发现了一个巨牛的人工智能学习网站,通俗易懂,风趣幽默,忍不住分享一下给大家.点击跳转到教程. RocketMQ 是出自 A 公司的开源产品,用 Java 语言实现,在设计时参考了 Kafka,并 ...
RocketMQ原理剖析
前言 MQ使用场景异步.解耦.削峰填谷 MQ选型吞吐量: Kafka具有更高的吞吐量.Kafka在Producer端将多个小消息合并,批量发送给Broker,从而提高系统的吞吐量.同时,Kafka ...

key rocketmq 有什么用_rocketmq 介绍（一）

key rocketmq 有什么用_rocketmq 介绍（一）相关推荐

最新文章

热门文章