B008-springcloud alibaba 短信服务 sms

- - 短信服务介绍
  - 短信服务使用
  - - 准备工作
    - - 阿里云官网实名认证
      - 开通短信服务
      - 申请认证秘钥
      - 申请短信签名
      - 申请短信模板
    - 短信服务API介绍
    - - 短信发送(SendSms)
      - 短信查询(QuerySendDetails)
      - 功能测试
  - 下单之后发送短信

短信服务介绍

短信服务（Short Message Service）是阿里云为用户提供的一种通信服务的能力。

产品优势：覆盖全面、高并发处理、消息堆积处理、开发管理简单、智能监控调度
产品功能：短信通知、短信验证码、推广短信、异步通知、数据统计
应用场景：短信验证码、系统信息推送、推广短信等
在这里插入图片描述

短信服务使用

接下来,我们使用短信验证码功能来演示短信服务的使用。流程如下:
在这里插入图片描述

准备工作

阿里云官网实名认证

https://www.aliyun.com

开通短信服务

搜索短信服务，开通

申请认证秘钥

右上方头像 - AccessKey 管理 - 创建 AccessKey

申请短信签名

国内消息 - 签名管理 - 添加签名 - 一般写自己公司名

申请短信模板

国内消息 - 模版管理 - 添加模版

短信服务API介绍

短信发送(SendSms)

调用SendSms发送短信。

请求参数
在这里插入图片描述
返回数据

短信查询(QuerySendDetails)

调用QuerySendDetails接口查看短信发送记录和发送状态。

请求参数
在这里插入图片描述
返回数据

功能测试

第1步: 引入阿里云服务依赖

<!--短信发送-->
<dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-alicloud-sms</artifactId>
</dependency>

第2步: 使用阿里云提供的Demo测试短信发送

略

下单之后发送短信

1 在shop-user 模块中加入sms依赖

<!--短信发送-->
<dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-alicloud-sms</artifactId>
</dependency>

2 将阿里短信给出的demo封装成工具类

@Slf4j
public class SmsUtil {//替换成自己申请的accessKeyIdprivate static String accessKeyId = "LTAIMLlf8NKYXn1M";//替换成自己申请的accessKeySecretprivate static String accessKeySecret = "hqyW0zTNzeSIFnZhMEkOaZXVVcr3Gj";static final String product = "Dysmsapi";static final String domain = "dysmsapi.aliyuncs.com";/*** 发送短信** @param phoneNumbers 要发送短信到哪个手机号* @param signName     短信签名[必须使用前面申请的]* @param templateCode 短信短信模板ID[必须使用前面申请的]* @param param        模板中${code}位置传递的内容*/public static void sendSms(String phoneNumbers, String signName, String templateCode, String param) {try {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(phoneNumbers);request.setSignName(signName);request.setTemplateCode(templateCode);request.setTemplateParam(param);request.setOutId("yourOutId");SendSmsResponse sendSmsResponse = acsClient.getAcsResponse(request);if (!"OK".equals(sendSmsResponse.getCode())) {log.info("发送短信失败,{}", sendSmsResponse);throw new RuntimeException(sendSmsResponse.getMessage());}} catch (Exception e) {log.info("发送短信失败,{}", e);throw new RuntimeException("发送短信失败");}}
}

3 修改短信发送的服务

//发送短信的服务
@Slf4j
@Service("shopSmsService")
@RocketMQMessageListener(consumerGroup = "shop-user",topic = "order-topic",consumeMode = ConsumeMode.CONCURRENTLY,//消费模式,指定是否顺序消费 CONCURRENTLY(同步,默认) ORDERLY(顺序)messageModel = MessageModel.CLUSTERING//消息模式 BROADCASTING(广播)  CLUSTERING(集群,默认)
)
public class SmsService implements RocketMQListener<Order> {@Autowiredprivate UserDao userDao;@Overridepublic void onMessage(Order message) {
//        log.info("收到一个订单信息{},接下来发送短信", JSON.toJSONString(message));log.info("接收到了一个订单信息{},接下来就可以发送短信通知了", message);//根据uid 获取手机号User user = userDao.findById(message.getUid()).get();//生成验证码 1-9 6StringBuilder builder = new StringBuilder();for (int i = 0; i < 6; i++) {builder.append(new Random().nextInt(9) + 1);}String smsCode = builder.toString();Param param = new Param(smsCode);try {//发送短信 {"code":"123456"}SmsUtil.sendSms(user.getTelephone(), "黑马旅游网", "SMS_170836451", JSON.toJSONString(param));log.info("短信发送成功");} catch (Exception e) {e.printStackTrace();}}@Data@AllArgsConstructor@NoArgsConstructorclass Param {private String code;}
}