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

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

开发者学堂课程【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
相关文章
|
2月前
|
消息中间件 SQL 分布式计算
大数据-76 Kafka 高级特性 稳定性-消费重复 生产者、Broker、消费者 导致的重复消费问题
大数据-76 Kafka 高级特性 稳定性-消费重复 生产者、Broker、消费者 导致的重复消费问题
47 1
|
4月前
|
消息中间件 负载均衡 Kafka
【Kafka消费秘籍】深入了解消费者组与独立模式,掌握消息消费的两种超能力!
【8月更文挑战第24天】Apache Kafka是一款高性能的分布式消息系统,支持灵活多样的消费模型以适应不同的应用场景。消息按主题组织,每个主题可划分为多个分区,确保消息顺序性。本文深入探讨了Kafka中的两大核心消费模式:消费者组(Consumer Group)和独立消费者(Standalone Consumer)。消费者组允许多个消费者协同工作,实现负载均衡及故障恢复,是最常用的消费模式。独立消费者模式则适用于需要高度定制化处理逻辑的场景,如消息重放等。通过对比这两种模式的特点和提供的示例代码,开发者可以根据具体需求选择最合适的消费策略,从而更好地利用Kafka构建高效的数据流应用程序。
136 3
|
负载均衡 网络性能优化
EMQ如何保证消息不重复消费?
EMQ(Erlang MQTT Broker)通过以下机制来保证消息不重复消费
795 2
|
7月前
|
消息中间件 监控 中间件
【工作中问题解决实践 十一】Kafka消费者消费堆积且频繁rebalance
【工作中问题解决实践 十一】Kafka消费者消费堆积且频繁rebalance
498 0
|
消息中间件 Kafka 测试技术
MQ 学习日志(七) 保证消息消费的顺序性
保证消息消费的顺序性
190 0
|
消息中间件 Java RocketMQ
消息消费要注意的细节|学习笔记
快速学习消息消费要注意的细节
消息消费要注意的细节|学习笔记
|
消息中间件 RocketMQ 开发者
消息消费初探|学习笔记
快速学习消息消费初探
消息消费初探|学习笔记
|
存储 消息中间件 安全
消息存储的流程|学习笔记
快速学习消息存储的流程
消息存储的流程|学习笔记
|
消息中间件 NoSQL Kafka
|
消息中间件 负载均衡 Java
消息消费基本流程|学习笔记
快速学习消息消费基本流程

热门文章

最新文章