本文源码:GitHub·点这里 || GitEE·点这里
Cassandra是一套开源分布式NoSQL数据库系统。它最初由Facebook开发,用于储存收件箱等简单格式数据,此后,由于Cassandra良好的可扩展性,逐渐发展成为了一种流行的分布式结构化数据存储方案。
弹性可扩展性
Cassandra是高度可扩展的;它允许添加更多的硬件以适应更多的客户和更多的数据根据要求,可以根据业务的数据流量轻松扩展集群规模。
架构特点
Cassandra可以基于分布式运行,并采用了许多容错机制。由于去中心化无主的策略,所以没有单点故障。可以做到不停服滚动升级。这是因为Cassandra可以支持多个节点的临时失效(取决于群集大小),对群集的整体性能影响可以忽略不计。并且Cassandra提供多地域容灾。Cassandra允许将数据复制到其他数据中心,并在多个地域保留多副本,十分适用于不能承担故障的关键业务,必须持续提供服务的应用程序。
数据存储机制
Cassandra适应所有可能的数据格式,包括:结构化,半结构化和非结构化。可以根据业务的需要动态地适应变化的数据结构,并且通过在多个数据中心之间复制数据,可以灵活地在需要时分发数据。有许多案例证明Cassandra可以在金融,医疗,物联网等领域使用。
资源整合能力
Cassandra可以很容易的跟其他开源组件做集成,其中包括Hadoop,Spark,Kafka,Solr等系列组件,成为大数据业务处理里面重要的一个角色。
jdk1.8
apache-cassandra-3.11.7-bin.tar.gz
centos7
三台服务:hop01、hop02、hop03节点
将该配置分发到集群的每个节点,注意listen_address和rpc_address是节点自己的IP地址即可。
进入命令行
创建keyspace,并选择
创建表,写入数据
查询数据
基于其他服务查看数据,可以看到数据已经在集群间做了同步过程:

这里核心需要cassandra依赖和操作的API依赖。
keyspace-name:类似关系型数据库的名称;
contact-points:集群下节点的IP地址;
port:默认端口;
cluster-name:上述配置的集群名称;
CassandraTemplate模板类,实现了一系列操作Cassandra数据库的基本方法,直接注入即可使用。
SpringBoot框架中定义的数据库访问核心接口。
接口实现
接口用法
注意这里的注解是基于cassandra特定的一套。
推荐阅读:数据源管理系列
序号
标题
01
数据源管理:主从库动态路由,AOP模式读写分离
02
数据源管理:基于JDBC模式,适配和管理动态数据源
03
数据源管理:动态权限校验,表结构和数据迁移流程
04
数据源管理:关系型分库分表,列式库分布式计算
05
数据源管理:PostGreSQL环境整合,JSON类型应用
06
数据源管理:基于DataX组件,同步数据和源码分析
07
数据源管理:OLAP查询引擎,ClickHouse集群化管理
08
数据源管理:Kafka集群环境搭建,消息存储机制详解
09
数据源管理:搜索引擎框架,ElasticSearch集群模式