阶段5 3.微服务项目【学成在线】_day06 页面发布 课程管理_04-页面发布-消费方Cms Client-消费方法-监听队列

创建mq的包,在里面创建ConsumerPostPage。监听MQ。接收页面发布的消息
阶段5 3.微服务项目【学成在线】_day06 页面发布 课程管理_04-页面发布-消费方Cms Client-消费方法-监听队列
写发布页面的方法postPage
阶段5 3.微服务项目【学成在线】_day06 页面发布 课程管理_04-页面发布-消费方Cms Client-消费方法-监听队列
从配置文件内获取要监听的队列的名称
阶段5 3.微服务项目【学成在线】_day06 页面发布 课程管理_04-页面发布-消费方Cms Client-消费方法-监听队列
这样使用@RabbitListener监听配置文件内的队列后,会触发当前这个postPage事件
阶段5 3.微服务项目【学成在线】_day06 页面发布 课程管理_04-页面发布-消费方Cms Client-消费方法-监听队列
拿到消息要解析的格式是json的格式。使用fastJson去解析。
阶段5 3.微服务项目【学成在线】_day06 页面发布 课程管理_04-页面发布-消费方Cms Client-消费方法-监听队列
解析json拿到pageId
阶段5 3.微服务项目【学成在线】_day06 页面发布 课程管理_04-页面发布-消费方Cms Client-消费方法-监听队列
注入Service类。调用里面的保存页面到服务器的具体路径下
阶段5 3.微服务项目【学成在线】_day06 页面发布 课程管理_04-页面发布-消费方Cms Client-消费方法-监听队列

判断页面是否为空,这里也需要打印日志
阶段5 3.微服务项目【学成在线】_day06 页面发布 课程管理_04-页面发布-消费方Cms Client-消费方法-监听队列

先查一下判断页面是否存在。如果不存在那么就返回空 并输出日志。
阶段5 3.微服务项目【学成在线】_day06 页面发布 课程管理_04-页面发布-消费方Cms Client-消费方法-监听队列

启动测试


启动程序就会创建这个交换机
阶段5 3.微服务项目【学成在线】_day06 页面发布 课程管理_04-页面发布-消费方Cms Client-消费方法-监听队列

队列和绑定的routingKey都被创建好了。routingKey就是站点Id
阶段5 3.微服务项目【学成在线】_day06 页面发布 课程管理_04-页面发布-消费方Cms Client-消费方法-监听队列
routingKey就是在配置文件内配置的
阶段5 3.微服务项目【学成在线】_day06 页面发布 课程管理_04-页面发布-消费方Cms Client-消费方法-监听队列

上一篇:Python之路Day06


下一篇:阶段5 3.微服务项目【学成在线】_day06 页面发布 课程管理_12-课程计划查询-需求分析