Spring Boot Reactive Redis 2 连接工厂导致健康检查失败

Question

当使用 Reactive Redis 和 Webflux 时，有 2 个 redis 连接工厂。一种 react 性和非 react 性。非 react 性的显示为 “DOWN” 状态，导致其余的健康检查失败。

为什么有 2 个连接工厂？

build.gradle.kts

dependencies {
    compile("org.springframework.boot:spring-boot-starter-data-redis-reactive:2.1.4.RELEASE")

    implementation("org.springframework.boot:spring-boot-starter-actuator")
    implementation("org.springframework.boot:spring-boot-starter-data-mongodb-reactive")
    implementation("org.springframework.boot:spring-boot-starter-security")
    implementation("org.springframework.boot:spring-boot-starter-webflux")
    implementation("com.fasterxml.jackson.module:jackson-module-kotlin")
    implementation("org.jetbrains.kotlin:kotlin-stdlib-jdk8")
    implementation("org.jetbrains.kotlin:kotlin-reflect")
    implementation("io.jsonwebtoken:jjwt:0.9.1")
    implementation("org.json:json:20180813")
    runtimeOnly("org.springframework.boot:spring-boot-devtools")

    testRuntimeOnly("org.junit.jupiter:junit-jupiter-engine:5.3.1")
    testImplementation("org.springframework.boot:spring-boot-starter-test")
    testImplementation("de.flapdoodle.embed:de.flapdoodle.embed.mongo")
    testImplementation("io.projectreactor:reactor-test")
    testImplementation("org.springframework.security:spring-security-test")
    testImplementation("org.junit.jupiter:junit-jupiter-api:5.3.1")
}

RedisConfig.kt

@Configuration
@EnableConfigurationProperties
class RedisConfig(@Value("\${redis.host}") private val redisHost: String,
                  @Value("\${redis.port}") private val redisPort: Int) {

    @Bean
    fun reactiveRedisConnectionFactory(): ReactiveRedisConnectionFactory {
        return LettuceConnectionFactory(redisHost, redisPort)
    }

    @Bean
    fun keyCommands(reactiveRedisConnectionFactory: ReactiveRedisConnectionFactory): ReactiveKeyCommands {
        return reactiveRedisConnectionFactory.reactiveConnection.keyCommands()
    }

    @Bean
    fun stringCommands(reactiveRedisConnectionFactory: ReactiveRedisConnectionFactory): ReactiveStringCommands {
        return reactiveRedisConnectionFactory.reactiveConnection.stringCommands()
    }

}

localhost:8080/actuator/health

{
    "status": "DOWN",
    "details": {
        "mongo": {
            "status": "UP",
            "details": {
                "version": "4.0.8"
            }
        },
        "diskSpace": {
            "status": "UP",
            "details": {
                "total": 101241290752,
                "free": 96678289408,
                "threshold": 10485760
            }
        },
        "redis": {
            "status": "DOWN",
            "details": {
                "reactiveRedisConnectionFactory": {
                    "status": "UP",
                    "details": {
                        "version": "5.0.4"
                    }
                },
                "redisConnectionFactory": {
                    "status": "DOWN",
                    "details": {
                        "error": "org.springframework.data.redis.RedisConnectionFailureException: Unable to connect to Redis; nested exception is io.lettuce.core.RedisConnectionException: Unable to connect to localhost:6379"
                    }
                }
            }
        }
    }
}

Answer 1

不确定为什么在使用响应式(Reactive) Redis 时会有两个连接工厂，但是，我确实找到了一个临时解决方法来让健康检查通过。

我使用自己的属性来配置 redis redis.host 和 redis.port。

通过切换使用spring.redis.host和spring.redis.port，它还会同时配置第二个非响应式(Reactive)连接工厂。由于它们现在都可以连接到 Redis，因此健康检查将通过。

{
    "status": "UP",
    "details": {
        "mongo": {
            "status": "UP",
            "details": {
                "version": "4.0.4"
            }
        },
        "diskSpace": {
            "status": "UP",
            "details": {
                "total": 499763888128,
                "free": 381951664128,
                "threshold": 10485760
            }
        },
        "redis": {
            "status": "UP",
            "details": {
                "reactiveRedisConnectionFactory": {
                    "status": "UP",
                    "details": {
                        "version": "5.0.4"
                    }
                },
                "redisConnectionFactory": {
                    "status": "UP",
                    "details": {
                        "version": "5.0.4"
                    }
                }
            }
        }
    }
}