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,将分区副本放在其它不同节点。

相关内容

热门资讯

怎么解除订阅安卓系统,安卓系统... 你是不是也和我一样,手机里订阅了好多服务,结果现在想解除订阅,却一头雾水?别急,今天就来手把手教你如...
安卓系统停用怎么开启,轻松恢复... 亲爱的手机控们,你是否曾经遇到过安卓系统突然停用的情况,让你手忙脚乱,不知所措?别担心,今天就来教你...
安卓系统电池健康度,电池健康度... 你有没有发现,你的安卓手机最近是不是有点儿不给力了?电池续航能力大不如前,充电速度也慢了不少?别急,...
安卓系统按键怎么截图,安卓系统... 你是不是也和我一样,有时候想截个图分享给朋友,却发现安卓手机的截图功能有点神秘呢?别急,今天就来手把...
购票系统安卓源代码,架构设计与... 你有没有想过,那些我们每天离不开的购票系统,它们背后的秘密是什么呢?今天,就让我带你一探究竟,揭开购...
安卓手机系统后台测试,深度解析... 你有没有发现,你的安卓手机后台总是悄悄地忙碌着?别小看了这些后台程序,它们可是手机系统稳定运行的关键...
安卓系统重启的图标,解锁设备新... 手机突然重启,是不是心里有点慌?别急,今天就来和你聊聊安卓系统重启的图标,让你一眼就能认出它,再也不...
车载智慧屏安卓系统,智能出行新... 你有没有发现,现在的车载智慧屏越来越智能了?尤其是那些搭载了安卓系统的,简直就像是个移动的小电脑,不...
安卓系统连上网权限,解锁设备无... 你有没有发现,你的安卓手机里有些应用总是偷偷连上网?别小看这个小小的网络权限,它可是能影响你隐私、消...
安卓谷歌操作系统,探索安卓谷歌... 你知道吗?在智能手机的世界里,有一个操作系统可是无人不知、无人不晓,那就是安卓谷歌操作系统。它就像一...
安卓系统手写%怎样调出,具体实... 你有没有遇到过这种情况:在使用安卓手机的时候,突然想用手写输入法来记录一些灵感或者重要信息,可是怎么...
安卓手机重置 系统设置,轻松恢... 手机用久了是不是感觉卡顿得厉害?别急,今天就来教你怎么给安卓手机来个大变身——重置系统设置!想象你的...
win如何安装安卓系统,Win... 哇,你有没有想过,让你的Win系统也能玩转安卓应用?没错,就是那种在手机上轻松自如的安卓系统,现在也...
苹果qq和安卓系统,跨平台体验... 你有没有发现,现在手机市场上,苹果和安卓的较量可是越来越激烈了呢!咱们就来聊聊这个话题,看看苹果QQ...
显示最好的安卓系统,探索最新旗... 你有没有想过,为什么安卓系统那么受欢迎呢?它就像一个魔法盒子,里面装满了各种神奇的魔法。今天,就让我...
安卓app怎么降级系统,系统版... 你有没有发现,有时候安卓手机的系统更新后,新功能虽然炫酷,但老系统用起来更顺手呢?别急,今天就来教你...
雷军脱离安卓系统,引领科技变革... 你知道吗?最近科技圈可是炸开了锅,因为我们的雷军大大竟然宣布要脱离安卓系统,这可真是让人大跌眼镜啊!...
安卓系统自动开网络,安卓系统自... 你有没有发现,手机里的安卓系统有时候会自动开启网络连接,这可真是让人又爱又恨啊!有时候,你正专心致志...
安卓系统怎样控制后台,因为服务... 手机里的安卓系统是不是感觉越来越卡了?后台程序太多,不仅耗电还影响性能。别急,今天就来教你怎么巧妙地...
安卓系统打游戏推荐,一触即达! 你有没有发现,现在手机游戏越来越好玩了?不管是休闲小游戏还是大型MMORPG,都能在手机上畅玩。但是...