RocketMQ--广播模式

曾经终败给现在 2023-06-11 13:21 15阅读 0赞

> 创建者

public class BroadcastProducer {
        public static void main(String[] args) throws Exception {
            DefaultMQProducer producer = new DefaultMQProducer("ProducerGroupName");
            producer.start();
    
            for (int i = 0; i < 100; i++){
                Message msg = new Message("TopicTest",
                    "TagA",
                    "OrderID188",
                    "Hello world".getBytes(RemotingHelper.DEFAULT_CHARSET));
                SendResult sendResult = producer.send(msg);
                System.out.printf("%s%n", sendResult);
            }
            producer.shutdown();
        }
    }

> 消费者

public class BroadcastConsumer {
        public static void main(String[] args) throws Exception {
            DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("example_group_name");
            consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);
            consumer.setMessageModel(MessageModel.BROADCASTING);
            consumer.subscribe("TopicTest", "TagA || TagC || TagD");
            consumer.registerMessageListener(new MessageListenerConcurrently() {
                @Override
                public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs,
                    ConsumeConcurrentlyContext context) {
                    return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
                }
            });
            consumer.start();
            System.out.printf("Broadcast Consumer Started.%n");
        }
    }

发表评论取消回复

表情：

评论列表（有 0 条评论，15人围观）

还没有评论，来说两句吧...

相关阅读

相关【RocketMQ】记录一次广播模式消费遇到的问题

文章目录问题详情问题定位问题解决问题详情业务团队反馈使用RocketMQ时，消费失败，报如下的错误：错误1:

电玩女神/ 2023年10月02日 14:03/ 0 赞/ 21 阅读

相关一文带你理解 RocketMQ 广播模式实现机制

今天聊聊 RocketMQ 的广播消息实现机制。 RocketMQ 有两种消费模式，集群模式和广播模式。集群模式是指 RocketMQ 中的一条消息只能被同一个消费者组中

- 日理万妓/ 2023年09月28日 15:40/ 0 赞/ 170 阅读

相关 RocketMQ--广播模式

> 创建者 public class BroadcastProducer { public static void main(String[] arg

曾经终败给现在/ 2023年06月11日 13:21/ 0 赞/ 16 阅读

相关 RocketMQ实践之广播模式（四）

发送消息： -------------------- package my.demo.broad; import org.apache.rocke

- 日理万妓/ 2022年09月15日 12:27/ 0 赞/ 210 阅读

相关 fanout广播模式

RabbitMQ完整的消息模型如下: ![这里写图片描述][2016-02-18_56c53cbd5232a.jpg] 生产者P会通过交换器

我会带着你远行/ 2022年06月11日 06:39/ 0 赞/ 168 阅读

相关 rabbitmq-fanout（广播模式）

RabbitMQ—fanout（广播模式） -------------------- 一、什么是fanout(广播模式) 简单的讲，就是把交换机（Exchange

骑猪看日落/ 2022年05月17日 04:15/ 0 赞/ 187 阅读

相关 RabbitMQ-fanout广播模式

RabbitMQ-fanout广播模式 fanout: 所有bind到该交换机的队列都可以接收消息。消息的接受者需要创建一个队列，绑定到该f

迷南。/ 2022年02月26日 02:22/ 0 赞/ 324 阅读

相关 RocketMQ——广播消费模式与集群消费模式

RocketMQ有两种消费模式：BROADCASTING广播模式，CLUSTERING集群模式，默认的是集群消费模式。本博客主要以广播模式为例！！！ 1.简介广播消

你的名字/ 2021年09月27日 00:04/ 0 赞/ 622 阅读

相关 8 SpringBoot整合RocketMQ实现消费者广播模式和负载均衡模式

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAamF2YTEyMzRf5

梦里梦外;/ 2021年09月09日 14:28/ 0 赞/ 370 阅读

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

1.集群消费方式一个ConsumerGroup中的Consumer实例平均分摊消费生产者发送的消息。例如某个Topic有九条消息，其中一个Consumer Group有三

左手的ㄟ右手/ 2021年06月10日 20:40/ 0 赞/ 685 阅读