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的主要内容,如果未能解决你的问题,请参考以下文章

Aerospike如何处理通过多个连接创建同一记录?

如何将 Array[Long] id 传递到 Aerospike Record UDF?

AS(AeroSpike)数据库常用操作

aerospike企业版收费吗

无法安装 aerospike,在“node-gyp 重建”步骤中使 aerospike 失败

Aerospike基本概念