消费者广播模式和负载均衡模式

消费消息

1）负载均衡模式

消费者采用负载均衡方式消费消息，多个消费者共同消费队列消息，每个消费者处理的消息不同

2）广播模式

消费者采用广播的方式消费消息，每个消费者消费的消息都是相同的

package com.leon.mq.rocketmq.base.consumer;import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;
import org.apache.rocketmq.common.message.MessageExt;
import org.apache.rocketmq.common.protocol.heartbeat.MessageModel;import java.util.List;/*** 消息的接受者*/
public class Consumer {public static void main(String[] args) throws Exception {//1.创建消费者Consumer，制定消费者组名DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("group1");//2.指定Nameserver地址consumer.setNamesrvAddr("192.168.25.135:9876;192.168.25.138:9876");//3.订阅主题Topic和Tagconsumer.subscribe("base", "*");//设定消费模式：负载均衡|广播模式consumer.setMessageModel(MessageModel.BROADCASTING);//4.设置回调函数，处理消息consumer.registerMessageListener(new MessageListenerConcurrently() {//接受消息内容@Overridepublic ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) {for (MessageExt msg : msgs) {System.out.println("consumeThread=" + Thread.currentThread().getName() + "," + new String(msg.getBody()));}return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;}});//5.启动消费者consumerconsumer.start();}
}

消费者广播模式和负载均衡模式相关推荐

LVS负载均衡群集概念、NAT模式LVS负载均衡实战部署
目录引言: 一.群集的含义 1.1 群集存在的必要 1.2 解决方法二.群集的种类 2.1 负载均衡群集(Load Balance Cluster) 2.2 高可用群集 (High Availab ...
LVS——DR模式（负载均衡）
1. DR模式(直接路由模式:Virtual Server via Direct Routing) DR模式是通过改写请求报文的目标MAC地址,将请求发给真实服务器的,而真实服务器响应后的处理结果直接 ...
DR模式——LVS负载均衡群集
文章目录一. LVS-DR 工作原理二. 数据包流向分析三. DR 模式的特点四. LVS-DR 数据包流向分析 1. Cilent (客户端)向目标 VIP 发送请求,Director (负 ...
lvs-nat负载均衡模式
文章的开始,我们要先弄懂一下几个问题 1. 为什么要使用lvs? 随着互联网的发展使多媒体网络服务器面对的访问量快速增加,服务器需要具备提供大量并发访问的能力,因此对于大负载的服务器来讲,CPU,I/ ...
LVS——TUN隧道模式（负载均衡）
1.什么IP隧道技术? 简单来说IP隧道技术就是将 [IP数据包] 的上面再封装一层[IP数据包], 然后路由器根据最外层的IP地址路由到目的地服务器,目的地服务器拆掉最外层的IP数据包,拿到里面的I ...
bond的主备模式_centos 7.0双网卡主备和负载均衡模式配置（bond0）
网卡bond是通过把多张网卡绑定为一个逻辑网卡,实现本地网卡的冗余,带宽扩容和负载均衡.在应用部署中是一种常用的技术,bond共有7中模式,mode 0-6,但是常用的模式有三种: mode=0:平衡 ...
Nginx+Tomcat实现负载均衡、动静分离集群部署
Nginx+Tomcat实现负载均衡.动静分离集群部署一.Tomcat多实例部署 1.安装好jdk 2.安装tomcat 3.配置tomcat环境变量 4.修改tomcat2中的server.xml ...
BizTalk高可用配置方法（故障转移集群+负载均衡）
非常感谢[chnking]写的两篇Biztalk 2009在Windows 2008 R2环境中的High Availability(Cluster群集)部署的文章,写的非常详细,只要按照步骤一步一 ...
Linux系统（五）负载均衡LVS集群之DR模式
序言 DR模式是lvs集群中三种负载均衡模式的其中一种,那么上一篇中我写啦关于NAT模式的搭建与原理,为什么还要有DR模式与IP隧道模式呢? 首先我们来看3张图.LVS/NAT模式如下图: LVS/I ...

消费者广播模式和负载均衡模式

消费消息

1）负载均衡模式

2）广播模式

消费者广播模式和负载均衡模式相关推荐

最新文章

热门文章