Aerospike API操作Map
Posted -早起的码农
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Aerospike API操作Map相关的知识,希望对你有一定的参考价值。
Aerospike是一个高性能、可扩展、可靠性强的NoSQL解决方案,支持RAM和SSD作为存储介质,并专门针对SSD特殊优化,广泛应用于实时竞价等实时计算领域。官方保证99%的操作在1ms内完成,并提供集群数据自动Rebalance、集群感知客户端等功能,且支持超大规模数据集(100T级别)的存储。
作为KV存储,Aerospike提供多种数据类型,其操作方式和Redis比较类似。除基础功能之外,Aerospike还支持AMC控制台、API等多种监控方式,有集群QPS、健康度、负载等多项监控指标,对运维比较友好。支持集群内数据的自动Rebalance,和Redis集群方案相比,维护成本下降不少,高负载下AS比redis略快,参考https://www.infoq.cn/article/2015%2F02%2Faerospikedb-redis-aws-nosql
Aerospike一般操作可以通过官方渠道获取到例子信息
https://github.com/aerospike/aerospike-client-java/tree/master/examples
下面是官方没有的map操作例子:
import com.aerospike.client.AerospikeClient;
import com.aerospike.client.Key;
import com.aerospike.client.Record;
import com.aerospike.client.Value;
import com.aerospike.client.cdt.MapOperation;
import com.aerospike.client.cdt.MapPolicy;
import com.aerospike.client.cdt.MapReturnType;
import com.aerospike.client.policy.WritePolicy;
import java.util.List;
public class AerospikeApiTest
public static void main(String args[])
final AerospikeClient client = new AerospikeClient("127.0.0.1", 3000);
WritePolicy policy = new WritePolicy();
policy.socketTimeout = 50; // 50 millisecond timeout.
Key key = new Key("test", "demoset", "mapkey");
//map中写入1个值
Record record = client.operate(policy, key, MapOperation.put(MapPolicy.Default, "mapbin", Value.get("key4"), Value.get("val1")));
//map中一次写入2个值
record = client.operate(policy, key, MapOperation.put(MapPolicy.Default, "mapbin", Value.get("key3"), Value.get("val1")),
MapOperation.put(MapPolicy.Default, "mapbin", Value.get("key4"), Value.get("val1")));
//删除map中的key,并查询map的长度
List list = client.operate(policy, key, MapOperation.removeByKey("mapbin", Value.get("key4"), MapReturnType.COUNT),
MapOperation.size("mapbin")).getList("mapbin");
System.out.println(list.get(1));
//如果为空map删除数据
if (((Long)list.get(1)) == 0)
client.delete(policy, key);
上面代码在高并发下,删除可能会有问题,如删除某个key时,正好有对key的写操作,就会造成误删,欢迎留言更严谨的删除方案。
觉得不错扫头像,关注我的公众号,获取更多大数据技能
以上是关于Aerospike API操作Map的主要内容,如果未能解决你的问题,请参考以下文章
如何将 Array[Long] id 传递到 Aerospike Record UDF?