Redis（三）Redis基本命令操作與API

一Redis 連接 Redis 連接命令主要是用於連接 redis 服務。實例以下實例演示了客戶端如何通過密碼驗證連接到 redis 服務，並檢測服務是否在運行：下表列出了 redis 連接的基本命令：二Redis 鍵(key) Redis key命令用於管理 redis 的鍵。語法實例 ...

一Redis 連接

Redis 連接命令主要是用於連接 redis 服務。

實例

以下實例演示了客戶端如何通過密碼驗證連接到 redis 服務，並檢測服務是否在運行：

redis 127.0.0.1:6379> AUTH "password"
OK
redis 127.0.0.1:6379> PING
PONG

下表列出了 redis 連接的基本命令：

序號	命令及描述
1	AUTH password 驗證密碼是否正確
2	ECHO message 列印字元串
3	PING 查看服務是否運行
4	QUIT 關閉當前連接
5	SELECT index 切換到指定的資料庫

二Redis 鍵(key)

Redis key命令用於管理 redis 的鍵。

語法

redis 127.0.0.1:6379> COMMAND KEY_NAME

實例

redis 127.0.0.1:6379> SET runoobkey redis
OK
redis 127.0.0.1:6379> DEL runoobkey
(integer) 1

在以上實例中 DEL 是一個命令， runoobkey 是一個鍵。如果鍵被刪除成功，命令執行後輸出 (integer) 1，否則將輸出 (integer) 0

下表給出了與 Redis 鍵相關的基本命令：

序號	命令及描述
1	DEL key 該命令用於在 key 存在時刪除 key。
2	DUMP key 序列化給定 key ，並返回被序列化的值。
3	EXISTS key 檢查給定 key 是否存在。
4	EXPIRE key seconds 為給定 key 設置過期時間。
5	EXPIREAT key timestamp EXPIREAT 的作用和 EXPIRE 類似，都用於為 key 設置過期時間。不同在於 EXPIREAT 命令接受的時間參數是 UNIX 時間戳(unix timestamp)。
6	PEXPIRE key milliseconds 設置 key 的過期時間以毫秒計。
7	PEXPIREAT key milliseconds-timestamp 設置 key 過期時間的時間戳(unix timestamp) 以毫秒計
8	KEYS pattern 查找所有符合給定模式( pattern)的 key 。
9	MOVE key db 將當前資料庫的 key 移動到給定的資料庫 db 當中。
10	PERSIST key 移除 key 的過期時間，key 將持久保持。
11	PTTL key 以毫秒為單位返回 key 的剩餘的過期時間。
12	TTL key 以秒為單位，返回給定 key 的剩餘生存時間(TTL, time to live)。
13	RANDOMKEY 從當前資料庫中隨機返回一個 key 。
14	RENAME key newkey 修改 key 的名稱
15	RENAMENX key newkey 僅當 newkey 不存在時，將 key 改名為 newkey 。
16	TYPE key 返回 key 所儲存的值的類型。

三Redis 數據類型

Redis支持五種數據類型：string（字元串），hash（哈希），list（列表），set（集合）及zset(sorted set：有序集合)。各個數據類型應用場景如下

類型	簡介	特性	場景
String(字元串)	二進位安全	可以包含任何數據,比如jpg圖片或者序列化的對象,一個鍵最大能存儲512M
Hash(字典)	鍵值對集合,即編程語言中的Map類型	適合存儲對象,並且可以像資料庫中update一個屬性一樣只修改某一項屬性值(Memcached中需要取出整個字元串反序列化成對象修改完再序列化存回去)	存儲、讀取、修改用戶屬性
List(列表)	鏈表(雙向鏈表)	增刪快,提供了操作某一段元素的API	1,最新消息排行等功能(比如朋友圈的時間線) 2,消息隊列
Set(集合)	哈希表實現,元素不重覆	1,添加、刪除,查找的複雜度都是O(1) 2,為集合提供了求交集、並集、差集等操作	1,共同好友 2,利用唯一性,統計訪問網站的所有獨立ip 3,好用推薦時,根據tag求交集,大於某個閾值就可以推薦
Sorted Set(有序集合)	將Set中的元素增加一個權重參數score,元素按score有序排列	數據插入集合時,已經進行天然排序	1,排行榜 2,帶權重的消息隊列

String（字元串）

string是redis最基本的類型，你可以理解成與Memcached一模一樣的類型，一個key對應一個value，一個鍵最大能存儲512MB。string類型是二進位安全的，意思是redis的string可以包含任何數據。比如jpg圖片或者序列化的對象。

語法

redis 127.0.0.1:6379> COMMAND KEY_NAME

實例

redis 127.0.0.1:6379> SET runoobkey redis
OK
redis 127.0.0.1:6379> GET runoobkey
"redis"

下表列出了常用的 redis 字元串命令：

序號	命令及描述
1	SET key value 設置指定 key 的值
2	GET key 獲取指定 key 的值。
3	GETRANGE key start end 返回 key 中字元串值的子字元
4	GETSET key value 將給定 key 的值設為 value ，並返回 key 的舊值(old value)。
5	GETBIT key offset 對 key 所儲存的字元串值，獲取指定偏移量上的位(bit)。
6	MGET key1 [key2..] 獲取所有(一個或多個)給定 key 的值。
7	SETBIT key offset value 對 key 所儲存的字元串值，設置或清除指定偏移量上的位(bit)。
8	SETEX key seconds value 將值 value 關聯到 key ，並將 key 的過期時間設為 seconds (以秒為單位)。
9	SETNX key value 只有在 key 不存在時設置 key 的值。
10	SETRANGE key offset value 用 value 參數覆寫給定 key 所儲存的字元串值，從偏移量 offset 開始。
11	STRLEN key 返回 key 所儲存的字元串值的長度。
12	MSET key value [key value ...] 同時設置一個或多個 key-value 對。
13	MSETNX key value [key value ...] 同時設置一個或多個 key-value 對，當且僅當所有給定 key 都不存在。
14	PSETEX key milliseconds value 這個命令和 SETEX 命令相似，但它以毫秒為單位設置 key 的生存時間，而不是像 SETEX 命令那樣，以秒為單位。
15	INCR key 將 key 中儲存的數字值增一。
16	INCRBY key increment 將 key 所儲存的值加上給定的增量值（increment）。
17	INCRBYFLOAT key increment 將 key 所儲存的值加上給定的浮點增量值（increment）。
18	DECR key 將 key 中儲存的數字值減一。
19	DECRBY key decrement key 所儲存的值減去給定的減量值（decrement）。
20	APPEND key value 如果 key 已經存在並且是一個字元串， APPEND 命令將指定的 value 追加到該 key 原來值（value）的末尾。

Hash（哈希）

hash 是一個鍵值(key=>value)對集合，是一個 string 類型的 field 和 value 的映射表，特別適合用於存儲對象。每個 hash 可以存儲 2³² -1 鍵值對（40多億）。

實例

127.0.0.1:6379>  HMSET runoobkey name "redis tutorial" description "redis basic commands for caching" likes 20 visitors 23000
OK
127.0.0.1:6379>  HGETALL runoobkey
1) "name"
2) "redis tutorial"
3) "description"
4) "redis basic commands for caching"
5) "likes"
6) "20"
7) "visitors"
8) "23000"

在以上實例中，我們設置了 redis 的一些描述信息(name, description, likes, visitors) 到哈希表的 runoobkey 中。

下表列出了 redis hash 基本的相關命令：

序號	命令及描述
1	HDEL key field1 [field2] 刪除一個或多個哈希表欄位
2	HEXISTS key field 查看哈希表 key 中，指定的欄位是否存在。
3	HGET key field 獲取存儲在哈希表中指定欄位的值。
4	HGETALL key 獲取在哈希表中指定 key 的所有欄位和值
5	HINCRBY key field increment 為哈希表 key 中的指定欄位的整數值加上增量 increment 。
6	HINCRBYFLOAT key field increment 為哈希表 key 中的指定欄位的浮點數值加上增量 increment 。
7	HKEYS key 獲取所有哈希表中的欄位
8	HLEN key 獲取哈希表中欄位的數量
9	HMGET key field1 [field2] 獲取所有給定欄位的值
10	HMSET key field1 value1 [field2 value2 ] 同時將多個 field-value (域-值)對設置到哈希表 key 中。
11	HSET key field value 將哈希表 key 中的欄位 field 的值設為 value 。
12	HSETNX key field value 只有在欄位 field 不存在時，設置哈希表欄位的值。
13	HVALS key 獲取哈希表中所有值
14	HSCAN key cursor [MATCH pattern] [COUNT count] 迭代哈希表中的鍵值對。

List（列表）

列表是簡單的字元串列表，按照插入順序排序。你可以添加一個元素到列表的左邊或者右邊。列表最多可存儲 2³² - 1 元素 (4294967295, 每個列表可存儲40多億)。

實例

redis 127.0.0.1:6379> LPUSH runoobkey redis
(integer) 1
redis 127.0.0.1:6379> LPUSH runoobkey mongodb
(integer) 2
redis 127.0.0.1:6379> LPUSH runoobkey mysql
(integer) 3
redis 127.0.0.1:6379> LRANGE runoobkey 0 10

1) "mysql"
2) "mongodb"
3) "redis"

在以上實例中我們使用了 LPUSH 將三個值插入了名為 runoobkey 的列表當中。

下表列出了列表相關的基本命令：

序號	命令及描述
1	BLPOP key1 [key2 ] timeout 移出並獲取列表的第一個元素，如果列表沒有元素會阻塞列表直到等待超時或發現可彈出元素為止。
2	BRPOP key1 [key2 ] timeout 移出並獲取列表的最後一個元素，如果列表沒有元素會阻塞列表直到等待超時或發現可彈出元素為止。
3	BRPOPLPUSH source destination timeout 從列表中彈出一個值，將彈出的元素插入到另外一個列表中並返回它；如果列表沒有元素會阻塞列表直到等待超時或發現可彈出元素為止。
4	LINDEX key index 通過索引獲取列表中的元素
5	LINSERT key BEFORE\|AFTER pivot value 在列表的元素前或者後插入元素
6	LLEN key 獲取列表長度
7	LPOP key 移出並獲取列表的第一個元素
8	LPUSH key value1 [value2] 將一個或多個值插入到列表頭部
9	LPUSHX key value 將一個值插入到已存在的列表頭部
10	LRANGE key start stop 獲取列表指定範圍內的元素
11	LREM key count value 移除列表元素
12	LSET key index value 通過索引設置列表元素的值
13	LTRIM key start stop 對一個列表進行修剪(trim)，就是說，讓列表只保留指定區間內的元素，不在指定區間之內的元素都將被刪除。
14	RPOP key 移除並獲取列表最後一個元素
15	RPOPLPUSH source destination 移除列表的最後一個元素，並將該元素添加到另一個列表並返回
16	RPUSH key value1 [value2] 在列表中添加一個或多個值
17	RPUSHX key value 為已存在的列表添加值

Set（集合）

Set是string類型的無序集合。集合是通過哈希表實現的，所以添加，刪除，查找的複雜度都是O(1)。集合中最大的成員數為 2³² - 1(4294967295, 每個集合可存儲40多億個成員)。

實例

redis 127.0.0.1:6379> SADD runoobkey redis
(integer) 1
redis 127.0.0.1:6379> SADD runoobkey mongodb
(integer) 1
redis 127.0.0.1:6379> SADD runoobkey mysql
(integer) 1
redis 127.0.0.1:6379> SADD runoobkey mysql
(integer) 0
redis 127.0.0.1:6379> SMEMBERS runoobkey

1) "mysql"
2) "mongodb"
3) "redis"

在以上實例中我們通過 SADD 命令向名為 runoobkey 的集合插入的三個元素。

下表列出了 Redis 集合基本命令：

序號	命令及描述
1	SADD key member1 [member2] 向集合添加一個或多個成員
2	SCARD key 獲取集合的成員數
3	SDIFF key1 [key2] 返回給定所有集合的差集
4	SDIFFSTORE destination key1 [key2] 返回給定所有集合的差集並存儲在 destination 中
5	SINTER key1 [key2] 返回給定所有集合的交集
6	SINTERSTORE destination key1 [key2] 返回給定所有集合的交集並存儲在 destination 中
7	SISMEMBER key member 判斷 member 元素是否是集合 key 的成員
8	SMEMBERS key 返回集合中的所有成員
9	SMOVE source destination member 將 member 元素從 source 集合移動到 destination 集合
10	SPOP key 移除並返回集合中的一個隨機元素
11	SRANDMEMBER key [count] 返回集合中一個或多個隨機數
12	SREM key member1 [member2] 移除集合中一個或多個成員
13	SUNION key1 [key2] 返回所有給定集合的並集
14	SUNIONSTORE destination key1 [key2] 所有給定集合的並集存儲在 destination 集合中
15	SSCAN key cursor [MATCH pattern] [COUNT count] 迭代集合中的元素

zset(sorted set:有序集合)

zset 和 set 一樣也是string類型元素的集合,且不允許重覆的成員。不同的是每個元素都會關聯一個double類型的分數。redis正是通過分數來為集合中的成員進行從小到大的排序。

zset的成員是唯一的,但分數(score)卻可以重覆。集合是通過哈希表實現的，所以添加，刪除，查找的複雜度都是O(1)。集合中最大的成員數為 2^{32 - 1} (4294967295, 每個集合可存儲40多億個成員)。

實例

redis 127.0.0.1:6379> ZADD runoobkey 1 redis
(integer) 1
redis 127.0.0.1:6379> ZADD runoobkey 2 mongodb
(integer) 1
redis 127.0.0.1:6379> ZADD runoobkey 3 mysql
(integer) 1
redis 127.0.0.1:6379> ZADD runoobkey 3 mysql
(integer) 0
redis 127.0.0.1:6379> ZADD runoobkey 4 mysql
(integer) 0
redis 127.0.0.1:6379> ZRANGE runoobkey 0 10 WITHSCORES

1) "redis"
2) "1"
3) "mongodb"
4) "2"
5) "mysql"
6) "4"

在以上實例中我們通過命令 ZADD 向 redis 的有序集合中添加了三個值並關聯上分數。

下表列出了 redis 有序集合的基本命令:

序號	命令及描述
1	ZADD key score1 member1 [score2 member2] 向有序集合添加一個或多個成員，或者更新已存在成員的分數
2	ZCARD key 獲取有序集合的成員數
3	ZCOUNT key min max 計算在有序集合中指定區間分數的成員數
4	ZINCRBY key increment member 有序集合中對指定成員的分數加上增量 increment
5	ZINTERSTORE destination numkeys key [key ...] 計算給定的一個或多個有序集的交集並將結果集存儲在新的有序集合 key 中
6	ZLEXCOUNT key min max 在有序集合中計算指定字典區間內成員數量
7	ZRANGE key start stop [WITHSCORES] 通過索引區間返回有序集合成指定區間內的成員
8	ZRANGEBYLEX key min max [LIMIT offset count] 通過字典區間返回有序集合的成員
9	ZRANGEBYSCORE key min max [WITHSCORES] [LIMIT] 通過分數返回有序集合指定區間內的成員
10	ZRANK key member 返回有序集合中指定成員的索引
11	ZREM key member [member ...] 移除有序集合中的一個或多個成員
12	ZREMRANGEBYLEX key min max 移除有序集合中給定的字典區間的所有成員
13	ZREMRANGEBYRANK key start stop 移除有序集合中給定的排名區間的所有成員
14	ZREMRANGEBYSCORE key min max 移除有序集合中給定的分數區間的所有成員
15	ZREVRANGE key start stop [WITHSCORES] 返回有序集中指定區間內的成員，通過索引，分數從高到底
16	ZREVRANGEBYSCORE key max min [WITHSCORES] 返回有序集中指定分數區間內的成員，分數從高到低排序
17	ZREVRANK key member 返回有序集合中指定成員的排名，有序集成員按分數值遞減(從大到小)排序
18	ZSCORE key member 返回有序集中，成員的分數值
19	ZUNIONSTORE destination numkeys key [key ...] 計算給定的一個或多個有序集的並集，並存儲在新的 key 中
20	ZSCAN key cursor [MATCH pattern] [COUNT count] 迭代有序集合中的元素（包括元素成員和元素分值）

四 Redis的API操作

單機版

Jedis 是比較主流的 Redis Java 客戶端。
第一步：導入Jedis需要的jar

<!-- Redis客戶端 -->
<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <jedis.version>2.7.2</jedis.version>
</dependency>

第二步：單元測試類
Jedis 的語法和 Redis 幾乎一樣，如果學好了Redis，Jedis也就沒問題了，可謂是買一送一。建議使用連接池的方式。

package com.itdragon.redis;
import java.util.HashMap;
import java.util.Map;
import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
import org.junit.Test;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;

public class TestJedisOperate {
    
    private final static String HOST = "112.74.83.71";
    private final static int PORT = 6379;

    /**
     * jedis 的語法和 redis 的語法幾乎一致，比較常用的有Hash，String，List
     */
    @Test
    public void jedisSignle() {
        Jedis jedis = new Jedis(HOST, PORT);
        jedis.set("account", "itdragon");
        System.out.println("set , get 操作 : " + jedis.get("account"));
        jedis.mset("account:01", "itdragon01", "account:02", "itdragon02");
        System.out.println("mset , mget 操作 : " + jedis.mget("account:01", "account:02"));
        jedis.hset("user", "name", "ITDragon");
        System.out.println("hset , hget 操作 : " + jedis.hget("user", "name"));
        Map<String, String> userMap = new HashMap<>();
        userMap.put("password", "123456");
        userMap.put("position", "Java");
        jedis.hmset("user", userMap);
        System.out.println("hmset , hmget 操作 : " + jedis.hmget("user", "name", "password", "position"));
        if (0 == jedis.llen("userList")) {
            jedis.lpush("userList", "1", "2", "3");
        }
        System.out.println("List 類型 lpush , lrange 操作 : " + jedis.lrange("userList", 0, -1));
        jedis.sadd("userSet", "1", "2", "2");
        System.out.println("Set 類型 sadd , smembers 操作 : " + jedis.smembers("userSet"));
        Map<String, Double> scoreMembers = new HashMap<>();
        scoreMembers.put("A", 65.0);
        scoreMembers.put("C", 67.0);
        scoreMembers.put("B", 66.0);
        jedis.zadd("userScore", scoreMembers);
        System.out.println("Set 類型 zadd , zrange 操作 : " + jedis.zrange("userScore", 0, -1));
        jedis.close();
    }
    
    @Test
    public void testJedisPool() {
        JedisPool pool = new JedisPool(HOST, PORT);
        Jedis jedis = pool.getResource();
        System.out.println("通過連接池獲取 key 為 account 的值 : " + jedis.get("account"));
        jedis.close();
        pool.close();
    }

}

Spring 整合 Redis

創建用於整合redis的文件 applicationContext-jedis.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p"
    xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
    http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd
    http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd
    http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-4.0.xsd">
    <!-- 載入配置文件 -->
    <context:property-placeholder location="classpath:resource/*.properties" />
    <!-- 連接池配置 (可以用 redis 預設配置，效果可能會更好)-->
    <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
        <!-- 最大連接數 -->
        <property name="maxTotal" value="30" />
        <!-- 最大空閑連接數 -->
        <property name="maxIdle" value="10" />
        <!-- 每次釋放連接的最大數目 -->
        <property name="numTestsPerEvictionRun" value="1024" />
        <!-- 釋放連接的掃描間隔（毫秒） -->
        <property name="timeBetweenEvictionRunsMillis" value="30000" />
        <!-- 連接最小空閑時間 -->
        <property name="minEvictableIdleTimeMillis" value="1800000" />
        <!-- 連接空閑多久後釋放, 當空閑時間>該值 且 空閑連接>最大空閑連接數 時直接釋放 -->
        <property name="softMinEvictableIdleTimeMillis" value="10000" />
        <!-- 獲取連接時的最大等待毫秒數,小於零:阻塞不確定的時間,預設-1 -->
        <property name="maxWaitMillis" value="1500" />
        <!-- 在獲取連接的時候檢查有效性, 預設false -->
        <property name="testOnBorrow" value="true" />
        <!-- 在空閑時檢查有效性, 預設false -->
        <property name="testWhileIdle" value="true" />
        <!-- 連接耗盡時是否阻塞, false報異常,ture阻塞直到超時, 預設true -->
        <property name="blockWhenExhausted" value="false" />
    </bean> 
    <!-- jedis客戶端單機版 -->
    <bean id="redisClient" class="redis.clients.jedis.JedisPool">
        <constructor-arg name="host" value="${redis.host}" />
        <constructor-arg name="port" value="${redis.ip}" />
        <!-- <constructor-arg name="poolConfig" ref="jedisPoolConfig" /> -->
    </bean>
    <bean id="jedisClient" class="com.itdragon.common.utils.JedisClientSingle"/>
</beans>

簡單封裝了Jedis 常用方法 JedisClientSingle.java

package com.xyg.utils;
import org.springframework.beans.factory.annotation.Autowired;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;

// 單例的Redis 工具類
public class JedisClientSingle {
    
    /**
     * connect timed out 問題： 
     * 1. 檢查redis服務是否開啟
     * 2. 檢查是否是因為防火牆的問題
     * 3. 檢查網路問題(如果在同一個區域網內幾乎不會出現這個問題)
     * Jedis jedis =new Jedis(HOST,PORT,100000);
     * JedisPool pool = new JedisPool(poolConfig, HOST, PORT, 100000);
     */
    
    @Autowired
    private JedisPool jedisPool; 
    
    public String get(String key) {
        Jedis jedis = jedisPool.getResource();
        String string = jedis.get(key);
        jedis.close();
        return string;
    }

    public String set(String key, String value) {
        Jedis jedis = jedisPool.getResource();
        String string = jedis.set(key, value);
        jedis.close();
        return string;
    }

    public String hget(String hkey, String key) {
        Jedis jedis = jedisPool.getResource();
        String string = jedis.hget(hkey, key);
        jedis.close();
        return string;
    }

    public long hset(String hkey, String key, String value) {
        Jedis jedis = jedisPool.getResource();
        Long result = jedis.hset(hkey, key, value);
        jedis.close();
        return result;
    }

    public long del(String key) {
        Jedis jedis = jedisPool.getResource();
        Long result = jedis.del(key);
        jedis.close();
        return result;
    }

    public long hdel(String hkey, String key) {
        Jedis jedis = jedisPool.getResource();
        Long result = jedis.hdel(hkey, key);
        jedis.close();
        return result;
    }

}

集群版

/**
 * 集群版測試
 * 若提示以下類似的錯誤：
 * java.lang.NumberFormatException: For input string: "6002@16002"
 * 若安裝的redis 版本大於4，則可能是jedis 的版本低了。選擇 2.9.0
 * 因為 cluster nodes 列印的信息中，4版本之前的是沒有 @16002 tcp埠信息
 * 0968ef8f5ca96681da4abaaf4ca556c2e6dd0242 112.74.83.71:6002@16002 master - 0 1512035804722 3 connected 10923-16383
 */
@Test
public void testJedisCluster() throws IOException {
    HashSet<HostAndPort> nodes = new HashSet<>();
    nodes.add(new HostAndPort(HOST, 7000));
    nodes.add(new HostAndPort(HOST, 7001));
    nodes.add(new HostAndPort(HOST, 7002));
    nodes.add(new HostAndPort(HOST, 7003));
    nodes.add(new HostAndPort(HOST, 7004));
    nodes.add(new HostAndPort(HOST, 7005));
    JedisCluster cluster = new JedisCluster(nodes);
    cluster.set("cluster-key", "cluster-value");
    System.out.println("集群測試 ： " + cluster.get("cluster-key"));
    cluster.close();
}