当以Servlet而非命令行方式运行时，Spring Boot可以连接到Cassandra

背景：我正在尝试为我们的Cassandra数据库设置基于代码的数据迁移系统。我没有大量的Java经验，但是如果这是一个.NET项目，我将在相同的解决方案下将迁移设置为另一个项目。但是，根据其他经验丰富的团队成员的建议，建议将迁移内容与应用程序的其余部分包含在同一软件包中（我很好）。还建议最简单的方法是通过Web API端点（我对此表示怀疑）来运行迁移。为了避免造成潜在的安全漏洞，我认为我会尝试制作一个命令行实用程序来执行迁移。

我有一个Spring Boot Web应用程序，其入口点类如下：

@Configuration
@SpringBootApplication
@EnableAutoConfiguration
@EnableCaching
@EnableScheduling
public class MyApplication extends SpringBootServletInitializer {

  @Override
  protected SpringApplicationBuilder configure(SpringApplicationBuilder application) {
    return application.sources(MyApplication.class);
  }

  public static void main(String[] args) {
    new MyApplication().configure(new SpringApplicationBuilder(MyApplication.class)).run(args);
  }
}

但是，我试图添加功能来运行通过命令行（例如java -jar MyApplication.jar migrate）与此应用程序一起打包的几个迁移脚本，因此我添加了以下类：

@Configuration
@SpringBootApplication
@EnableAutoConfiguration
public class MigrationRunner implements CommandLineRunner {

  @Autowired
  Session session;

  @Override
  public void run(String[] args)
  {
    MigrationResources mr = new MigrationResources();
    mr.addMigration(...);
    mr.addMigration(...);

    MigrationEngine.withSession(session).migrate(mr);
  }
}

然后像这样更新我的入口点类：

// annotations
public class MyApplication extends SpringBootServletInitializer {

  private final static String MIGRATE_COMMAND = "migrate";

  @Override
  protected SpringApplicationBuilder configure(SpringApplicationBuilder application) {
    return application.sources(MyApplication.class);
  }

  public static void main(String[] args) {
    if (args.length > 0 && args[0].equalsIgnoreCase(MIGRATE_COMMAND)) {
      new SpringApplicationBuilder()
          .sources(MigrationRunner.class)
          .run(Arrays.copyOfRange(args,1,args.length));
    } else {
      new MyApplication().configure(new SpringApplicationBuilder(MyApplication.class)).run(args);
    }
  }
}

问题是，当我使用migrate arg执行此操作时，Spring会引发此错误：

创建名称为'migrationRunner'的bean时出错：通过字段'session'表示不满意的依赖关系


在类路径资源[org / springframework / boot / autoconfigure / data / cassandra / CassandraDataAutoConfiguration.class]中创建名称为“会话”的bean时出错：初始化方法失败


所有尝试查询的主机均失败（尝试：server022 / XX.YY.ZZ.022：9042（com.datastax.driver.core.exceptions.TransportException：[server022 / XX.YY.ZZ.022： [9042]连接已关闭），server022 / XX.YY.ZZ.020：9042（com.datastax.driver.core.exceptions.TransportException：[server020 / XX.YY.ZZ.020：9042]连接已关闭），server020 / XX.YY.ZZ.021：9042（com.datastax.driver.core.exceptions.TransportException：[server020 / XX.YY.ZZ.021：9042]连接已关闭））

在没有migrate arg的情况下运行它仍然可以正常工作。我怀疑，即使它似乎正在获取所有其他配置属性（服务器名称，键空间等），Spring仍未为该Cassandra服务器选择正确的证书。

问题：如何制作一个也具有命令行模式且可以在两种模式下都连接到已配置的Cassandra服务器的Spring Boot servlet？

您需要做的就是

@SpringBootApplication
public class MyApplication
    public static void main(String[] args) {
        SpringApplication.run(MyApplication.class,args);
    }
}

您已经使应用程序复杂化了。如果您运行的MyApplication.main默认在端口8080中运行。

奖金，如果您都需要从同一个class开始。

@SpringBootApplication
public class MigrationRunner implements CommandLineRunner {

  @Autowired
  Session session;


  public static void main(String[] args) {
        SpringApplication.run(MyApplication.class,args);
  }

  @Override
  public void run(String[] args)
  {
    MigrationResources mr = new MigrationResources();
    mr.addMigration(...);
    mr.addMigration(...);

    MigrationEngine.withSession(session).migrate(mr);
  }
}

当以Servlet而非命令行方式运行时，Spring Boot可以连接到Cassandra

liningoo 回答：当以Servlet而非命令行方式运行时，Spring Boot可以连接到Cassandra

大家都在问