开发者学堂课程【RocketMQ 知识精讲与项目实战(第二阶段):消息消费方准备工作】学习笔记,与课程紧密联系,让用户快速学习知识。
课程地址:https://developer.aliyun.com/learning/course/703/detail/12427
消息消费方准备工作
内容介绍:
一、配置 RocketMQ 属性值
二、创建监听类消费信息
一、配置 RocketMQ 属性值
消息已经发送到 MQ 里,接下来要开发消息的消费方。
按照流程,消息的消费方分别要在库存服务、优惠券服务,用户服务和订单服务里开发。
消费方要配置 name-server 地址,消费者组名,以及 topic。
mq.order.consumer.group.name=order_orderTopic_cancel_group
m
q.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,其次是消费者的组,最后就是消息的模型。
继续输入
(t
opic=”${}”,consumerGroup=””,messageModel=
)。
m
q.order.consumer.group.name
,m
q.order.topic
,
mq.order.tag.camcel 是名字,分别输入对应的大括号中。
消息消费的模型根据消息发送后同时都要去消费的分析,所以消息消费的模型是广播的模式,设置 broadcasting。
其他几个模块也通过这种方式,准备对应的 listener,做好准备工作。