Java實現(xiàn)發(fā)送短信驗證碼+redis限制發(fā)送的次數(shù)功能
更新時間：2022年04月18日 14:25:15 作者：IamaMartian
這篇文章主要介紹了Java實現(xiàn)發(fā)送短信驗證碼+redis限制發(fā)送的次數(shù),本文通過示例代碼給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下
java實現(xiàn)短信驗證碼發(fā)送，由于我們使用第三方平臺進行驗證碼的發(fā)送，所以首先，我們要在一個平臺進行注冊。這樣的平臺有很多，有的平臺在新建賬號的時候會附帶贈幾條免費短信。這里我僅做測試使用(具體哪個平臺見參考三，很簡單，注冊賬號就行，記得添加短信簽名)。
另外，在實際項目中，如果有人惡意攻擊，不停的發(fā)送短信驗證碼，就會造成很大的損失。故對發(fā)送次數(shù)做一定的限制就非常必要，這里我們限制一個手機號一天可以發(fā)多少短信和短信平臺無關(guān)。
這里采用的是存redis來實現(xiàn)這一個功能。就是每次調(diào)用發(fā)送驗證碼這個接口都會判斷手機號碼是否在redis中存為key了。如果沒有則創(chuàng)建一個key為手機號碼value是1.因為redis中不支持數(shù)字所以將其變?yōu)榱藄tring類型。如果redis中已經(jīng)有這個key了則將此key的值取出來加1再存進redis中。
代碼實現(xiàn)：
pom.xml
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.6.2</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>com.lmc</groupId>
<artifactId>springboot-sendsms</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>springboot-sendsms</name>
<description>Demo project for Spring Boot</description>
<properties>
<java.version>1.8</java.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpclient</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>RespBean.java
package com.lmc.bean;
public class RespBean {
private Integer status;
private String msg;
private Object obj;
public static RespBean build() {
return new RespBean();
}
public static RespBean ok(String msg) {
return new RespBean(200, msg, null);
}
public static RespBean ok(String msg, Object obj) {
return new RespBean(200, msg, obj);
}
public static RespBean error(String msg) {
return new RespBean(500, msg, null);
}
public static RespBean error(String msg, Object obj) {
return new RespBean(500, msg, obj);
}
private RespBean() {
}
private RespBean(Integer status, String msg, Object obj) {
this.status = status;
this.msg = msg;
this.obj = obj;
}
public Integer getStatus() {
return status;
}
public RespBean setStatus(Integer status) {
this.status = status;
return this;
}
public String getMsg() {
return msg;
}
public RespBean setMsg(String msg) {
this.msg = msg;
return this;
}
public Object getObj() {
return obj;
}
public RespBean setObj(Object obj) {
this.obj = obj;
return this;
}
}RedisConfig.java
package com.lmc.config;
import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import java.net.UnknownHostException;
@Configuration
public class RedisConfig {
@Bean
@ConditionalOnMissingBean(name = "redisTemplate")
public RedisTemplate<String, Object> redisTemplate(
RedisConnectionFactory redisConnectionFactory)
throws UnknownHostException {
Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<Object>(Object.class);
ObjectMapper om = new ObjectMapper();
om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
jackson2JsonRedisSerializer.setObjectMapper(om);
RedisTemplate<String, Object> template = new RedisTemplate<String, Object>();
template.setConnectionFactory(redisConnectionFactory);
template.setKeySerializer(jackson2JsonRedisSerializer);
template.setValueSerializer(jackson2JsonRedisSerializer);
template.setHashKeySerializer(jackson2JsonRedisSerializer);
template.setHashValueSerializer(jackson2JsonRedisSerializer);
template.afterPropertiesSet();
return template;
}
@ConditionalOnMissingBean(StringRedisTemplate.class)
public StringRedisTemplate stringRedisTemplate(
StringRedisTemplate template = new StringRedisTemplate();
}SMSController.java
package com.lmc.controller;
import com.lmc.bean.RespBean;
import com.lmc.utils.HttpClientUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.Calendar;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.TimeUnit;
/**
* @description:
* @Author: lmc
* @date: 2021/12/26 10:21
*/
@RestController
public class SMSController {
@Autowired
StringRedisTemplate stringRedisTemplate;
@RequestMapping("/send")
public RespBean sendSMS() {
String Uid = "xxxxxxxx";
String Key = "xxxxxxxxxxxxxxx";
String smsMob = "xxxxxxxxx";
String sendSMSCount = "sendSMSCount:" + smsMob;
if ("2".equals(stringRedisTemplate.opsForValue().get(sendSMSCount))) {
return RespBean.error("今天已達到發(fā)送短信驗證碼上限，請明天再試");
}
//短信內(nèi)容
String smsText = "歡迎使用xx系統(tǒng)，驗證碼：8888";
Map maps = new HashMap();
maps.put("Uid", Uid);
maps.put("Key", Key);
maps.put("smsMob", smsMob);
maps.put("smsText", smsText);
String result = HttpClientUtils.sendHttpPost("http://utf8.sms.webchinese.cn", maps);
int i = Integer.parseInt(result);
if (i > 0) {
if (stringRedisTemplate.opsForValue().get(sendSMSCount) == null) {
stringRedisTemplate.opsForValue().set(sendSMSCount, "1", getEndTime(), TimeUnit.MILLISECONDS);
} else {
String value = stringRedisTemplate.opsForValue().get(sendSMSCount);
int times = Integer.parseInt(value) + 1;
String timesStr = String.valueOf(times);
stringRedisTemplate.opsForValue().set(sendSMSCount, timesStr, getEndTime(), TimeUnit.MILLISECONDS);
}
return RespBean.ok("發(fā)送成功");
return RespBean.ok("發(fā)送失敗");
}
//獲取當前時間到今天結(jié)束時間所剩余的毫秒數(shù)：
public static long getEndTime() {
//獲取當前時間的毫秒數(shù)
long time = new java.util.Date().getTime();
//獲取到今天結(jié)束的毫秒數(shù)
Calendar todayEnd = Calendar.getInstance();
todayEnd.set(Calendar.HOUR_OF_DAY, 23); // Calendar.HOUR 12小時制。HOUR_OF_DAY 24小時制
todayEnd.set(Calendar.MINUTE, 59);
todayEnd.set(Calendar.SECOND, 59);
todayEnd.set(Calendar.MILLISECOND, 999);
long endTime = todayEnd.getTimeInMillis();
//這里endTime-time獲取的是到23：59：59：999的毫秒數(shù)。再加1才是到24點整的毫秒數(shù)
return endTime-time+1;
}HttpClientUtils.java(HttpClient工具類，可以復用)
package com.lmc.utils;
import java.io.IOException;
import java.net.URL;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.apache.http.NameValuePair;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.client.methods.HttpRequestBase;
import org.apache.http.conn.ssl.DefaultHostnameVerifier;
import org.apache.http.conn.util.PublicSuffixMatcher;
import org.apache.http.conn.util.PublicSuffixMatcherLoader;
import org.apache.http.entity.ContentType;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.util.EntityUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class HttpClientUtils {
private static Logger logger = LoggerFactory.getLogger(HttpClientUtils.class);
// 鏈接相關(guān)參數(shù)
private static int socketTimeout = 15000;
private static int connectTimeout = 15000;
private static int connectionRequestTimeout = 15000;
private static RequestConfig requestConfig = null;
// 連接池相關(guān)參數(shù)
private static int connMgrMaxTotal = 100;
private static int connMgrMaxPerRoute = 50;
private static PoolingHttpClientConnectionManager connMgr = null;
static {
requestConfig = RequestConfig.custom().setSocketTimeout(socketTimeout).setConnectTimeout(connectTimeout).setConnectionRequestTimeout(connectionRequestTimeout).build();
connMgr = new PoolingHttpClientConnectionManager();
connMgr.setDefaultMaxPerRoute(connMgrMaxPerRoute);
connMgr.setMaxTotal(connMgrMaxTotal);
}
private static String doHttp(HttpRequestBase httpRequestBase) {
CloseableHttpClient httpClient = null;
CloseableHttpResponse response = null;
String responseContent = null;
try {
// 創(chuàng)建默認的httpClient實例.
String scheme = httpRequestBase.getURI().getScheme();
if (scheme.equalsIgnoreCase("https")) {
PublicSuffixMatcher publicSuffixMatcher = PublicSuffixMatcherLoader.load(new URL(httpRequestBase.getURI().toString()));
DefaultHostnameVerifier hostnameVerifier = new DefaultHostnameVerifier(publicSuffixMatcher);
httpClient = HttpClients.custom().setSSLHostnameVerifier(hostnameVerifier).setConnectionManager(connMgr).build();
//httpClient = HttpClients.custom().setSSLHostnameVerifier(hostnameVerifier).build();
} else if (scheme.equalsIgnoreCase("http")) {
httpClient = HttpClients.custom().setConnectionManager(connMgr).build();
//httpClient = HttpClients.createDefault();
} else {
throw new IllegalArgumentException("url的scheme錯誤，必須是http或者https！ ");
}
httpRequestBase.setConfig(requestConfig);
// 執(zhí)行請求
response = httpClient.execute(httpRequestBase);
// 如果這里有必要獲取的是其他資料都可以在這里進行邏輯處理
responseContent = EntityUtils.toString(response.getEntity(), "UTF-8");
return responseContent;
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
// 關(guān)閉連接,釋放資源
if (response != null) {
// EntityUtils.consume(response.getEntity());
response.close();
}
// 這里不能關(guān)閉httpClient，這個會關(guān)鏈接池
//if (httpClient != null) {
// httpClient.close();
//}
} catch (IOException e) {
e.printStackTrace();
}
return responseContent;
/**
* sendHttpGet(url)
* @param url
* @return
*/
public static String sendHttpGet(String url) {
return doHttp(new HttpGet(url));
* sendHttpGet()
* @param param key1=value1&key2=value2&key3=value3
public static String sendHttpGet(String url, String param) {
// 創(chuàng)建httpGet
HttpGet httpGet = new HttpGet(url + '?' + param);
return doHttp(httpGet);
* sendHttpPost()
public static String sendHttpPost(String url, String param) {
// 創(chuàng)建httpPost
HttpPost httpPost = new HttpPost(url);
StringEntity stringEntity = new StringEntity(param, "UTF-8");
stringEntity.setContentType("application/x-www-form-urlencoded");
httpPost.setEntity(stringEntity);
return doHttp(httpPost);
* sendHttpGet
* @param param 是個map<String, String>
public static String sendHttpGet(String url, Map<String, String> param) {
String paramStr = "";
for (String key : param.keySet()) {
String tmp = "";
tmp = "&" + key + "=" + param.get(key);
paramStr += tmp;
paramStr = paramStr.substring(1);
HttpGet httpGet = new HttpGet(url + '?' + paramStr);
return doHttp(httpGet);
* sendHttpPost
* @param param 是個map<String,String>
public static String sendHttpPost(String url, Map<String, String> param) {
// 創(chuàng)建參數(shù)隊列
List<NameValuePair> nameValuePairs = new ArrayList<NameValuePair>();
for (String key : param.keySet()) {
nameValuePairs.add(new BasicNameValuePair(key, param.get(key)));
}
try {
httpPost.setEntity(new UrlEncodedFormEntity(nameValuePairs, "UTF-8"));
} catch (Exception e) {
e.printStackTrace();
return doHttp(httpPost);
public static String sendHttpPostJson(String url, String json) {
// StringEntity stringEntity = new StringEntity(param, "UTF-8");
// stringEntity.setContentType("application/json");
// stringEntity.setContentEncoding("UTF-8");
StringEntity stringEntity = new StringEntity(json, ContentType.create("application/json", "UTF-8"));
public static void main(String[] args) {
String url = "http://api.crpay.com/payapi/gateway";
String param = "merchant_no=TOF00001&method=unified.trade.pay&version=1.0";
Map map = new HashMap<String, String>();
map.put("merchant_no", "TOF00001");
map.put("method", "unified.trade.pay");
map.put("version", "1.0");
// 這個工具是走的鏈接池，但是在關(guān)閉httpClient會關(guān)閉連接池的地方已經(jīng)注銷
//System.out.println(HttpClientUtils.sendHttpPost(url, map));
//System.out.println(HttpClientUtils.sendHttpPost(url, param));
//System.out.println(HttpClientUtils.sendHttpGet(url, map));
System.out.println(HttpClientUtils.sendHttpGet("https://www.baidu.com"));
System.out.println(HttpClientUtils.sendHttpGet("http://www.baidu.com/s?wd=aaa"));
Map map2 = new HashMap<String, String>();
map2.put("wd", "aaa");
System.out.println(HttpClientUtils.sendHttpGet("http://www.baidu.com/s",map2));
// doHttp是靜態(tài)私有方法，不能使用多次，會報Connection pool shut down
System.out.println(HttpClientUtils.doHttp(new HttpGet("http://www.baidu.com/s?wd=aaa")));
System.out.println(HttpClientUtils.doHttp(new HttpGet("https://www.baidu.com/")));
System.out.println(HttpClientUtils.sendHttpGet("https://www.cnblogs.com/hugo-zhangzhen/p/6858013.html"));
System.out.println(HttpClientUtils.sendHttpGet("https://www.cnblogs.com/hugo-zhangzhen/p/6739658.html"));
System.out.println(HttpClientUtils.sendHttpGet("https://www.cnblogs.com/hugo-zhangzhen/p/6737810.html"));
System.out.println(HttpClientUtils.sendHttpGet("http://blog.csdn.net/xiechengfa/article/details/42016153"));
}application.properties
# 配置redis spring.redis.host=127.0.0.1 spring.redis.port=6379 spring.redis.password=123456
項目結(jié)果如下：
結(jié)果展示：
使用postman調(diào)用接口，超過2次后，顯示如下。
在具體項目中的流程一般如下：
①構(gòu)造手機驗證碼，需要生成一個6位的隨機數(shù)字串；
②找短信平臺獲取使用接口向短信平臺發(fā)送手機號和驗證碼，然后短信平臺再把驗證碼發(fā)送到制定手機號上；
③將手機號驗證碼、操作時間存入Session中，作為后面驗證使用；
④接收用戶填寫的驗證碼、手機號及其他注冊數(shù)據(jù)；
⑤對比提交的驗證碼與Session中的驗證碼是否一致，同時判斷提交動作是否在有效期內(nèi)；
⑥驗證碼正確且在有效期內(nèi)，請求通過，處理相應的業(yè)務。
參考：
接收短信驗證碼條數(shù)限制（java發(fā)送短信驗證碼限制） - 簡書
Java 實現(xiàn)手機發(fā)送短信驗證碼 - 胖頭陀春天 - 博客園
到此這篇關(guān)于Java實現(xiàn)發(fā)送短信驗證碼+redis限制發(fā)送的次數(shù)的文章就介紹到這了,更多相關(guān)java短信驗證碼限制發(fā)送次數(shù)內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
這篇文章主要給大家介紹了關(guān)于Java中如何正確定義字符串的相關(guān)資料,在Java中定義一個字符串最簡單的方法是用雙引號把它包圍起來,文中通過代碼介紹的非常詳細,需要的朋友可以參考下2023-10-10
本文主要介紹了Spring?控制反轉(zhuǎn)和依賴注入，文中通過示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2022-02-02
Spring?Boot開發(fā)時Java對象和Json對象之間的轉(zhuǎn)換
在Spring?Boot開發(fā)中,我們經(jīng)常需要處理Java對象和Json對象之間的轉(zhuǎn)換,本文將介紹如何在Spring?Boot項目中實現(xiàn)Java對象和Json對象之間的轉(zhuǎn)換,感興趣的朋友跟隨小編一起看看吧2023-09-09
springboot集成gzip和zip數(shù)據(jù)壓縮傳輸(適用大數(shù)據(jù)信息傳輸)
?在大數(shù)據(jù)量的傳輸中,壓縮數(shù)據(jù)后進行傳輸可以一定程度的解決速度問題,本文主要介紹了springboot集成gzip和zip數(shù)據(jù)壓縮傳輸,具有一定的參考價值,感興趣的可以了解一下2023-09-09
SpringMVC4+MyBatis+SQL Server2014實現(xiàn)數(shù)據(jù)庫讀寫分離
這篇文章主要介紹了SpringMVC4+MyBatis+SQL Server2014實現(xiàn)讀寫分離,需要的朋友可以參考下2017-04-04
這篇文章主要介紹了Java計算機編程語言發(fā)展史,編程語言?可以簡單的理解為一種計算機和人都能識別的語言。一種計算機語言讓程序員能夠準確地定義計算機所需要使用的數(shù)據(jù)，并精確地定義在不同情況下所應當采取的行動,下面詳細內(nèi)容，需要的小伙伴可以參考一下2022-01-01
JAVA 16位ID生成工具類含16位不重復的隨機數(shù)數(shù)字+大小寫
這篇文章主要介紹了JAVA 16位ID生成工具類含16位不重復的隨機數(shù)數(shù)字+大小寫，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2020-02-02
這篇文章主要介紹了Java list如何根據(jù)id獲取子節(jié)點,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2020-03-03
這篇文章主要介紹了Java中的動態(tài)代理實現(xiàn)代碼實例,jdk動態(tài)代理本質(zhì)上是使用被代理對象的類加載器,通過被代理類實現(xiàn)的接口在運行時動態(tài)構(gòu)造出代理類來增強原始類的功能的方法,需要的朋友可以參考下2023-12-12
下面小編就為大家?guī)硪黄獪\談java中null是什么,以及使用中要注意的事項。小編覺得挺不錯的，現(xiàn)在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2017-09-09