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

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

（1）聊聊RedisTemplate的自動(dòng)配置 其實(shí)現(xiàn)在就可以在代碼中注入RedisTemplate，為啥可以直接注入呢？先看下源碼吧。下圖為RedisAutoConfiguration類(lèi)中的截圖，為了防止圖片失效，代碼也貼上。

通過(guò)源碼可以看出，SpringBoot自動(dòng)幫我們?cè)谌萜髦猩闪艘粋€(gè)RedisTemplate和一個(gè)StringRedisTemplate。但是，這個(gè)RedisTemplate的泛型是<Object,Object>，寫(xiě)代碼不方便，需要寫(xiě)好多類(lèi)型轉(zhuǎn)換的代碼；我們需要一個(gè)泛型為<String,Object>形式的RedisTemplate。并且，這個(gè)RedisTemplate沒(méi)有設(shè)置數(shù)據(jù)存在Redis時(shí)，key及value的序列化方式。看到這個(gè)@ConditionalOnMissingBean注解后，就知道如果Spring容器中有了RedisTemplate對(duì)象了，這個(gè)自動(dòng)配置的RedisTemplate不會(huì)實(shí)例化。因此我們可以直接自己寫(xiě)個(gè)配置類(lèi)，配置RedisTemplate。（2）既然自動(dòng)配置不好用，就重新配置一個(gè)RedisTemplate

包的結(jié)構(gòu)如下

代碼如下：

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配置類(lèi)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; } }　四、編寫(xiě)一個(gè)RedisUtil類(lèi)

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工具類(lèi)15 * @author YUX16 * @date 2018年6月7日17 */ @Componentpublic final class RedisUtil { @Autowired private RedisTemplate<String, Object> redisTemplate; // =============================common============================ /** * 26 * 指定緩存失效時(shí)間 * 27 * * @param key 鍵 * 28 * @param time 時(shí)間(秒) * 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 * 根據(jù)key 獲取過(guò)期時(shí)間 * 45 * * @param key 鍵 不能為null * 46 * @return 時(shí)間(秒) 返回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 可以傳一個(gè)值 或多個(gè) * 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 * 普通緩存放入并設(shè)置時(shí)間 * 110 * * @param key 鍵 * 111 * @param value 值 * 112 * @param time 時(shí)間(秒) time要大于0 如果time小于等于0 將設(shè)置無(wú)限期 * 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 項(xiàng) 不能為null * 160 * @return 值 * 161 */ public Object hget(String key, String item) { return redisTemplate.opsForHash().get(key, item); } /** * 167 * 獲取hashKey對(duì)應(yīng)的所有鍵值 * 168 * * @param key 鍵 * 169 * @return 對(duì)應(yīng)的多個(gè)鍵值 * 170 */ public Map<Object, Object> hmget(String key) { return redisTemplate.opsForHash().entries(key); } /** * 176 * HashSet * 177 * * @param key 鍵 * 178 * @param map 對(duì)應(yīng)多個(gè)鍵值 * 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 并設(shè)置時(shí)間 * 193 * * @param key 鍵 * 194 * @param map 對(duì)應(yīng)多個(gè)鍵值 * 195 * @param time 時(shí)間(秒) * 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表中放入數(shù)據(jù),如果不存在將創(chuàng)建 * 213 * * @param key 鍵 * 214 * @param item 項(xiàng) * 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表中放入數(shù)據(jù),如果不存在將創(chuàng)建 * 230 * * @param key 鍵 * 231 * @param item 項(xiàng) * 232 * @param value 值 * 233 * @param time 時(shí)間(秒) 注意:如果已存在的hash表有時(shí)間,這里將會(huì)替換原有的時(shí)間 * 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 項(xiàng) 可以使多個(gè) 不能為null * 253 */ public void hdel(String key, Object... item) { redisTemplate.opsForHash().delete(key, item); } /** * 259 * 判斷hash表中是否有該項(xiàng)的值 * 260 * * @param key 鍵 不能為null * 261 * @param item 項(xiàng) 不能為null * 262 * @return true 存在 false不存在 * 263 */ public boolean hHasKey(String key, String item) { return redisTemplate.opsForHash().hasKey(key, item); } /** * 269 * hash遞增 如果不存在,就會(huì)創(chuàng)建一個(gè) 并把新增后的值返回 * 270 * * @param key 鍵 * 271 * @param item 項(xiàng) * 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 項(xiàng) * 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 * 根據(jù)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 * 根據(jù)value從一個(gè)set中查詢(xún),是否存在 * 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 * 將數(shù)據(jù)放入set緩存 * 322 * * @param key 鍵 *323 * @param values 值 可以是多個(gè) *324 * @return 成功個(gè)數(shù) * 325 */ public long sSet(String key, Object... values) { try { return redisTemplate.opsForSet().add(key, values); } catch (Exception e) { e.printStackTrace(); return 0; } } /** * 336 * 將set數(shù)據(jù)放入緩存 * 337 * * @param key 鍵 *338 * @param time 時(shí)間(秒) *339 * @param values 值 可以是多個(gè) *340 * @return 成功個(gè)數(shù) * 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緩存的長(zhǎng)度 * 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 值 可以是多個(gè) *372 * @return 移除的個(gè)數(shù) * 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緩存的內(nèi)容 * 387 * * @param key 鍵 * 388 * @param start 開(kāi)始 * 389 * @param end 結(jié)束 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緩存的長(zhǎng)度 * 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 * 通過(guò)索引 獲取list中的值 * 417 * * @param key 鍵 * 418 * @param index 索引 index>=0時(shí)， 0 表頭，1 第二個(gè)元素，依次類(lèi)推；index<0時(shí)，-1，表尾，-2倒數(shù)第二個(gè)元素，依次類(lèi)推 * 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 時(shí)間(秒) * 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 時(shí)間(秒) * @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 時(shí)間(秒) * 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 時(shí)間(秒) * 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 * 根據(jù)索引修改list中的某條數(shù)據(jù) * 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個(gè)值為value * 522 * * @param key 鍵 * 523 * @param count 移除多少個(gè) * 524 * @param value 值 * 525 * @return 移除的個(gè)數(shù) * 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可用

到此這篇關(guān)于Redis和springboot 整合redisUtil類(lèi)的示例代碼的文章就介紹到這了,更多相關(guān)Redis和springboot 整合redisUtil類(lèi)內(nèi)容請(qǐng)搜索好吧啦網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持好吧啦網(wǎng)！