黑马十次方项目day0510之消息队列消费者环境搭建

创建消息消费者模块

在tensequare_parent中, 创建子模块tensquare_sms
pom中内容如下


<project xmlns&＃61;"http://maven.apache.org/POM/4.0.0"xmlns:xsi&＃61;"http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation&＃61;"http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><parent><artifactId>tensquare_parentartifactId><groupId>com.tensquaregroupId><version>1.0-SNAPSHOTversion>parent><modelVersion>4.0.0modelVersion><artifactId>tensquare_smsartifactId><dependencies><dependency><groupId>org.springframework.bootgroupId><artifactId>spring-boot-starter-amqpartifactId>dependency>dependencies>project>


yml

指定端口号, 指定Rabbitmq的地址

server: port: 9009spring:rabbitmq:host: 1


主启动类

package com.tensquare.sms;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;/*** 类名称:SmsApplication* 类描述:主启动类** &＃64;author: taohongchao* 创建时间:2019/1/27 16:29* Version 1.0*/
&＃64;SpringBootApplication
public class SmsApplication {public static void main(String[] args){SpringApplication.run(SmsApplication.class);}}


消息的消费者

在com.tensquare.sms.listener.SmsListener中,写消息的消费者

package com.tensquare.sms.listener;import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;import java.util.Map;/*** 类名称:SmsListener* 类描述:TODO** &＃64;author: taohongchao* 创建时间:2019/1/27 16:33* Version 1.0*/
&＃64;Component
&＃64;RabbitListener( queues &＃61; "sms")
public class SmsListener {&＃64;RabbitHandlerpublic void executeSms(Map map) {System.out.println(map.get("mobile"));System.out.println(map.get("checkCode"));}
}


测试

启动SmsApplication ,进行测试
控制台打印如下. 打印出来了手机号和验证码, 代码消费消息成功了.