<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId></dependency>二、在application.yml 配置redis服務器

spring: # 環境 dev|test|prod profiles: active: dev servlet: multipart: max-file-size: 100MB max-request-size: 100MB enabled: true redis: database: 0 # Redis服務器數據庫 host: 192.168.6.27 # Redis服務器地址 port: 6379 # Redis服務器連接端口 password: 123456 # Redis服務器連接密碼（默認為空） timeout: 6000ms # 連接超時時間（毫秒） jedis: pool: max-active: 200 # 連接池最大連接數（使用負值表示沒有限制） max-wait: -1 # 連接池最大阻塞等待時間（使用負值表示沒有限制） max-idle: 10 # 連接池中的最大空閑連接 min-idle: 0 # 連接池中的最小空閑連接三、寫一個redis配置類

（1）聊聊RedisTemplate的自動配置 其實現在就可以在代碼中注入RedisTemplate，為啥可以直接注入呢？先看下源碼吧。下圖為RedisAutoConfiguration類中的截圖，為了防止圖片失效，代碼也貼上。

通過源碼可以看出，SpringBoot自動幫我們在容器中生成了一個RedisTemplate和一個StringRedisTemplate。但是，這個RedisTemplate的泛型是<Object,Object>，寫代碼不方便，需要寫好多類型轉換的代碼；我們需要一個泛型為<String,Object>形式的RedisTemplate。并且，這個RedisTemplate沒有設置數據存在Redis時，key及value的序列化方式。看到這個@ConditionalOnMissingBean注解后，就知道如果Spring容器中有了RedisTemplate對象了，這個自動配置的RedisTemplate不會實例化。因此我們可以直接自己寫個配置類，配置RedisTemplate。（2）既然自動配置不好用，就重新配置一個RedisTemplate

包的結構如下

代碼如下：

package com.yux.redisdemo.redis; 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.Jackson2JsonRedisSerializer; import org.springframework.data.redis.serializer.StringRedisSerializer; import com.fasterxml.jackson.annotation.JsonAutoDetect; import com.fasterxml.jackson.annotation.PropertyAccessor; import com.fasterxml.jackson.databind.ObjectMapper; /**15 * redis配置類16 * @author YUX17 * @date 2018年6月6日18 *19 */ @Configurationpublic class RedisConfig { @Bean @SuppressWarnings('all') 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 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; } }　四、編寫一個RedisUtil類

package com.yux.redisdemo.redis; import java.util.List; import java.util.Map; import java.util.Set; import java.util.concurrent.TimeUnit; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.stereotype.Component; import org.springframework.util.CollectionUtils; /**14 * Redis工具類15 * @author YUX16 * @date 2018年6月7日17 */ @Componentpublic final class RedisUtil { @Autowired private RedisTemplate<String, Object> redisTemplate; // =============================common============================ /** * 26 * 指定緩存失效時間 * 27 * * @param key 鍵 * 28 * @param time 時間(秒) * 29 * @return 30 */ 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; } } /** * 44 * 根據key 獲取過期時間 * 45 * * @param key 鍵 不能為null * 46 * @return 時間(秒) 返回0代表為永久有效 * 47 */ public long getExpire(String key) { return redisTemplate.getExpire(key, TimeUnit.SECONDS); } /** * 53 * 判斷key是否存在 * 54 * * @param key 鍵 * 55 * @return true 存在 false不存在 * 56 */ public boolean hasKey(String key) { try { return redisTemplate.hasKey(key); } catch (Exception e) { e.printStackTrace(); return false; } } /** * 67 * 刪除緩存 * 68 * * @param key 可以傳一個值 或多個 * 69 */ @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============================= /** * 83 * 普通緩存獲取 * 84 * * @param key 鍵 * 85 * @return 值 * 86 */ public Object get(String key) { return key == null ? null : redisTemplate.opsForValue().get(key); } /** * 92 * 普通緩存放入 * 93 * * @param key 鍵 * 94 * @param value 值 * 95 * @return true成功 false失敗 * 96 */ public boolean set(String key, Object value) { try { redisTemplate.opsForValue().set(key, value); return true; } catch (Exception e) { e.printStackTrace(); return false; } } /** * 109 * 普通緩存放入并設置時間 * 110 * * @param key 鍵 * 111 * @param value 值 * 112 * @param time 時間(秒) time要大于0 如果time小于等于0 將設置無限期 * 113 * @return true成功 false 失敗 * 114 */ 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; } } /** * 130 * 遞增 * 131 * * @param key 鍵 * 132 * @param delta 要增加幾(大于0) * 133 * @return 134 */ public long incr(String key, long delta) { if (delta < 0) { throw new RuntimeException('遞增因子必須大于0'); } return redisTemplate.opsForValue().increment(key, delta); } /** * 143 * 遞減 * 144 * * @param key 鍵 * 145 * @param delta 要減少幾(小于0) * 146 * @return 147 */ public long decr(String key, long delta) { if (delta < 0) { throw new RuntimeException('遞減因子必須大于0'); } return redisTemplate.opsForValue().increment(key, -delta); } // ================================Map================================= /** * 157 * HashGet * 158 * * @param key 鍵 不能為null * 159 * @param item 項 不能為null * 160 * @return 值 * 161 */ public Object hget(String key, String item) { return redisTemplate.opsForHash().get(key, item); } /** * 167 * 獲取hashKey對應的所有鍵值 * 168 * * @param key 鍵 * 169 * @return 對應的多個鍵值 * 170 */ public Map<Object, Object> hmget(String key) { return redisTemplate.opsForHash().entries(key); } /** * 176 * HashSet * 177 * * @param key 鍵 * 178 * @param map 對應多個鍵值 * 179 * @return true 成功 false 失敗 * 180 */ public boolean hmset(String key, Map<String, Object> map) { try { redisTemplate.opsForHash().putAll(key, map); return true; } catch (Exception e) { e.printStackTrace(); return false; } } /** * 192 * HashSet 并設置時間 * 193 * * @param key 鍵 * 194 * @param map 對應多個鍵值 * 195 * @param time 時間(秒) * 196 * @return true成功 false失敗 * 197 */ 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; } } /** * 212 * 向一張hash表中放入數據,如果不存在將創建 * 213 * * @param key 鍵 * 214 * @param item 項 * 215 * @param value 值 * 216 * @return true 成功 false失敗 * 217 */ 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; } } /** * 229 * 向一張hash表中放入數據,如果不存在將創建 * 230 * * @param key 鍵 * 231 * @param item 項 * 232 * @param value 值 * 233 * @param time 時間(秒) 注意:如果已存在的hash表有時間,這里將會替換原有的時間 * 234 * @return true 成功 false失敗 * 235 */ 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; } } /** * 250 * 刪除hash表中的值 * 251 * * @param key 鍵 不能為null * 252 * @param item 項 可以使多個 不能為null * 253 */ public void hdel(String key, Object... item) { redisTemplate.opsForHash().delete(key, item); } /** * 259 * 判斷hash表中是否有該項的值 * 260 * * @param key 鍵 不能為null * 261 * @param item 項 不能為null * 262 * @return true 存在 false不存在 * 263 */ public boolean hHasKey(String key, String item) { return redisTemplate.opsForHash().hasKey(key, item); } /** * 269 * hash遞增 如果不存在,就會創建一個 并把新增后的值返回 * 270 * * @param key 鍵 * 271 * @param item 項 * 272 * @param by 要增加幾(大于0) * 273 * @return 274 */ public double hincr(String key, String item, double by) { return redisTemplate.opsForHash().increment(key, item, by); } /** * 280 * hash遞減 * 281 * * @param key 鍵 * 282 * @param item 項 * 283 * @param by 要減少記(小于0) * 284 * @return 285 */ public double hdecr(String key, String item, double by) { return redisTemplate.opsForHash().increment(key, item, -by); } // ============================set============================= /** * 292 * 根據key獲取Set中的所有值 * 293 * * @param key 鍵 * 294 * @return 295 */ public Set<Object> sGet(String key) { try { return redisTemplate.opsForSet().members(key); } catch (Exception e) { e.printStackTrace(); return null; } } /** * 306 * 根據value從一個set中查詢,是否存在 * 307 * * @param key 鍵 * 308 * @param value 值 * 309 * @return true 存在 false不存在 * 310 */ public boolean sHasKey(String key, Object value) { try { return redisTemplate.opsForSet().isMember(key, value); } catch (Exception e) { e.printStackTrace(); return false; } } /** * 321 * 將數據放入set緩存 * 322 * * @param key 鍵 *323 * @param values 值 可以是多個 *324 * @return 成功個數 * 325 */ public long sSet(String key, Object... values) { try { return redisTemplate.opsForSet().add(key, values); } catch (Exception e) { e.printStackTrace(); return 0; } } /** * 336 * 將set數據放入緩存 * 337 * * @param key 鍵 *338 * @param time 時間(秒) *339 * @param values 值 可以是多個 *340 * @return 成功個數 * 341 */ 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; } } /** * 355 * 獲取set緩存的長度 * 356 * * @param key 鍵 * 357 * @return 358 */ public long sGetSetSize(String key) { try { return redisTemplate.opsForSet().size(key); } catch (Exception e) { e.printStackTrace(); return 0; } } /** * 369 * 移除值為value的 * 370 * * @param key 鍵 *371 * @param values 值 可以是多個 *372 * @return 移除的個數 * 373 */ 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================================= /** * 386 * 獲取list緩存的內容 * 387 * * @param key 鍵 * 388 * @param start 開始 * 389 * @param end 結束 0 到 -1代表所有值 * 390 * @return 391 */ 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; } } /** * 402 * 獲取list緩存的長度 * 403 * * @param key 鍵 * 404 * @return 405 */ public long lGetListSize(String key) { try { return redisTemplate.opsForList().size(key); } catch (Exception e) { e.printStackTrace(); return 0; } } /** * 416 * 通過索引 獲取list中的值 * 417 * * @param key 鍵 * 418 * @param index 索引 index>=0時， 0 表頭，1 第二個元素，依次類推；index<0時，-1，表尾，-2倒數第二個元素，依次類推 * 419 * @return 420 */ public Object lGetIndex(String key, long index) { try { return redisTemplate.opsForList().index(key, index); } catch (Exception e) { e.printStackTrace(); return null; } } /** * 431 * 將list放入緩存 * 432 * * @param key 鍵 * 433 * @param value 值 * 434 * @param time 時間(秒) * 435 * @return 436 */ 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; } } /** * 467 * 將list放入緩存 * 468 * * @param key 鍵 * 469 * @param value 值 * 470 * @param time 時間(秒) * 471 * @return 472 */ public boolean lSet(String key, List<Object> value) { try { redisTemplate.opsForList().rightPushAll(key, value); return true; } catch (Exception e) { e.printStackTrace(); return false; } } /** * 484 * 將list放入緩存 * 485 * <p> * 486 * * @param key 鍵 * 487 * @param value 值 * 488 * @param time 時間(秒) * 489 * @return 490 */ 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; } } /** * 504 * 根據索引修改list中的某條數據 * 505 * * @param key 鍵 * 506 * @param index 索引 * 507 * @param value 值 * 508 * @return 509 */ 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; } } /** * 521 * 移除N個值為value * 522 * * @param key 鍵 * 523 * @param count 移除多少個 * 524 * @param value 值 * 525 * @return 移除的個數 * 526 */ 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; } }}五、在service中注入RedisUtil可用

到此這篇關于Redis和springboot 整合redisUtil類的示例代碼的文章就介紹到這了,更多相關Redis和springboot 整合redisUtil類內容請搜索好吧啦網以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持好吧啦網！