RocketMQ广播消费与集群消费

2024-04-11 04:11:06

之前的博客只是为了验证rmq安装是否成功，以及生产消费消息能否正常走通，如果是多个消费端消费生产者发送的消息会有什么样的效果？这个可以用代码校验一下，还是先了解两个比较常用的消费端的术语：
1.集群消费方式
一个ConsumerGroup中的Consumer实例平均分摊消费生产者发送的消息。例如某个Topic有九条消息，其中一个Consumer Group有三个实例（可能是3个进程，或者3台机器），那么每个实例只消费其中的3条消息，Consumer不指定消费方式的话默认是集群消费的，适用于大部分消息的业务
2.广播消费方式
一条消息被多个Consumer消费，几十这些Consumer属于同一个ConsumerGroup，消息也会被ConsumerGroup中的每个Consumer消费一次，广播消费中的ConsumerGroup概念可以认为在消息划分层面没有意义，适用于一些分发消息的场景，比如我订单下单成功了，需要通知财务系统，客服系统等等这种分发的场景，可以通过修改Consumer中的MessageModel来设置消费方式为广播消费

默认集群消费方式

生产者循环生产消息，假设生产20条，启动两个消费者，理论上是分摊消费的

编写两个消费者，启动消费者

发现每个消费者消费了十条数据。

修改消费方式，广播消费测试

启动两个消费者，理论上是各自消费二十条数据

每个消费者消费了20条消息，通过日志还可以发现，消费端的消费方式是多线程消费的，进入源码查看

内部定义了很多默认值，包括消费方式默认集群，线程最小默认20，最大默认64，批量下去消息默认32，消费默认一次消费一条等一些默认信息

RocketMQ广播消费与集群消费相关推荐

java kafka 集群消费_kafka集群搭建和使用Java写kafka生产者消费者
转自:http://chengjianxiaoxue.iteye.com/blog/2190488 1 kafka集群搭建 1.zookeeper集群搭建在110, 111,112 2.kafka使 ...
RocketMQ 简单梳理及集群部署笔记【转】
一.RocketMQ 基础知识介绍 Apache RocketMQ是阿里开源的一款高性能.高吞吐量.队列模型的消息中间件的分布式消息中间件. 上图是一个典型的消息中间件收发消息的模型,RocketMQ ...
RocketMQ 简单梳理及集群部署笔记
一.RocketMQ 基础知识介绍 Apache RocketMQ是阿里开源的一款高性能.高吞吐量.队列模型的消息中间件的分布式消息中间件. 上图是一个典型的消息中间件收发消息的模型,RocketMQ ...
昨晚，我们的消费者居然停止消费kafka集群数据了
以下文章来源方志朋的博客,回复"666"获面试宝典图片来源:伪装者来源 | https://juejin.im/post/6874957625998606344 笔者所在的是一 ...
java kafka 集群消费_kafka集群简单生产者消费者实例
项目描述本项目是个简单的kafka集群简单生产者和消费者实例,生产者能生产消息,消费者能消费消息,这里将消费的消息存入了mysql数据库,适合刚kafka刚入门的朋友借鉴使用,里面的zookeepe ...
kafka 小案例【二】 --kafka 设置多个消费着集群
这个配是我在http://www.cnblogs.com/zhangXingSheng/p/6646972.html 的基础上再添加的配置设置多个消息集群 (1)复制两份配置文件 > cp c ...
RocketMQ（三）—— 集群模式的说明
集群理论复制与刷盘策略复制: 复制策略是Broker的Master与Slave间的数据同步方式.分为同步复制与异步复制: 同步复制:消息写入master后,master会等待slave同步数据成功 ...
从rocketmq到kafka：集群、一致性与重平衡
rabbitmq的消息可靠性 rabbitmq-幂等引出的性能分析从rabbitmq到rocketmq 经过上面三篇文章的学习,本篇再来学习 kafka 就会比较简单,概念都是相通的,关键是要联系和 ...
kafka集群消费之ConsumerRecord类
java.lang.Object继承 org.apache.kafka.clients.consumer.ConsumerRecord <K,V> public final class C ...

最新文章

热门文章