SpringWebFlux有没有一种方法可以在Java中使用Redis reactive设置超时？

Question

我正在使用ReactiveRedisConnection配置到本地redis容器的连接

但在未来，应用程序将托管在Web服务器上，而redis将托管在不同的服务器上

有没有设置请求超时的选项

Answer 1

可以在反应式连接实现上配置超时。如果您使用莴苣进行Redis连接，则可以执行以下操作

@Bean
public ReactiveRedisConnectionFactory reactiveRedisConnectionFactory() {
    return new LettuceConnectionFactory(new RedisStandaloneConfiguration(), LettuceClientConfiguration.builder().commandTimeout(Duration.ofSeconds(2)).build());
}

然后使用connectionFactory创建ReactiveRedisTemplate

@Bean
public ReactiveRedisTemplate<String, String> reactiveRedisTemplateString
  (ReactiveRedisConnectionFactory connectionFactory) {
    return new ReactiveRedisTemplate<>(connectionFactory, RedisSerializationContext.string());
}

Answer 2

经过一些研究和测试，我发现必须在请求查询上设置超时

因此，在config类上：

@Bean
public ReactiveRedisTemplate<String, String> reactiveRedisTemplateString
(ReactiveRedisConnectionFactory connectionFactory) {
    return new ReactiveRedisTemplate<>
              (connectionFactory, RedisSerializationContext.string());
}

在服务中：

@Autowired
private ReactiveRedisTemplate<String, Response> repository;

public Mono<String> execute(String value){
        return repository.opsForHash().entries("KEY_TO_SEARCH")
                .timeout(Duration.ofMillis(TIMEOUT))
                .collect(Collectors.toMap("CODE_HERE");

编辑：感谢所有在这里帮忙的人