說明：分兩篇介紹，第一篇為基本概念介紹，第二篇為實(shí)際應(yīng)用养距；該篇為應(yīng)用部分。
1日熬、常用操作命令
??Aerospike提供一套類SQL操作棍厌，和Mysql語(yǔ)法極其相似(命令解析參考注釋)，在安裝aerospike的服務(wù)器上竖席，通過aql --help 可以查看系統(tǒng)提供的幫助文檔耘纱，很詳細(xì)，里面還有很多DEMO語(yǔ)句毕荐。然后通過aql -h ip -p port 連上服務(wù)器（直接aql默認(rèn)連接127.0.0.1 3000）束析，進(jìn)入下面操作：
--查看配置了哪些ns，和mysql中創(chuàng)建了哪個(gè)db對(duì)應(yīng)
aql> show namespaces ;
+--------------+
| namespaces |
+--------------+
| "testMemory" |
| "testFile" |
+--------------+
2 rows in set (0.000 secs)
OK
--插入一條測(cè)試數(shù)據(jù)憎亚，demo為as中的set,系統(tǒng)會(huì)幫我們創(chuàng)建员寇；類似于mysql中的table
aql> INSERT INTO testMemory.demo (PK, pass, name) VALUES ('key1', 123, 'abc')
OK, 1 record affected.
--bins列相當(dāng)于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 相當(dāng)于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
--查詢?cè)搉s下的所有sets，這種mysql中是不支持的哦
aql> select * from testMemory
+------+-------+
| pass | name |
+------+-------+
| 123 | "abc" |
+------+-------+
1 row in set (0.071 secs)
--對(duì)上面的相比第美，該查詢明確指定了set丁恭，相當(dāng)于mysql中對(duì)表查詢
aql> select * from testMemory.demo
+------+-------+
| pass | name |
+------+-------+
| 123 | "abc" |
+------+-------+
1 row in set (0.077 secs)
--再插入一個(gè)set節(jié)點(diǎn)對(duì)比下
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)
--根據(jù)PK查詢，相當(dāng)于mysql表中的主鍵斋日，AS還支持索引查詢牲览，但不支持不帶索引的bin查詢
aql> select * from testMemory.demo where PK='key1'
+------+-------+
| pass | name |
+------+-------+
| 123 | "abc" |
+------+-------+
1 row in set (0.001 secs)
--根據(jù)PK刪除記錄，AS中的更新其實(shí)就是覆蓋
aql> delete from testMemory.demo where PK='key1'
OK, 1 record affected.
aql> select * from testMemory.demo
0 rows in set (0.082 secs)
--關(guān)于索引恶守，沒有建立索引時(shí)是不能根據(jù)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測(cè)試
public class ASTest {
AerospikeClient client = null;
@Before
public void init() {
// 第一參數(shù)是AS服務(wù)地址，第二參數(shù)是對(duì)外端口
client = new AerospikeClient("192.168.75.142", 3000);
}
/** 測(cè)試寫AS */
@Test
public void testSave() {
// policy 是用來定義策略兔港，AS中定義多種策略實(shí)現(xiàn)(比如超時(shí)庸毫，過期機(jī)制，事務(wù)等)衫樊，也可設(shè)置為null
WritePolicy policy = new WritePolicy();
for (int i = 100; i < 110; i++) {
// Key第一個(gè)參數(shù)ns,第二個(gè)參數(shù)set,第三個(gè)參數(shù)用來唯一標(biāo)識(shí)的PK
Key key = new Key("testMemory", "demo", "zhangsan" + i);
// bin可以很多個(gè)飒赃，多到參考我們受限個(gè)數(shù)
Bin nameBin = new Bin("name", "張三" + i);
Bin passBin = new Bin("pass", "123456");
// expire這是一個(gè)偽的過期時(shí)間
Bin expireBin = new Bin("expire", System.currentTimeMillis() + 1 * 60 * 60 * 1000L);
// 這才是真的過期策略，小于105的100秒后會(huì)消失科侈，可以通過命令查看
if (i < 105) {
policy.timeout = 50;
policy.expiration = 100; // 重要的事情只說一遍载佳，單位(秒)
} else {
policy.expiration = -1; // 不過期
}
client.put(policy, key, nameBin, passBin, expireBin);
}
}
/** 測(cè)試讀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); 最后一個(gè)參數(shù)不傳時(shí)，將把所有的bins全查出來
for (Record r : recordArr) {
if (r != null) {
System.out.println(">>>name:" + r.getString("name") + "---pass:" + r.getString("pass"));
}
}
}
}
2.3 查看測(cè)試結(jié)果
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)
