【金融项目】尚融宝项目（十六）

31、RabbitMQ

31.1、整合Rabbit MQ发送短信

31.1.1、MQ服务器设置

1、访问MQ控制台

http://192.168.100.103:15672

2、创建用户

创建用户 srbuser，配置管理员权限

3、创建虚拟机

创建虚拟机 /srbhost，在Set permission中为新建的用户分配访问虚拟机 /srbhost 和 / 的权限

31.1.2、创建rabbit-mq模块

1、创建模块

srb下创建rabbit-mq模块

2、引入依赖

<dependencies>
    <dependency>
        <groupId>org.springframework.bootgroupId>
        <artifactId>spring-boot-starter-amqpartifactId>
    dependency>
    <dependency>
        <groupId>com.alibabagroupId>
        <artifactId>fastjsonartifactId>
    dependency>
    <dependency>
        <groupId>org.projectlombokgroupId>
        <artifactId>lombokartifactId>
    dependency>
dependencies>
1
2
3
4
5
6
7
8
9
10
11
12
13
14

**3、创建MQConfig **

package com.atguigu.srb.rabbitutil.config;

@Configuration
public class MQConfig {
    @Bean
    public MessageConverter messageConverter(){
        //json字符串转换器
        return new Jackson2JsonMessageConverter();
    }
}
1
2
3
4
5
6
7
8
9
10

**4、创建MQConst **

package com.atguigu.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";//消息队列
}
1
2
3
4
5
6
7

5、创建MQService

package com.atguigu.srb.rabbitutil.service;

@Service
@Slf4j
public class MQService {
    @Resource
    private AmqpTemplate amqpTemplate;
    /**
     *  发送消息
     * @param exchange 交换机
     * @param routingKey 路由
     * @param message 消息
     */
    public boolean sendMessage(String exchange, String routingKey, Object message) {
        log.info("发送消息...........");
        amqpTemplate.convertAndSend(exchange, routingKey, message);
        return true;
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

31.1.3、service-base中创建SmsDTO

package com.atguigu.srb.base.dto;

@Data
@ApiModel(description = "短信")
public class SmsDTO {
    @ApiModelProperty(value = "手机号")
    private String mobile;
    @ApiModelProperty(value = "消息内容")
    private String message;
}
1
2
3
4
5
6
7
8
9
10

31.1.4、service-core中发送消息

1、引入依赖

<dependency>
    <groupId>com.atguigugroupId>
    <artifactId>rabbit-mqartifactId>
    <version>0.0.1-SNAPSHOTversion>
dependency>
1
2
3
4
5
6

**2、添加yml配置 **

  #spring:
  rabbitmq:
    host: 192.168.100.103
    port: 5672
    virtual-host: /srbhost
    username: srbuser
    password: 123456
1
2
3
4
5
6
7

3、根据bindCode获取手机号

UserInfoService接口：

String getMobileByBindCode(String bindCode);
1

UserInfoServiceImpl实现：

@Override
public String getMobileByBindCode(String bindCode) {
    QueryWrapper<UserInfo> userInfoQueryWrapper = new QueryWrapper<>();
    userInfoQueryWrapper.eq("bind_code", bindCode);
    UserInfo userInfo = baseMapper.selectOne(userInfoQueryWrapper);
    return userInfo.getMobile();
}
1
2
3
4
5
6
7

4、向MQ发送消息

UserAccountServiceImpl 充值回调方法的最后添加发送消息的代码：

@Resource
private UserInfoService userInfoService;
@Resource
private MQService mqService;

@Transactional(rollbackFor = Exception.class)
@Override
public void notify(Map<String, Object> paramMap) {
    log.info("充值成功：" + JSONObject.toJSONString(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);
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

31.1.5、service-sms中监听消息

1、引入依赖

<dependency>
    <groupId>com.atguigugroupId>
    <artifactId>rabbit-mqartifactId>
    <version>0.0.1-SNAPSHOTversion>
dependency>
1
2
3
4
5
6

2、添加配置 yml

  #spring:
  rabbitmq:
    host: 192.168.100.103
    port: 5672
    virtual-host: /srbhost
    username: srbuser
    password: 123456
1
2
3
4
5
6
7

3、创建MQ监听器

package com.atguigu.srb.sms.receiver;

@Component
@Slf4j
public class SmsReceiver {
    @Resource
    private SmsService smsService;
    @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<String,Object> param = new HashMap<>();
        param.put("code", smsDTO.getMessage());
        smsService.send(smsDTO.getMobile(), SmsProperties.TEMPLATE_CODE, param);
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

本文章参考B站 尚硅谷《尚融宝》Java微服务分布式金融项目，仅供个人学习使用，部分内容为本人自己见解，与尚硅谷无关。