Clients

Lettuce Cluster

레디스 개발자 교육 신청	레디스 정기점검/기술지원 Redis Technical Support	레디스 엔터프라이즈 서버 Redis Enterprise Server

Cluster

Class 변수로 선언

public static RedisClusterClient redisCluster = null;
public static StatefulRedisClusterConnection<String, String> connection = null;
public static RedisAdvancedClusterCommands<String, String> cluster = null;
public static RedisAdvancedClusterAsyncCommands<String, String> clusterAsync = null;

Connection

클러스터 내 노드의 IP, Port를 지정해서 접속한다. 어떤 노드를 지정해서 접속해도 접속에 성공하면 cluster nodes 명령을 실행해서 클러스터 내 모든 노드의 정보를 lettuce가 가지고 있다. 노드는 하나만 지정해도 되지만, 그 노드가 다운되었을 경우에 대비해서 여러 노드를 지정한다. 복제(replica) 노드를 지정해도 된다.

enablePeriodicRefresh(): 지정한 시간마다 클러스터 구성 정보를 가져와서 업데이트한다. 노드가 추가/삭제되었거나, 노드 다운으로 역할 변경(마스터 -> 복제(replica)), 슬롯이 이동했을 경우 등 클러스터 구성 정보가 변경되었을 경우 최신 정보로 업데이트해야 한다. 노드가 많을 경우 너무 짧은 시간을 지정하면 refresh 부하가 발생할 수 있다.
redisCluster.reloadPartitions(): 수동으로 refresh할 경우 이 메서드를 사용한다.
setReadFrom(ReadFrom.SLAVE): 이렇게 설정하면 get 같은 조회 명령은 복제(replica) 노드에서 실행된다. 마스터/복제(replica)간 부하 분산(Load-Balancing)을 할 수 있다.
autoReconnect(): ConnectionWatchdog이 노드 다운을 감지하면 연결을 시도한다. Default는 true이다. enablePeriodicRefresh()와 중복되는 경향이 있다.
RedisClusterClient로 접속했을 경우 ping, info같은 명령의 실행 노드를 지정할 수 없다. 노드를 지정하고 싶을 경우 RedisClient로 접속한다.

String host = "192.168.56.103";
int port1 = 7001;
int port2 = 7005;
RedisURI node1 = RedisURI.create(host, port1);
RedisURI node2 = RedisURI.create(host, port2);
node1.setTimeout(1);
node2.setTimeout(1);

try {
	redisCluster = RedisClusterClient.create(Arrays.asList(node1, node2));
} catch (Exception e) {
	System.out.println(e);
	return;
}

ClusterTopologyRefreshOptions topologyRefreshOptions = ClusterTopologyRefreshOptions.builder()
		.enablePeriodicRefresh(30, TimeUnit.SECONDS)		
		.enableAllAdaptiveRefreshTriggers()
		.build();

redisCluster.setOptions(ClusterClientOptions.builder()
		 .topologyRefreshOptions(topologyRefreshOptions)
		 .autoReconnect(false)
		 .build());

connection = redisCluster.connect();
connection.setReadFrom(ReadFrom.SLAVE);	// -> Readonly 
cluster = connection.sync();
clusterAsync = connection.async();
String ret = cluster.ping();
System.out.println(port+"-cluster] ping -> "+ret);
String ret2 = cluster.info("server");
System.out.println("info server -> "+ret2);

SET in cluster

데이터는 클러스터 내 모든 마스터 노드에 고르게 분산 저장됩니다.

protected void set() {
	long loop = 1000000;
	long start = System.currentTimeMillis(); 
	for (int i=idx; i<(idx+loop); i++) {
		try {
			String ret = cluster.set(key+i, "value"+i);
			System.out.println("set "+key+i+" value"+i+" -> "+ret+" "+(System.currentTimeMillis()/1000));
		} catch (Exception e) {
			System.out.println(e);
		}
	}
	idx += loop;
	System.out.println("set elapsed time(ms) -> "+(System.currentTimeMillis() - start)); 
}

MSET in cluster

Multi key command가 redis-cli에서는 안되지만 lettuce에서는 된다. 단 mset이 키 개수만큼 실행된다.

// mset 명령이 key 개수만큼 실행된다. 
protected void mset() {
	Map<String, String> keys = new HashMap<String, String>();
	for (int i=1000; i<2000; i++) {
		keys.put(key+i, "value"+i);
	}
	long start = System.currentTimeMillis(); 
	try {
		String ret = cluster.mset(keys);
		System.out.println("mset -> "+ret);
	} catch (Exception e) {
		System.out.println(e);
	}
	System.out.println("mset elapsed time(ms) -> "+(System.currentTimeMillis() - start)); 
}

MGET in cluster

protected void mget() {
	String key = "key";
	String keys[ ] = new String[10];
	int idx = 0;
	try {
		for (int i=0; i<10; i++) {
			keys[i] = key+idx;
			idx++;
		}
		List<String> ret = cluster.mget(keys);
		System.out.println(ret.toString());
	} catch (Exception e) {
		System.out.println(e);
	}
}

KEYS in cluster

클러스터 내 모든 마스터 노드에서 키를 조회한다.

protected void keys() {
	try {
		List<String> ret = cluster.keys("*");
		System.out.println("keys * -> "+ret.size()+" (count)");
	} catch (Exception e) {
		System.out.println(e);
	}
}

DBSIZE in cluster

클러스터 내 모든 마스터 노드의 키의 합계를 리턴한다.

protected void dbsize() {
	try {
		Long dbsize = cluster.dbsize();
		System.out.println("dbsize -> "+dbsize);
	} catch (Exception e) {
		System.out.println(e);
	}
}

MEMORYUSAGE in cluster

키가 사용하는 메모리량을 리턴합니다. 지정한 키가 있는 노드에 접속해서 메모리 사용량을 계산합니다.

protected void memoryUsage() {
	try {
		Long mem = cluster.memoryUsage();
		System.out.println("memoryUsage -> "+mem);
	} catch (Exception e) {
		System.out.println(e);
	}
}

Pipeline SET in cluster

Pipeline/Async를 이용하면 속도가 빠르다.

protected void pipelineSet() {
	long start = System.currentTimeMillis(); 
	try {
		List<RedisFuture<?>> futures = new ArrayList<RedisFuture<?>>();
		for (int i=0; i<100000; i++) {
				futures.add(clusterAsync.set("key-" + i, "value-" + i));
		}
	} catch (Exception e) {
		System.out.println(e);
	}
	System.out.println("Cluster Pipeline set elapsed time(ms) -> "+(System.currentTimeMillis() - start)); 
}

SHUTDOWN in cluster

클러스터 내 모든 노드를 shutdown한다. True로 설정하면 RDB 파일을 저장하고 shutdown된다.

// SHUTDOWN -> 클러스터 내 모든 노드를 shutdown한다. True -> save rdb
protected void clusterShutdown() {
	try {
		cluster.shutdown(true);
	} catch (Exception e) {
		System.out.println(e);
	}
}

Cluster Commands

Lettuce Cluster Commands

Cluster Meet -> Simply string reply.
Cluster Forget -> Simply string reply.
Cluster AddSlots -> Simply string reply.
Cluster DelSlots -> Simply string reply.
Cluster Info -> Bulk string reply.
Cluster Nodes -> Bulk string reply.
Cluster Replicate -> Simply string reply.
Cluster Slaves -> Array(List<String>) reply.
Cluster Keyslot -> Integer reply.
Cluster CountKeysInSlot -> Integer reply.
Cluster GetKeysInSlot -> Array(List<String>) reply.
Cluster SetSlot -> Simply string reply.
Cluster Slots -> 3 Nested array(List<Object>) reply.
Cluster Failover -> Simply string reply.
Cluster Count-Failure-Reports -> Integer reply.
Cluster Reset -> Simply string reply.
Cluster SaveConfig -> Simply string reply.
Cluster Set-Config-Epoch -> Simply string reply.
Cluster ReadOnly -> Simply string reply.
Cluster ReadWrite -> Simply string reply.

Cluster Meet

// CLUSTER MEET ip port -> Simply string reply
protected void clusterMeet() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("CLUSTER MEET ip port -> Simply string reply");
	String ret = null;
	String host = "192.168.56.103";
	int port = 7002;
	try {
		ret = cluster.clusterMeet(host, port);
	} catch (Exception e) {
		System.out.println(e);
		return;
	}
	System.out.println("cluster meet "+host+" "+port+" -> "+ret);
}

Cluster Forget

// CLUSTER FORGET nodeId -> Simply string reply
protected void clusterForget() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("CLUSTER FORGET nodeid -> Simply string reply");
	String ret = null;
	String nodeId = "xxxxxxxxxxxxxx";
	try {
		ret = cluster.clusterForget(nodeId);
	} catch (Exception e) {
		System.out.println(e);
		return;
	}
	System.out.println("cluster forget "+nodeId+" -> "+ret);
}

Cluster AddSlots

// CLUSTER ADDSLOTS slot [slot ...] -> Simply string reply
protected void clusterAddSlots() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("CLUSTER ADDSLOTS slot [slot ...] -> Simply string reply");
	String ret = null;
	int slot = 0;
	try {
		ret = cluster.clusterAddSlots(slot);
	} catch (Exception e) {
		System.out.println(e);
		return;
	}
	System.out.println("cluster addslots "+slot+" -> "+ret);
}

Cluster DelSlots

// CLUSTER DELSLOTS slot [slot ...] -> Simply string reply
protected void clusterDelSlots() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("CLUSTER DELSLOTS slot [slot ...] -> Simply string reply");
	String ret = null;
	int slot = 0;
	try {
		ret = cluster.clusterDelSlots(slot);
	} catch (Exception e) {
		System.out.println(e);
		return;
	}
	System.out.println("cluster delslots "+slot+" -> "+ret);
}

Cluster Info

// CLUSTER INFO -> Bulk string reply
protected void clusterInfo() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("CLUSTER INFO -> Bulk string reply");
	String ret = null;
	try {
		ret = cluster.clusterInfo();
	} catch (Exception e) {
		System.out.println(e);
		return;
	}
	System.out.println("cluster info -> ");
	System.out.println(ret);
}

Cluster Nodes

// CLUSTER NODES -> Bulk string reply
protected void clusterNodes() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("CLUSTER NODES -> Bulk string reply");
	String ret = null;
	try {
		ret = cluster.clusterNodes();
	} catch (Exception e) {
		System.out.println(e);
		return;
	}
	System.out.println("cluster nodes -> ");
	System.out.println(ret);
}

Cluster Replicate

// CLUSTER REPLICATE -> Simple string reply
protected void clusterReplicate() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("CLUSTER REPLICATE -> Simple string reply");
	String nodeId = "xxxxxxxxxxxxxx";
	String ret = null;
	try {
		ret = cluster.clusterReplicate(nodeId);
	} catch (Exception e) {
		System.out.println(e);
		return;
	}
	System.out.println("cluster replicate -> "+ret);
}

Cluster Slaves

// CLUSTER SLAVES -> Array reply
protected void clusterSalves() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("CLUSTER SLAVES -> List<String>");
	String nodeId = "95f485be27ef3fcf0e9a2bae6005fdecfa981c8b";
	List<String> list = null;
	try {
		list = cluster.clusterSlaves(nodeId);
	} catch (Exception e) {
		System.out.println(e);
		return;
	}
	System.out.println("cluster slaves -> "+list.size());
	ListIterator<String> itr=list.listIterator();
	while(itr.hasNext()){  
		System.out.println(itr.next());  
	}  
}

Cluster Keyslot

// CLUSTER KEYSLOT slot -> integer
protected void clusterKeySlot() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("CLUSTER KEYSLOT slot -> long.");
	String key = "key";
	long ret = 0;
	try {
		ret = cluster.clusterKeyslot(key);
	} catch (Exception e) {
		System.out.println(e);
		return;
	}
	System.out.println("cluster keyslot "+key+" -> "+ret);
}

Cluster CountKeysInSlot

// CLUSTER COUNTKEYSINSLOT slot -> integer
protected void clusterCountKeysInSlot() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("CLUSTER COUNTKEYSINSLOT slot -> return Long");
	try {
		for (int i=0; i<16384; i++) {
			Long count = cluster.clusterCountKeysInSlot(i);
			if (count > 1) {
				System.out.println("clusterCountKeyInSlot "+i+" -> "+count);
			}
		}
	} catch (Exception e) {
		System.out.println(e);
	}
}

Cluster GetKeysInSlot

// CLUSTER GETKEYSINSLOT slot count -> array reply.
protected void clusterGetKeysInSlot() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("CLUSTER GETKEYSINSLOT slot count -> List<String>");
	int slot = 0;
	List<String> list;
	try {
		list = cluster.clusterGetKeysInSlot(slot, 10);
	} catch (Exception e) {
		System.out.println(e);
		return;
	}
	System.out.println("cluster countkeysinslot "+slot+" -> "+list.size());
	ListIterator<String> itr=list.listIterator();
	while(itr.hasNext()){  
		System.out.println(itr.next());  
	}  
}

Cluster SetSlot

// CLUSTER SETSLOT slot MIGRATING|IMPORTING|STABLE|NODE [node-id] -> Simple string reply.
protected void clusterSetSlot() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("CLUSTER SETSLOT slot MIGRATING|IMPORTING|STABLE|NODE [node-id] -> Simple string reply.");
	int slot = 0;
	String ret;
	String nodeId = "95f485be27ef3fcf0e9a2bae6005fdecfa981c8b";
	// MIGRATING
	try {
		ret = cluster.clusterSetSlotMigrating(slot, nodeId);
		System.out.println("cluster setslot "+slot+" migrating "+nodeId +" -> "+ret);
	} catch (Exception e) {
		System.out.println("cluster setslot "+slot+" migrating "+nodeId +" -> ");
		System.out.println(e);
	}
	// IMPORTING
	try {
		ret = cluster.clusterSetSlotImporting(slot, nodeId);
		System.out.println("cluster setslot "+slot+" importing "+nodeId +" -> "+ret);
	} catch (Exception e) {
		System.out.println("cluster setslot "+slot+" importing "+nodeId +" -> ");
		System.out.println(e);
	}
	// STABLE
	try {
		ret = cluster.clusterSetSlotStable(slot);
		System.out.println("cluster setslot "+slot+" -> "+ret);
	} catch (Exception e) {
		System.out.println("cluster setslot "+slot+" -> ");
		System.out.println(e);
	}
	// NODE
	try {
		ret = cluster.clusterSetSlotNode(slot, nodeId);
		System.out.println("cluster setslot "+slot+" node "+nodeId+" -> "+ret);
	} catch (Exception e) {
		System.out.println("cluster setslot "+slot+" node "+nodeId+" -> ");
		System.out.println(e);
	}	
}

Cluster Slots

// CLUSTER SLOTS -> 3 Nested array reply.
protected void clusterSlots() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("CLUSTER SLOTS -> List<Object>");
	List<Object> list;
	try {
		list = cluster.clusterSlots();
	} catch (Exception e) {
		System.out.println(e);
		return;
	}
	System.out.println("cluster slots -> "+list.size());
	for (int i=0; i<list.size(); i++) {
		System.out.println(i+". "+list.get(i));
		List<Object> o = (List<Object>) list.get(i);
		for (int j=0; j<o.size(); j++) {
			if (j < 2) {
				System.out.println("  "+j+") "+o.get(j));
			} else {
				List<Object> o2 = (List<Object>) o.get(j);
				for (int k=0; k<o2.size(); k++) {
					System.out.println("    "+k+"> "+o2.get(k));
				}
			}
		}
	}
}

Cluster Failover

// CLUSTER FAILOVER -> Simple string reply.
protected void clusterFailover() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("CLUSTER FAILOVER -> Simple string reply");
	// true: No option, 마스터가 살아있을 때 사용 
	// false: [FORCE|TAKEOVER], 마스터가 다운되었을 때 사용
	String ret;
	try {
		ret = cluster.clusterFailover(true);	// true: master가 살아있을 때 사용한다. maybe
		System.out.println("cluster failover -> "+ret);
	} catch (Exception e) {
		System.out.println(e);
		return;
	}
}

Cluster Count-Failure-Reports

// CLUSTER COUNT-FAILURE-REPORTS -> integer reply.
protected void clusterCountFailureReports() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("CLUSTER COUNT-FAILURE-REPORTS -> return long.");
	String nodeId = "xxxx";
	try {
		long count = cluster.clusterCountFailureReports(nodeId);
		System.out.println("cluster count-failure-reports "+nodeId+" -> "+count);
	} catch (Exception e) {
		System.out.println(e);
		return;
	}
}

Cluster Reset

// CLUSTER RESET -> Simple string reply.
protected void clusterReset() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("CLUSTER RESET -> return Simple String.");
	String ret;
	try {
		ret = cluster.clusterReset(false);		// soft
		System.out.println("cluster reset soft -> "+ret);
	} catch (Exception e) {
		System.out.println(e);
		return;
	}
	try {
		ret = cluster.clusterReset(true);	// hard -> true for hard reset. Generates a new nodeId and currentEpoch/configEpoch are set to 0
		System.out.println("cluster reset hard -> "+ret);
	} catch (Exception e) {
		System.out.println(e);
		return;
	}
}

Cluster SaveConfig

// CLUSTER SAVECONFIG -> Simple string reply.
protected void clusterSaveConfig() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("CLUSTER SAVECONFIG -> Simple string reply.");
	String ret;
	try {
		ret = cluster.clusterSaveconfig();
		System.out.println("cluster saveconfig -> "+ret);
	} catch (Exception e) {
		System.out.println(e);
		return;
	}
}

Cluster Set-Config-Epoch

// CLUSTER SET-CONFIG-EPOCH -> Simple string reply.
protected void clusterSetConfigEpoch() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("CLUSTER SET-CONFIG-EPOCH -> Simple string reply.");
	try {
		String ret = cluster.clusterSetConfigEpoch(0);
		System.out.println("cluster set-config-epoch 0 -> "+ret);
	} catch (Exception e) {
		System.out.println(e);
		return;
	}
}

Cluster ReadOnly

// READONLY -> Simple string reply.
protected void clusterReadOnly() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("CLUSTER READONLY -> Simple string reply.");
	String ret;
	try {
		ret = cluster.readOnly();
	} catch (Exception e) {
		System.out.println(e);
		return;
	}
	System.out.println("readonly -> "+ret);
}

Cluster ReadWrite

// READWRITE -> Simple string reply.
protected void clusterReadWrite() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("CLUSTER READWRITE -> Simple string reply.");
	String ret;
	try {
		ret = cluster.readWrite();
	} catch (Exception e) {
		System.out.println(e);
		return;
	}
	System.out.println("readwrite -> "+ret);
}

<< Sentinel Failover	Cluster	Cluster Failover >>

Email 답글이 올라오면 이메일로 알려드리겠습니다.