mall整合Redis實現快取功能
本文主要講解mall整合Redis的過程,以簡訊驗證碼的儲存驗證為例。
Redis的安裝和啟動
Redis是用C語言開發的一個高效能鍵值對資料庫,可用於資料快取,主要用於處理大量資料的高訪問負載。
下載Redis,下載地址:https://github.com/MicrosoftArchive/redis/releases
下載完後解壓到指定目錄
在當前位址列輸入cmd後,執行redis的啟動命令:redis-server.exe redis.windows.conf
整合Redis
新增專案依賴
在pom.xml中新增Redis相關依賴
<!--redis依賴配置--><dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId></dependency>
修改SpringBoot配置檔案
在application.yml中新增Redis的配置及Redis中自定義key的配置。
在spring節點下新增Redis的配置
redis: host: localhost # Redis伺服器地址 database: 0 # Redis資料庫索引(預設為0) port: 6379 # Redis伺服器連線埠 password: # Redis伺服器連線密碼(預設為空) jedis: pool: max-active: 8 # 連線池最大連線數(使用負值表示沒有限制) max-wait: -1ms # 連線池最大阻塞等待時間(使用負值表示沒有限制) max-idle: 8 # 連線池中的最大空閒連線 min-idle: 0 # 連線池中的最小空閒連線 timeout: 3000ms # 連線超時時間(毫秒)
在根節點下新增Redis自定義key的配置
# 自定義redis keyredis: key: prefix: authCode: "portal:authCode:" expire: authCode: 120 # 驗證碼超期時間
新增RedisService介面用於定義一些常用Redis操作
package com.macro.mall.tiny.service;
/**
* redis操作Service,
* 物件和陣列都以json形式進行儲存
* Created by macro on 2018/8/7.
*/
public interface RedisService {
/**
* 儲存資料
*/
void set(String key, String value);
/**
* 獲取資料
*/
String get(String key);
/**
* 設定超期時間
*/
boolean expire(String key, long expire);
/**
* 刪除資料
*/
void remove(String key);
/**
* 自增操作
* @param delta 自增步長
*/
Long increment(String key, long delta);
}
注入StringRedisTemplate,實現RedisService介面
package com.macro.mall.tiny.service.impl;
import com.macro.mall.tiny.service.RedisService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Service;
import java.util.concurrent.TimeUnit;
/**
* redis操作Service的實現類
* Created by macro on 2018/8/7.
*/
@Service
public class RedisServiceImpl implements RedisService {
@Autowired
private StringRedisTemplate stringRedisTemplate;
@Override
public void set(String key, String value) {
stringRedisTemplate.opsForValue().set(key, value);
}
@Override
public String get(String key) {
return stringRedisTemplate.opsForValue().get(key);
}
@Override
public boolean expire(String key, long expire) {
return stringRedisTemplate.expire(key, expire, TimeUnit.SECONDS);
}
@Override
public void remove(String key) {
stringRedisTemplate.delete(key);
}
@Override
public Long increment(String key, long delta) {
return stringRedisTemplate.opsForValue().increment(key,delta);
}
}
新增UmsMemberController
新增根據電話號碼獲取驗證碼的介面和校驗驗證碼的介面
package com.macro.mall.tiny.controller;
import com.macro.mall.tiny.common.api.CommonResult;
import com.macro.mall.tiny.service.UmsMemberService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;
/**
* 會員登入註冊管理Controller
* Created by macro on 2018/8/3.
*/
@Controller
@Api(tags = "UmsMemberController", description = "會員登入註冊管理")
@RequestMapping("/sso")
public class UmsMemberController {
@Autowired
private UmsMemberService memberService;
@ApiOperation("獲取驗證碼")
@RequestMapping(value = "/getAuthCode", method = RequestMethod.GET)
@ResponseBody
public CommonResult getAuthCode(@RequestParam String telephone) {
return memberService.generateAuthCode(telephone);
}
@ApiOperation("判斷驗證碼是否正確")
@RequestMapping(value = "/verifyAuthCode", method = RequestMethod.POST)
@ResponseBody
public CommonResult updatePassword(@RequestParam String telephone,
@RequestParam String authCode) {
return memberService.verifyAuthCode(telephone,authCode);
}
}
新增UmsMemberService介面
package com.macro.mall.tiny.service;
import com.macro.mall.tiny.common.api.CommonResult;
/**
* 會員管理Service
* Created by macro on 2018/8/3.
*/
public interface UmsMemberService {
/**
* 生成驗證碼
*/
CommonResult generateAuthCode(String telephone);
/**
* 判斷驗證碼和手機號碼是否匹配
*/
CommonResult verifyAuthCode(String telephone, String authCode);
}
新增UmsMemberService介面的實現類UmsMemberServiceImpl
生成驗證碼時,將自定義的Redis鍵值加上手機號生成一個Redis的key,以驗證碼為value存入到Redis中,並設定過期時間為自己配置的時間(這裡為120s)。校驗驗證碼時根據手機號碼來獲取Redis裡面儲存的驗證碼,並與傳入的驗證碼進行比對。
package com.macro.mall.tiny.service.impl;
import com.macro.mall.tiny.common.api.CommonResult;
import com.macro.mall.tiny.service.RedisService;
import com.macro.mall.tiny.service.UmsMemberService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;
import java.util.Random;
/**
* 會員管理Service實現類
* Created by macro on 2018/8/3.
*/
@Service
public class UmsMemberServiceImpl implements UmsMemberService {
@Autowired
private RedisService redisService;
@Value("${redis.key.prefix.authCode}")
private String REDIS_KEY_PREFIX_AUTH_CODE;
@Value("${redis.key.expire.authCode}")
private Long AUTH_CODE_EXPIRE_SECONDS;
@Override
public CommonResult generateAuthCode(String telephone) {
StringBuilder sb = new StringBuilder();
Random random = new Random();
for (int i = 0; i < 6; i++) {
sb.append(random.nextInt(10));
}
//驗證碼繫結手機號並存儲到redis
redisService.set(REDIS_KEY_PREFIX_AUTH_CODE + telephone, sb.toString());
redisService.expire(REDIS_KEY_PREFIX_AUTH_CODE + telephone, AUTH_CODE_EXPIRE_SECONDS);
return CommonResult.success(sb.toString(), "獲取驗證碼成功");
}
//對輸入的驗證碼進行校驗
@Override
public CommonResult verifyAuthCode(String telephone, String authCode) {
if (StringUtils.isEmpty(authCode)) {
return CommonResult.failed("請輸入驗證碼");
}
String realAuthCode = redisService.get(REDIS_KEY_PREFIX_AUTH_CODE + telephone);
boolean result = authCode.equals(realAuthCode);
if (result) {
return CommonResult.success(null, "驗證碼校驗成功");
} else {
return CommonResult.failed("驗證碼不正確");
}
}
}
執行專案
訪問Swagger的API文件地址http://localhost:8080/swagger-ui.html ,對介面進行測試。