SpringBoot2整合Redis
公司使用了soringboot-2.0.4寫新專案，今天在整合redis的時候到處碰壁，最後誤打誤撞整理出來了，現在記錄一下，方便以後使用。
- Pom依賴
因為使用了redis最新的類 RedisStandaloneConfiguration所以要加入jedis包，不然在程式碼中會報錯，下面會說明。不是因為排除掉本身的jedis包導致的，具體原因未知。
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> <!-- 1.5的版本預設採用的連線池技術是jedis 2.0以上版本預設連線池是lettuce, 在這裡採用 jedis，所以需要排除lettuce的jar --> <exclusions> <exclusion> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> </exclusion> <exclusion> <groupId>io.lettuce</groupId> <artifactId>lettuce-core</artifactId> </exclusion> </exclusions> </dependency> <dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> </dependency>
- Redis配置
我使用了yaml配置檔案
# -- Redis 配置
redisconfig:
host: XXXX
port: 6379
password: XXXX
timeout: 10000 因為在JedisConnectionFactory中，它用了一個自己的JedisConnectionFactory.MutableJedisClientConfiguration()，
MutableJedisClientConfiguration會自動生成一個JedisPoolConfig，這個JedisPoolConfig繼承自GenericObjectPoolConfig
他的pool的配置就是8個。 我認為夠用了，所以沒有配置連線池相關資訊。
- 配置Redis
package com.quark.data.tenant.server.configuration; import java.time.Duration; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.data.redis.connection.RedisConnectionFactory; import org.springframework.data.redis.connection.RedisPassword; import org.springframework.data.redis.connection.RedisStandaloneConfiguration; import org.springframework.data.redis.connection.jedis.JedisClientConfiguration; import org.springframework.data.redis.connection.jedis.JedisConnectionFactory; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer; import org.springframework.data.redis.serializer.StringRedisSerializer; import com.quark.data.tenant.server.model.conf.RedisConfig; import com.quark.data.tenant.server.util.PropertiesUtil; import com.quark.data.tenant.server.util.RedisUtil; @Configuration public class MyRedisConfiguration { // propertiesUtil 是我的yaml屬性檔案類 @Autowired private PropertiesUtil propertiesUtil; @Bean public JedisConnectionFactory jedisConnectionFactory() { RedisConfig redisconfig = propertiesUtil.getRedisconfig(); RedisStandaloneConfiguration redisStandaloneConfiguration = new RedisStandaloneConfiguration(); redisStandaloneConfiguration.setHostName(redisconfig.getHost()); redisStandaloneConfiguration.setPort(redisconfig.getPort()); redisStandaloneConfiguration.setPassword(RedisPassword.of(redisconfig.getPassword())); JedisClientConfiguration.JedisClientConfigurationBuilder jedisClientConfiguration = JedisClientConfiguration .builder(); jedisClientConfiguration.connectTimeout(Duration.ofMillis(redisconfig.getTimeout()));// connection // 如果不加入Jedis的包 這裡會報錯，原因未知 JedisConnectionFactory factory = new JedisConnectionFactory(redisStandaloneConfiguration, jedisClientConfiguration.build()); return factory; } /** * 例項化 RedisTemplate 物件 * * @return */ @Bean public RedisTemplate<String, Object> functionDomainRedisTemplate(RedisConnectionFactory redisConnectionFactory) { RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>(); initDomainRedisTemplate(redisTemplate, redisConnectionFactory); return redisTemplate; } /** * 設定資料存入 redis 的序列化方式,並開啟事務 * * @param redisTemplate * @param factory */ private void initDomainRedisTemplate(RedisTemplate<String, Object> redisTemplate, RedisConnectionFactory factory) { redisTemplate.setKeySerializer(new StringRedisSerializer()); redisTemplate.setHashKeySerializer(new StringRedisSerializer()); redisTemplate.setHashValueSerializer(new GenericJackson2JsonRedisSerializer()); redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer()); redisTemplate.setEnableTransactionSupport(true); redisTemplate.setConnectionFactory(factory); } @Bean public RedisUtil redisUtil() { // 注入redis工具類，在其他地方直接自動注入就可以使用了 RedisUtil redisUtil = new RedisUtil(); JedisConnectionFactory jedisConnectionFactory = jedisConnectionFactory(); RedisTemplate<String, Object> functionDomainRedisTemplate = functionDomainRedisTemplate(jedisConnectionFactory); redisUtil.setRedisTemplate(functionDomainRedisTemplate); return redisUtil; } }
- Redis工具類
package com.quark.data.tenant.server.util;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.TimeUnit;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils;
@Component
public class RedisUtil {
private RedisTemplate<String, Object> redisTemplate;
public void setRedisTemplate(RedisTemplate<String, Object> redisTemplate) {
this.redisTemplate = redisTemplate;
}
/**
* 指定快取失效時間
* @param key 鍵
* @param time 時間(秒)
* @return
*/
public boolean expire(String key,long time){
try {
if(time>0){
redisTemplate.expire(key, time, TimeUnit.SECONDS);
}
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 根據key 獲取過期時間
* @param key 鍵 不能為null
* @return 時間(秒) 返回0代表為永久有效
*/
public long getExpire(String key){
return redisTemplate.getExpire(key,TimeUnit.SECONDS);
}
/**
* 判斷key是否存在
* @param key 鍵
* @return true 存在 false不存在
*/
public boolean hasKey(String key){
try {
return redisTemplate.hasKey(key);
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 刪除快取
* @param key 可以傳一個值 或多個
*/
@SuppressWarnings("unchecked")
public void del(String ... key){
if(key!=null&&key.length>0){
if(key.length==1){
redisTemplate.delete(key[0]);
}else{
redisTemplate.delete(CollectionUtils.arrayToList(key));
}
}
}
/**
* 普通快取獲取
* @param key 鍵
* @return 值
*/
public Object get(String key){
return key==null?null:redisTemplate.opsForValue().get(key);
}
/**
* 普通快取放入
* @param key 鍵
* @param value 值
* @return true成功 false失敗
*/
public boolean set(String key,Object value) {
try {
redisTemplate.opsForValue().set(key, value);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 普通快取放入並設定時間
* @param key 鍵
* @param value 值
* @param time 時間(秒) time要大於0 如果time小於等於0 將設定無限期
* @return true成功 false 失敗
*/
public boolean set(String key,Object value,long time){
try {
if(time>0){
redisTemplate.opsForValue().set(key, value, time, TimeUnit.SECONDS);
}else{
set(key, value);
}
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 遞增
* @param key 鍵
* @param by 要增加幾(大於0)
* @return
*/
public long incr(String key, long delta){
if(delta<0){
throw new RuntimeException("遞增因子必須大於0");
}
return redisTemplate.opsForValue().increment(key, delta);
}
/**
* 遞減
* @param key 鍵
* @param by 要減少幾(小於0)
* @return
*/
public long decr(String key, long delta){
if(delta<0){
throw new RuntimeException("遞減因子必須大於0");
}
return redisTemplate.opsForValue().increment(key, -delta);
}
/**
* HashGet
* @param key 鍵 不能為null
* @param item 項 不能為null
* @return 值
*/
public Object hget(String key,String item){
return redisTemplate.opsForHash().get(key, item);
}
/**
* 獲取hashKey對應的所有鍵值
* @param key 鍵
* @return 對應的多個鍵值
*/
public Map<Object,Object> hmget(String key){
return redisTemplate.opsForHash().entries(key);
}
/**
* HashSet
* @param key 鍵
* @param map 對應多個鍵值
* @return true 成功 false 失敗
*/
public boolean hmset(String key, Map<String,Object> map){
try {
redisTemplate.opsForHash().putAll(key, map);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* HashSet 並設定時間
* @param key 鍵
* @param map 對應多個鍵值
* @param time 時間(秒)
* @return true成功 false失敗
*/
public boolean hmset(String key, Map<String,Object> map, long time){
try {
redisTemplate.opsForHash().putAll(key, map);
if(time>0){
expire(key, time);
}
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 向一張hash表中放入資料,如果不存在將建立
* @param key 鍵
* @param item 項
* @param value 值
* @return true 成功 false失敗
*/
public boolean hset(String key,String item,Object value) {
try {
redisTemplate.opsForHash().put(key, item, value);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 向一張hash表中放入資料,如果不存在將建立
* @param key 鍵
* @param item 項
* @param value 值
* @param time 時間(秒) 注意:如果已存在的hash表有時間,這裡將會替換原有的時間
* @return true 成功 false失敗
*/
public boolean hset(String key,String item,Object value,long time) {
try {
redisTemplate.opsForHash().put(key, item, value);
if(time>0){
expire(key, time);
}
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 刪除hash表中的值
* @param key 鍵 不能為null
* @param item 項 可以使多個 不能為null
*/
public void hdel(String key, Object... item){
redisTemplate.opsForHash().delete(key,item);
}
/**
* 判斷hash表中是否有該項的值
* @param key 鍵 不能為null
* @param item 項 不能為null
* @return true 存在 false不存在
*/
public boolean hHasKey(String key, String item){
return redisTemplate.opsForHash().hasKey(key, item);
}
/**
* hash遞增 如果不存在,就會建立一個 並把新增後的值返回
* @param key 鍵
* @param item 項
* @param by 要增加幾(大於0)
* @return
*/
public double hincr(String key, String item,double by){
return redisTemplate.opsForHash().increment(key, item, by);
}
/**
* hash遞減
* @param key 鍵
* @param item 項
* @param by 要減少記(小於0)
* @return
*/
public double hdecr(String key, String item,double by){
return redisTemplate.opsForHash().increment(key, item,-by);
}
//============================set=============================
/**
* 根據key獲取Set中的所有值
* @param key 鍵
* @return
*/
public Set<Object> sGet(String key){
try {
return redisTemplate.opsForSet().members(key);
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
/**
* 根據value從一個set中查詢,是否存在
* @param key 鍵
* @param value 值
* @return true 存在 false不存在
*/
public boolean sHasKey(String key,Object value){
try {
return redisTemplate.opsForSet().isMember(key, value);
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 將資料放入set快取
* @param key 鍵
* @param values 值 可以是多個
* @return 成功個數
*/
public long sSet(String key, Object...values) {
try {
return redisTemplate.opsForSet().add(key, values);
} catch (Exception e) {
e.printStackTrace();
return 0;
}
}
/**
* 將set資料放入快取
* @param key 鍵
* @param time 時間(秒)
* @param values 值 可以是多個
* @return 成功個數
*/
public long sSetAndTime(String key,long time,Object...values) {
try {
Long count = redisTemplate.opsForSet().add(key, values);
if(time>0) expire(key, time);
return count;
} catch (Exception e) {
e.printStackTrace();
return 0;
}
}
/**
* 獲取set快取的長度
* @param key 鍵
* @return
*/
public long sGetSetSize(String key){
try {
return redisTemplate.opsForSet().size(key);
} catch (Exception e) {
e.printStackTrace();
return 0;
}
}
/**
* 移除值為value的
* @param key 鍵
* @param values 值 可以是多個
* @return 移除的個數
*/
public long setRemove(String key, Object ...values) {
try {
Long count = redisTemplate.opsForSet().remove(key, values);
return count;
} catch (Exception e) {
e.printStackTrace();
return 0;
}
}
/**
* 獲取list快取的內容
* @param key 鍵
* @param start 開始
* @param end 結束 0 到 -1代表所有值
* @return
*/
public List<Object> lGet(String key,long start, long end){
try {
return redisTemplate.opsForList().range(key, start, end);
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
/**
* 獲取list快取的長度
* @param key 鍵
* @return
*/
public long lGetListSize(String key){
try {
return redisTemplate.opsForList().size(key);
} catch (Exception e) {
e.printStackTrace();
return 0;
}
}
/**
* 通過索引 獲取list中的值
* @param key 鍵
* @param index 索引 index>=0時， 0 表頭，1 第二個元素，依次類推；index<0時，-1，表尾，-2倒數第二個元素，依次類推
* @return
*/
public Object lGetIndex(String key,long index){
try {
return redisTemplate.opsForList().index(key, index);
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
/**
* 將list放入快取
* @param key 鍵
* @param value 值
* @param time 時間(秒)
* @return
*/
public boolean lSet(String key, Object value) {
try {
redisTemplate.opsForList().rightPush(key, value);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 將list放入快取
* @param key 鍵
* @param value 值
* @param time 時間(秒)
* @return
*/
public boolean lSet(String key, Object value, long time) {
try {
redisTemplate.opsForList().rightPush(key, value);
if (time > 0) expire(key, time);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 將list放入快取
* @param key 鍵
* @param value 值
* @param time 時間(秒)
* @return
*/
public boolean lSet(String key, List<Object> value) {
try {
redisTemplate.opsForList().rightPushAll(key, value);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 將list放入快取
* @param key 鍵
* @param value 值
* @param time 時間(秒)
* @return
*/
public boolean lSet(String key, List<Object> value, long time) {
try {
redisTemplate.opsForList().rightPushAll(key, value);
if (time > 0) expire(key, time);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 根據索引修改list中的某條資料
* @param key 鍵
* @param index 索引
* @param value 值
* @return
*/
public boolean lUpdateIndex(String key, long index,Object value) {
try {
redisTemplate.opsForList().set(key, index, value);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 移除N個值為value
* @param key 鍵
* @param count 移除多少個
* @param value 值
* @return 移除的個數
*/
public long lRemove(String key,long count,Object value) {
try {
Long remove = redisTemplate.opsForList().remove(key, count, value);
return remove;
} catch (Exception e) {
e.printStackTrace();
return 0;
}
}
}
每一次的指正都促進我的成長，如果我有錯誤或您有疑問，請在下方留言。
相關推薦
springboot2整合redis，並自定義@Cache
1.maven依賴 <dependency> <groupId>org.apache.commons</groupId> <artifactId>commons-pool2</artifactId>
Springboot2整合Redis以及jackson序列化
pom.xml <!--redis--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-bo
SpringBoot2整合Redis
公司使用了soringboot-2.0.4寫新專案，今天在整合redis的時候到處碰壁，最後誤打誤撞整理出來了，現在記錄一下，方便以後使用。 Pom依賴 因為使用了redis最新的類 RedisStandaloneConfiguration所以要加入jedis包，不然在程式
SpringBoot2整合Redis快取
在學習springboot整合redis的時候遇到這樣一個奇怪的問題：我從資料庫中取得的物件已經放入了redis中，而且從redis的客服端也可以檢視到對應的key，開始的時候還是正常的，能正常的從快取中取得並返回我需要的類；但是過一段時間第二次訪問這個方法時（這時應該是到r
springboot2整合spring-session-data-redis，實現session共享
1.新增Maven依賴 <dependency> <groupId>org.apache.commons</groupId> <artifactId>commons-pool2</artifactId>
springboot2.0x全系列一springboot2.0x整合Redis
上一篇：地址：https://blog.csdn.net/qq_34077993/article/details/83417464 springboot整合redis非常的方便 首先在pom檔案中引進依賴： <!-- Spring Boot Redis依賴開始 --> <
Springboot2.0整合Redis(註解開發)
一. pom.xm檔案引入對應jar包 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis&l
springboot2.x簡單詳細教程--整合Redis實戰（第 九章）
一、分散式快取Redis介紹 簡介:講解為什麼要用快取和介紹什麼是Redis，新手練習工具 1.什麼是Redis 由c語言編寫的,以鍵值對的形式儲存的非關係資料庫. 快取技術(駐留在記憶體中)
SpringBoot2.0學習筆記：(十) Spring Boot中整合Redis
一、關於Lettuce 關於在SpringBoot2.0.x版本中整合Redis,我們先看一下官方的遷移文件有什麼說的： Spring Boot2.0遷移指南 當你使用spring-boot-starter-redis的時候，Lettuce現已取代Jedis作為Redis驅動
springboot2.0.6 整合redis實踐
整合redis之前，先提前安裝一下redis，redis官方下載的是不支援windows安裝的，點選redis-window版本下載，下載解壓雙擊redis-server就啟動了。 本文還會用到一個redis視覺化的工具，點選redis desktop manager下載 1.pom.x
SpringBoot2.0-整合Redis
目錄 由於版本原因，SpringBoot2.0整合Redis和低版本的SpringBoot不太一樣，經測試，本文這套整合方案可以使用。 一、build.gradle //redis clienet compile("redis
springboot2.x版本整合redis(單機/叢集)(使用lettuce)
在springboot1.x系列中，其中使用的是jedis,但是到了springboot2.x其中使用的是Lettuce。 此處springboot2.x，所以使用的是Lettuce。關於jedis跟lettuce的區別： Lettuce 和 Jedis 的定位都是Redis的client，所
springboot2.0整合redis案例
首先建立一個springboot專案。 新增pom配置： <dependency> <groupId>org.springframework.boot</groupId>
SpringBoot2.x整合Redis實戰 4節課
1、分散式快取Redis介紹 簡介:講解為什麼要用快取和介紹什麼是Redis，新手練習工具 1、redis官網 https://redis.io/download
SpringBoot2.0（13）整合Redis詳解及踩過的坑（Could not get a resource from the pool）
SpringBoot2.0整合Redis 首先安裝的過程就不提了。上一個專案的redis是配置在Windows下的，整合很簡單，也沒有做什麼配置。這次為了進行測試，裝在了linux下。在SpringBoot整合的過程中遇到了一些小坑，分享一下。 po
SpringBoot2.0整合Redis
【1】pom依賴 新增redis依賴如下： <!--整合redis--> <dependency> <groupId>org.springframework.boot</groupId> &
spring整合redis
data sch throws ack xid .org source protect pid 1，利用spring-data-redis整合 項目使用的pom.xml： <project xmlns="http://maven.apache.org/POM/4.0
Spring整合Redis做數據緩存（Windows環境）
端口號 init 技術分享 factory redis-cli @service tab long 配置 當我們一個項目的數據量很大的時候，就需要做一些緩存機制來減輕數據庫的壓力，提升應用程序的性能，對於java項目來說，最常用的緩存組件有Redis、Ehcache和Mem
Spring整合Redis(spring-data-redis)
nds 獲取 可能 div 普通 工具 long red 等待 歷經幾天看了大量的博客資料，差不多算是搞定了，目前只是針對單個數據源，集群暫時沒研究 maven依賴 <properties> <!-- redis 版本 --> &l
java 整合redis緩存 SSM 後臺框架 rest接口 shiro druid maven bootstrap html5
websocket redis 多數據源 springmvc ssm A代碼編輯器，在線模版編輯，仿開發工具編輯器，pdf在線預覽，文件轉換編碼B 集成代碼生成器 [正反雙向](單表、主表、明細表、樹形表，快速開發利器)+快速表單構建器 freemaker模版技術 ，0個代碼不用寫，生成完