Aerospike之路
admin
2024-03-30 21:41:24
0

Docker

重要概念

镜像:理解为某个系统
容器:镜像运行时的实体

环境准备

安装(mac系统,且已安装brew)

brew docker

基本操作

# 查看、删除镜像
docker images
docker rmi 镜像名
# 查看、删除容器
docker ps -a
dcokder container kill 容器id

Aerospike

官方文档
博客参考

#aerospike-server

安装

docker pull aerospike/aerospike-server
docker run -d --name as_server -p 3000:3000 

*配置文件

进程号存储文件、工作目录、各种端口、副本、过期时间、日志路径、数据持久化路径、

#java 操作

入门

一个基本入门,添加包含两个bin的记录到as中,后面的很多变形都是基于这个架子的修改,像策略的引入等

public class AsQuickStartClient {public static void main(String[] args) {//1.创建连接,集群需用Host配置多个地址AerospikeClient client = new AerospikeClient("localhost", 3000);//2.创建keyKey key = new Key("test", "set1", "key1");//3.创建binBin phone = new Bin("phone", 1008611);Bin name = new Bin("name", "zone");//4.根据key添加或修改client.put(null, key, phone, name);//5.根据key查询Record record = client.get(null, key);System.out.println(record);//6.关闭连接client.close();}
}

添加或更新

public class AsCreateOrUpdateClient {public static void main(String[] args) {AerospikeClient client = new AerospikeClient( "localhost", 3000);Key key = new Key("test", "set1", "key1");//写入策略WritePolicy writePolicy = new WritePolicy();//...具体策略下文Bin age = new Bin("age",17);client.put(writePolicy, key, age);Record record = client.get(null, key);System.out.println(record);//ttlSystem.out.println(record.getTimeToLive());client.close();}
}
  • 是否保存原生的key

    writePolicy.sendKey = true;
    
  • 设置record的过期时间 单位是秒

    writePolicy.expiration = 0;
    

    💡-2代表修改时不更新过期时间、-1永不过期、0由配置文件决定,默认30d、大于0代表多少秒过期

  • 版本,默认每次更新都加1

    //设置预期版本和预期策略,预期和实际不符合策略时会抛出异常
    writePolicy.generation = 1;
    writePolicy.generationPolicy = GenerationPolicy.EXPECT_GEN_EQUAL;
    

    💡NONE表示无限制 EXPECT_GEN_GT表示预期大于实际则成功 EXPECT_GEN_EQUAL表示预期等于实际则成功

  • 记录存在处理

    //REPLACE_ONLY、UPDATE_ONLY都需要保证记录存在,否则Key not found异常
    writePolicy.recordExistsAction = RecordExistsAction.UPDATE_ONLY;
    //UPDATE、REPLACE是当记录不存在时能创建,且替换可能比更新更具优势UPDAATE
    writePolicy.recordExistsAction = RecordExistsAction.REPLACE;
    //CREATE_ONLY仅创建,存在则报Key already exists异常
    
  • 字符串和数字的更新还可通过拼接append/prepend或加减法add,而不是put

    //年龄是累加的效果
    client.add(writePolicy,key,age);
    
  • 单纯的过期时间更新可用touch函数代替put函数

复杂的添加和修改

public class AsOperationClient {public static void main(String[] args) {AerospikeClient client = new AerospikeClient( "localhost", 3000);Key key = new Key("test", "set1", "key1");//...具体见下文client.close();}
}

Operation

	Bin age = new Bin("age",17);Bin name = new Bin("name","zone");Bin hobby = new Bin("hobby", new String[]{"study", "painting", "basketball"});//operateRecord record1 = client.operate(null, key, Operation.put(name), Operation.get(), Operation.put(hobby), Operation.put(age));System.out.println("获取中间的记录:" + record1);Record record2 = client.operate(null, key,Operation.get("hobby"), Operation.get("age"));System.out.println("获取指定字段:" + record2);

ListOperation

   List list = new ArrayList<>();list.add(0);list.add(1);list.add(2);System.out.println(list);Bin listBin = new Bin("listBin", list);Record record = client.operate(null, key,Operation.put(listBin),ListOperation.getByRankRange("listBin",0, ListReturnType.VALUE),ListOperation.increment("listBin",0),ListOperation.insert("listBin", 0, Value.get(3)));System.out.println("处理结果:" + record);System.out.println("最终结果:" + client.get(null, key));

MapOperation

        Map hotWord = new HashMap<>();hotWord.put("卧槽", 90);hotWord.put("扑街", 50);hotWord.put("你好", 10);Bin hw = new Bin("hw", hotWord);client.put(null,key,hw);System.out.println("开始的结果" + client.get(null, key));Record record = client.operate(null,key, MapOperation.put(MapPolicy.Default,"hw", Value.get("扑街"), Value.get(100)), MapOperation.increment(MapPolicy.Default,"hw", Value.get("你好"), Value.get(100)), MapOperation.getByRankRange("hw",0, MapReturnType.KEY_VALUE));System.out.println("处理的结果" + record);

💡更新的时候,map、list的修改操作会返回集合大小、其他默认返回null,get则返回这个bin,且返回的结果会根据bin进行分组(例如上面的record既返回函数修改结果,也返回查询结果)封装为一个列表

删除

 public class AsDeleteClient {public static void main(String[] args) {AerospikeClient client = new AerospikeClient( "localhost", 3000);Key key = new Key("ns1","set1","key1");//...下文client.close();}
}

删除记录

boolean result = client.delete(null, key);

💡但是该删除并没有把磁盘的也删除,重启后会恢复

彻底删除记录

// 通过设置过期时间为1
WritePolicy policy = new WritePolicy();
policy.expiration = 1;
client.touch(policy,key);

💡成功的版本是4.3.1,用最新的不行,可能是配置的原因

删除bin

//删除---将bin值更新为null,当它是记录中唯一的一个bin时,会删除整个记录。
Bin hw = Bin.asNull("hw");
client.put(null, key, hw);

简单查询

public class AsReadClient {public static void main(String[] args) {AerospikeClient client = new AerospikeClient( "localhost", 3000);Key key = new Key("test","set1","key1");//自定义读取策略--例如防止超时Policy policy = new Policy();policy.socketTimeout = 300;//判断记录是否存在--只需查看索引boolean exists = client.exists(policy, key);System.out.format("1.Exists: %s \n", exists);//仅获取元数据Record recordMetada = client.getHeader(policy, key);System.out.format("2.RecordMetada: %s \n", recordMetada);//获取整个记录信息Record record = client.get(policy, key);System.out.format("3.Record: %s \n", record);//指定binRecord hwRecord = client.get(policy, key, "hw");System.out.format("4.hwRecord: %s \n", hwRecord);client.close();}
}

💡上面很多方法都是针对单个key,即一条记录,可使用其他构造方法,key可作为数组传入,获取多个记录

⚡️指定key的同时指定bin,aerospike-server也是需要低版本,才能使用

    List brs = new ArrayList<>();//true代表读取全部brs.add(new BatchRead(key2, true));//读取指定binbrs.add(new BatchRead(key1, new String[]{"hw"}));//根据key指定不同的binclient.get(null, brs);brs.forEach(item -> {System.out.println(item.record);});

为避免版本问题,一下测试均为低版本

表达式查询

client.query()、 client.scanAll();

*lua脚本学习

待更

*异步操作

上面的操作都是基于同步方式,下面简单举例异步的方式

aerospike-tools

安装

参考:官方文档

docker pull aerospike/aerospike-tools
docker run -ti  aerospike/aerospike-tools aql --host 172.17.0.2

💡ip地址是根据docker inspect -f '{{.NetworkSettings.IPAddress}}' as_server获得的,不过一样都是172.17.0.2,其中as_server就是上面aerospike-server的容器名

配置命令

# 查看全部配置
get all 
# 设置输出格式 json or table
set output json

⚡️命名空间已经默认配置在配置文件,而不是由你创建

crud命令

# 查看命名空间、集
show namespaces;
show sets
# 查询
select * from test.set1;
# 插入或修改,pk字段是必须的,不区分大小写(索引--可理解为主键),但bin区分,例如Key="value"和key="value"是两个不同的bin
insert into test.set1 (pk,key) values("index","value");
# 删除
delete from test.set1 where pk="index"

重要概念

Aerospike

分布式、高可用的NoSQL数据库;可以存到固态硬盘,简单省钱;面向行的数据库;

分三层:客户端(AS API)、

数据模型组成

区别于传统数据库,不需要定义表的模式(create table),这是因为存放k-v的Bin,数据类型无需指定,由值确定。

  • namespace数据库:命名空间,包括记录+索引+策略(数据物理存储方式、记录有多少副本、)
  • set表:集
  • Record记录:主键(Key)+元数据(版本、ttl、上次更新时间)+多个Bin
  • Key主键
  • Bin列:存放k-v

每个记录都是由多个k-v构成,其中一个k-v是PK:Key(而且这个字段是不区分大小写的,当你使用tools命令插入一条数据时,他是必须携带一个PK的),也就是存放主键的,他是唯一的,这个PK就是Key,如果使用java客户端添加数据的话,需要Policy.sendKey = true才能看到

索引指向set

digest摘要是通过key和setName计算出来的

集群:命名空间会被分为4096个逻辑分区,然后均匀分布到各个节点中,且记录是通过哈希均匀映射到这些分区的
数据复制和同步:副本,类似es,将分区副本放在其它不同节点。

相关内容

热门资讯

安卓系统所有手机通用,揭秘所有... 你有没有发现,现在市面上各种各样的手机,品牌琳琅满目,让人挑花了眼?不过,不管你用的是哪个品牌的手机...
安卓系统变ios系统好用吗,体... 你有没有想过,为什么有些人从安卓手机换到了苹果的iPhone,而且好像换了之后整个人都精神焕发呢?没...
华为安卓系统文件删除,轻松掌握... 你有没有遇到过这种情况?手机里的文件突然不见了,尤其是华为安卓系统里的那些重要文件,真是让人心头一紧...
安卓1.5系统软件,初代智能革... 你有没有想过,手机里的那些看似普通的系统,其实背后藏着无数的故事呢?今天,就让我带你走进安卓1.5系...
安卓 代替系统音效设置,打造个... 你有没有发现,手机里的那些系统音效有时候真的让人有点烦躁呢?比如那个每次接电话时“叮咚”一声,或者是...
安卓系统整体性,构建移动设备的... 你知道吗?在智能手机的世界里,安卓系统就像是个全能的魔术师,它不仅拥有丰富的魔法,还能让各种神奇的魔...
安卓系统能玩鬼泣么?,畅享动作... 你有没有想过,在安卓系统上玩《鬼泣》这款游戏会是怎样的体验呢?没错,就是那个让你热血沸腾、挑战极限的...
安卓系统手机编曲软件,音乐创作... 你有没有想过,用手机也能轻松编曲?没错,就是那个你每天不离手的安卓系统手机!现在,我就要给你揭秘几款...
车载导航显示安卓系统,车载导航... 你有没有发现,现在的车载导航系统越来越智能了?尤其是那些搭载了安卓系统的车载导航,简直就像是个贴心的...
安卓系统启动黑屏,安卓系统启动... 手机屏幕突然黑了,这可怎么办?别急,今天就来和你聊聊安卓系统启动黑屏这个让人头疼的问题。你知道吗,这...
怎么解除订阅安卓系统,安卓系统... 你是不是也和我一样,手机里订阅了好多服务,结果现在想解除订阅,却一头雾水?别急,今天就来手把手教你如...
安卓系统停用怎么开启,轻松恢复... 亲爱的手机控们,你是否曾经遇到过安卓系统突然停用的情况,让你手忙脚乱,不知所措?别担心,今天就来教你...
安卓系统电池健康度,电池健康度... 你有没有发现,你的安卓手机最近是不是有点儿不给力了?电池续航能力大不如前,充电速度也慢了不少?别急,...
安卓系统按键怎么截图,安卓系统... 你是不是也和我一样,有时候想截个图分享给朋友,却发现安卓手机的截图功能有点神秘呢?别急,今天就来手把...
购票系统安卓源代码,架构设计与... 你有没有想过,那些我们每天离不开的购票系统,它们背后的秘密是什么呢?今天,就让我带你一探究竟,揭开购...
安卓手机系统后台测试,深度解析... 你有没有发现,你的安卓手机后台总是悄悄地忙碌着?别小看了这些后台程序,它们可是手机系统稳定运行的关键...
安卓系统重启的图标,解锁设备新... 手机突然重启,是不是心里有点慌?别急,今天就来和你聊聊安卓系统重启的图标,让你一眼就能认出它,再也不...
车载智慧屏安卓系统,智能出行新... 你有没有发现,现在的车载智慧屏越来越智能了?尤其是那些搭载了安卓系统的,简直就像是个移动的小电脑,不...
安卓系统连上网权限,解锁设备无... 你有没有发现,你的安卓手机里有些应用总是偷偷连上网?别小看这个小小的网络权限,它可是能影响你隐私、消...
安卓谷歌操作系统,探索安卓谷歌... 你知道吗?在智能手机的世界里,有一个操作系统可是无人不知、无人不晓,那就是安卓谷歌操作系统。它就像一...