Где можно закрыть соединение Lettuce Redis в моем приложении Spring Boot?

Я инициализировал приложение Spring Boot с конфигурацией Lettuce (io.lettuce.core.api), подобной этой

@Configuration
class RedisConfiguration  {

    @Value("${spring.redis.host}")
    private String redisHostname;
    @Value("${spring.redis.port}")
    private int redisPort;

    private StatefulRedisConnection<String, String> redisConnection;
    private static RedisClient redisClient;

    @Bean
    public RedisCommands connectionFactory() {
        RedisURI redisURI = RedisURI.create(redisHostname,redisPort);
        redisClient = RedisClient.create(redisURI);
        redisConnection = redisClient.connect();
        RedisCommands<String, String> syncCommands = 
        redisConnection.sync();
        return syncCommands;
    }
}

Я хочу звонить redisClient.shutdown();, когда приложение закрывается или закрывается. Где правильно разорвать соединение Redis?

java spring spring-boot spring-data-redis lettuce

30.05.2019 21:36

Пользовательский скаляр GraphQL

Листовые узлы системы типов GraphQL называются скалярами. Достигнув скалярного типа, невозможно спуститься дальше по иерархии типов. Скалярный тип...

Как вычислять биты и понимать побитовые операторы в Java - объяснение с примерами

В компьютерном программировании биты играют важнейшую роль в представлении и манипулировании данными на двоичном уровне. Побитовые операции...

Поднятие тревоги для долго выполняющихся методов в Spring Boot

Приходилось ли вам сталкиваться с требованиями, в которых вас могли попросить поднять тревогу или выдать ошибку, когда метод Java занимает больше...

Принятие принципов SOLID в Spring Boot: Создание обслуживаемых и масштабируемых приложений

Коллекции (ArrayList , HashSet , HashMap)

Полный курс Java для разработчиков веб-сайтов и приложений

Получите сертификат Java Web и Application Developer, используя наш курс.

5 411

Перейти к ответу Данный вопрос помечен как решенный

Ответы 1

Ответ принят как подходящий

У вас есть два варианта:

Использование @PreDestroy:

    @PreDestroy
    public StatefulRedisConnection<String, String> redisConnection() {
        redisConnection.close();
        redisClient.close();
    }

С помощью @Bean методов

Убедитесь, что RedisClient и StatefulRedisConnection представлены как бобы. Командные интерфейсы (RedisCommands) не предоставляют метод close().

@Configuration
class RedisConfiguration  {

    @Value("${spring.redis.host}")
    private String redisHostname;
    @Value("${spring.redis.port}")
    private int redisPort;

    @Bean(destroyMethod = "close")
    public StatefulRedisConnection<String, String> redisClient() {
        RedisURI redisURI = RedisURI.create(redisHostname,redisPort);
        return RedisClient.create(redisURI);
        redisConnection = redisClient.connect();
    }

    @Bean(destroyMethod = "close")
    public StatefulRedisConnection<String, String> redisConnection(RedisClient client) {
        return client.connect();
    }

    @Bean
    public RedisCommands redisCommands(StatefulRedisConnection<String, String> connection) {
        return connection.sync();
    }
}

Первый метод короче, а подход @Bean позволяет вам взаимодействовать с промежуточными объектами в вашем приложении.

Безопасно ли создавать RedisAdvancedClusterCommands как singleton spring bean-компонент и делиться им с несколькими сервисными потоками? В большинстве онлайн-примеров я вижу, что StatefulRedisClusterConnection объявляется как bean-компонент, а RedisAdvancedClusterCommands создается для каждого вызова службы? Однако тот факт, что интерфейс помечен как thread-safe в документации и отсутствие RedisTransactionalCommands или аналогичного интерфейса, заставляет меня думать, что его безопасно использовать в потоках обслуживания.

— 16.01.2020 12:53

09.06.2019 16:54