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 控制器运行测试时出现错误

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 驱动依赖，尝试使用 Spring Data Cassandra 的 1.5.0.M1 版本，并在 buildscript 中覆盖了 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);
    }
}