springboot中activeMQ消息隊列的引入與使用（發送短信）

1.引入pom依賴

<!--activemq-->
<dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-activemq</artifactId>
</dependency>
2.application.properties配置文件中

#activemq
spring.activemq.broker-url=tcp://192.168.0.110:61616
spring.activemq.user=admin
spring.activemq.password=admin
spring.activemq.pool.enabled=false

3.創建類
Producer 類(生產者)

@Service
@Slf4j
public class Producer {
    @Autowired
    private JmsMessagingTemplate JmsMessagingTemplate;//紅線運行無錯,貌似是idea的問題 ,可忽略

    public void sendMsg(String destinationName,String message){
        log.info("發送消息:"+message);
        Destination Destination = new ActiveMQQueue(destinationName);
        JmsMessagingTemplate.convertAndSend(Destination,message);
    }
}

Consumer 類(消費者)

@Service
@Slf4j
public class Consumer {
    @Autowired
    private RedisService redisService;
    
    @JmsListener(destination = "test.queue")
    public void receiveMsg(String msg){
        log.info("收到消息:"+msg);
    }

    @JmsListener(destination = "order")
    public void order(String msg){
        log.info("收到消息:"+msg);
    }

    @JmsListener(destination = "sendmsg")
    public void sendmsg(String msg)throws Exception{
        log.info("消息隊列收到消息:"+msg);
        JSONObject jo = JSONObject.parseObject(msg);
        String mobile=jo.getString("mobile");
        String msg1 = "{\"code\":\"" + jo.getString("code") + "\"}";
        SendSmsResponse response = AliyunSms.sendSms(mobile, "SMS_146801291", msg1);
    }
}
4.測試

@ResponseBody
@RequestMapping(value = "/getIdenCode1",method = RequestMethod.POST)
public ReturnVO getIdenCode1(HttpServletRequest request) {
    String mobile = request.getParameter("mobile");
    String code="123456";
    if (StringUtils.isBlank(mobile)) {
        return new ReturnVO(0,"缺少必要參數");
    }
    //消息隊列
    producer.sendMsg("sendmsg","{\"mobile\":\""+mobile+"\",\"code\":\""+code+"\"}");
    return new ReturnVO(true);
}
5.附件類

<!--阿里短信-->
<dependency>
   <groupId>com.aliyun</groupId>
   <artifactId>aliyun-java-sdk-core</artifactId>
   <version>3.7.1</version>
</dependency>
<dependency>
   <groupId>com.aliyun</groupId>
   <artifactId>aliyun-java-sdk-dysmsapi</artifactId>
   <version>1.1.0</version>
</dependency>

<!-- fastjson阿里巴巴jSON處理器 -->
<dependency>
   <groupId>com.alibaba</groupId>
   <artifactId>fastjson</artifactId>
   <version>1.2.13</version>
</dependency>

阿里雲短信工具類

public class AliyunSms {
    //產品名稱:雲通信短信API產品,開發者無需替換
    static final String product = "Dysmsapi";
    //產品域名,開發者無需替換
    static final String domain = "dysmsapi.aliyuncs.com";

    // TODO 此處需要替換成開發者自己的AK(在阿里雲訪問控制台尋找)
    static final String accessKeyId = "accessKeyId";
    static final String accessKeySecret = "accessKeySecret";

    public static SendSmsResponse sendSms(String phone, String template, String msg) throws ClientException {
        //可自助調整超時時間
        System.setProperty("sun.net.client.defaultConnectTimeout", "10000");
        System.setProperty("sun.net.client.defaultReadTimeout", "10000");
        //初始化acsClient,暫不支持region化
        IClientProfile profile = DefaultProfile.getProfile("cn-hangzhou", accessKeyId, accessKeySecret);
        DefaultProfile.addEndpoint("cn-hangzhou", "cn-hangzhou", product, domain);
        IAcsClient acsClient = new DefaultAcsClient(profile);
        //組裝請求對象-具體描述見控制台-文檔部分內容
        SendSmsRequest request = new SendSmsRequest();
        //必填:待發送手機號
        request.setPhoneNumbers(phone);
        //必填:短信簽名-可在短信控制台中找到
        request.setSignName("短信簽名");
        //必填:短信模板-可在短信控制台中找到
        request.setTemplateCode(template);
        //可選:模板中的變量替換JSON串,如模板內容為"親愛的${name},您的驗證碼為${code}"時,此處的值為
        request.setTemplateParam(msg);
        //選填-上行短信擴展碼(無特殊需求用戶請忽略此字段)
        //request.setSmsUpExtendCode("90997");
        //可選:outId為提供給業務方擴展字段,最終在短信回執消息中將此值帶回給調用者
//        request.setOutId("yourOutId");
        //hint 此處可能會拋出異常，注意catch
        SendSmsResponse sendSmsResponse = acsClient.getAcsResponse(request);
        return sendSmsResponse;
    }

    public static QuerySendDetailsResponse querySendDetails(String bizId) throws ClientException {
        //可自助調整超時時間
        System.setProperty("sun.net.client.defaultConnectTimeout", "10000");
        System.setProperty("sun.net.client.defaultReadTimeout", "10000");
        //初始化acsClient,暫不支持region化
        IClientProfile profile = DefaultProfile.getProfile("cn-hangzhou", accessKeyId, accessKeySecret);
        DefaultProfile.addEndpoint("cn-hangzhou", "cn-hangzhou", product, domain);
        IAcsClient acsClient = new DefaultAcsClient(profile);
        //組裝請求對象
        QuerySendDetailsRequest request = new QuerySendDetailsRequest();
        //必填-號碼
        request.setPhoneNumber("12300000000");
        //可選-流水號
        request.setBizId(bizId);
        //必填-發送日期 支持30天內記錄查詢，格式yyyyMMdd
        SimpleDateFormat ft = new SimpleDateFormat("yyyyMMdd");
        request.setSendDate(ft.format(new Date()));
        //必填-頁大小
        request.setPageSize(10L);
        //必填-當前頁碼從1開始計數
        request.setCurrentPage(1L);
        //hint 此處可能會拋出異常，注意catch
        QuerySendDetailsResponse querySendDetailsResponse = acsClient.getAcsResponse(request);
        return querySendDetailsResponse;
    }
}