什么是消息中间件
消息中间件(MessageQueue,MQ)
主要功能:异步
同步调用示例:
异步调用示例:
一、消息中间件的使用常见
异步与解耦,示例如下:
流量削峰(时间换空间),示例如下:
数据分发,示例如下:
二、RocketMQ的产品发展
前世
MetaQ:2011年,阿里基于Kafka的设计使用Java完全重写并推出了MetaQ1.0版本 。
2012年,阿里对MetaQ的存储进行了改进,推出MetaQ2.0,同年阿里把Meta2.0从阿里内部开源出来,取名RocketMQ,为了命名上的规范以及版本上的延续,对外称为RocketMQ3.0。
今生
2016年,阿里宣布将开源分布式消息中间件RocketMQ捐赠给Apache,同时RocketMQ3也升级为RocketMQ4,现在RocketMQ主要维护的是4.x的版本,也是大家使用得最多的版本。
未来
2021年,RocketMQ在github上发布5.0预览版。RocketMQ5.0定义为云原生的消息、事件、流的超融合平台。因为尚未正式发布,目前不需要过多了解。
三、RockerMQ各角色介绍
RockerMQ的基本概念
主题:例如衣服、电器、食品等
分组:主要用于事务分组
消息队列:一个主题有一个或者若干个队列;但是消费者没有生产者快,一个队列对应一个消费者
偏移量:消费者详情;消费了多少数据。