spring-boot-cache整合redis

引入依赖

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-cache</artifactId>
</dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

配置

spring:cache:type: redisredis:host: localhostport: 6379username:password:database: 1

配置类

package com.qiangesoft.cache.config;import org.springframework.cache.CacheManager;
import org.springframework.cache.annotation.CachingConfigurerSupport;
import org.springframework.cache.annotation.EnableCaching;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.cache.RedisCacheConfiguration;
import org.springframework.data.redis.cache.RedisCacheManager;
import org.springframework.data.redis.cache.RedisCacheWriter;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.RedisSerializationContext;
import org.springframework.data.redis.serializer.StringRedisSerializer;import java.time.Duration;/*** 缓存配置** @author qiangesoft* @date 2024-05-15*/
@EnableCaching
@Configuration
public class RedisCacheConfig extends CachingConfigurerSupport {private static final StringRedisSerializer STRING_SERIALIZER = new StringRedisSerializer();private static final GenericJackson2JsonRedisSerializer JACKSON__SERIALIZER = new GenericJackson2JsonRedisSerializer();@Beanpublic CacheManager cacheManager(RedisConnectionFactory redisConnectionFactory) {RedisCacheConfiguration cacheConfiguration = RedisCacheConfiguration.defaultCacheConfig()// 三分钟有效期.entryTtl(Duration.ofMinutes(3)).serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(STRING_SERIALIZER)).serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(JACKSON__SERIALIZER));return RedisCacheManager.builder(RedisCacheWriter.nonLockingRedisCacheWriter(redisConnectionFactory)).cacheDefaults(cacheConfiguration).build();}@Beanpublic RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {// 配置redisTemplateRedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();redisTemplate.setConnectionFactory(redisConnectionFactory);// key序列化redisTemplate.setKeySerializer(STRING_SERIALIZER);// value序列化redisTemplate.setValueSerializer(JACKSON__SERIALIZER);// Hash key序列化redisTemplate.setHashKeySerializer(STRING_SERIALIZER);// Hash value序列化redisTemplate.setHashValueSerializer(JACKSON__SERIALIZER);redisTemplate.afterPropertiesSet();return redisTemplate;}}

服务类

package com.qiangesoft.cache.service;import lombok.extern.slf4j.Slf4j;
import org.springframework.cache.annotation.CacheEvict;
import org.springframework.cache.annotation.CachePut;
import org.springframework.cache.annotation.Cacheable;
import org.springframework.stereotype.Service;import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;/*** 用户服务类** @author qiangesoft* @date 2024-05-15*/
@Slf4j
@Service
public class UserInfoService {/*** 模拟数据库*/private final Map<Long, UserInfo> userInfoMap = new ConcurrentHashMap<>();private final String CACHE_KEY = "user";@CachePut(cacheNames = CACHE_KEY, key = "#userInfo.id")public UserInfo add(UserInfo userInfo) {log.info("UserInfoService.add() execute db !");userInfoMap.put(userInfo.getId(), userInfo);return userInfo;}@CacheEvict(cacheNames = CACHE_KEY, key = "#id")public void removeById(Long id) {log.info("UserInfoService.removeById() execute db !");userInfoMap.remove(id);}@CacheEvict(cacheNames = CACHE_KEY, allEntries = true)public void remove() {log.info("UserInfoService.remove() execute db !");userInfoMap.clear();}@CacheEvict(cacheNames = CACHE_KEY, key = "#userInfo.id")public void updateById(UserInfo userInfo) {log.info("UserInfoService.updateById() execute db !");userInfoMap.put(userInfo.getId(), userInfo);}@Cacheable(cacheNames = CACHE_KEY + ":list")public List<UserInfo> listAll() {log.info("UserInfoService.listAll() execute db !");return new ArrayList<>(userInfoMap.values());}@Cacheable(cacheNames = CACHE_KEY, key = "#id", unless = "#result == null")public UserInfo getById(Long id) {log.info("UserInfoService.getById() execute db !");UserInfo userInfo = userInfoMap.get(id);return userInfo;}}

测试

package com.qiangesoft.cache.controller;import com.qiangesoft.cache.service.UserInfo;
import com.qiangesoft.cache.service.UserInfoService;
import com.qiangesoft.cache.utils.CacheManagerUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;import java.util.List;/*** 用户测试** @author qiangesoft* @date 2024-05-15*/
@RequestMapping("/user")
@RestController
public class UserInfoController {@Autowiredprivate UserInfoService userInfoService;@Autowiredprivate CacheManagerUtil cacheManagerUtil;@PostMappingpublic void add(@RequestBody UserInfo userInfo) {userInfoService.add(userInfo);}@DeleteMapping("/{id}")public void removeById(@PathVariable Long id) {userInfoService.removeById(id);}@DeleteMapping("/all")public void remove() {userInfoService.remove();}@PutMappingpublic void updateById(@RequestBody UserInfo userInfo) {userInfoService.updateById(userInfo);}@GetMappingpublic List<UserInfo> listAll() {return userInfoService.listAll();}@GetMapping("/{id}")public UserInfo getById(@PathVariable Long id) {return userInfoService.getById(id);}@GetMapping("/current")public Object current(String id) {Object user = cacheManagerUtil.getCache("user", id);return user;}}