你知道如何在springboot中使用redis嗎
阿新 • • 發佈：2019-05-29
特別說明：本文針對的是新版 spring boot 2.1.3，其 spring data 依賴為 spring-boot-starter-data-redis,且其預設連線池為 lettuce
redis 作為一個高效能的記憶體資料庫，如果不會用就太落伍了，之前在 node.js 中用過 redis，本篇記錄如何將 redis 整合到 spring boot 中。提供 redis 操作類，和註解使用 redis 兩種方式。主要內容如下：
- docker 安裝 redis
- springboot 整合 redis
- 編寫 redis 操作類
- 通過註解使用 redis
安裝 redis
通過 docker 安裝，docker compose 編排檔案如下：
# docker-compose.yml
version: "2"
services:
redis:
container_name: redis
image: redis:3.2.10
ports:
- "6379:6379" 然後在docker-compose.yml所在目錄使用docker-compose up -d命令，啟動 redis。
整合 springboot
說明：springboot 版本為 2.1.3
新增 maven 依賴
只需新增spring-boot-starter-data-redis
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> <exclusions> <exclusion> <groupId>io.lettuce</groupId> <artifactId>lettuce-core</artifactId> </exclusion> </exclusions> </dependency> <dependency> <groupId>org.apache.commons</groupId> <artifactId>commons-pool2</artifactId> </dependency> <dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> </dependency>
編寫 springboot 配置檔案
配置檔案如下：
server:
port: 8081
servlet:
context-path: /sso
spring:
application:
name: SSO
cache:
type: redis
redis:
database: 0
host: 192.168.226.5
port: 6379
# 有密碼填密碼，沒有密碼不填
password:
# 連線超時時間（ms)
timeout: 1000ms
# 高版本springboot中使用jedis或者lettuce
jedis:
pool:
# 連線池最大連線數（負值表示無限制）
max-active: 8
# 連線池最大阻塞等待時間（負值無限制)
max-wait: 5000ms
# 最大空閒連結數
max-idle: 8
# 最小空閒連結數
min-idle: 0編寫配置類
配置類程式碼如下：
@EnableCaching//開啟快取
@Configuration
public class RedisConfig extends CachingConfigurerSupport {
/**
* 設定快取管理器，這裡可以配置預設過期時間等
*
* @param connectionFactory 連線池
* @return
*/
@Bean
public CacheManager cacheManager(RedisConnectionFactory connectionFactory) {
RedisCacheConfiguration redisCacheConfiguration = RedisCacheConfiguration
.defaultCacheConfig()
.entryTtl(Duration.ofSeconds(60));
//注意：請勿使用先new 配置物件，然後在呼叫entryTtl方法的方式來操作
//會導致配置不生效，原因是呼叫.entryTtl方法會返回一個新的配置物件，而不是在原來的配置物件上修改
RedisCacheWriter redisCacheWriter = RedisCacheWriter.nonLockingRedisCacheWriter(connectionFactory);
RedisCacheManager manager = new RedisCacheManager(redisCacheWriter, redisCacheConfiguration);
return manager;
}
@SuppressWarnings("all")
@Bean
public RedisTemplate<String, String> redisTemplate(JedisConnectionFactory factory) {
StringRedisTemplate template = new StringRedisTemplate(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);
RedisSerializer stringSerializer = new StringRedisSerializer();
template.setKeySerializer(stringSerializer);
template.setValueSerializer(jackson2JsonRedisSerializer);
template.setHashKeySerializer(stringSerializer);
template.setHashValueSerializer(jackson2JsonRedisSerializer);
template.afterPropertiesSet();
return template;
}
//使用jedis連線池建立jedis連線工廠
@Bean
public JedisConnectionFactory jedisConnectionFactory() {
logger.info("jedisConnectionFactory:初始化了");
JedisPoolConfig config = new JedisPoolConfig();
config.setMaxIdle(maxIdle);
config.setMinIdle(minIdle);
config.setMaxWaitMillis(maxWaitMillis);
config.setMaxTotal(maxActive);
//連結耗盡時是否阻塞，預設true
config.setBlockWhenExhausted(true);
//是否啟用pool的jmx管理功能，預設true
config.setJmxEnabled(true);
JedisConnectionFactory factory = new JedisConnectionFactory();
factory.setPoolConfig(config);
factory.setHostName(host);
factory.setPort(port);
factory.setPassword(password);
factory.setDatabase(database);
factory.setTimeout(timeout);
return factory;
}
}使用方法
有兩種方法來進行快取操作，一種是在方法上新增快取註解實現各種操作，一種是手動控制。個人比較喜歡手動控制，覺得這樣都在自己的掌控中。
通過註解使用
主要有以下 5 個註解：
@CacheConfig: 類級別快取，設定快取 key 字首之類的@Cacheable: 觸發快取入口@CacheEvict: 觸發移除快取@CachePut: 更新快取@Caching: 組合快取
@CacheConfig
該註解可以將快取分類，它是類級別註解，主要用於給某個類的快取全域性配置，例子如下：
@CacheConfig(cacheNames = "redis_test")
@Service
public class RedisService {
//....
}上面 CacheConfig 會給類下通過註解生成的 key 加上 redis_test 的字首。
@Cacheable
方法級別註解，根據 key 查詢快取:
- 如果 key 不存在，將方法返回值快取到 redis 中
- 如果 key 存在，直接從快取中取值
例子如下：
/**
* 快取時間，首次查詢後會快取結果,key中的值可使用表示式計算.
* 如不提供key，將使用預設key構造方法生成一個key
* @return long
*/
@Cacheable(key = "'currentTime'")
public long getTime() {
return System.currentTimeMillis();
}多次呼叫此段程式碼會發現每次返回的值都是一樣的。
CachePut
用於更新快取，每次呼叫都會想 db 請求，快取資料
- 如果 key 存在，更新內容
- 如果 key 不存在，插入內容
程式碼如下：
/**
* 一般用於更新查插入操作，每次都會請求db
*/
@CachePut(key = "'currentTime'+#id")
public long updateTime(String id) {
return System.currentTimeMillis();
}每次呼叫此方法都會根據 key 重新整理 redis 中的快取資料。
@CacheEvict
根據 key 刪除快取中的資料。allEntries=true 表示刪除快取中所有資料。
程式碼如下：
@CacheEvict(key = "'currentTime'+#id",allEntries=false)
public void deleteTime(String id) {
}@Caching
本註解可將其他註解組合起來使用。比如下面的例子：
//value屬性為key指定字首
@Caching(put = {@CachePut(value = "user", key = "'name_'+#user.name"),
@CachePut(value = "user", key = "'pass_'+#user.password")})
public User testCaching(User user) {
return user;
}上面的程式碼執行後將在 redis 中插入兩條記錄。使用keys *將看到如下結果：
手動控制
手動控制就相當於 mybatis 的手寫 sql 語句，需要呼叫redisTemplate中的各種方法來進行快取查詢，快取更新，快取刪除等操作。
使用方法參見 util/RedisUtil 中的方法。redisTemplate基本可以實現所有的 redis 操作。
本篇原創釋出於：springboot 整合 redis
專案原始碼：：github