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

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

开发者学堂课程【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一站式入门使用
从源码编译、部署broker、部署namesrv,使用java客户端首发消息等一站式入门RocketMQ。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
相关文章
|
12月前
|
负载均衡 网络性能优化
EMQ如何保证消息不重复消费?
EMQ(Erlang MQTT Broker)通过以下机制来保证消息不重复消费
569 2
|
2月前
|
消息中间件 监控 中间件
【工作中问题解决实践 十一】Kafka消费者消费堆积且频繁rebalance
【工作中问题解决实践 十一】Kafka消费者消费堆积且频繁rebalance
154 0
|
消息中间件 缓存 算法
阿里二面:RocketMQ 消息积压了,增加消费者有用吗?
阿里二面:RocketMQ 消息积压了,增加消费者有用吗?
220 0
阿里二面:RocketMQ 消息积压了,增加消费者有用吗?
|
消息中间件 存储 RocketMQ
阿里二面:RocketMQ同一个消费组内的消费者订阅量不同tag,会有问题吗?
阿里二面:RocketMQ同一个消费组内的消费者订阅量不同tag,会有问题吗?
677 0
阿里二面:RocketMQ同一个消费组内的消费者订阅量不同tag,会有问题吗?
|
消息中间件 Java RocketMQ
消息消费要注意的细节|学习笔记
快速学习消息消费要注意的细节
72 0
消息消费要注意的细节|学习笔记
|
双11 iOS开发 开发者
消费者需求的不同状态 | 学习笔记
快速学习消费者需求的不同状态。
411 0
消费者需求的不同状态 | 学习笔记
|
消息中间件 RocketMQ 开发者
消息消费初探|学习笔记
快速学习消息消费初探
71 0
消息消费初探|学习笔记
|
消息中间件 NoSQL Kafka
|
消息中间件 负载均衡 Java
消息消费基本流程|学习笔记
快速学习消息消费基本流程
76 0
|
消息中间件 RocketMQ 开发者
消息消费概述|学习笔记
快速学习消息消费概述
70 0