public
class
ConsumeMessageClusteringDemo {
protected
void
init() {
DefaultMQPushConsumer consumer =
new
DefaultMQPushConsumer(
"ConsumerGroupName"
);
/**
* 订阅指定topic下tags分别等于TagA或TagC或TagD
*/
try
{
consumer.setMessageModel(MessageModel.BROADCASTING);
consumer.subscribe(
"TopicTest1"
,
"TagA || TagC || TagD"
);
/**
* 订阅指定topic下所有消息<br>
* 注意:一个consumer对象可以订阅多个topic
*/
consumer.subscribe(
"TopicTest2"
,
"*"
);
/**
* 设置Consumer第一次启动是从队列头部开始消费还是队列尾部开始消费<br>
* 如果非第一次启动,那么按照上次消费的位置继续消费
*/
consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);
consumer.registerMessageListener(
new
MessageListenerConcurrently() {
/**
* 默认msgs里只有一条消息,可以通过设置consumeMessageBatchMaxSize参数来批量接收消息
*/
@Override
public
ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) {
System.out.println(Thread.currentThread().getName() +
" Receive New Messages: "
+ msgs);
MessageExt msg = msgs.get(
0
);
if
(msg.getTopic().equals(
"TopicTest1"
)) {
if
(msg.getTags() !=
null
&& msg.getTags().equals(
"TagA"
)) {
String msgbody =
new
String(msg.getBody());
System.out.println(msgbody);
}
else
if
(msg.getTags() !=
null
&& msg.getTags().equals(
"TagC"
)) {
String msgbody =
new
String(msg.getBody());
System.out.println(msgbody);
}
else
if
(msg.getTags() !=
null
&& msg.getTags().equals(
"TagD"
)) {
String msgbody =
new
String(msg.getBody());
System.out.println(msgbody);
}
}
else
if
(msg.getTopic().equals(
"TopicTest2"
)) {
}
return
ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
}
});
/**
* Consumer对象在使用之前必须要调用start初始化,初始化一次即可<br>
*/
consumer.start();
}
catch
(MQClientException e) {
e.printStackTrace();
}
}
}
相关推荐
(最新) 阿里云消息 RocketMQ开发手册,加入最新的规则
RocketMQ 开发手册 3.2.4.pdf,RocketMQ官方开发手册文档
描述 RocketMQ 的多个关键特性的实现原理,幵对消息中间件遇到的各种问题迕行总结,阐述 RocketMQ 如何解决返些问题。
强大的mq队列学习文档 ,开发手册强大的mq队列学习文档 ,开发手册强大的mq队列学习文档 ,开发手册
本文档旨在描述 RocketMQ 的多个关键特性的实现原理,幵对消息中间件遇到的各种问题迕行总结,阐述 RocketMQ 如何解决返些问题。文中主要引用了 JMS 规范不 CORBA Notification 规范,规范为我们设计系统挃明了 方吐...
RocketMQ开发指南针对V3.2.4版本
RocketMQ 开发手册3.2.4.pdf,发布时间为2015年,值的一看
rocketMQ-开发手册-3.2.4中文版最新,
RocketMQ 开发指南v3.2.4.pdf
RocketMQ相关文档: RocketMQ实战与原理解析.杨开元(详细书签).pdf RocketMQ架构原理剖析.pptx RocketMQ 开发手册3.2.4.pdf
rocketmq4.5.0安装部署,有安装包、开发手册、配置文件,有2主没有从部署模式和2主2从部署模式,含有mq监控平台部署步骤,以及相关的注意事项。
阿里云原生技术+云原生架构+云原生实践等资料合集,13份。 2021阿里巴巴DevOps实践手册 2021云原生开发者洞察白皮书 ...Knative 云原生应用开发指南 Serverless入门与实战 Spring Cloud Alibabab 从入门到实战
yudao-cloud是以 ruoyi-vue-pro 为基础,实现的 ...基于 Spring Cloud Alibaba + Gateway + Nacos + RocketMQ + Vue & Element 实现的后台管理系统 + 用户小程序,支持 RBAC 动态权限、多租户、数据权限、工作流、三方
SpringCloud Alibaba是阿里巴巴集团开源的一套微服务架构解决方案。其中涵盖了非常多的内容,包括:...该文档详细介绍了Spring Cloud Alibaba服务架构、整个结构、所有组件用法详解,是一本入门和开发参考的必备手册。
包含了常用的MySQL、Redis、RocketMQ、Kafka、Elasticsearch、PostgreSQL、ZooKeeper、Nacos、配置参数详细说明。 这份文档是工作中整理的,现在分享出来,希望给用到的同行提供个参考。 后续如果有其它开发中间件的...
SpringCloud Alibaba是阿里巴巴集团开源的一套微服务架构解决方案。其中涵盖了非常多的内容,包括:...该文档详细介绍了Spring Cloud Alibaba服务架构、整个结构、所有组件用法详解,是一本入门和开发参考的必备手册。
JAVA高级架构师技术栈任何技能通过“刻意练习”都可以达到融会贯通的境界,就像烹饪一样,这里有一份JAVA开发技术手册,只需要增加自己练习的次数。觉得不错,就★Star吧 :party_popper:数据结构和算法数据结构 :...
阿里巴巴Java开发规范手册 UMPAY——编码规范 日志规范 异常规范 网络 协议 TCP/IP HTTP hession file HTTPS 负载均衡 容器 JBOSS tomcat resin jetty 容灾 日志框架 开源框架 slf4j 框架实现...