AeroSpike基本应用

说明:分两篇介绍,第一篇为基本概念介绍,第二篇为实际应用;该篇为应用部分。

1、常用操作命令


  Aerospike提供一套类SQL操作,和Mysql语法极其相似(命令解析参考注释),在安装aerospike的服务器上,通过aql --help 可以查看系统提供的帮助文档,很详细,里面还有很多DEMO语句。然后通过aql -h ip -p port 连上服务器(直接aql默认连接127.0.0.1 3000),进入下面操作:

--查看配置了哪些ns,和mysql中创建了哪个db对应
aql> show namespaces ;
+--------------+
| namespaces   |
+--------------+
| "testMemory" |
| "testFile"   |
+--------------+
2 rows in set (0.000 secs)
OK
--插入一条测试数据,demo为as中的set,系统会帮我们创建;类似于mysql中的table
aql> INSERT INTO testMemory.demo (PK, pass, name) VALUES ('key1', 123, 'abc')
OK, 1 record affected.
--bins列相当于mysql table中的column
aql> show bins ;
+-------+--------+-------+--------------+
| quota | bin    | count | namespace    |
+-------+--------+-------+--------------+
| 32768 | "pass" | 2     | "testMemory" |
| 32768 | "name" | 2     | "testMemory" |
+-------+--------+-------+--------------+
2 rows in set (0.000 secs)
OK
--sets 相当于mysql中的show tables
aql> show sets ;
+------------------+--------------+----------------+---------+-------------------+--------+-------------------+----------+
| disable-eviction | ns           | set-enable-xdr | objects | stop-writes-count | set    | memory_data_bytes | deleting |
+------------------+--------------+----------------+---------+-------------------+--------+-------------------+----------+
| "false"          | "testMemory" | "use-default"  | 1       | 0                 | "demo" | 34                | "false"  |
+------------------+--------------+----------------+---------+-------------------+--------+-------------------+----------+
1 row in set (0.001 secs)
OK
--查询该ns下的所有sets,这种mysql中是不支持的哦
aql> select * from testMemory 
+------+-------+
| pass | name  |
+------+-------+
| 123  | "abc" |
+------+-------+
1 row in set (0.071 secs)

--对上面的相比,该查询明确指定了set,相当于mysql中对表查询
aql> select * from testMemory.demo
+------+-------+
| pass | name  |
+------+-------+
| 123  | "abc" |
+------+-------+
1 row in set (0.077 secs)
--再插入一个set节点对比下
aql> INSERT INTO testMemory.demo1 (PK, pass, name,age) VALUES ('key111', 123, 'abc',12)
OK, 1 record affected.

aql> select * from testMemory
+------+-------+-----+
| pass | name  | age |
+------+-------+-----+
| 123  | "abc" |     |
| 123  | "abc" | 12  |
+------+-------+-----+
2 rows in set (0.058 secs)

aql> select * from testMemory.demo1
+------+-------+-----+
| pass | name  | age |
+------+-------+-----+
| 123  | "abc" | 12  |
+------+-------+-----+
1 row in set (0.080 secs)

--根据PK查询,相当于mysql表中的主键,AS还支持索引查询,但不支持不带索引的bin查询
aql> select * from testMemory.demo where PK='key1'
+------+-------+
| pass | name  |
+------+-------+
| 123  | "abc" |
+------+-------+
1 row in set (0.001 secs)
--根据PK删除记录,AS中的更新其实就是覆盖
aql> delete from testMemory.demo where PK='key1'
OK, 1 record affected.
aql> select * from testMemory.demo
0 rows in set (0.082 secs)
--关于索引,没有建立索引时是不能根据bin查询的
aql> select * from testMemory.demo1 where name='abc'
0 rows in set (0.003 secs)
Error: (201) AEROSPIKE_ERR_INDEX_NOT_FOUND

aql>  CREATE INDEX idx_demo1_name ON testMemory.demo1 (name) STRING
OK, 1 index added.
--建立索引后则可以
aql> select * from testMemory.demo1 where name='abc'
+------+-------+-----+
| pass | name  | age |
+------+-------+-----+
| 123  | "abc" | 12  |
+------+-------+-----+
1 row in set (0.025 secs)

2、Java客户端操作


2.1 引入配置

<dependency>
    <groupId>com.aerospike</groupId>
    <artifactId>aerospike-client</artifactId>
    <version>3.2.2.bs</version>
</dependency>

2.2 Junit测试

public class ASTest {
    AerospikeClient client = null;
    @Before
    public void init() {
        // 第一参数是AS服务地址,第二参数是对外端口
        client = new AerospikeClient("192.168.75.142", 3000);
    }
    /** 测试写AS */
    @Test
    public void testSave() {
        // policy 是用来定义策略,AS中定义多种策略实现(比如超时,过期机制,事务等),也可设置为null
        WritePolicy policy = new WritePolicy();
        for (int i = 100; i < 110; i++) {
            // Key第一个参数ns,第二个参数set,第三个参数用来唯一标识的PK
            Key key = new Key("testMemory", "demo", "zhangsan" + i);
            // bin可以很多个,多到参考我们受限个数
            Bin nameBin = new Bin("name", "张三" + i);
            Bin passBin = new Bin("pass", "123456");
            // expire这是一个伪的过期时间
            Bin expireBin = new Bin("expire", System.currentTimeMillis() + 1 * 60 * 60 * 1000L);
            // 这才是真的过期策略,小于105的100秒后会消失,可以通过命令查看
            if (i < 105) {
                policy.timeout = 50;
                policy.expiration = 100; // 重要的事情只说一遍,单位(秒)
            } else {
                policy.expiration = -1; // 不过期
            }
            client.put(policy, key, nameBin, passBin, expireBin);
        }
    }
    /** 测试读AS,而且是批量读 */
    @Test
    public void testQuery() {
        String[] bin_names = { "name", "pass" }; // 查询字段
        Key[] keys = new Key[10]; // 查询key
        int index = 0;
        for (int i = 100; i < 110; i++) {
            keys[index++] = new Key("testMemory", "demo", "zhangsan" + i);
        }
        Record[] recordArr = client.get(null, keys, bin_names); // 批量查询
        // client.get(null, keys); 最后一个参数不传时,将把所有的bins全查出来
        for (Record r : recordArr) {
            if (r != null) {
                System.out.println(">>>name:" + r.getString("name") + "---pass:" + r.getString("pass"));
            }
        }
    }
}

2.3 查看测试结果

aql> select * from testMemory.demo
+-------------+----------+---------------+
| name        | pass     | expire        |
+-------------+----------+---------------+
| "张三103" | "123456" | 1566466510845 |
| "张三107" | "123456" | 1566466510847 |
| "张三108" | "123456" | 1566466510847 |
| "张三106" | "123456" | 1566466510847 |
| "张三102" | "123456" | 1566466510845 |
| "张三101" | "123456" | 1566466510823 |
| "张三100" | "123456" | 1566466510813 |
| "张三104" | "123456" | 1566466510846 |
| "张三105" | "123456" | 1566466510846 |
| "张三109" | "123456" | 1566466510848 |
+-------------+----------+---------------+
10 rows in set (0.064 secs)

aql> select * from testMemory.demo
+-------------+----------+---------------+
| name        | pass     | expire        |
+-------------+----------+---------------+
| "张三107" | "123456" | 1566466510847 |
| "张三108" | "123456" | 1566466510847 |
| "张三106" | "123456" | 1566466510847 |
| "张三105" | "123456" | 1566466510846 |
| "张三109" | "123456" | 1566466510848 |
+-------------+----------+---------------+
5 rows in set (0.056 secs)
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 218,858评论 6 508
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 93,372评论 3 395
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 165,282评论 0 356
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 58,842评论 1 295
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 67,857评论 6 392
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 51,679评论 1 305
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 40,406评论 3 418
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 39,311评论 0 276
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 45,767评论 1 315
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,945评论 3 336
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 40,090评论 1 350
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,785评论 5 346
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 41,420评论 3 331
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,988评论 0 22
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 33,101评论 1 271
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 48,298评论 3 372
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 45,033评论 2 355

推荐阅读更多精彩内容