AI 助理
备案控制台
开发者社区 微服务 文章 正文

RabbitMQ实战-消费者自定义监听

2021-12-20 469
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： RabbitMQ实战-消费者自定义监听

最开始我们都是编写while循环，通过consumer.nextDelivery方法获取下一条消息，然后进行消费处理。


其实还有另一种选择，使用自定义的Consumer，它更方便，解耦性更强，也是在实际工作中最常用的使用方式。


自定义Con实现只需要继承 DefaultConsumer 类，重写 handleDelivery 方法即可。


代码实现

自定义Con

image.png

Con

image.png

Pro

image.png

启动Con后,查看管控台

image.png

image.png

启动Pro,Con接收消息

image.png

文章标签：
云消息队列 MQ
消息中间件
关键词：
云消息队列 MQ实战
云消息队列 MQ消费者
云消息队列 MQ监听
云消息队列 MQ自定义
消息队列RabbitMQ版消费者
相关实践学习
快速体验阿里云云消息队列RocketMQ版
本实验将带您快速体验使用云消息队列RocketMQ版Serverless系列实例进行获取接入点、创建Topic、创建订阅组、收发消息、查看消息轨迹和仪表盘。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列：消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验：基于MNS，0基础轻松构建 Web Client 本节课带您一起基于MNS，0基础轻松构建 Web Client
javaedge
目录
相关文章
东阳马生架构
|
8月前
|
消息中间件 大数据 关系型数据库
RocketMQ实战—3.基于RocketMQ升级订单系统架构
本文主要介绍了基于MQ实现订单系统核心流程的异步化改造、基于MQ实现订单系统和第三方系统的解耦、基于MQ实现将订单数据同步给大数据团队、秒杀系统的技术难点以及秒杀商详页的架构设计和基于MQ实现秒杀系统的异步化架构。
东阳马生架构
627 64
RocketMQ实战—3.基于RocketMQ升级订单系统架构
东阳马生架构
|
8月前
|
消息中间件 Java 数据库
RocketMQ实战—9.营销系统代码初版
本文主要介绍了实现营销系统四大促销场景的代码初版：全量用户推送促销活动、全量用户发放优惠券、特定用户推送领取优惠券消息、热门商品定时推送。
东阳马生架构
283 8
RocketMQ实战—9.营销系统代码初版
东阳马生架构
|
8月前
|
消息中间件 搜索推荐 调度
RocketMQ实战—8.营销系统业务和方案介绍
本文详细介绍了电商营销系统的业务流程、技术架构及挑战解决方案。涵盖核心交易与支付后履约流程，优惠券和促销活动的发券、领券、用券、销券机制，以及会员与推送的数据库设计。技术架构基于Nacos服务注册中心、Dubbo RPC框架、RocketMQ消息中间件和XXLJob分布式调度工具，实现系统间高效通信与任务管理。针对千万级用户量下的推送和发券场景，提出异步化、分片处理与惰性发券等优化方案，解决高并发压力。同时，通过RocketMQ实现系统解耦，提升扩展性，并利用XXLJob完成爆款商品推荐的分布式调度推送。整体设计确保系统在大规模用户场景下的性能与稳定性。
东阳马生架构
333 6
RocketMQ实战—8.营销系统业务和方案介绍
varin
|
3月前
|
消息中间件 Ubuntu Java
SpringBoot整合MQTT实战：基于EMQX实现双向设备通信
本教程指导在Ubuntu上部署EMQX 5.9.0并集成Spring Boot实现MQTT双向通信，涵盖服务器搭建、客户端配置及生产实践，助您快速构建企业级物联网消息系统。
varin
1626 1
东阳马生架构
|
8月前
|
消息中间件 存储 NoSQL
RocketMQ实战—6.生产优化及运维方案
本文围绕RocketMQ集群的使用与优化，详细探讨了六个关键问题。首先，介绍了如何通过ACL配置实现RocketMQ集群的权限控制，防止不同团队间误用Topic。其次，讲解了消息轨迹功能的开启与追踪流程，帮助定位和排查问题。接着，分析了百万消息积压的处理方法，包括直接丢弃、扩容消费者或通过新Topic间接扩容等策略。此外，提出了针对RocketMQ集群崩溃的金融级高可用方案，确保消息不丢失。同时，讨论了为RocketMQ增加限流功能的重要性及实现方式，以提升系统稳定性。最后，分享了从Kafka迁移到RocketMQ的双写双读方案，确保数据一致性与平稳过渡。
东阳马生架构
378 6
Shepherd
|
6月前
|
消息中间件 存储 Kafka
一文带你从入门到实战全面掌握RocketMQ核心概念、架构部署、实践应用和高级特性
本文详细介绍了分布式消息中间件RocketMQ的核心概念、部署方式及使用方法。RocketMQ由阿里研发并开源，具有高性能、高可靠性和分布式特性，广泛应用于金融、互联网等领域。文章从环境搭建到消息类型的实战（普通消息、延迟消息、顺序消息和事务消息）进行了全面解析，并对比了三种消费者类型（PushConsumer、SimpleConsumer和PullConsumer）的特点与适用场景。最后总结了使用RocketMQ时的关键注意事项，如Topic和Tag的设计、监控告警的重要性以及性能与可靠性的平衡。通过学习本文，读者可掌握RocketMQ的使用精髓并灵活应用于实际项目中。
Shepherd
5272 9
一文带你从入门到实战全面掌握RocketMQ核心概念、架构部署、实践应用和高级特性
东阳马生架构
|
8月前
|
消息中间件 Java 中间件
RocketMQ实战—2.RocketMQ集群生产部署
本文主要介绍了大纲什么是消息中间件、消息中间件的技术选型、RocketMQ的架构原理和使用方式、消息中间件路由中心的架构原理、Broker的主从架构原理、高可用的消息中间件生产部署架构、部署一个小规模的RocketMQ集群进行压测、如何对RocketMQ集群进行可视化的监控和管理、进行OS内核参数和JVM参数的调整、如何对小规模RocketMQ集群进行压测、消息中间件集群生产部署规划梳理。
东阳马生架构
1372 8
RocketMQ实战—2.RocketMQ集群生产部署
东阳马生架构
|
8月前
|
消息中间件 NoSQL 大数据
RocketMQ实战—5.消息重复+乱序+延迟的处理
本文围绕RocketMQ的使用与优化展开，分析了优惠券重复发放的原因及解决方案。首先，通过案例说明了优惠券系统因消息重复、数据库宕机或消费失败等原因导致重复发券的问题，并提出引入幂等性机制（如业务判断法、Redis状态判断法）来保证数据唯一性。其次，探讨了死信队列在处理消费失败时的作用，以及如何通过重试和死信队列解决消息处理异常。接着，分析了订单库同步中消息乱序的原因，提出了基于顺序消息机制的代码实现方案，确保消息按序处理。此外，介绍了利用Tag和属性过滤数据提升效率的方法，以及延迟消息机制优化定时退款扫描的功能。最后，总结了RocketMQ生产实践中的经验.
东阳马生架构
752 4
RocketMQ实战—5.消息重复+乱序+延迟的处理
东阳马生架构
|
8月前
|
消息中间件 Java 测试技术
RocketMQ实战—7.生产集群部署和生产参数
本文详细介绍了RocketMQ生产集群的部署与调优过程，包括集群规划、环境搭建、参数配置和优化策略。
东阳马生架构
524 1
RocketMQ实战—7.生产集群部署和生产参数
东阳马生架构
|
8月前
|
消息中间件 NoSQL Java
RocketMQ实战—10.营销系统代码优化
本文主要介绍了如何对营销系统的四大促销场景的代码进行优化，包括：全量用户推送促销活动、全量用户发放优惠券、特定用户推送领取优惠券消息、热门商品定时推送。
东阳马生架构
263 3

热门文章

最新文章

  • 1
    其他问题排查 | 《Rocket MQ 使用排查指南》第四章
  • 2
    java初中级面试题(SSM+Mysql+微服务(SpringCloud+Dubbo)+消息队列(RocketMQ)+缓存(Redis+MongoDB)+设计模式+搜索引擎(ES)+JVM
  • 3
    springboot RabbitMQ 连接超时配置
  • 4
    基于 RocketMQ 构建阿里云事件驱动引擎EventBridge
  • 5
    基于开源JAVA MQTT Client连接阿里云IoT
  • 6
    AMQP-RabbitMQ/4/路由模式
  • 7
    使用Go语言（Golang）可以实现MQTT协议的点对点（P2P）消息发送。MQTT协议本身支持多种消息收发模式
  • 8
    基于 RocketMQ Prometheus Exporter 打造定制化 DevOps 平台
  • 9
    SpringBoot项目整合Redis，Rabbitmq发送、消费、存储邮件
  • 10
    将 Flink 融合进消息系统，RocketMQ 为什么选择了与 Kafka 不一样的路
  • 1
    【java常见的面试题】RabbitMQ如何设置消息过期 ?
    472
  • 2
    【java常见的面试题】使用RabbitMQ如何保证消息不丢失 ?
    379
  • 3
    【java常见的面试题】为什么会选择使用RabbitMQ ? 有什么好处 ?
    492
  • 4
    【java常见的面试题】项目中哪里用到了RabbitMQ ?
    241
  • 5
    RabbitMQ延时队列插件rabbitmq_delayed_message_exchange-3.8.0.ez，有需要的朋友可自取
    641
  • 6
    RabbitMQ入门指南：初学者也能读懂的教程（五）
    244
  • 7
    RabbitMQ入门指南：初学者也能读懂的教程（四）
    306
  • 8
    RabbitMQ入门指南：初学者也能读懂的教程（三）
    341
  • 9
    RabbitMQ入门指南：初学者也能读懂的教程（二）
    256
  • 10
    RabbitMQ入门指南：初学者也能读懂的教程（一）
    1917

    • 相关课程

    更多
  • 消息队列 RocketMQ 消息集成
  • 消息队列 MNS 入门课程
  • RocketMQ知识精讲与项目实战（第一阶段）
  • RocketMQ知识精讲与项目实战（第二阶段）
  • RocketMQ知识精讲与项目实战（第三阶段）
  • 微服务实战-RocketMQ Binder

    • 相关电子书

    更多
  • RocketMQ Client-GO 介绍
  • RocketMQ Prometheus Exporter 打造定制化 DevOps 平台
  • 基于 RocketMQ Prometheus Exporter 打造定制化 DevOps 平台
    • 下一篇
    基于Python+Vue开发的口腔牙科预约管理系统