當(dāng)前位置：首頁 > 运维知识 > 数据库 >内容正文

数据库

RedisTemplate在项目中的应用

發(fā)布時(shí)間：2023/12/10 数据库 29 豆豆

生活随笔收集整理的這篇文章主要介紹了 RedisTemplate在项目中的应用小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,幫大家做個(gè)參考.

RedisTemplate在項(xiàng)目中的應(yīng)用

如下主要通去年無聊做的 "涂涂影院后臺(tái)管理系統(tǒng)" 一個(gè) demo，看 RedisTemplate 的使用。

主要用到地方：視頻首頁輪播圖的獲取，以及搜索檢索界面，如下圖所示：

由于是非maven非springboot項(xiàng)目，故配置有所繁瑣，但正所謂有繁才有簡，在下面會(huì)帶大家看一下springboot中配置redis是怎樣簡單。

好了，先回到 "涂涂影院" 來吧。

本項(xiàng)目環(huán)境

√開發(fā)工具：Eclipse

√JDK：1.8

√Redis;

eclipse中截圖

相信非springboot項(xiàng)目里的配置大家都應(yīng)該很熟悉吧，主要就是配置繁瑣的 xml，搭建一個(gè) ssm 項(xiàng)目可參考之前的例子：SSM(Spring+SpringMVC+Mybatis)框架環(huán)境搭建

1、spring-redis.xml

<?xml?version="1.0"?encoding="UTF-8"?>
<beans?xmlns="http://www.springframework.org/schema/beans"
???????xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
???????xmlns:context="http://www.springframework.org/schema/context"
???????xsi:schemaLocation="http://www.springframework.org/schema/beans
????????http://www.springframework.org/schema/beans/spring-beans.xsd?
????????http://www.springframework.org/schema/context?
????????http://www.springframework.org/schema/context/spring-context.xsd">

????
?????<context:component-scan?base-package="com.jeenotes.common.cache"?/>

?????
????<context:property-placeholder?location="classpath:resources/jeenotes.properties"??ignore-unresolvable="true"/>

????
????<bean?id="jedisPoolConfig"?class="redis.clients.jedis.JedisPoolConfig">
????????
????????<property?name="maxTotal"?value="${redis.pool.maxTotal}"?/>
????????
????????<property?name="maxIdle"?value="${redis.pool.maxIdle}"?/>
????????
????????<property?name="maxWaitMillis"?value="${redis.pool.maxWaitMillis}"?/>
????????
????????<property?name="testOnBorrow"?value="${redis.pool.testOnBorrow}"?/>
????</bean>

????
??????
????<bean?id="jedisConnectionFactory"?class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">
????????<property?name="hostName"?value="${redis.ip}"?/>
????????<property?name="port"?value="${redis.port}"?/>
????????<property?name="password"?value="${redis.pass}"?/>
????????<property?name="poolConfig"?ref="jedisPoolConfig"?/>
????</bean>?

????
????
????
????
????
????<bean?id="redisTemplate"?class="org.springframework.data.redis.core.StringRedisTemplate">
????????<property?name="connectionFactory"?ref="jedisConnectionFactory"?/>
????????
????????

????</bean>

</beans>

注釋比較詳細(xì)，簡要概述，jedisPoolConfig 用來配置 redis 連接池的一些配置，JedisConnectionFactory 則作為連接池的工廠類；還記得上文中提到的 redis 序列化問題嗎？上邊配置中（StringRedisTemplate）正是用到了 String 序列化策略。

2、RedisCache.java

/**
?*?redis緩存
?*?
?*?@author?niceyoo
?*
?*/
@Component
public?class?RedisCache?{

????public?final?static?String?CAHCENAME="cache";//緩存名
????public?final?static?int?CAHCETIME=300;//默認(rèn)緩存時(shí)間???以秒計(jì)算的

????@Autowired
????private?RedisTemplate<String,?String>?redisTemplate;

????public?<T>?boolean?putCache(String?key,?T?obj)?{
????????final?byte[]?bkey?=?key.getBytes();
????????final?byte[]?bvalue?=?ProtoStuffSerializerUtil.serialize(obj);
????????boolean?result?=?redisTemplate.execute(new?RedisCallback<Boolean>()?{
????????????@Override
????????????public?Boolean?doInRedis(RedisConnection?connection)?throws?DataAccessException?{
????????????????return?connection.setNX(bkey,?bvalue);
????????????}
????????});
????????return?result;
????}

????public?<T>?void?putCacheWithExpireTime(String?key,?T?obj,?final?long?expireTime)?{
????????final?byte[]?bkey?=?key.getBytes();
????????final?byte[]?bvalue?=?ProtoStuffSerializerUtil.serialize(obj);
????????redisTemplate.execute(new?RedisCallback<Boolean>()?{
????????????@Override
????????????public?Boolean?doInRedis(RedisConnection?connection)?throws?DataAccessException?{
????????????????connection.setEx(bkey,?expireTime,?bvalue);
????????????????return?true;
????????????}
????????});
????}

????public?<T>?boolean?putListCache(String?key,?List<T>?objList)?{
????????final?byte[]?bkey?=?key.getBytes();
????????final?byte[]?bvalue?=?ProtoStuffSerializerUtil.serializeList(objList);
????????boolean?result?=?redisTemplate.execute(new?RedisCallback<Boolean>()?{
????????????@Override
????????????public?Boolean?doInRedis(RedisConnection?connection)?throws?DataAccessException?{
????????????????return?connection.setNX(bkey,?bvalue);
????????????}
????????});
????????return?result;
????}

????public?<T>?boolean?putListCacheWithExpireTime(String?key,?List<T>?objList,?final?long?expireTime)?{
????????final?byte[]?bkey?=?key.getBytes();
????????final?byte[]?bvalue?=?ProtoStuffSerializerUtil.serializeList(objList);
????????boolean?result?=?redisTemplate.execute(new?RedisCallback<Boolean>()?{
????????????@Override
????????????public?Boolean?doInRedis(RedisConnection?connection)?throws?DataAccessException?{
????????????????connection.setEx(bkey,?expireTime,?bvalue);
????????????????return?true;
????????????}
????????});
????????return?result;
????}

????public?<T>?T?getCache(final?String?key,?Class<T>?targetClass)?{
????????byte[]?result?=?redisTemplate.execute(new?RedisCallback<byte[]>()?{
????????????@Override
????????????public?byte[]?doInRedis(RedisConnection?connection)?throws?DataAccessException?{
????????????????return?connection.get(key.getBytes());
????????????}
????????});
????????if?(result?==?null)?{
????????????return?null;
????????}
????????return?ProtoStuffSerializerUtil.deserialize(result,?targetClass);
????}

????public?<T>?List<T>?getListCache(final?String?key,?Class<T>?targetClass)?{
????????byte[]?result?=?redisTemplate.execute(new?RedisCallback<byte[]>()?{
????????????@Override
????????????public?byte[]?doInRedis(RedisConnection?connection)?throws?DataAccessException?{
????????????????return?connection.get(key.getBytes());
????????????}
????????});
????????if?(result?==?null)?{
????????????return?null;
????????}
????????return?ProtoStuffSerializerUtil.deserializeList(result,?targetClass);
????}

????/**
?????*?精確刪除key
?????*?
?????*?@param?key
?????*/
????public?void?deleteCache(String?key)?{
????????redisTemplate.delete(key);
????}

????/**
?????*?模糊刪除key
?????*?
?????*?@param?pattern
?????*/
????public?void?deleteCacheWithPattern(String?pattern)?{
????????Set<String>?keys?=?redisTemplate.keys(pattern);
????????redisTemplate.delete(keys);
????}

????/**
?????*?清空所有緩存
?????*/
????public?void?clearCache()?{
????????deleteCacheWithPattern(RedisCache.CAHCENAME+"|*");
????}
}

RedisCache.java 實(shí)現(xiàn)了對(duì)對(duì)數(shù)據(jù)增刪改查的幾種方法，如何使用呢？

我們以首頁的輪播圖為例：

在需要使用的類中注入該組件：

看一下如下方法：

@ResponseBody
@RequestMapping("huandeng")
public?ResultMobileBannerBean?huandeng(Model?model)?{

????String?cache_key?=?RedisCache.CAHCENAME?+?"|getPcHomeHuanDengList";
????ResultMobileBannerBean?result_cache?=?cache.getCache(cache_key,?ResultMobileBannerBean.class);

????if(result_cache?!=?null){
????????return?result_cache;
????}

????ResultMobileBannerBean?bannerBean?=?new?ResultMobileBannerBean();
????bannerBean.setCode("000000");
????List<HomeBanner>?homeBannerList?=?homeManagerService.findMobileHomeBannerList();
????bannerBean.setBannerList(homeBannerList);
????cache.putCacheWithExpireTime(cache_key,?bannerBean,?RedisCache.CAHCETIME);

????return?bannerBean;
}

主要是 ResultMobileBannerBean result_cache = cache.getCache(cache_key, ResultMobileBannerBean.class); 在去數(shù)據(jù)庫請(qǐng)求數(shù)據(jù)之前，先去 redis 中讀取緩存信息，如果返回的數(shù)據(jù)非空的話，則返回該數(shù)據(jù)，否則去數(shù)據(jù)庫查詢數(shù)據(jù)，查詢后在存放在 redis 中。

項(xiàng)目源碼：https://gitee.com/niceyoo/jeenotes-ssm.git

springboot 中是如何引用 redis 的呢？

1、maven依賴

<dependency>
????<groupId>org.springframework.boot</groupId>
????<artifactId>spring-boot-starter-redis</artifactId>
????<version>1.4.7.RELEASE</version>
</dependency>

<dependency>
????<groupId>com.google.code.gson</groupId>
????<artifactId>gson</artifactId>
????<version>2.8.5</version>
</dependency>

2、yml配置信息

spring:
??#?Redis
??redis:
????host:?127.0.0.1
????password:
????#?數(shù)據(jù)庫索引?默認(rèn)0
????database:?0
????port:?6379
????#?超時(shí)時(shí)間?Duration類型?3秒
????timeout:?3S

3、項(xiàng)目中引用

@Autowired
private?StringRedisTemplate?redisTemplate;

@RequestMapping(value?=?"/getByParentId/{parentId}",?method?=?RequestMethod.GET)
@ApiOperation(value?=?"通過parentId獲取")
public?Result<List<Department>>?getByParentId(@PathVariable?String?parentId,
??????????????????????????????????????????????@ApiParam("是否開始數(shù)據(jù)權(quán)限過濾")?@RequestParam(required?=?false,?defaultValue?=?"true")?Boolean?openDataFilter){

????List<Department>?list?=?new?ArrayList<>();
????User?u?=?securityUtil.getCurrUser();
????String?key?=?"department::"+parentId+":"+u.getId()+"_"+openDataFilter;
????String?v?=?redisTemplate.opsForValue().get(key);
????if(StrUtil.isNotBlank(v)){
????????list?=?new?Gson().fromJson(v,?new?TypeToken<List<Department>>(){}.getType());
????????return?new?ResultUtil<List<Department>>().setData(list);
????}
????list?=?departmentService.findByParentIdOrderBySortOrder(parentId,?openDataFilter);
????list?=?setInfo(list);
????redisTemplate.opsForValue().set(key,
????????????new?GsonBuilder().registerTypeAdapterFactory(HibernateProxyTypeAdapter.FACTORY).create().toJson(list));
????return?new?ResultUtil<List<Department>>().setData(list);
}

RedisTemplate 定義了 5 種數(shù)據(jù)結(jié)構(gòu)操作：

redisTemplate.opsForValue();//操作字符串

redisTemplate.opsForHash();//操作hash

redisTemplate.opsForList();//操作list

redisTemplate.opsForSet();//操作set

redisTemplate.opsForZSet();//操作有序set

最優(yōu)補(bǔ)充

從上文可看出 RedisTemplate 在 springboot 中應(yīng)用尤為簡單，所以趕快切到 springboot 中吧~

如果文章有錯(cuò)的地方歡迎指正，大家互相留言交流。習(xí)慣在微信看技術(shù)文章，想要獲取更多的Java資源的同學(xué)，可以關(guān)注微信公眾號(hào)：niceyoo

posted @ 2019-05-07 23:47 niceyoo 閱讀(...) 評(píng)論(...) 編輯收藏

總結(jié)

以上是生活随笔為你收集整理的RedisTemplate在项目中的应用的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。

上一篇： Hadoop HBase概念学习系列之H
下一篇： MySQL+Amoeba实现数据库主从复