springboot WebFilter中使用redis

在 Spring Boot 中使用 Redis 在 WebFilter 中的示例：

1. 在 pom.xml 中添加 Redis 相关依赖：

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

2. 创建 Redis 配置类 RedisConfig.java：

@Configuration
public class RedisConfig {

    @Value("${spring.redis.host}")
    private String host;

    @Value("${spring.redis.port}")
    private int port;

    @Value("${spring.redis.password}")
    private String password;

    @Value("${spring.redis.timeout}")
    private int timeout;

    @Bean
    public JedisPool redisPoolFactory() {
        JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
        jedisPoolConfig.setMaxIdle(8);
        jedisPoolConfig.setMaxTotal(8);
        jedisPoolConfig.setMinIdle(0);
        jedisPoolConfig.setMaxWaitMillis(-1);

        JedisPool jedisPool = new JedisPool(jedisPoolConfig, host, port, timeout, password);

        return jedisPool;
    }
}

3. 创建 WebFilter 类 RedisWebFilter.java：

@Component
public class RedisWebFilter implements WebFilter {

    @Autowired
    private JedisPool jedisPool;

    @Override
    public Mono<Void> filter(ServerWebExchange exchange, WebFilterChain chain) {
        // 获取请求 URL
        String url = exchange.getRequest().getURI().getPath();

        // 判断 URL 是否需要使用 Redis 缓存
        if (needCache(url)) {
            // 从 Redis 缓存中获取数据
            Jedis jedis = jedisPool.getResource();
            String data = jedis.get(url);
            if (data != null) {
                // 如果缓存中有数据，直接返回数据
                exchange.getResponse().setStatusCode(HttpStatus.OK);
                exchange.getResponse().getHeaders().setContentType(MediaType.APPLICATION_JSON);
                return exchange.getResponse().writeWith(Mono.just(exchange.getResponse().bufferFactory().wrap(data.getBytes())));
            }
        }

        // 如果缓存中没有数据，继续执行后续的过滤器和处理器
        return chain.filter(exchange).doOnSuccess(v -> {
            // 处理完后，需要将数据存入 Redis 缓存
            if (needCache(url)) {
                String data = "cache data";
                Jedis jedis = jedisPool.getResource();
                jedis.set(url, data);
                jedis.expire(url, 60);
            }
        });
    }

    private boolean needCache(String url) {
        // 判断 URL 是否需要使用 Redis 缓存
        return true;
    }
}

在 RedisWebFilter 中，我们通过 JedisPool 获取 Jedis 对象，然后通过 Jedis 的 get 和 set 方法进行 Redis 缓存的读写操作。需要注意的是，在写入 Redis 缓存时，我们通过 expire 方法设置了缓存的过期时间为 60 秒。

最后，我们需要在配置文件 application.properties 中添加 Redis 相关配置：

spring.redis.host=localhost
spring.redis.port=6379
spring.redis.password=
spring.redis.timeout=3000