Spring Boot 集成 Redis-CFANZ编程社区

前言

随着Web应用的发展和数据量的增加，数据存储方案不断更新。Redis作为一个内存NoSQL数据库随着其高效的性能和易用性，越来越受到开发者的青睐。本文笔者将介绍如何在Spring Boot中集成Redis以及如何在实际应用中使用Redis。

摘要

本文旨在介绍如何在Spring Boot中集成Redis，并针对实际应用场景进行案例分析。本文首先介绍了Redis的基本概念和原理，然后详细阐述了如何在Spring Boot中集成Redis。接着针对实际应用场景，给出了相应的案例分析和优缺点分析。最后，笔者给出了全文的总结和结论。

简介

Redis简介

Redis是一个高性能的key-value存储系统，与其他key-value存储系统不同的是Redis支持多种数据结构，如字符串，散列，列表，集合等。Redis以其高效的性能和易用性，被广泛应用于缓存、计数器、消息队列、排行榜等领域。

Spring Boot简介

Spring Boot是一款基于Spring框架的快速开发框架，采用约定优于配置的方式，极大地简化了Spring应用的开发和部署。Spring Boot集成了大量常用的技术和框架，如Spring MVC、MyBatis、JPA等，很大程度上减少了开发人员需要关注的细节，使开发者可以专注于业务逻辑的实现。

源代码解析

pom.xml配置

在Spring Boot应用中集成Redis首先需要在pom.xml中添加相关的依赖。

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

Redis配置

Spring Boot集成Redis需要配置RedisTemplate，RedisConnectionFactory以及Redis的连接信息。

@Configuration
public class RedisConfig {

    @Bean
    JedisConnectionFactory jedisConnectionFactory() {
        RedisStandaloneConfiguration config = new RedisStandaloneConfiguration();
        config.setHostName("localhost");
        config.setPort(6379);
        return new JedisConnectionFactory(config);
    }

    @Bean
    public RedisTemplate<String, Object> redisTemplate() {
        RedisTemplate<String, Object> template = new RedisTemplate<>();
        template.setConnectionFactory(jedisConnectionFactory());
        return template;
    }

}

Redis常用操作

@Autowired
private RedisTemplate<String, String> redisTemplate;

/**
 * Redis String操作 - set、get、del
 */
public void stringOperations() {
    // set操作
    redisTemplate.opsForValue().set("key", "value");

    // get操作
    String value = redisTemplate.opsForValue().get("key");

    // del操作
    redisTemplate.delete("key");
}

/**
 * Redis List操作 - lpush、rpush、lpop、rpop、lrange
 */
public void listOperations() {
    // lpush操作
    redisTemplate.opsForList().leftPush("list_key", "value1");
    redisTemplate.opsForList().leftPush("list_key", "value2");

    // rpush操作
    redisTemplate.opsForList().rightPush("list_key", "value3");
    redisTemplate.opsForList().rightPush("list_key", "value4");

    // lpop操作
    String leftValue = redisTemplate.opsForList().leftPop("list_key");

    // rpop操作
    String rightValue = redisTemplate.opsForList().rightPop("list_key");

    // lrange操作
    List<String> rangeList = redisTemplate.opsForList().range("list_key", 0, -1);
}

/**
 * Redis Set操作 - sadd、srem、smembers
 */
public void setOperations() {
    // sadd操作
    redisTemplate.opsForSet().add("set_key", "value1", "value2", "value3");

    // srem操作
    redisTemplate.opsForSet().remove("set_key", "value1");

    // smembers操作
    Set<String> members = redisTemplate.opsForSet().members("set_key");
}

/**
 * Redis Hash操作 - hset、hmset、hget、hmget、del
 */
public void hashOperations() {
    // hset操作
    redisTemplate.opsForHash().put("hash_key", "field1", "value1");

    // hmset操作
    Map<String, String> map = new HashMap<>();
    map.put("field1", "value1");
    map.put("field2", "value2");
    redisTemplate.opsForHash().putAll("hash_key", map);

    // hget操作
    String hashValue = (String) redisTemplate.opsForHash().get("hash_key", "field1");

    // hmget操作
    List<String> hashValues = redisTemplate.opsForHash().multiGet("hash_key", Arrays.asList("field1", "field2"));

    // del操作
    redisTemplate.opsForHash().delete("hash_key", "field1");
}

应用场景案例

缓存

Redis最常用的功能之一就是作为缓存服务器，将热点数据缓存在内存中，以便快速访问。在Spring Boot中使用Redis作为缓存服务器可以使用Spring Cache抽象，只需要简单地配置一下Redis连接信息和相关的缓存注解即可。

@Configuration
@EnableCaching
public class CacheConfig extends CachingConfigurerSupport {

    @Bean
    @Override
    public KeyGenerator keyGenerator() {
        return (target, method, params) -> {
            StringBuilder sb = new StringBuilder();
            sb.append(target.getClass().getName());
            sb.append(method.getName());
            for (Object obj : params) {
                sb.append(obj.toString());
            }
            return sb.toString();
        };
    }

    @Bean
    public RedisTemplate<String, Serializable> redisTemplate(JedisConnectionFactory jedisConnectionFactory) {
        RedisTemplate<String, Serializable> redisTemplate = new RedisTemplate<>();
        redisTemplate.setConnectionFactory(jedisConnectionFactory);
        return redisTemplate;
    }

    @Bean
    public CacheManager cacheManager(RedisTemplate<String, Serializable> redisTemplate) {
        RedisCacheConfiguration redisCacheConfiguration = RedisCacheConfiguration.defaultCacheConfig()
                .entryTtl(Duration.ofMinutes(1));
        return RedisCacheManager.builder(redisTemplate.getConnectionFactory())
                .cacheDefaults(redisCacheConfiguration).build();
    }
}

在需要缓存的方法上添加缓存注解即可。

@Cacheable(value = "user", key = "#id")
public User getUserById(String id) {
    return userDao.selectById(id);
}

排行榜

Redis支持有序集合数据类型，能够在插入数据的同时按照指定的排序方式进行排序，非常适用于一些排行榜或者比赛得分等应用场景。

public void addScore(String member, double score) {
    redisTemplate.opsForZSet().add("score", member, score);
}

public List<String> getTop(int n) {
    Set<String> set = redisTemplate.opsForZSet().reverseRange("score", 0, n - 1);
    if (set != null) {
        return new ArrayList<>(set);
    }
    return null;
}