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

创建消息消费者模块

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

    
        tensquare_parent
        com.tensquare
        1.0-SNAPSHOT
    
    4.0.0

    tensquare_sms
    
        
            org.springframework.boot
            spring-boot-starter-amqp
        

    

yml

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

server: 
  port: 9009

spring:
  rabbitmq:
    host: 1

主启动类

package com.tensquare.sms;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

/**
 * 类名称:SmsApplication
 * 类描述:主启动类
 *
 * @author: taohongchao
 * 创建时间:2019/1/27 16:29
 * Version 1.0
 */
@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
 *
 * @author: taohongchao
 * 创建时间:2019/1/27 16:33
 * Version 1.0
 */
@Component
@RabbitListener( queues = "sms")
public class SmsListener {

    @RabbitHandler
    public void executeSms(Map map) {
        System.out.println(map.get("mobile"));
        System.out.println(map.get("checkCode"));
    }
}

测试

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