mall整合Redis實現緩存功能

本文主要講解mall整合Redis的過程，以短信驗證碼的存儲驗證爲例。

Redis的安裝和啓動

Redis是用C語言開發的一個高性能鍵值對數據庫，可用於數據緩存，主要用於處理大量數據的高訪問負載。

• 下載Redis,下載地址：github.com/MicrosoftAr…

• 下載完後解壓到指定目錄

• 在當前地址欄輸入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 key
redis:
 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 ,對接口進行測試。

項目源碼地址

github.com/macrozheng/…

公衆號

mall項目全套學習教程連載中，關注公衆號第一時間獲取。