Redis整合Springboot實現單機配置

整體結構

配置文件

<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>com.cc</groupId><artifactId>spring-redis</artifactId><version>0.0.1-SNAPSHOT</version><packaging>jar</packaging><name>spring-redis</name><description>Demo project for Spring Boot</description><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>1.5.13.RELEASE</version><relativePath /> <!-- lookup parent from repository --></parent><properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding><java.version>1.8</java.version></properties><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId></dependency><dependency><groupId>org.apache.commons</groupId><artifactId>commons-pool2</artifactId><version>2.4.2</version></dependency><dependency><groupId>com.fasterxml.jackson.core</groupId><artifactId>jackson-databind</artifactId><version>2.8.0</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency></dependencies><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project>

RedisConfig

package com.cc.springredis.config;import com.cc.springredis.RedisUtil;
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.serializer.GenericJackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;@Configuration
public class RedisConfig {/*** 實例化 RedisTemplate 對象** @return*/@Beanpublic 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) {//如果不配置Serializer，那么存儲的時候缺省使用String，如果用User類型存儲，那么會提示錯誤User can't cast to String！  redisTemplate.setKeySerializer(new StringRedisSerializer());redisTemplate.setHashKeySerializer(new StringRedisSerializer());redisTemplate.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());// 開啟事務redisTemplate.setEnableTransactionSupport(true);redisTemplate.setConnectionFactory(factory);}/*** @return RedisUtil* @throws* @Title: redisUtil*/@Bean(name = "redisUtil")public RedisUtil redisUtil(RedisTemplate<String, Object> redisTemplate) {RedisUtil redisUtil = new RedisUtil();redisUtil.setRedisTemplate(redisTemplate);return redisUtil;}}

RedisUtil

package com.cc.springredis;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.util.CollectionUtils;public class RedisUtil {private RedisTemplate<String, Object> redisTemplate;public void setRedisTemplate(RedisTemplate<String, Object> redisTemplate) {this.redisTemplate = redisTemplate;}// =============================common============================/*** 指定緩存失效時間* * @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));}}}// ============================String=============================/*** 普通緩存獲取* * @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);}// ================================Map=================================/*** 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=================================/*** 獲取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  值* @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  值* @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;}}
}

測試類SpringRedisApplicationTests

package com.cc.springredis;import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;import javax.annotation.Resource;@RunWith(SpringRunner.class)
@SpringBootTest(classes = SpringRedisApplication.class)
public class SpringRedisApplicationTests {@Resourceprivate RedisUtil redisUtil;@Testpublic void testRedis() {redisUtil.set("test", "1111111111");System.out.println(redisUtil.get("test"));}}

application.properties


########################################################
###REDIS (RedisProperties) redis基本配置；
########################################################
# database name
spring.redis.database=0
# server host1 單機使用，對應服務器ip
spring.redis.host=192.168.133.130
# server password 密碼，如果沒有設置可不配
#spring.redis.password=
#connection port  單機使用，對應端口號
spring.redis.port=10190
# pool settings ...池配置
spring.redis.pool.max-idle=8
spring.redis.pool.min-idle=0
spring.redis.pool.max-active=8
spring.redis.pool.max-wait=-1

?

本文來自互聯網用戶投稿，該文觀點僅代表作者本人，不代表本站立場。本站僅提供信息存儲空間服務，不擁有所有權，不承擔相關法律責任。
如若轉載，請注明出處：http://www.pswp.cn/news/447270.shtml
繁體地址，請注明出處：http://hk.pswp.cn/news/447270.shtml
英文地址，請注明出處：http://en.pswp.cn/news/447270.shtml

如若內容造成侵權/違法違規/事實不符，請聯系多彩編程網進行投訴反饋email:809451989@qq.com，一經查實，立即刪除！

相關文章

撐起整個互聯網的7大開源技術

撐起整個互聯網的7大開源技術

撐起整個互聯網的7大開源技術 很多人可能尚未意識到&#xff0c;我們使用的電腦中運行有開源軟件&#xff0c;手機中運行有開源軟件&#xff0c;家里的電視也運行有開源軟件&#xff0c;甚至小小的數碼產品中也運行有開源軟件&#xff0c;尤其是互聯網服務器端軟件&#xff0c…
閱讀更多...
Redis整合springboot實現哨兵模式

Redis整合springboot實現哨兵模式

整體結構 RedisConfig package com.cc.springredis.config;import com.cc.springredis.RedisUtil; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.data.redis.connection.R…
閱讀更多...
Redis整合springboot實現集群模式

Redis整合springboot實現集群模式

整體結構 Redis.config package com.cc.springredis.config;import com.cc.springredis.RedisUtil; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.data.redis.connection…
閱讀更多...
一個窮人是從什么時候開始有錢的？

一個窮人是從什么時候開始有錢的？

2010年&#xff0c;文野31歲那年&#xff0c;買房后第二年&#xff0c;完成了「人生中最重要的一次轉變」。 這一年&#xff0c;他在心里對自己的定位&#xff0c;從窮人變成了有錢人。 「一些人哪怕有錢了&#xff0c;心里也永遠甩不脫窮的影子。」這是我曾經在《 階段性勝…
閱讀更多...
Redis整合springboot實現消息隊列

Redis整合springboot實現消息隊列

publisher消息的發出 代碼整體的結構 publisherConfig package com.cc.springbootredispublisher.config;import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.data.redis.conne…
閱讀更多...
人最重要的能力是什么?

人最重要的能力是什么?

我見過很多人有能力、能成功&#xff0c;但并不幸福。人最重要的能力是什么? 人生最重要的能力是什么?我的答案是&#xff0c;隨時保持內心平靜的能力。 我開始想到的是“堅持”&#xff0c;后來我認為不對&#xff0c;“堅持”僅僅是成功所必備的能力&#xff0c;并不是人生…
閱讀更多...
Redis數據緩存

Redis數據緩存

代碼的整體結構 配置文件 <?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.apac…
閱讀更多...
hevc/265 開源項目及相關

hevc/265 開源項目及相關

1.X265 個是有兩個版本&#xff0c;一個是國內人搞的&#xff0c;是國外公司搞的 1.國外公司版本 只是一個編碼器&#xff0c;目前沒有支持解碼 開發語言 c web url: www.x265.org source url: https://bitbucket.org/multicoreware/x265 x265 is an open-source projec…
閱讀更多...
IPFS星際文件系統的簡介

IPFS星際文件系統的簡介

IPFS簡介 IPFS&#xff08;InterPlanetary File System&#xff09;叫星際文件傳輸系統&#xff0c;本質是一個基于點對點的分布式超媒體分發協議&#xff0c;它整合了分布式系統&#xff0c;為所有人提供全球統一的可尋址空間&#xff0c;因為他具有良好的安全性、較高的傳輸…
閱讀更多...
ARM和NEON指令 very nice

ARM和NEON指令 very nice

在移動平臺上進行一些復雜算法的開發&#xff0c;一般需要用到指令集來進行加速。目前在移動上使用最多的是ARM芯片。 ARM是微處理器行業的一家知名企業&#xff0c;其芯片結構有&#xff1a;armv5、armv6、armv7和armv8系列。芯片類型有&#xff1a;arm7、arm9、arm11、corte…
閱讀更多...
IPFS下載安裝和配置

IPFS下載安裝和配置

參考鏈接 因為這個網站訪問速度很慢&#xff0c;我提供了IPFS的MAC版本。有需要的查看我的資源下載。 大致流程 安裝 $ ls go-ipfs_v0.4.10_darwin-amd64.tar.gz $ tar xvfz go-ipfs_v0.4.10_darwin-amd64.tar.gz x go-ipfs/build-log x go-ipfs/install.sh x go-ipfs/ipfs…
閱讀更多...
IPFS的相關操作命令

IPFS的相關操作命令

新增文件 在桌面新建名字為1121的文件夾&#xff0c;在文件夾里面新建file.txt文件&#xff0c;在文件里面輸入數據&#xff0c;保存退出 $ pwd /Users/CHY/Desktop $ mkdir 1121 $ cd 1121/ $ vi file.txt $ cat file.txt 哈哈&#xff0c;為什么只有我不快樂 給文件輸入內容…
閱讀更多...
Neon Intrinsics各函數介紹

Neon Intrinsics各函數介紹

#ifndef __ARM_NEON__ #error You must enable NEON instructions (e.g. -mfloat-abisoftfp -mfpuneon) to use arm_neon.h #endif/*(1)、正常指令&#xff1a;生成大小相同且類型通常與操作數向量相同的結果向量&#xff1b; (2)、長指令&#xff1a;對雙字向量操作數執行運算…
閱讀更多...
npm安裝包總是失敗了的，請參考

npm安裝包總是失敗了的，請參考

鏡像使用方法 &#xff08;三種辦法任意一種都能解決問題&#xff0c;建議使用第三種&#xff0c;將配置寫死&#xff0c;下次用的時候配置還在&#xff09;: 1.通過config命令 npm config set registry https://registry.npm.taobao.org npm info underscore //&#xff08…
閱讀更多...
arm 開發工具比較（ADS vs RealviewMDK vs RVDS）

arm 開發工具比較（ADS vs RealviewMDK vs RVDS）

ADS REALVIEW MDK RVDS 公司 ARM Keil&#xff08;后被ARM收購&#xff09; ARM 版本 最新1.2 ,被RVDS取代 最新4.0 是否免費 破解情況 有 有 工程管理 CodeWarrior IDE nVision IDE Eclipse/ CodeWarrior IDE 編譯器 ARM C compiler for AD…
閱讀更多...
解決macOS Catalina(10.15)解決阻止程序運行“macOS無法驗證此App不包含惡意軟件”

解決macOS Catalina(10.15)解決阻止程序運行“macOS無法驗證此App不包含惡意軟件”

在終端里面輸入如下命令 sudo spctl --master-disable 下面圖片對比執行命令前后&#xff0c;安全性與隱私 界面上顯示的差異&#xff1a;使用命令之后&#xff0c;界面變了
閱讀更多...
MSYS2 + MinGW-w64 + Git + gVim 環境配置

MSYS2 + MinGW-w64 + Git + gVim 環境配置

原文 http://dantvt.is-programmer.com/posts/63161.html 以前用 MSYS 的多&#xff0c;最近重裝系統順帶把環境重新配一下&#xff0c;發現 MSYS2 挺順手的。 一、安裝 MSYS2 先裝 MSYS2 的好處是之后可以將 $HOME 設為 /home/name/&#xff0c;再裝其他 *nix 系工具時配置…
閱讀更多...
MAC版 的最新Docker 2.2版本配置國內代理的解決辦法

MAC版 的最新Docker 2.2版本配置國內代理的解決辦法

點擊Docker圖標&#xff0c;選擇Preference選項&#xff0c;進行國內代理的問題 輸入內容如下 {"experimental": false,"debug": true,"registry-mirrors": ["https://docker.mirrors.ustc.edu.cn", "https://hub-mirror.c.163.…
閱讀更多...
常用的Homebrew的命令的使用

常用的Homebrew的命令的使用

&#xff08;1&#xff09;安裝軟件&#xff1a;brew install 軟件名&#xff0c;例如&#xff1a;brew install wget &#xff08;2&#xff09;搜索軟件&#xff1a;brew search 軟件名 &#xff08;3&#xff09;卸載軟件&#xff1a;brew uninstall 軟件名 &#xff08;…
閱讀更多...
微軟正式提供Visual Studio 2013正式版下載（附直接鏈接匯總）

微軟正式提供Visual Studio 2013正式版下載（附直接鏈接匯總）

轉自 http://www.iruanmi.com/visual-studio-2013/ 微軟已經向MSDN訂閱用戶提供了Visual Studio 2013正式版鏡像下載&#xff0c;不過非MSDN用戶可以在微軟的Visual Studio 2013官方網站上下載到正式版鏡像&#xff08;通過下載專業版本&#xff0c;已驗證與MSDN版本一致&…
閱讀更多...
最新文章

Copyright @ 2022~2023