java - Spring Boot 1.4.1 和 Cassandra 3.x

Question

我想在 Spring Boot 项目中使用 Cassandra 3.x。我发现 Spring Data Cassandra 项目的当前发布版本仅支持 Cassandra 2.x。所以我想使用 DataStax Driver 而不是 Spring Data Cassandra 项目。我加了

compile 'com.datastax.cassandra:cassandra-driver-core:3.1.1'

作为依赖项。现在我可以将值插入到 Cassandra 集群上的键空间中。但是当为 REST Controller 运行测试时，我得到一个错误

java.lang.NoClassDefFoundError: io/netty/handler/codec/http/FullHttpRequest

所以我加了

compile 'io.netty:netty-all:4.1.6.Final'

作为依赖项，错误消失了。但是现在所有测试都使用

TestRestTemplate.postForObject(...)

或

TestRestTemplate.put(...)

失败。但是使用

TestRestTemplate.getForObject(...)

按预期工作。我假设 Spring Boot 的依赖项与我添加为依赖项的 Netty 版本存在一些冲突。

我发现最新版本的 DataStax Cassandra 驱动程序在没有额外的 Netty 依赖项的情况下工作是 2.1.5，日期为 2015 年 3 月并且不支持 Cassandra 3。使用这个驱动程序一切正常，但我不想要使用那么旧的驱动程序。

更新:我删除了 DataStax 驱动程序依赖项并尝试使用 1.5.0.M1 版本的 Spring Data Cassandra 并在构建脚本中覆盖了 Spring、Spring Data Cassandra 和 Cassandra 驱动程序版本。

ext['spring.version'] = '5.0.0.M2'
ext['spring-data-releasetrain.version'] = 'Ingalls-M1'
ext['cassandra-driver.version'] = '3.1.1'

这导致了以下错误:

java.lang.NoClassDefFoundError: io/netty/util/Timer

使用 Cassandra 功能时。当我再次包含 Netty 时，Cassandra 功能可以工作，但我使用 TestRestTemplate.put 和 .post 的测试不再运行。我再次尝试升级到 Spring Boot 版本 2.0.0.BUILD-SNAPSHOT，其中还包括 Spring Data Cassandra 1.5.0.M1。现在，当我启动应用程序并使用 DataStax 驱动程序功能时，我得到与以前相同的 NoClassDefFoundError。将 Netty 添加为依赖项再次杀死了我基于 TestRestTemplate 的单元测试...

更新:TestRestTemplate 不工作，因为 Spring Boot 将其配置为在类路径上找到 Netty 时使用 Netty4ClientHttpRequestFactory 而 Netty4ClientHttpRequestFactory 没有' 似乎有效。

参见 https://github.com/spring-projects/spring-boot/issues/7240和 https://jira.spring.io/browse/SPR-14860

有关修复，请参阅我对这个问题的回答。

Answer 1

我坚持使用 Spring Data Cassandra 1.5.0.M1 和 Cassandra 驱动程序 3.1.1，并使用以下版本覆盖:

ext['spring.version'] = '5.0.0.M2'
ext['spring-data-releasetrain.version'] = 'Ingalls-M1'
ext['cassandra-driver.version'] = '3.1.1'

为了使 Cassandra 驱动程序功能正常工作，我必须将 Netty 添加为依赖项。

compile 'io.netty:netty-all:4.1.6.Final'

要制作 TestRestTemplate.postForObject(...) 和 TestRestTemplate.put(...) 我必须提供一个 RestTemplateBuilder @Bean 并将其配置为使用 SimpleClientHttpRequestFactory。

@TestConfiguration
static class TestConfig {
    @Bean
    public RestTemplateBuilder restTemplateBuilder() {
        return new RestTemplateBuilder().detectRequestFactory(false).requestFactory(SimpleClientHttpRequestFactory.class);
    }
}