摘要:配置文件數(shù)據(jù)庫索引默認(rèn)為服務(wù)器地址服務(wù)器連接端口服務(wù)器連接密碼默認(rèn)為空連接池最大連接數(shù)使用負(fù)值表示沒有限制連接池最大阻塞等待時(shí)間使用負(fù)值表示沒有限制連接池中的最大空閑連接連接池中的最小空閑連接連接超時(shí)時(shí)間毫秒自定義采用的序列化方式
配置文件
spring: redis: # Redis數(shù)據(jù)庫索引(默認(rèn)為0) database: 0 # Redis服務(wù)器地址 host: 192.168.133.128 # Redis服務(wù)器連接端口 port: 6379 # Redis服務(wù)器連接密碼(默認(rèn)為空) password: redis jedis: pool: #連接池最大連接數(shù)(使用負(fù)值表示沒有限制) max-active: 8 # 連接池最大阻塞等待時(shí)間(使用負(fù)值表示沒有限制) max-wait: -1 # 連接池中的最大空閑連接 max-idle: 8 # 連接池中的最小空閑連接 min-idle: 0 # 連接超時(shí)時(shí)間(毫秒) timeout: 10000自定義RedisTemplate
@Configuration public class RedisConfig { @Bean public RedisTemplateredis工具類redisTemplate(RedisConnectionFactory factory) { RedisTemplate template = new RedisTemplate(); template.setConnectionFactory(factory); Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class); ObjectMapper om = new ObjectMapper(); om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY); om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL); jackson2JsonRedisSerializer.setObjectMapper(om); StringRedisSerializer stringRedisSerializer = new StringRedisSerializer(); // key采用String的序列化方式 template.setKeySerializer(stringRedisSerializer); // hash的key也采用String的序列化方式 template.setHashKeySerializer(stringRedisSerializer); // value序列化方式采用jackson template.setValueSerializer(jackson2JsonRedisSerializer); // hash的value序列化方式采用jackson template.setHashValueSerializer(jackson2JsonRedisSerializer); template.afterPropertiesSet(); return template; } }
@Component public class RedisUtil2 { @Autowired private RedisTemplate測試redisTemplate; /** * 指定緩存失效時(shí)間 * * @param key 鍵 * @param time 時(shí)間(秒) * @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; } } /** * 根據(jù)key 獲取過期時(shí)間 * * @param key 鍵 不能為null * @return 時(shí)間(秒) 返回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 可以傳一個(gè)值 或多個(gè) */ @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; } } /** * 普通緩存放入并設(shè)置時(shí)間 * * @param key 鍵 * @param value 值 * @param time 時(shí)間(秒) time要大于0 如果time小于等于0 將設(shè)置無限期 * @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 delta 要增加幾(大于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 delta 要減少幾(小于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 項(xiàng) 不能為null * @return 值 */ public Object hget(String key, String item) { return redisTemplate.opsForHash().get(key, item); } /** * 獲取hashKey對(duì)應(yīng)的所有鍵值 * * @param key 鍵 * @return 對(duì)應(yīng)的多個(gè)鍵值 */ public Map
@RestController public class RedisController { @Autowired private RedisUtils redisUtils; @Autowired private RedisUtil2 redisUtil2; @GetMapping("test-set-string") public String testSetString(String key, String value) { redisUtils.set(key, value,60L); return "success set string"; } @GetMapping("test-get-string") public String testGetString(String key) { return redisUtils.getString(key); } @GetMapping("test-set-string2") public String testSetString2(String key, String value) { redisUtil2.set(key, value,60L); return "success set string2"; } @GetMapping("test-get-string2") public String testGetString2(String key) { return redisUtils.getString(key); } }測試存入對(duì)象 pojo
package com.learn.jredis.pojo; import java.io.Serializable; public class User implements Serializable { private static final long serialVersionUID = -1L; private String username; private Integer age; public User(String username, Integer age) { this.username = username; this.age = age; } public User() { } public String getUsername() { return username; } public void setUsername(String username) { this.username = username; } public Integer getAge() { return age; } public void setAge(Integer age) { this.age = age; } }存入代碼
@GetMapping("test-set-obj") public String testSetObj() { User user = new User("木子", 20); redisUtil2.set(user.getUsername(), user); return "success set obj"; } @GetMapping("test-get-obj") public Object testGetObj(String key) { return redisUtil2.get(key); }結(jié)果
{ username: "木子", age: 20 }
代碼:springboot-redis
文章版權(quán)歸作者所有,未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為,您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請(qǐng)注明本文地址:http://specialneedsforspecialkids.com/yun/74130.html
摘要:至此,已完成整合獨(dú)立模塊做緩存詳情請(qǐng)看地址相關(guān)文章系列整合獨(dú)立模塊 項(xiàng)目github地址:https://github.com/5-Ason/aso...具體可看 ./db/db-redis 和 ./db/db-cache 兩個(gè)模塊 // TODO 在整合redis之前需要先本地配置好redis環(huán)境,遲點(diǎn)有時(shí)間補(bǔ)一下linux下下載安裝配置redis 本文主要實(shí)現(xiàn)的是對(duì)數(shù)據(jù)操作進(jìn)行獨(dú)立...
摘要:至此,已完成整合獨(dú)立模塊做緩存詳情請(qǐng)看地址相關(guān)文章系列整合獨(dú)立模塊 項(xiàng)目github地址:https://github.com/5-Ason/aso...具體可看 ./db/db-redis 和 ./db/db-cache 兩個(gè)模塊 // TODO 在整合redis之前需要先本地配置好redis環(huán)境,遲點(diǎn)有時(shí)間補(bǔ)一下linux下下載安裝配置redis 本文主要實(shí)現(xiàn)的是對(duì)數(shù)據(jù)操作進(jìn)行獨(dú)立...
摘要:相比它支持存儲(chǔ)的類型相對(duì)更多字符哈希集合有序集合列表,同時(shí)是線程安全的?;诘倪B接實(shí)例,可以在多個(gè)線程間并發(fā)訪問,且線程安全,滿足多線程環(huán)境下的并發(fā)訪問,同時(shí)它是可伸縮的設(shè)計(jì),一個(gè)連接實(shí)例不夠的情況也可以按需增加連接實(shí)例。 SpringBoot 是為了簡化 Spring 應(yīng)用的創(chuàng)建、運(yùn)行、調(diào)試、部署等一系列問題而誕生的產(chǎn)物,自動(dòng)裝配的特性讓我們可以更好的關(guān)注業(yè)務(wù)本身而不是外部的XML...
閱讀 3925·2021-10-12 10:12
閱讀 2886·2021-09-10 11:18
閱讀 3673·2019-08-30 15:54
閱讀 2808·2019-08-30 15:53
閱讀 638·2019-08-30 13:54
閱讀 965·2019-08-30 13:21
閱讀 2260·2019-08-30 12:57
閱讀 1687·2019-08-30 11:10