devbox
繁依Fanyi0
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

阿里云发送短信配置

作者：繁依Fanyi0 | 2024-03-29 15:58:20

赞

踩

阿里云发送短信配置

依赖

  1. <dependency>
  2.     <groupId>org.apache.httpcomponents</groupId>
  3.     <artifactId>httpclient</artifactId>
  4.     <version>4.2.1</version>
  5. </dependency>
  6. <dependency>
  7.     <groupId>org.apache.httpcomponents</groupId>
  8.     <artifactId>httpcore</artifactId>
  9.     <version>4.2.1</version>
  10. </dependency>
  11. <dependency>
  12.     <groupId>commons-lang</groupId>
  13.     <artifactId>commons-lang</artifactId>
  14.     <version>2.6</version>
  15. </dependency>
  16. <dependency>
  17.     <groupId>org.eclipse.jetty</groupId>
  18.     <artifactId>jetty-util</artifactId>
  19.     <version>9.3.7.v20160115</version>
  20. </dependency>
  21.     <!-- redis的起步依赖 -->
  22.         <dependency>
  23.             <groupId>org.springframework.boot</groupId>
  24.             <artifactId>spring-boot-starter-data-redis</artifactId>
  25.         </dependency>

配置类

  1.  
  2.  
  3. import org.apache.commons.lang.StringUtils;
  4. import org.apache.http.HttpResponse;
  5. import org.apache.http.NameValuePair;
  6. import org.apache.http.client.HttpClient;
  7. import org.apache.http.client.entity.UrlEncodedFormEntity;
  8. import org.apache.http.client.methods.HttpDelete;
  9. import org.apache.http.client.methods.HttpGet;
  10. import org.apache.http.client.methods.HttpPost;
  11. import org.apache.http.client.methods.HttpPut;
  12. import org.apache.http.conn.ClientConnectionManager;
  13. import org.apache.http.conn.scheme.Scheme;
  14. import org.apache.http.conn.scheme.SchemeRegistry;
  15. import org.apache.http.conn.scheme.SchemeSocketFactory;
  16.  
  17. import org.apache.http.conn.ssl.SSLSocketFactory;
  18. import org.apache.http.entity.ByteArrayEntity;
  19. import org.apache.http.entity.StringEntity;
  20. import org.apache.http.impl.client.DefaultHttpClient;
  21. import org.apache.http.message.BasicNameValuePair;
  22.  
  23.  
  24. import javax.net.ssl.SSLContext;
  25. import javax.net.ssl.TrustManager;
  26. import javax.net.ssl.X509TrustManager;
  27. import java.io.UnsupportedEncodingException;
  28. import java.net.URLEncoder;
  29. import java.security.KeyManagementException;
  30. import java.security.NoSuchAlgorithmException;
  31. import java.security.cert.X509Certificate;
  32. import java.util.ArrayList;
  33. import java.util.List;
  34. import java.util.Map;
  35.  
  36. public class HttpUtils {
  37.  
  38.     /**
  39.      * get
  40.      *
  41.      * @param host
  42.      * @param path
  43.      * @param method
  44.      * @param headers
  45.      * @param querys
  46.      * @return
  47.      * @throws Exception
  48.      */
  49.     public static HttpResponse doGet(String host, String path, String method,
  50.                                      Map<String, String> headers,
  51.                                      Map<String, String> querys)
  52.             throws Exception {
  53.         HttpClient httpClient = wrapClient(host);
  54.  
  55.         HttpGet request = new HttpGet(buildUrl(host, path, querys));
  56.         for (Map.Entry<String, String> e : headers.entrySet()) {
  57.             request.addHeader(e.getKey(), e.getValue());
  58.         }
  59.  
  60.         return httpClient.execute(request);
  61.     }
  62.  
  63.     /**
  64.      * post form
  65.      *
  66.      * @param host
  67.      * @param path
  68.      * @param method
  69.      * @param headers
  70.      * @param querys
  71.      * @param bodys
  72.      * @return
  73.      * @throws Exception
  74.      */
  75.     public static HttpResponse doPost(String host, String path, String method,
  76.                                       Map<String, String> headers,
  77.                                       Map<String, String> querys,
  78.                                       Map<String, String> bodys)
  79.             throws Exception {
  80.         HttpClient httpClient = wrapClient(host);
  81.  
  82.         HttpPost request = new HttpPost(buildUrl(host, path, querys));
  83.         for (Map.Entry<String, String> e : headers.entrySet()) {
  84.             request.addHeader(e.getKey(), e.getValue());
  85.         }
  86.  
  87.         if (bodys != null) {
  88.             List<NameValuePair> nameValuePairList = new ArrayList<NameValuePair>();
  89.  
  90.             for (String key : bodys.keySet()) {
  91.                 nameValuePairList.add(new BasicNameValuePair(key, bodys.get(key)));
  92.             }
  93.             UrlEncodedFormEntity formEntity = new UrlEncodedFormEntity(nameValuePairList, "utf-8");
  94.             formEntity.setContentType("application/x-www-form-urlencoded; charset=UTF-8");
  95.             request.setEntity(formEntity);
  96.         }
  97.  
  98.         return httpClient.execute(request);
  99.     }
  100.  
  101.     /**
  102.      * Post String
  103.      *
  104.      * @param host
  105.      * @param path
  106.      * @param method
  107.      * @param headers
  108.      * @param querys
  109.      * @param body
  110.      * @return
  111.      * @throws Exception
  112.      */
  113.     public static HttpResponse doPost(String host, String path, String method,
  114.                                       Map<String, String> headers,
  115.                                       Map<String, String> querys,
  116.                                       String body)
  117.             throws Exception {
  118.         HttpClient httpClient = wrapClient(host);
  119.  
  120.         HttpPost request = new HttpPost(buildUrl(host, path, querys));
  121.         for (Map.Entry<String, String> e : headers.entrySet()) {
  122.             request.addHeader(e.getKey(), e.getValue());
  123.         }
  124.  
  125.         if (StringUtils.isNotBlank(body)) {
  126.             request.setEntity(new StringEntity(body, "utf-8"));
  127.         }
  128.  
  129.         return httpClient.execute(request);
  130.     }
  131.  
  132.     /**
  133.      * Post stream
  134.      *
  135.      * @param host
  136.      * @param path
  137.      * @param method
  138.      * @param headers
  139.      * @param querys
  140.      * @param body
  141.      * @return
  142.      * @throws Exception
  143.      */
  144.     public static HttpResponse doPost(String host, String path, String method,
  145.                                       Map<String, String> headers,
  146.                                       Map<String, String> querys,
  147.                                       byte[] body)
  148.             throws Exception {
  149.         HttpClient httpClient = wrapClient(host);
  150.  
  151.         HttpPost request = new HttpPost(buildUrl(host, path, querys));
  152.         for (Map.Entry<String, String> e : headers.entrySet()) {
  153.             request.addHeader(e.getKey(), e.getValue());
  154.         }
  155.  
  156.         if (body != null) {
  157.             request.setEntity(new ByteArrayEntity(body));
  158.         }
  159.  
  160.         return httpClient.execute(request);
  161.     }
  162.  
  163.     /**
  164.      * Put String
  165.      * @param host
  166.      * @param path
  167.      * @param method
  168.      * @param headers
  169.      * @param querys
  170.      * @param body
  171.      * @return
  172.      * @throws Exception
  173.      */
  174.     public static HttpResponse doPut(String host, String path, String method,
  175.                                      Map<String, String> headers,
  176.                                      Map<String, String> querys,
  177.                                      String body)
  178.             throws Exception {
  179.         HttpClient httpClient = wrapClient(host);
  180.  
  181.         HttpPut request = new HttpPut(buildUrl(host, path, querys));
  182.         for (Map.Entry<String, String> e : headers.entrySet()) {
  183.             request.addHeader(e.getKey(), e.getValue());
  184.         }
  185.  
  186.         if (StringUtils.isNotBlank(body)) {
  187.             request.setEntity(new StringEntity(body, "utf-8"));
  188.         }
  189.  
  190.         return httpClient.execute(request);
  191.     }
  192.  
  193.     /**
  194.      * Put stream
  195.      * @param host
  196.      * @param path
  197.      * @param method
  198.      * @param headers
  199.      * @param querys
  200.      * @param body
  201.      * @return
  202.      * @throws Exception
  203.      */
  204.     public static HttpResponse doPut(String host, String path, String method,
  205.                                      Map<String, String> headers,
  206.                                      Map<String, String> querys,
  207.                                      byte[] body)
  208.             throws Exception {
  209.         HttpClient httpClient = wrapClient(host);
  210.  
  211.         HttpPut request = new HttpPut(buildUrl(host, path, querys));
  212.         for (Map.Entry<String, String> e : headers.entrySet()) {
  213.             request.addHeader(e.getKey(), e.getValue());
  214.         }
  215.  
  216.         if (body != null) {
  217.             request.setEntity(new ByteArrayEntity(body));
  218.         }
  219.  
  220.         return httpClient.execute(request);
  221.     }
  222.  
  223.     /**
  224.      * Delete
  225.      *
  226.      * @param host
  227.      * @param path
  228.      * @param method
  229.      * @param headers
  230.      * @param querys
  231.      * @return
  232.      * @throws Exception
  233.      */
  234.     public static HttpResponse doDelete(String host, String path, String method,
  235.                                         Map<String, String> headers,
  236.                                         Map<String, String> querys)
  237.             throws Exception {
  238.         HttpClient httpClient = wrapClient(host);
  239.  
  240.         HttpDelete request = new HttpDelete(buildUrl(host, path, querys));
  241.         for (Map.Entry<String, String> e : headers.entrySet()) {
  242.             request.addHeader(e.getKey(), e.getValue());
  243.         }
  244.  
  245.         return httpClient.execute(request);
  246.     }
  247.  
  248.     private static String buildUrl(String host, String path, Map<String, String> querys) throws UnsupportedEncodingException {
  249.         StringBuilder sbUrl = new StringBuilder();
  250.         sbUrl.append(host);
  251.         if (!StringUtils.isBlank(path)) {
  252.             sbUrl.append(path);
  253.         }
  254.         if (null != querys) {
  255.             StringBuilder sbQuery = new StringBuilder();
  256.             for (Map.Entry<String, String> query : querys.entrySet()) {
  257.                 if (0 < sbQuery.length()) {
  258.                     sbQuery.append("&");
  259.                 }
  260.                 if (StringUtils.isBlank(query.getKey()) && !StringUtils.isBlank(query.getValue())) {
  261.                     sbQuery.append(query.getValue());
  262.                 }
  263.                 if (!StringUtils.isBlank(query.getKey())) {
  264.                     sbQuery.append(query.getKey());
  265.                     if (!StringUtils.isBlank(query.getValue())) {
  266.                         sbQuery.append("=");
  267.                         sbQuery.append(URLEncoder.encode(query.getValue(), "utf-8"));
  268.                     }
  269.                 }
  270.             }
  271.             if (0 < sbQuery.length()) {
  272.                 sbUrl.append("?").append(sbQuery);
  273.             }
  274.         }
  275.  
  276.         return sbUrl.toString();
  277.     }
  278.  
  279.     private static HttpClient wrapClient(String host) {
  280.         HttpClient httpClient = new DefaultHttpClient();
  281.         if (host.startsWith("https://")) {
  282.             sslClient(httpClient);
  283.         }
  284.  
  285.         return httpClient;
  286.     }
  287.  
  288.     private static void sslClient(HttpClient httpClient) {
  289.         try {
  290.             SSLContext ctx = SSLContext.getInstance("TLS");
  291.             X509TrustManager tm = new X509TrustManager() {
  292.                 public X509Certificate[] getAcceptedIssuers() {
  293.                     return null;
  294.                 }
  295.                 public void checkClientTrusted(X509Certificate[] xcs, String str) {
  296.  
  297.                 }
  298.                 public void checkServerTrusted(X509Certificate[] xcs, String str) {
  299.  
  300.                 }
  301.             };
  302.             ctx.init(null, new TrustManager[] { tm }, null);
  303.             SSLSocketFactory ssf = new SSLSocketFactory(ctx);
  304.             ssf.setHostnameVerifier(SSLSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER);
  305.             ClientConnectionManager ccm = httpClient.getConnectionManager();
  306.             SchemeRegistry registry = ccm.getSchemeRegistry();
  307.             registry.register(new Scheme("https", 443, (SchemeSocketFactory) ssf));
  308.         } catch (KeyManagementException ex) {
  309.             throw new RuntimeException(ex);
  310.         } catch (NoSuchAlgorithmException ex) {
  311.             throw new RuntimeException(ex);
  312.         }
  313.     }
  314. }

controller

  1. @RestController
  2. @RequestMapping("api/user/sms")
  3. public class SmsController {
  4.  
  5.     @Resource
  6.     private SmsService smsService ;
  7.  
  8.     @GetMapping(value = "/sendCode/{phone}")
  9.     public Result sendValidateCode(@PathVariable String phone) {
  10.         smsService.sendValidateCode(phone);
  11.         return Result.build(null , ResultCodeEnum.SUCCESS) ;
  12.     }
  13.  
  14. }

servicesImpl

  1. import com.alibaba.nacos.common.utils.StringUtils;
  2. import com.atguigu.service.SmsService;
  3. import com.atguigu.utils.HttpUtils;
  4. import jakarta.annotation.Resource;
  5. import org.apache.commons.lang3.RandomStringUtils;
  6. import org.apache.http.HttpResponse;
  7. import org.springframework.data.redis.core.RedisTemplate;
  8.  
  9. import java.util.HashMap;
  10. import java.util.Map;
  11. import java.util.concurrent.TimeUnit;
  12.  
  13. public class SmsServiceImpl implements SmsService {
  14.     @Resource
  15.     private RedisTemplate<String,String> redisTemplate;
  16.     @Override
  17.     public void sendValidateCode(String phone) {
  18.         String code = redisTemplate.opsForValue().get("phone:code:" + phone);
  19.         if(StringUtils.hasText(code)) {
  20.             return;
  21.         }
  22.  
  23.         String validateCode = RandomStringUtils.randomNumeric(4);      // 生成验证码
  24.         redisTemplate.opsForValue().set("phone:code:" + phone , validateCode , 5 , TimeUnit.MINUTES);
  25.         sendSms(phone , validateCode) ;
  26.     }
  27.     public void sendSms(String phone, String validateCode)
  28.     {
  29.         String host = "https://dfsns.market.alicloudapi.com";
  30.         String path = "/data/send_sms";
  31.         String method = "POST";
  32.         String appcode = "你自己的AppCode";
  33.         Map<String, String> headers = new HashMap<String, String>();
  34.         //最后在header中的格式(中间是英文空格)为Authorization:APPCODE 83359fd73fe94948385f570e3c139105
  35.         headers.put("Authorization", "APPCODE " + appcode);
  36.         //根据API的要求，定义相对应的Content-Type
  37.         headers.put("Content-Type", "application/x-www-form-urlencoded; charset=UTF-8");
  38.         Map<String, String> querys = new HashMap<String, String>();
  39.         Map<String, String> bodys = new HashMap<String, String>();
  40.         bodys.put("content", "code:"+validateCode);
  41.         bodys.put("template_id", "CST_ptdie100");  //注意，CST_ptdie100该模板ID仅为调试使用，调试结果为"status": "OK" ，即表示接口调用成功，然后联系客服报备自己的专属签名模板ID，以保证短信稳定下发
  42.         bodys.put("phone_number", phone);
  43.  
  44.  
  45.         try {
  46.             /**
  47.              * 重要提示如下:
  48.              * HttpUtils请从
  49.              * https://github.com/aliyun/api-gateway-demo-sign-java/blob/master/src/main/java/com/aliyun/api/gateway/demo/util/HttpUtils.java
  50.              * 下载
  51.              *
  52.              * 相应的依赖请参照
  53.              * https://github.com/aliyun/api-gateway-demo-sign-java/blob/master/pom.xml
  54.              */
  55.             HttpResponse response = HttpUtils.doPost(host, path, method, headers, querys, bodys);
  56.             System.out.println(response.toString());
  57.             //获取response的body
  58.             //System.out.println(EntityUtils.toString(response.getEntity()));
  59.         } catch (Exception e) {
  60.             e.printStackTrace();
  61.         }
  62.     }
  63. }

还需要导入mybatis-config.xml

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration PUBLIC
        "-//mybatis.org//DTD Config 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>
    <settings>
        <!-- 设置驼峰标识 -->
        <setting name="mapUnderscoreToCamelCase" value="true"/>
        <!-- 打印SQL语句 -->
        <setting name="logImpl" value="STDOUT_LOGGING"/>
    </settings>
    <plugins>
        <!-- 分页插件 -->
        <plugin interceptor="com.github.pagehelper.PageInterceptor"/>
    </plugins>
</configuration>

日志文件logback-spring.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <configuration>
  3.  
  4.     <contextName>logback</contextName>
  5.  
  6.     <!-- 日志的输出目录 -->
  7.     <property name="log.path" value="D://logs//spzx-manager//logs" />
  8.  
  9.     <!--控制台日志格式：彩色日志-->
  10.     <!-- magenta:洋红 -->
  11.     <!-- boldMagenta:粗红-->
  12.     <!-- cyan:青色 -->
  13.     <!-- white:白色 -->
  14.     <!-- magenta:洋红 -->
  15.     <property name="CONSOLE_LOG_PATTERN" value="%yellow(%date{yyyy-MM-dd HH:mm:ss}) %highlight([%-5level]) %green(%logger) %msg%n"/>
  16.  
  17.     <!--文件日志格式-->
  18.     <property name="FILE_LOG_PATTERN" value="%date{yyyy-MM-dd HH:mm:ss} [%-5level] %thread %file:%line %logger %msg%n" />
  19.  
  20.     <!--编码-->
  21.     <property name="ENCODING" value="UTF-8" />
  22.  
  23.     <!-- 控制台日志 -->
  24.     <appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
  25.         <!-- 临界值过滤器 -->
  26.         <filter class="ch.qos.logback.classic.filter.ThresholdFilter">
  27.             <level>INFO</level>
  28.         </filter>
  29.         <encoder>
  30.             <pattern>${CONSOLE_LOG_PATTERN}</pattern>
  31.             <charset>${ENCODING}</charset>
  32.         </encoder>
  33.     </appender>
  34.  
  35.     <!-- 文件日志 -->
  36.     <appender name="FILE" class="ch.qos.logback.core.FileAppender">
  37.         <file>${log.path}//log.log</file>
  38.         <append>true</append>
  39.         <encoder>
  40.             <pattern>%date{yyyy-MM-dd HH:mm:ss} %msg%n</pattern>
  41.             <charset>${ENCODING}</charset>
  42.         </encoder>
  43.     </appender>
  44.  
  45.     <!-- 开发环境 -->
  46.     <springProfile name="dev">
  47.         <!-- com.atguigu日志记录器：业务程序INFO级别  -->
  48.         <logger name="com.atguigu" level="INFO" />
  49.         <!-- 根日志记录器：INFO级别  -->
  50.         <root level="INFO">
  51.             <appender-ref ref="CONSOLE" />
  52.             <appender-ref ref="FILE" />
  53.         </root>
  54.     </springProfile>
  55.  
  56. </configuration>

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/繁依Fanyi0/article/detail/335998
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号