创建mq的包,在里面创建ConsumerPostPage。监听MQ。接收页面发布的消息
写发布页面的方法postPage
从配置文件内获取要监听的队列的名称
这样使用@RabbitListener监听配置文件内的队列后,会触发当前这个postPage事件
拿到消息要解析的格式是json的格式。使用fastJson去解析。
解析json拿到pageId
注入Service类。调用里面的保存页面到服务器的具体路径下
判断页面是否为空,这里也需要打印日志
先查一下判断页面是否存在。如果不存在那么就返回空 并输出日志。
启动测试
启动程序就会创建这个交换机
队列和绑定的routingKey都被创建好了。routingKey就是站点Id
routingKey就是在配置文件内配置的