Cassandra客户端工具

Apache Cassandra 是一个大规模可扩展的分布式开源NoSQL数据库，完美适用于跨数据中心／云端的结构化数据、半结构化数据和非结构化数据，同时，Cassandra 高可用、线性可扩展、高性能、无单点。

引入工具包

<dependency>
    <groupId>com.wueasy</groupId>
    <artifactId>wueasy-data-cassandra</artifactId>
    <version>最新版本</version>
</dependency>

连接配置

从3.4版本开始，spring boot升级至2.3.0.RELEASE，对应的连接信息也做了相应的修改。

3.4.0以上版本配置

• cassandra：配置cassandra连接集合，可以配置多个cassandra连接
  • demo：cassandra连接的key，可以配置多个，唯一
    • keyspaceName：键空间名称
    • contactpoints：新群集使用的接触点。多个逗号分隔
    • port：端口，默认9042
    • localDatacenter：本地数据中心
    • username：用户名
    • password：密码

wueasy :
  data:
    cassandra:
      demo: 
        keyspaceName: wueasy
        contactpoints: 49.234.40.74
        port: 9042
        username: cassandra
        password: cassandra
        localDatacenter: cn-hangzhou-g

3.x版本配置

• cassandra：配置cassandra连接集合，可以配置多个cassandra连接
  • demo：cassandra连接的key，可以配置多个，唯一
    • keyspaceName：键空间名称
    • contactpoints：新群集使用的接触点。多个逗号分隔
    • port：端口，默认9042
    • clusterName：群集的可选名称
    • username：用户名
    • password：密码

wueasy :
  data:
    cassandra:
      demo: 
        keyspaceName: wueasy
        contactpoints: 49.234.40.74
        port: 9042

java中引用cassandra客户端

通过@Qualifier注解注入，并指定服务名称。

• 服务名称说明：规则由cassandra配置的连接key + CassandraTemplate组成

@Autowired
@Qualifier("demoCassandraTemplate")
private  CassandraTemplate cassandraTemplate;