springboot整合RabbitMQ发送短信的实现

# 安装
rpm -ivh erlang-21.3.8.9-1.el7.x86_64.rpm 
rpm -ivh socat-1.7.3.2-1.el6.lux.x86_64.rpm 
rpm -ivh rabbitmq-server-3.8.1-1.el7.noarch.rpm 

# 卸载
#rpm -qa | grep rabbitmq

# 启用管理插件
rabbitmq-plugins enable rabbitmq_management

# 启动RabbitMQ
systemctl start rabbitmq-server.service
#systemctl status rabbitmq-server.service
#systemctl restart rabbitmq-server.service
#systemctl stop rabbitmq-server.service

# 查看进程
ps -ef | grep rabbitmq

# 添加管理员账号密码
rabbitmqctl add_user admin admin

# 分配账号角色
rabbitmqctl set_user_tags admin administrator

# 修改密码（需要修改一次密码，否则无法登录）
rabbitmqctl change_password admin 123456

# 查看用户列表
rabbitmqctl list_users

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

		
			com.alibaba
			fastjson
		

		
			org.projectlombok
			lombok
		
	

package com.indi.srb.rabbitutil.config;

@Configuration
public class MQConfig {
    @Bean
    public MessageConverter messageConverter(){
        // json字符串转换器
        return new Jackson2JsonMessageConverter();
    }
}

package com.indi.srb.rabbitutil.constant;

public class MQConst {
    public static final String EXCHANGE_TOPIC_SMS = "exchange.topic.sms";//交换机
    public static final String ROUTING_SMS_ITEM = "routing.sms.item";//路由
    public static final String QUEUE_SMS_ITEM  = "queue.sms.item";//消息队列
}

package com.indi.srb.rabbitutil.service;

@Service
@Slf4j
public class MQService {
    @Resource
    private AmqpTemplate amqpTemplate;

    /**
     * 发送消息
     * @param exchange  交换机
     * @param routingKey    路由
     * @param message   消息
     * @return
     */
    public boolean sendMessage(String exchange,String routingKey, Object message){
        log.info("发送消息");
        amqpTemplate.convertAndSend(exchange,routingKey,message);
        return true;
    }
}

package com.indi.srb.base.dto;

@Data
@ApiModel(description = "短信")
public class SmsDTO {
    @ApiModelProperty(value = "手机号")
    private String mobile;

    @ApiModelProperty(value = "消息内容")
    private String message;
}

		
		
			com.indi
			rabbit-mq
			1.0-SNAPSHOT
		

  #spring:
  rabbitmq:
    host: 虚拟机ip
    port: 5672
    virtual-host: /srbhost
    username: srbuser
    password: 123456

    // 根据bindCode获取手机号
	String getMobileByBindCode(String bindCode);

    @Override
    public String getMobileByBindCode(String bindCode) {
        QueryWrapper queryWrapper = new QueryWrapper<>();
        queryWrapper.select("mobile").eq("bind_code",bindCode);
        UserInfo userInfo = baseMapper.selectOne(queryWrapper);
        return userInfo.getMobile();
    }

    @Resource
    private UserInfoService userInfoService;

    @Resource
    private MQService mqService;

    @Transactional(rollbackFor = Exception.class)
    @Override
    public String notify(Map paramMap) {
        log.info("发消息");
        String mobile = userInfoService.getMobileByBindCode(bindCode);
        SmsDTO smsDTO = new SmsDTO();
        smsDTO.setMobile(mobile);
        smsDTO.setMessage("充值成功");
        mqService.sendMessage(MQConst.EXCHANGE_TOPIC_SMS,MQConst.ROUTING_SMS_ITEM,smsDTO);
        return "success";
    }

		
		
			com.indi
			rabbit-mq
			1.0-SNAPSHOT
		

  #spring:
  rabbitmq:
    host: 虚拟机ip
    port: 5672
    virtual-host: /srbhost
    username: srbuser
    password: 123456

package com.indi.srb.sms.receiver;

@Component
@Slf4j
public class SmsReceiver {
    @Resource
    private SmsService smsService;

    // 此处的exchange与key必须与发消息传的一致
    @RabbitListener(bindings = @QueueBinding(
            value = @Queue(value = MQConst.QUEUE_SMS_ITEM, durable = "true"),
            exchange = @Exchange(value = MQConst.EXCHANGE_TOPIC_SMS),
            key = {MQConst.ROUTING_SMS_ITEM}
    ))
    public void send(SmsDTO smsDTO) throws IOException {
        log.info("SmsReceiver 消息监听");
        Map param = new HashMap<>();
        param.put("code", smsDTO.getMessage());
        smsService.send(smsDTO.getMobile(), SmsProperties.TEMPLATE_CODE, param);
    }
}