Redis 是一种高性能的键值存储数据库,而 Spring Boot 是一个简化了开发过程的 Java 框架。将两者结合,可以轻松地在 Spring Boot 项目中使用 Redis 来实现数据缓存、会话管理和分布式锁等功能。
话不多说直接干货!!!
org.springframework.boot spring-boot-starter-data-redis
在 application.yml 配置文件中添加 Redis 连接信息,根据自己 Redis 服务器配置,修改主机和端口信息
spring: redis: # 地址 host: localhost # 端口,默认为6379 port: 6379 # 数据库索引 database: 0 # 密码 password:
@Configuration public class RedisConfiguration { /** JSON 序列化器来对值进行序列化和反序列化 */ @Bean public RedisTemplateredisTemplate(RedisConnectionFactory cf) { RedisTemplate rt= new RedisTemplate<>(); rt.setConnectionFactory(cf); rt.setKeySerializer(new StringRedisSerializer()); rt.setValueSerializer(new GenericJackson2JsonRedisSerializer()); return rt; } }
/** 在服务类或控制器中注入 RedisTemplate */ @Autowired private RedisTemplateredisTemplate;
//使用注入的 RedisTemplate 来进行 Redis 操作,设置键值对、获取值 /** 设置键值对 */ redisTemplate.opsForValue().set("key", "value"); /** 获取值 */ String value = (String) redisTemplate.opsForValue().get("key");
org.springframework.boot spring-boot-starter-cache
//开启spring cache @EnableCaching @SpringBootApplication public class Application { // ... }
@Service public class redisService { @Cacheable(value = "cacheName", key = "#code") public Object getData(String id) { // 从数据库或其他数据源获取数据 return data; } @CachePut(value = "cacheName", key = "#code") public Object updateData(String id, Object newData) { // 更新数据库或其他数据源的数据 return newData; } @CacheEvict(value = "cacheName", key = "#code") public void deleteData(String id) { // 删除数据库或其他数据源的数据 } }
org.redisson redisson-spring-boot-starter 3.16.3
spring: redis: # 地址 redisson: config: classpath:redisson-single.yml #在 redisson-single.yml 配置文件中配置 Redisson 的连接信息
@Autowired private RedissonClient redissonClient; public void doSomething() { RLock lock = redissonClient.getLock("lockName"); try { lock.lock(); // 执行需要加锁的操作 } finally { lock.unlock(); } }
打开 Redis 配置文件 redis.conf
# 最大连接数 maxclients 10000 # TCP 连接的队列长度 tcp-backlog 500 # 连接池中的最大空闲连接数 maxidle 100 # 连接池中的最小空闲连接数 minidle 10 # 连接超时时间(毫秒) timeout 3000 # 是否开启 TCP 连接的保活机制 tcp-keepalive 0
@Configuration public class JedisConfig { @Bean public JedisPoolConfig jedisPoolConfig() { JedisPoolConfig poolConfig = new JedisPoolConfig(); poolConfig.setMaxTotal(10000); poolConfig.setMaxIdle(100); poolConfig.setMinIdle(10); poolConfig.setMaxWaitMillis(3000); // 其他配置项设置 return poolConfig; } @Bean public JedisConnectionFactory jedisConnectionFactory(JedisPoolConfig poolConfig) { RedisStandaloneConfiguration config = new RedisStandaloneConfiguration(); config.setHostName("127.0.0.1"); config.setPort(6379); // 其他 Redis 配置项设置 JedisClientConfiguration clientConfig = JedisClientConfiguration.builder() .usePooling().poolConfig(poolConfig) .build(); return new JedisConnectionFactory(config, clientConfig); } @Bean public RedisTemplateredisTemplate(JedisConnectionFactory connectionFactory) { RedisTemplate template = new RedisTemplate<>(); template.setConnectionFactory(connectionFactory); template.setKeySerializer(new StringRedisSerializer()); template.setValueSerializer(new GenericJackson2JsonRedisSerializer()); return template; } }
timeout 5000 //单位为毫秒
@Bean public JedisClientConfiguration jedisClientConfiguration() { Duration timeout = Duration.ofSeconds(5); return JedisClientConfiguration.builder() .readTimeout(timeout) .build(); } @Bean public JedisConnectionFactory jedisConnectionFactory(JedisClientConfiguration clientConfig) { // 其他配置项设置 return new JedisConnectionFactory(config, clientConfig); }