cassandra学习笔记4--Cassandra Java客户端

2024-05-01 17:32

本文主要是介绍cassandra学习笔记4--Cassandra Java客户端,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

  现在开始深入了解一下cassandra的数据模型。cassandra是一种NoSQL数据库,NoSQL并不是指没有SQL语句,而是指No Relationalcassandra的数据模型结合了Dynamokey/valueBigTable
 
的面向列的特点,主要被设计为存储大规模的分布式数据。
     PS:图片在这里显示不全,why?要看图片,可以另存为或复制图片地址,在浏览器里打开。

一、cassandra数据模型的特点

        1.它基于key-value模型

        cassandra的数据库由ColumnFamilies组成,一个ColumnFamily是一个key-value键值对的集合。若和关系型数据库类比,ColumnFamily相当于表,而里面的key-value键值对相当于表里的一条记录。

        2.它的key-value模型有多层嵌套

        ColumnFamily里的每条记录都是一个key-value对,value部分存放的是无限制的Columns。每个Column都有一个Column Namevalue,因此Column实际也是一个key-value对。但Columnvalue部分已经是最基本的数据存储单元,不能再向下嵌套了。在这种嵌套下,ColumnFamily的每条记录都包含一个key和一个由Columns组成的value(至少有一个Column),也就是说ColumnFamilyvalue只是一个中间人,实际存储数据的是value里的Columns。如下图所示。


        上面所说的是双层嵌套,还有一种三层嵌套。在这种情况下,ColumnFamily每条记录的value部分不是Columns,而是一种被称为SuperColumn的结构。SuperColumnkeySuperColumn name,它的value部分可以存储多个Columns,如下图所示:


        这样就有以下三种嵌套:

[java]  view plain copy
  1. ColumnFamily: key - value(SuperColumn)  
  2. SuperColumn: key(SuperColumn name) - value(Column)  
  3. Column: key(Column name) - value  

        SuperColumn里不能再存储SuperColumn,因此cassandra的嵌套最多为三层。

        3.ColumnSuperColumnname部分都可以用来存储实际数据

        首先,它们的name部分可以用来当做属性名。比如在一个存储用户邮箱的记录里,它是这样的:

[java]  view plain copy
  1. Column name=Email,value="fykhlp@163.com";  

        这是我们在传统关系型数据库里所习惯和使用的。但在cassandra里,name部分也可以直接用来存储实际数据。比如在一个只用来存储用户邮箱的记录里,我们可以这样:

[java]  view plain copy
  1. Column name="fykhlp@163.com",value=null;  

        这得益于(a)cassandra的非结构化数据存储,数据的存储不需要固定的位置(b)name部分也是使用字节流存储(关系型数据库的字段名必须是字符),因此可以存储任何类型的数据。

        4.ColumnSuperColumn按照name的顺序存储

        需要注意的是,cassandra并不是按照value的顺序存储数据,而是按照name。关于这点下文会详细说明。

二、cassandra数据模型的构成

        在这一部分,将详细讲解cassandra数据模型的各个组成部分。

        1.Column

        Column是数据存储的最小单位。它是一个包括namevaluetimestamp(时间戳)的元祖。下面是一个Column的示例:

[java]  view plain copy
  1. {  
  2.     name:"age",  
  3.     value:24,  
  4.     timestamp:123456789  
  5. }  

        方便书写,后文将省略时间戳,我们将Column看成一个name-value对。namevalue都是字节流,长度没有限制。

        2.SuperColumn

        一个SuperColumn是一个真正的name-value对,它没有时间戳。而且它的value部分可以包含无限个Column并且用Columnname部分作为关键字。下面是一个SuperColumn的示例:

[java]  view plain copy
  1. {  
  2.     name:"homeAddress"  
  3.     //value部分是多个Columns  
  4.     value:  
  5.     //这里的key是Column的name部分  
  6.     street:{name:"street",value:"XiTuCheng road"},  
  7.     city:{name:"city",value:"BeiJing"},  
  8.     zip:{name:"zip",value:"410083"},  
  9. }  

        在后面,不再写出namevalue,上文将简写为:

[java]  view plain copy
  1. homeAddress:{  
  2.     street:"XiTuCheng road",  
  3.     city:"BeiJing",  
  4.     zip:"410083",  
  5. }  

        3.Row

        在介绍下文的ColumnFamily前,我们先熟悉一下Row。在cassandra里,每个ColumnFamily都存在一个单独的文件里,这个文件以Row为单位存储并排序。因此,我们应尽量将相关的Column放在同一个ColumnFamily里。

        ColumnFamily的组成是一行行的Row,一个Row就是一个key-value对,key决定数据将被存在哪台机器上(笔记二的token部分有解释),value部分就是ColumnsSuperColumns

        4.ColumnFamily

        ColumnFamily是一个可以包含无数个Row的结构,又因为Rowvalue部分是ColumnsSuperColumns,因此ColumnFamily实际是ColumnsSuperColumns的容器。ColumnFamily对应关系型数据库里的“表”。下面给出ColumnFamilyRow的一个简单示例(使用Column):

[java]  view plain copy
  1. User={//这是一个ColumnFamily,名字是User  
  2.     zhangsan:{//这是一个Row,Row的key是zhangsan  
  3.     //下面的value可以有无限制的Columns,这里有两个  
  4.         username:"zhangsan",  
  5.         email:"zhangsan@163.com",  
  6.     },//这个Row结束了  
  7.     lisi:{//这是第二个Row,Row的key是lisi  
  8.     //value部分,依然是Columns,lisi有三个  
  9.         username:"lisi",  
  10.         email:"lisi@163.com",  
  11.         phone:"123456"  
  12.     },//Row结束  
  13. }  

        又如下图所示:


        在这个层面没有设计模式的要求,Row没有预先定义它们应该包含的Columns列表,就如上面的示例,李四可以随意的多一个phoneColumn。一个Row可能有成千上万个Columns而另一个Row可能只有一个Columncassandra在这一点上有无法比拟的灵活性。

        5.属性为SuperColumnFamily

        上面的示例是一个type为标准的(StandardColumnFamily,另外也有SuperColumnFamily,这取决于我们创建ColumnFamily时的定义。顾名思义,一个类型为SuperColumnFamilyRow存储的不是Columns,而是SuperColumns。在这种情况下,一个Rowvalue部分有若干个SuperColumns,一个SuperColumnsvalue部分又有若干个Columns。如下图所示:


        为什么要有SuperColumn呢?SuperColumn提供了比普通Column多一级的一对多关系。Column只能让一个key存储一组相关联的Columns,而这个能让一个key存储多组相关联的Columns

        这里给出一个应用:假设我们提供一种网上地址本的服务,用户可以在这保存他的朋友们的地址,而地址又是由不同的属性如邮编、街道、城市等组成。这时候我们可以采用SuperColumn。对于ColumnFamily,它的key使用的是用户自己的名字,value部分是若干SuperColumns。每个SuperColumnsname部分是用户某个朋友的名字,value部分是若干Columns,存储地址的各个属性。下面是示例:

[java]  view plain copy
  1. AddressBook={//这是一个SuperColumnFamily,名字是AddressBook  
  2.       
  3.     zhangsan:{//这是一个Row,key是zhangsan,张三的地址本  
  4.     //下面是Row的Value部分,可以有任意个SuperColumns  
  5.         lisi:{//这是SuperColumn的name  
  6.             //下面是Columns,表示地址  
  7.             street:"XiTuCheng road",  
  8.             zip:"410083",  
  9.             city:"BeiJing"  
  10.         },  
  11.         wangwu:{//另一个SuperColumn  
  12.             street:"XiTuCheng road",  
  13.             zip:"410083",  
  14.             city:"BeiJing"  
  15.         },  
  16.         zhaoliu:{//SuperColumn  
  17.             street:"XiTuCheng road",  
  18.             zip:"410083",  
  19.             city:"BeiJing"  
  20.         },  
  21.         .......  
  22.     }//end the row of zhangsan  
  23.       
  24.     lisi:{//这是另一个Row,key是lisi,李四的地址本  
  25.         wangwu:{//SuperColumn  
  26.             street:"XiTuCheng road",  
  27.             zip:"410083",  
  28.             city:"BeiJing"  
  29.         },  
  30.         zhangsan:{//SuperColumn  
  31.             street:"XiTuCheng road",  
  32.             zip:"410083",  
  33.             city:"BeiJing"  
  34.         },  
  35.         .......  
  36.     }  
  37. }  

        6.KeySpace

        KeySpace是最外层的容器,也是最大的容器,通常一个应用程序对应一个KeySpace。所有的ColumnFamily都位于一个KeySpace里面,它相当于关系数据库里的DB

三、cassandra的数据排序

        前面所介绍的是cassandra里各种数据容器的概念,现在来看看数据模型的另外一个关键地方即数据是如何排序的。cassandra和关系型数据库不同,你无法在取出数据时指定一种排序(order by)。数据在你存储到集群,被写入数据库时已经按照预定的规则被排好序。当你取出数据时,它们的顺序已经确定了。

        如前问所说,cassandra是按照name而不是value进行排序。cassandra在写入数据的时候,每个row中的所有Columns会按照name自动排好序。排序的规则由ColumnFamilyCompareWith选项确定,可选的有:BytesTypeUTF8TypeLexicalUUIDTypeTimeUUIDTypeAsciiTypeLongType。这些选项将Column Name看作不同的数据类型来排序,如LongType将它视为64bit Long类型。如下面给出的例子:

[java]  view plain copy
  1. {name: 123, value: “hello there”},  
  2. {name: 832416, value: “kjjkbcjkcbbd”},  
  3. {name: 3, value: “101010101010″},  
  4. {name: 976, value: “kjjkbcjkcbbd”}  

        采用LongType排序类型,结果是:

[java]  view plain copy
  1. {name: 3, value: “101010101010″},  
  2. {name: 123, value: “hello there”},  
  3. {name: 976, value: “kjjkbcjkcbbd”},  
  4. {name: 832416, value: “kjjkbcjkcbbd”}  

        采用UTF8Type排序类型,结果是:

[java]  view plain copy
  1. {name: 123, value: “hello there”},  
  2. {name: 3, value: “101010101010″},  
  3. {name: 832416, value: “kjjkbcjkcbbd”},  
  4. {name: 976, value: “kjjkbcjkcbbd”}  

        这些排序规则也适用于SuperColumnsRow内的排序,但对于SuperColumn内的Columns,用来定义排序规则的参数不再是RowSuperColumn里的CompareWith,而是CompareSubcolumnsWith

        我们可以自定义排序规则,实现接口org.apache.cassandra.db.marsha1.IType即可。


这篇关于cassandra学习笔记4--Cassandra Java客户端的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/952265

相关文章

Java实现检查多个时间段是否有重合

《Java实现检查多个时间段是否有重合》这篇文章主要为大家详细介绍了如何使用Java实现检查多个时间段是否有重合,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录流程概述步骤详解China编程步骤1:定义时间段类步骤2:添加时间段步骤3:检查时间段是否有重合步骤4:输出结果示例代码结语作

Java中String字符串使用避坑指南

《Java中String字符串使用避坑指南》Java中的String字符串是我们日常编程中用得最多的类之一,看似简单的String使用,却隐藏着不少“坑”,如果不注意,可能会导致性能问题、意外的错误容... 目录8个避坑点如下:1. 字符串的不可变性:每次修改都创建新对象2. 使用 == 比较字符串,陷阱满

Java判断多个时间段是否重合的方法小结

《Java判断多个时间段是否重合的方法小结》这篇文章主要为大家详细介绍了Java中判断多个时间段是否重合的方法,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录判断多个时间段是否有间隔判断时间段集合是否与某时间段重合判断多个时间段是否有间隔实体类内容public class D

IDEA编译报错“java: 常量字符串过长”的原因及解决方法

《IDEA编译报错“java:常量字符串过长”的原因及解决方法》今天在开发过程中,由于尝试将一个文件的Base64字符串设置为常量,结果导致IDEA编译的时候出现了如下报错java:常量字符串过长,... 目录一、问题描述二、问题原因2.1 理论角度2.2 源码角度三、解决方案解决方案①:StringBui

Java覆盖第三方jar包中的某一个类的实现方法

《Java覆盖第三方jar包中的某一个类的实现方法》在我们日常的开发中,经常需要使用第三方的jar包,有时候我们会发现第三方的jar包中的某一个类有问题,或者我们需要定制化修改其中的逻辑,那么应该如何... 目录一、需求描述二、示例描述三、操作步骤四、验证结果五、实现原理一、需求描述需求描述如下:需要在

Java中ArrayList和LinkedList有什么区别举例详解

《Java中ArrayList和LinkedList有什么区别举例详解》:本文主要介绍Java中ArrayList和LinkedList区别的相关资料,包括数据结构特性、核心操作性能、内存与GC影... 目录一、底层数据结构二、核心操作性能对比三、内存与 GC 影响四、扩容机制五、线程安全与并发方案六、工程

JavaScript中的reduce方法执行过程、使用场景及进阶用法

《JavaScript中的reduce方法执行过程、使用场景及进阶用法》:本文主要介绍JavaScript中的reduce方法执行过程、使用场景及进阶用法的相关资料,reduce是JavaScri... 目录1. 什么是reduce2. reduce语法2.1 语法2.2 参数说明3. reduce执行过程

如何使用Java实现请求deepseek

《如何使用Java实现请求deepseek》这篇文章主要为大家详细介绍了如何使用Java实现请求deepseek功能,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录1.deepseek的api创建2.Java实现请求deepseek2.1 pom文件2.2 json转化文件2.2

Java调用DeepSeek API的最佳实践及详细代码示例

《Java调用DeepSeekAPI的最佳实践及详细代码示例》:本文主要介绍如何使用Java调用DeepSeekAPI,包括获取API密钥、添加HTTP客户端依赖、创建HTTP请求、处理响应、... 目录1. 获取API密钥2. 添加HTTP客户端依赖3. 创建HTTP请求4. 处理响应5. 错误处理6.

Spring AI集成DeepSeek的详细步骤

《SpringAI集成DeepSeek的详细步骤》DeepSeek作为一款卓越的国产AI模型,越来越多的公司考虑在自己的应用中集成,对于Java应用来说,我们可以借助SpringAI集成DeepSe... 目录DeepSeek 介绍Spring AI 是什么?1、环境准备2、构建项目2.1、pom依赖2.2