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的写操作，就会造成误删，欢迎留言更严谨的删除方案。
————————————————
版权声明：本文为CSDN博主「qifengdao」的原创文章，遵循CC 4.0 BY-SA版权协议，转载请附上原文出处链接及本声明。
原文链接：https://blog.csdn.net/liuzhoulong/article/details/88058607