首页 > 其他分享 >Rocket

Rocket

时间:2024-07-20 21:31:44浏览次数:7  
标签:消费者 Rocket 生产者 Broker 默认 Topic 消息

  1. Name Server:Broker 的注册中心,所有的 Broker 都要注册到 Name Server
  2. Broker:RocketMQ 服务,是多个,每个 Broker 可以配置主从节点
  3. Topic:消息主题,由多个 Queue 组成(默认4个,默认不会自动创建,可以修改配置为自动创建)
  4. Queue:消息队列,真正接受消息的载体
  5. Tag:消息分类,给消息打个标签,在生产消息和消费消息时作进一步区分
  6. group:分组,可以给消息生产者和消费者指定一个归属的组,不管是生产者还是消费者只能属于一个组
  7. producer:消息生产者,生产者可以发消息到任意 Topic(和分组也无关,一句话就是发消息无限制)
  8. consumer:消息消费者,同一个消费者组下的消费者必须消费同一个 Top 的消息

一条消息发送到 Topic 后,默认轮询确定出将要投递消息的队列(第一次到a,第二次到b...)

如果是负载均衡模式(默认的轮询):假设 Topic 有 n 个队列,订阅这个 Topic 的消费者组的消费者的数量要 <= n,因为每个队列都要被一个具体的消费者消费,如果 > n,就会有消费者永远空闲着

标签:消费者,Rocket,生产者,Broker,默认,Topic,消息
From: https://www.cnblogs.com/cyrushuang/p/18313813

相关文章

  • RocketMQ实现黑马点评优惠卷下单
    背景在现代电商系统中,秒杀活动因其高并发、高负载的特点,对系统的稳定性和性能要求极高。为了有效地处理秒杀活动中的高并发请求,消息队列成为了一个重要的解决方案。本文将介绍如何使用RocketMQ来实现秒杀下单的功能。目标通过RocketMQ来实现一个秒杀订单的处理流程,保证在......
  • 使用RocketMQ 实现基于标签过滤的消息队列生产和消费
    在分布式系统中,消息队列(MessageQueue,MQ)是一种常见的通信方式,它能够解耦系统组件,提供异步通信,提升系统的伸缩性和可靠性。ApacheRocketMQ是一款开源的分布式消息中间件,具有高性能、低延迟、高可靠性和高可用性等特点。本文将介绍如何使用ApacheRocketMQ实现基于标签过......
  • Rocketmq双主双从部署
    一、概要RocketMQ是一个分布式消息和流媒体平台,具有低延迟、高性能和可靠性、万亿级容量和灵活的可扩展性。整个流程如下:1)启动NameServer,NameServer起来后监听端口,等待Broker、Producer、Consumer连上来完成注册,相当于一个路由控制中心。2)Broker启动,跟所有的NameServer保......
  • RocketMQ概念与模型
    为啥要用MQ?这个都应该会背了,6个字解耦、异步、削峰RocketMQ的优缺点?适用场景?主要与Kafka相比单机吞吐量:十万级(类似kafka)消息堆积:支持10亿级别消息堆积源码是Java天生为金融互联网领域而生,对于可靠性要求很高的场景,尤其电商里订单扣款、业务削峰,业务场景在阿里双11经历过......
  • debian11 podman搭建rocketmq (初步测试)
    前言由于个人学习测试需要,想要在debian11环境下,使用podman搭建一个简单的单节点rocketmq,搭建过程比较繁琐,所以记录下来留作后续参考。由于对rocketmq镜像不熟悉,有些配置可能存在错误,会在后续有能力优化时继续更新此文档。后续可能会补充podman-compose实现方式,目前是shell脚本......
  • 深入解析RocketMQ的存储设计艺术(一)
    1. DomainModel领域模型(DomainModel)是对领域内的概念类或现实世界中对象的可视化表示。又称概念模型、领域对象模型、分析对象模型。它专注于分析问题领域本身,发掘重要的业务领域概念,并建立业务领域概念之间的关系。1.1 MessageMessage是RocketMQ消息引擎中的主体。mes......
  • jmeter插件开发—RocketMQ4.9
    上期是使用java测试了rocketmq中间件的测试,考虑到后期性能测试,准备封装为jmeter插件。参考TesterHome的文章环境说明JDK1.8.0,Jmeter5.4.3,maven构建工具(使用JDK17时遇到过跟Jmeter设置的外观有冲突)实现代码(pom.xml已贴在上期的文章最后)以下为全部代码,可以自行调整相关参数,实现......
  • RocketMQ 基础教程-高级功能汇总
    作者简介:大家好,我是smart哥,前中兴通讯、美团架构师,现某互联网公司CTO联系qq:184480602,加我进群,大家一起学习,一起进步,一起对抗互联网寒冬学习必须往深处挖,挖的越深,基础越扎实!阶段1、深入多线程阶段2、深入多线程设计模式阶段3、深入juc源码解析阶段4、深入jdk其余源码解析......
  • RocketMQ 基础教程-RocketMQ整合SpringBoot
    作者简介:大家好,我是smart哥,前中兴通讯、美团架构师,现某互联网公司CTO联系qq:184480602,加我进群,大家一起学习,一起进步,一起对抗互联网寒冬学习必须往深处挖,挖的越深,基础越扎实!阶段1、深入多线程阶段2、深入多线程设计模式阶段3、深入juc源码解析阶段4、深入jdk其余源码解析......
  • MQ测试方法(RocketMQ 4.X)
    官网了解rocketmq背景我们知道一般消息中间件的基础消费模型如下,生产者产生一类主题消息,而消费者就消费一类主题消息。 Rocket也是采用该模型,并进行了扩展,实现了多人发不同的topic且多人消费的场景。 上面还能看出,一个Topic下有多个队列,可以在不同Broker上。再结合一下部......