Spring Reactive Stack（四）响应式方式访问Redis

calendar Mar 4, 2021 · 1 分钟阅读 · 后端开发 SpringReactive Redis  ·
分享到: weibo copy

Spring Data Redis中同时支持了Jedis客户端和Lettuce客户端。但是仅Lettuce是支持Reactive方式的操作；这里选择默认的Lettuce客户端。

  1. 创建Maven项目，并在pom.xml导入依赖:
<!-- reactive redis依赖包（包含Lettuce客户端） -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis-reactive</artifactId>
</dependency>
  1. 配置文件application.yml
spring:
  redis:
    host: 127.0.0.1
    port: 6379
    password: 123456
    #Redis数据库索引（默认为0）
    database: 0
    #连接超时时间（毫秒）
    timeout: 5000
  1. 注入配置类：
@Configuration
public class ReactiveRedisConfig {
    @Bean
    public ReactiveRedisTemplate reactiveRedisTemplate(ReactiveRedisConnectionFactory factory) {
        return new ReactiveRedisTemplate<>(factory, RedisSerializationContext.string());
    }
}
  1. 简单的RedisService封装
@Service
@AllArgsConstructor
public class RedisService {

    private final ReactiveRedisTemplate<String, String> redisTemplate;

    public Mono<String> get(String key) {
        return key==null ? null : redisTemplate.opsForValue().get(key);
    }
    public Mono<Boolean> set(String key, String value) {
        return redisTemplate.opsForValue().set(key, value);
    }
    public Mono<Boolean> set(String key, String value, Long time) {
        return redisTemplate.opsForValue().set(key, value, Duration.ofSeconds(time));
    }
    public Mono<Boolean> exists(String key) {
        return redisTemplate.hasKey(key);
    }
    public Mono<Long> remove(String key) {
        return redisTemplate.delete(key);
    }
}
  1. 测试
@SpringBootTest
class ReactiveRedisTest {
    @Resource
    private RedisService redisService;

    @Test
    void test1() {
        // 保存5分钟
        redisService.set("test1", "test1_value", 5 * 60L).subscribe(System.out::println);
        redisService.get("test1").subscribe(System.out::println);
    }
}

测试运行结果：

true
test1_value

本文使用Spring Boot版本：2.4.3

END .

相关系列文章

×