如何动态设置 Spring Data Cassandra 键空间？

Question

我们正在使用带有Spring Data for Apache Cassandra 的 Spring Boot 1.5.10，一切正常。

我们有一个新要求，我们需要在服务启动并运行时连接到不同的键空间。

通过使用 Spring Cloud Config Server，我们可以轻松设置 spring.data.cassandra.keyspace-name 的值，但是，我们不确定是否有一种方法可以动态切换（强制）服务以使用这个新的 keyspace，而无需是否必须先重新启动？

有什么想法或建议吗？

Answer 1

将 @RefreshScope 与属性/存储库一起使用不起作用，因为键空间绑定到 Cassandra Session bean。

将 Spring Data Cassandra 1.5 与 Spring Boot 1.5 一起使用，您至少有两个选择：

1. 声明@RefreshScope CassandraSessionFactoryBean，另见CassandraDataAutoConfiguration。这将在刷新并重新创建所有依赖 bean 时中断所有 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 抽象，为 CQL/会话调用的代码控制路由提供了 AbstractRoutingSessionFactory。

Answer 2

是的，您可以在持有spring.data.cassandra.keyspace-name 值的bean 上使用@RefreshScope 注释。

通过 Spring Cloud Config Server 更改配置值后，您必须在应用程序的 /refresh 端点上发出 POST。

来自Spring cloud documentation：

标记为@RefreshScope 的Spring @Bean 将在配置发生更改时得到特殊处理。这解决了只有在初始化时才注入配置的有状态 bean 的问题。例如，如果通过环境更改数据库 URL 时 DataSource 有打开的连接，我们可能希望这些连接的持有者能够完成他们正在做的事情。然后下次有人从池中借用连接时，他会使用新 URL 获得一个。

来自RefreshScope classjavadoc：

允许在运行时动态刷新 Bean 的 Scope 实现（参见 refresh(String) 和 refreshAll()）。如果一个 bean 被刷新，那么下次访问该 bean（即执行一个方法）时，就会创建一个新实例。所有生命周期方法都应用于 bean 实例，因此在 bean 工厂中注册的任何销毁回调都会在刷新时调用，然后在创建新实例时正常调用初始化回调。一个新的 bean 实例是从原始 bean 定义创建的，因此任何外部化的内容（字符串文字中的属性占位符或表达式）在创建时都会重新评估。