消息消费方准备工作|学习笔记

简介: 快速学习消息消费方准备工作

开发者学堂课程【RocketMQ 知识精讲与项目实战(第二阶段)消息消费方准备工作】学习笔记,与课程紧密联系,让用户快速学习知识。

课程地址https://developer.aliyun.com/learning/course/703/detail/12427


消息消费方准备工作


内容介绍:

一、配置 RocketMQ 属性值

二、创建监听类消费信息


一、配置 RocketMQ 属性值

消息已经发送到 MQ 里,接下来要开发消息的消费方。

按照流程,消息的消费方分别要在库存服务、优惠券服务,用户服务和订单服务里开发。

image.png

消费方要配置 name-server 地址,消费者组名,以及 topic。

mq.order.consumer.group.name=order_orderTopic_cancel_group

mq.order.topic= orderTopic

mq.order.tag.camcel= order_ cancel

将这些信息分别设置到上述微服务里。设置 coupon-service, name server 已经配置。

其次, orderTopic_consume_group 进行处理。

发现在 goods-services 里,消费者的组以及当前的主题也配置。最后 order-service 也要去进行设置,可以从笔记里面复制代码。

#下单失败消息发送组的注释应该写到#RocketMQ 下方。


二、创建监听类消费信息

order 已经配置。在 user service 里也有接收消息相关的 topic 以及相关配置。之后根据前面的 demo 编写,需要设置监听器的类,通过它们去接受消息。所以要做好每个微服务的准备工作。

首先设置统一的名字叫做 mq. CancelMQListener,输入 MessageListener。

然后设置 Component,在 Component 下要设置 RocketMQmessageListener。

这里需要指定三个属性,首先指定 topic,其次是消费者的组,最后就是消息的模型。

继续输入

(topic=”${}”,consumerGroup=””,messageModel=)。

mq.order.consumer.group.name,mq.order.topic

mq.order.tag.camcel 是名字,分别输入对应的大括号中。

image.png

消息消费的模型根据消息发送后同时都要去消费的分析,所以消息消费的模型是广播的模式,设置 broadcasting。

image.png

其他几个模块也通过这种方式,准备对应的 listener,做好准备工作。

相关实践学习
消息队列RocketMQ版:基础消息收发功能体验
本实验场景介绍消息队列RocketMQ版的基础消息收发功能,涵盖实例创建、Topic、Group资源创建以及消息收发体验等基础功能模块。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
相关文章
|
4月前
|
消息中间件 SQL 分布式计算
大数据-76 Kafka 高级特性 稳定性-消费重复 生产者、Broker、消费者 导致的重复消费问题
大数据-76 Kafka 高级特性 稳定性-消费重复 生产者、Broker、消费者 导致的重复消费问题
68 1
|
6月前
|
消息中间件 负载均衡 Kafka
【Kafka消费秘籍】深入了解消费者组与独立模式,掌握消息消费的两种超能力!
【8月更文挑战第24天】Apache Kafka是一款高性能的分布式消息系统,支持灵活多样的消费模型以适应不同的应用场景。消息按主题组织,每个主题可划分为多个分区,确保消息顺序性。本文深入探讨了Kafka中的两大核心消费模式:消费者组(Consumer Group)和独立消费者(Standalone Consumer)。消费者组允许多个消费者协同工作,实现负载均衡及故障恢复,是最常用的消费模式。独立消费者模式则适用于需要高度定制化处理逻辑的场景,如消息重放等。通过对比这两种模式的特点和提供的示例代码,开发者可以根据具体需求选择最合适的消费策略,从而更好地利用Kafka构建高效的数据流应用程序。
195 3
|
9月前
|
消息中间件
【面试问题】如何确保消息正确地发送至 RabbitMQ? 如何确保消息接收方消费了消息?
【1月更文挑战第27天】【面试问题】如何确保消息正确地发送至 RabbitMQ? 如何确保消息接收方消费了消息?
|
8月前
|
消息中间件 网络协议 物联网
消息队列 MQ产品使用合集之如何让消费者不从最开始进行消费,而是从最后一条消息开始消费
消息队列(MQ)是一种用于异步通信和解耦的应用程序间消息传递的服务,广泛应用于分布式系统中。针对不同的MQ产品,如阿里云的RocketMQ、RabbitMQ等,它们在实现上述场景时可能会有不同的特性和优势,比如RocketMQ强调高吞吐量、低延迟和高可用性,适合大规模分布式系统;而RabbitMQ则以其灵活的路由规则和丰富的协议支持受到青睐。下面是一些常见的消息队列MQ产品的使用场景合集,这些场景涵盖了多种行业和业务需求。
|
8月前
|
消息中间件 存储 负载均衡
消息队列 MQ产品使用合集之POP消费模式是否可以保证消息顺序性
阿里云消息队列MQ(Message Queue)是一种高可用、高性能的消息中间件服务,它允许您在分布式应用的不同组件之间异步传递消息,从而实现系统解耦、流量削峰填谷以及提高系统的可扩展性和灵活性。以下是使用阿里云消息队列MQ产品的关键点和最佳实践合集。
|
8月前
|
消息中间件 存储 监控
揭秘Kafka中消息丢失的背后故事
揭秘Kafka中消息丢失的背后故事
45 0
|
9月前
|
消息中间件 监控 中间件
【工作中问题解决实践 十一】Kafka消费者消费堆积且频繁rebalance
【工作中问题解决实践 十一】Kafka消费者消费堆积且频繁rebalance
572 0
|
消息中间件 NoSQL 关系型数据库
实战:如何防止mq消费方消息重复消费、rocketmq理论概述、rocketmq组成、普通消息的发送
实战:如何防止mq消费方消息重复消费 如果因为网络延迟等原因,mq无法及时接收到消费方的应答,导致mq重试。(计算机网络)。在重试过程中造成重复消费的问题
2816 1
实战:如何防止mq消费方消息重复消费、rocketmq理论概述、rocketmq组成、普通消息的发送
|
消息中间件 Java RocketMQ
消息消费要注意的细节|学习笔记
快速学习消息消费要注意的细节
105 0
消息消费要注意的细节|学习笔记
|
消息中间件 RocketMQ 开发者
消息消费初探|学习笔记
快速学习消息消费初探
消息消费初探|学习笔记