消息发送到topic多个MessageQueue

接下来演示一下对topic创建多个messageQueue的演示

1. 创建一个队列，设置2个写队列以及2个读队列，如果读和写队列不一致，会存在消息无法消费到
的问题

2. 构建生产者和消费者:参考上面写的生产者消费者代码

3. 消费者数量控制对于队列的消费情况
   a) 如果消费队列为2，启动一个消费者，那么这个消费者会消费者两个队列，

   b) 如果两个消费者消费这个队列，那么意味着消息会均衡分摊到这两个消费者中

   c）如果消费者数大于readQueueNumbs，那么会有一些消费者消费不到消息，浪费资源

消息发送到topic多个MessageQueue相关推荐

rocketmq 消息自定义_RocketMQ的消息发送及消费
RocketMQ消息支持的模式: 消息支持的模式分为三种:NormalProducer(普通同步),消息异步发送,OneWay. 消息同步发送: 普通消息的发送和接收在前面已经演示过了,在前面的案例中 ...
RocketMQ3.2.2生产者发送消息自动创建Topic队列数无法超过4个
问题现象 RocketMQ3.2.2版本,测试时尝试发送消息时自动创建Topic,设置了队列数量为8: producer.setDefaultTopicQueueNums(8); 同时设置broker ...
RocketMQ：Producer启动流程与消息发送源码分析
文章目录 Producer 1.方法和属性 2.启动流程 3.消息发送 3.1验证消息 3.2查找路由 3.3选择队列 3.4发送消息 3.5发送批量消息 Producer 在RocketMQ中,消息 ...
producer send源码_RocketMq系列之Producer顺序消息发送源码分析（四）
有序消息消息有序指的是可以按照消息的发送顺序来消费. RocketMQ可以严格的保证消息有序.但这个顺序,不是全局顺序,只是分区(queue)顺序. 顺序消息生产者 public static vo ...
RocketMQ消息发送之pull和push
RocketMQ学习(五)--RocketMQ消息发送之pull和push import org.apache.rocketmq.client.exception.MQClientException; ...
RocketMQ 源码学习笔记 Producer 是怎么将消息发送至 Broker 的？
RocketMQ 源码学习笔记 Producer 是怎么将消息发送至 Broker 的? 文章目录 RocketMQ 源码学习笔记 Producer 是怎么将消息发送至 Broker 的? 前言项目 ...
RocketMQ源码解析-Producer消息发送
首先以默认的异步消息发送模式作为例子.DefaultMQProducer中的send()方法会直接调用DefaultMQProducerImpl的send()方法,在DefaultMQProducer ...
Rocket之消息发送
涉及角色生产者组:一个逻辑概念,在使用生产者实例的时候需要指定一个组名.一个生产者组可以生产多个Topic的消息. 生产者实例:一个生产者组部署了多个进程,每个进程都可以称为一个生产者实例. Top ...
RocketMQ学习(四)——RocketMQ消息发送
RocketMQ 网络架构图 RocketMQ分布式消息队列的网络部署架构图如下图所示于上图中几个角色的说明: (1) NameServer: RocketMQ集群的命名服务器(也可以说是注册中心) ...

消息发送到topic多个MessageQueue

消息发送到topic多个MessageQueue相关推荐

最新文章

热门文章