Spring Boot 1.4.1 和 Cassandra 3.x

Spring Boot 1.4.1 and Cassandra 3.x

我想在 Spring 引导项目中使用 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 版本,并覆盖了构建脚本中的 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 Version 2.0.0.BUILD-SNAPSHOT,其中还包括 Spring Data Cassandra 1.5.0.M1。现在,当我启动应用程序并使用 DataStax 驱动程序功能时,我得到与以前相同的 NoClassDefFoundError。将 Netty 添加为依赖项再次杀死了我基于 TestRestTemplate 的单元测试...

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

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

如需修复,请参阅我对这个问题的回答。

我坚持使用 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);
    }
}