Как динамически установить пространство ключей Spring Data Cassandra?

Использование @RefreshScope со свойствами/репозиториями не работает, так как пространство ключей привязано к bean-компоненту Cassandra Session.

Используя Spring Data Cassandra 1.5 с Spring Boot 1.5, у вас есть как минимум два варианта:

1. Объявите @RefreshScope CassandraSessionFactoryBean, см. также CassandraDataAutoConfiguration. Это прервет все операции Cassandra при обновлении и заново создаст все зависимые компоненты.

2. Прослушайте RefreshScopeRefreshedEvent и измените пространство клавиш через USE my-new-keyspace;. Этот подход является менее инвазивным и не прерывает выполнение запросов. Вы бы в основном использовали прослушиватель событий.

   @Component
   class MySessionRefresh {
   
     private final Session session;
     private final Environment environment;
   
     // omitted constructors for brevity
   
     @EventListener
     @Order(Ordered.LOWEST_PRECEDENCE)
     public void handle(RefreshScopeRefreshedEvent event) {
   
       String keyspace = environment.getProperty("spring.data.cassandra.keyspace-name");
       session.execute("USE " + keyspace + ";");
     }
   }
   

В Spring Data Cassandra 2 мы представили SessionFactory, предоставляющая AbstractRoutingSessionFactory для управляемой кодом маршрутизации вызовов CQL/сеанса.

Да, вы можете использовать @RefreshScope аннотация для bean-компонентов, содержащих значение spring.data.cassandra.keyspace-name.

После изменения значения конфигурации через Spring Cloud Config Server вы должны выполнить POST на конечной точке /refresh вашего приложения.

Из Документация по облаку Spring:

Spring @Bean, помеченный как @RefreshScope, получит специальную обработку при изменении конфигурации. Это решает проблему bean-компонентов с отслеживанием состояния, конфигурация которых вводится только при инициализации. Например, если у DataSource есть открытые соединения, когда URL-адрес базы данных изменяется через среду, мы, вероятно, хотим, чтобы владельцы этих соединений могли завершить то, что они делают. Затем в следующий раз, когда кто-то заимствует соединение из пула, он получает соединение с новым URL.

Из класс RefreshScope javadoc:

Реализация Scope, позволяющая динамически обновлять bean-компоненты во время выполнения (см. refresh(String) и refreshAll()). Если bean-компонент обновляется, то при следующем доступе к bean-компоненту (т. е. при выполнении метода) создается новый экземпляр. Все методы жизненного цикла применяются к экземплярам компонента, поэтому любые обратные вызовы уничтожения, которые были зарегистрированы в фабрике компонентов, вызываются при ее обновлении, а затем обратные вызовы инициализации вызываются как обычно при создании нового экземпляра. Новый экземпляр компонента создается из исходного определения компонента, поэтому любое внешнее содержимое (заполнители свойств или выражения в строковых литералах) переоценивается при его создании.