SpringBoot之Redis訪問(spring-boot-starter-data-redis)

　　依賴注入：

<!--dependency for redis-->
<!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-data-redis -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
    <version>2.1.5.RELEASE</version>
</dependency>

　　配置文件 application.yml：

#默認使用配置 #項目啓動的時候也能夠設置 Java -jar xxxxxx.jar spring.profiles.actiove=prod 也能夠這樣啓動設置配置文件，可是這只是用於開發和測試。 spring: profiles: active: dev #指定默認啓動環境application-dev.yml include: redis #引入文件application-redis.yml

　　Redis 對應配置文件 application-redis.yml：

#redis redis:  #redis機器ip hostname: 127.0.0.1  #redis端口 port: 6379  #redis密碼 password:  #redis超時時間（毫秒），若是不設置，取默認值2000 timeout: 10000  #最大空閒數 maxIdle: 300  #鏈接池的最大數據庫鏈接數。設爲0表示無限制,若是是jedis 2.4之後用redis.maxTotal #maxActive=600 #控制一個pool可分配多少個jedis實例,用來替換上面的redis.maxActive,若是是jedis 2.4之後用該屬性 maxTotal: 1000 #最大創建鏈接等待時間。若是超過此時間將接到異常。設爲-1表示無限制。 maxWaitMillis: 1000  #鏈接的最小空閒時間 默認1800000毫秒(30分鐘) minEvictableIdleTimeMillis: 300000 #每次釋放鏈接的最大數目,默認3 numTestsPerEvictionRun: 1024 #逐出掃描的時間間隔(毫秒) 若是爲負數,則不運行逐出線程, 默認-1 timeBetweenEvictionRunsMillis: 30000  #是否在從池中取出鏈接前進行檢驗,若是檢驗失敗,則從池中去除鏈接並嘗試取出另外一個 testOnBorrow: true  #在空閒時檢查有效性, 默認false testWhileIdle: true  #redis集羣配置 #spring.cluster.nodes=192.168.1.1:7001,192.168.1.1:7002,192.168.1.1:7003,192.168.1.1:7004,192.168.1.1:7005,192.168.1.1:7006 #spring.cluster.max-redirects=3 #哨兵模式 #sentinel.host1=192.168.1.1 #sentinel.port1=26379 #sentinel.host2=192.168.1.2 #sentinel.port2=26379

　　覆寫替換系統默認redisTemplete：

@Configuration public class RedisConfig { /* * 定義緩存數據 key 生成策略的bean 包名+類名+方法名+全部參數 */
// @Bean // public KeyGenerator wiselyKeyGenerator(){ // return new KeyGenerator() { // @Override // public Object generate(Object target, Method method, Object... params) { // StringBuilder sb = new StringBuilder(); // sb.append(target.getClass().getName()); // sb.append(method.getName()); // for (Object obj : params) { // sb.append(obj.toString()); // } // return sb.toString(); // } // }; //
// }

    /* * 要啓用spring緩存支持,需建立一個 CacheManager的 bean，CacheManager 接口有不少實現，這裏Redis 的集成，用 * RedisCacheManager這個實現類 Redis 不是應用的共享內存，它只是一個內存服務器，就像 MySql 似的， * 咱們須要將應用鏈接到它並使用某種「語言」進行交互，所以咱們還須要一個鏈接工廠以及一個 Spring 和 Redis 對話要用的 * RedisTemplate， 這些都是 Redis 緩存所必需的配置，把它們都放在自定義的 CachingConfigurerSupport 中 */
// @Bean // public CacheManager cacheManager( RedisTemplate redisTemplate) { // RedisCacheManager cacheManager = new RedisCacheManager(redisTemplate); //        // cacheManager.setDefaultExpiration(60);//設置緩存保留時間（seconds） // return cacheManager; // } // 1.項目啓動時此方法先被註冊成bean被spring管理,若是沒有這個bean，則redis可視化工具中的中文內容（key或者value）都會以二進制存儲，不易檢查。  @Bean public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) { RedisTemplate<String, Object> template = new RedisTemplate<String, Object>(); template.setConnectionFactory(factory); Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class); ObjectMapper objectMapper = new ObjectMapper(); objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY); objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL); jackson2JsonRedisSerializer.setObjectMapper(objectMapper); 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; } }

　　啓動類：

@SpringBootApplication public class Application { public static void main(String[] args) { SpringApplication.run(Application.class, args); } }

　　程序接口：

@RestController @RequestMapping("/v1/test") public class RedisController { // @Autowired
//　　 系統默認的StringRedisTemplete // private StringRedisTemplate stringRedisTemplate;
 @Resource private RedisUtil redisUtil; //添加
    @PostMapping(value = "/add") public void saveRedis() { redisUtil.set("test-key2","test-value"); // stringRedisTemplate.opsForValue().set("test-key", "test-value");
 } //獲取
    @GetMapping(value = "/get") public String getRedis() { return redisUtil.get("test-key2").toString(); // return stringRedisTemplate.opsForValue().get("test-key");
 } }

　　此處抽離出一個公用RedisUtil：

@Componentpublic class RedisUtil { @Resource private RedisTemplate<String, Object> 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 delete(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 delta 要增長几(大於0) * @return long */
    public long increment(String key, long delta) { if ( delta < 0){ throw new RuntimeException("遞增因子必須大於0"); } return redisTemplate.opsForValue().increment(key, delta); } /** * 遞減 * * @param key 鍵 * @param delta 要減小几(小於0) * @return long */
    public long decrement(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 hashGet(String key, String item) { return redisTemplate.opsForHash().get(key, item); } /** * 獲取hashKey對應的全部鍵值 * @param key 鍵 * @return 對應的多個鍵值 */
    public Map<Object,Object> hashGetAll(String key) { return redisTemplate.opsForHash().entries(key); } /** * HashSet * * @param key 鍵 * @param map 對應多個鍵值 * @return true 成功 false 失敗 */
    public boolean hashSetAll(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 hashSetAll(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 hashSet(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 hashGet(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 hashDelete(String key, Object... item) { redisTemplate.opsForHash().delete(key, item); } /** * 判斷hash表中是否有該項的值 * * @param key 鍵 不能爲null * @param item 項 不能爲null * @return true 存在 false不存在 */
    public boolean hasHashKey(String key, String item) { return redisTemplate.opsForHash().hasKey(key, item); } /** * hash遞增 若是不存在,就會建立一個 並把新增後的值返回 * * @param key 鍵 * @param item 項 * @param by 要增長几(大於0) * @return double */
    public double hashIncrement(String key, String item, double by) { return redisTemplate.opsForHash().increment(key, item, by); } /** * hash遞減 * * @param key 鍵 * @param item 項 * @param by 要減小記(小於0) * @return double */
    public double hashDecrement(String key, String item, double by) { return redisTemplate.opsForHash().increment(key, item, -by); } // ============================set=============================
    /** * 根據key獲取Set中的全部值 * @param key 鍵 * @return Set<Object> */
    public Set<Object> setMembers(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 setIsMember(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 setAdd(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 setAdd(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 long */
    public long setSize(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 { return redisTemplate.opsForSet().remove(key, values); } catch (Exception e) { e.printStackTrace(); return 0; } } // ===============================list=================================

    /** * 獲取list緩存的內容 * @param key 鍵 * @param start 開始 * @param end 結束 0 到 -1表明全部值 * @return List<Object> */
    public List<Object> listGet(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 long */
    public long listGetSize(String key) { try { return redisTemplate.opsForList().size(key); } catch (Exception e) { e.printStackTrace(); return 0; } } /** * 經過索引 獲取list中的值 * * @param key 鍵 * @param index 索引 index&gt;=0時， 0 表頭，1 第二個元素，依次類推；index&lt;0時，-1，表尾，-2倒數第二個元素，依次類推 * @return Object */
    public Object listGetIndex(String key, long index) { try { return redisTemplate.opsForList().index(key, index); } catch (Exception e) { e.printStackTrace(); return null; } } /** * 將list放入緩存 * * @param key 鍵 * @param value 值 * @return true 成功 false 不成功 */
    public boolean listSet(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 true 成功 false 不成功 */
    public boolean listSet(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 true 成功 false 不成功 */
    public boolean listSet(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 true 成功 false 不成功 */
    public boolean listSet(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 true 成功 false 不成功 */
    public boolean listUpdateByIndex(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 listRemove(String key, long count, Object value) { try { return redisTemplate.opsForList().remove(key, count, value); } catch (Exception e) { e.printStackTrace(); return 0; } } }