洛阳网站建设启辰网络,无锡网络推广,网站申请页面,网红营销的价值目录
关键字摘要
Q1#xff1a;RocketMQ是什么#xff1f;
Q2: 作为消息中间件#xff0c;RocketMQ和kafka有什么区别#xff1f;
Q3: RocketMQ的基本架构是怎样的#xff1f;
Q4#xff1a;RocketMQ有哪些核心概念#xff1f;
总结
RocketMQ是一个开源的分布式消…目录
关键字摘要
Q1RocketMQ是什么
Q2: 作为消息中间件RocketMQ和kafka有什么区别
Q3: RocketMQ的基本架构是怎样的
Q4RocketMQ有哪些核心概念
总结
RocketMQ是一个开源的分布式消息中间件。它是一种低延迟、高可用、高可靠、高并发的消息队列系统用于在分布式系统中进行异步通信。
关键字摘要
低延迟、高可用、高可靠、高并发 的消息中间件适合在线业务分为producer、consumer、nameserver、broker等角色另外还有主题Topic、队列MessageQueue、消息Message、消费者组ConsumerGroup、订阅关系Subscription等核心概念
Q1RocketMQ是什么
RocketMQ是一个开源的分布式消息中间件。它是一种 低延迟、高可用、高可靠、高并发 的消息队列系统用于在分布式系统中进行异步通信。
Q2: 作为消息中间件RocketMQ和kafka有什么区别
作为消息中间件RocketMQ和kafka的「消息模型」上比较相似都有 生产、存储消息堆积、消费 三大部分。
主要区别还是使用场景。
RocketMQ比kafka多了一些业务特性比如 定时消息、延迟消息、事务消息RocketMQ和kafka的不是同一个概念、广播消息、消息轨迹 等所以我们一般把RocketMQ用在在线业务场景中。
而kafka由于大数据生态完善在系统间的数据流管道、实时数据处理等场景中依旧占据优势。
当然RocketMQ 5.x版本进一步强化了自身在 事件、流处理 场景上的结合。不过目前观察主要还是阿里云自身在做相关生态建设和应用业界落地上还不算主流。
Q3: RocketMQ的基本架构是怎样的 RocketMQ 4.x基本架构
RocketMQ 4.x版本中主要分为4个角色
producer发布消息的角色。Producer通过负载均衡模块选择相应的 Broker 集群队列进行消息投递。consumer消息消费的角色。提供实时订阅消息的能力。brokerBroker主要负责消息的存储、投递和查询以及服务高可用保证。nameserverNameServer是一个简单的 Topic 路由注册中心。支持 Topic、Broker 的动态注册与发现。
RocketMQ 5.x 为了更好适应云原生环境下的「存算分离」在部署架构上做了一个变化。
新增无状态的代理模块Proxy作为「计算层」将 Broker 原来的协议适配、权限管理、消息管理等计算功能抽离到了代理模块中。
而Broker 则专注于「存储层」主要负责消息存储功能。
这样在云环境下可以更好地进行资源调度。 RocketMQ 5.x基本架构
Q4RocketMQ有哪些核心概念 RocketMQ核心概念
前面提到过消息中间件的逻辑架构上比较相似都有消息 生产、存储消息堆积、消费三大部分。
就RocketMQ而言核心概念也是围绕这三个部分展开7个核心概念
消息生产
生产者ProducerRocketMQ 中用于产生消息的实体。
消息存储 主题TopicRocketMQ 消息传输和存储的分组容器主题内部由多个队列MessageQueue组成。 队列MessageQueueRocketMQ 消息传输和存储的实际单元容器类比于kafka中的分区。 消息MessageRocketMQ 的最小传输单元。在初始化发送和完成存储后即不可变。 消息消费 消费者分组ConsumerGroupRocketMQ 发布订阅模型中定义的独立的消费身份分组用于统一管理底层运行的多个消费者Consumer。 消费者ConsumerRocketMQ 消费消息的运行实体。消费者必须被指定到某一个消费组中。 订阅关系SubscriptionRocketMQ 发布订阅模型中消息过滤、重试、消费进度的 持久化「规则配置」。消费组通过定义订阅关系控制指定消费组下的消费者如何实现消息过滤、消费重试及消费进度恢复等。
总结
低延迟、高可用、高可靠、高并发的消息中间件。适合在线业务。分为producer、consumer、nameserver、broker等角色。另外还有主题Topic、队列MessageQueue、消息Message、消费者组ConsumerGroup、订阅关系Subscription等核心概念。
