Redisson Cluster

Redis Developer Course	Redis Technical Support	Redis Enterprise Server

Cluster

Class 변수로 선언

String key = "keyX";
String value = "value";
int idx = 0;

SET in cluster

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

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

SET Async in cluster

protected void asyncSet() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("set");
	String key = "keyAsync-";
	long loop = 1000;
	long start = System.currentTimeMillis(); 
	for (int i=idx; i<(idx+loop); i++) {
		try {
			Redis.redissonCluster.getBucket(key+i).setAsync(value+i);
		} catch (Exception e) {
			System.out.println(e);
		}
	}
	idx += loop;
	System.out.println("set "+loop+" elapsed time(ms) -> "+(System.currentTimeMillis() - start)); 
}

MSET in cluster -> 해당하는 메소드 없음.

protected void mset() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("mset -> 해당하는 명령 없음. Redisson 3.5.7 (2018.01.28)");
}

MGET in cluster -> 해당하는 메소드 없음.

protected void mget() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("mget -> 해당하는 명령 없음. Redisson 3.5.7 (2018.01.28)");
}

KEYS in cluster

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

protected void keys() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("keys -> 클러스터의 모든 키를 가져온다.");
	try {
		Collection<String> keys = Redis.redissonCluster.getKeys().findKeysByPattern("*");
		System.out.println("keys * -> size: "+keys.size()+", "+keys.toString());
	} catch (Exception e) {
		System.out.println(e);
	}
}

DBSIZE in cluster

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

protected void dbsize() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("dbsize");
	try {
		long dbsize = Redis.redissonCluster.getKeys().count();
		System.out.println("dbsize -> "+dbsize);
	} catch (Exception e) {
		System.out.println(e);
	}
}

Pipeline SET in cluster

에러가 발생해서 실행할 수 없었다.

protected void pipelineSet() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("Cluster Pipeline set");
	System.out.println("1월 29, 2018 12:42:48 오전 io.netty.util.internal.logging.Slf4JLogger error");
	System.out.println("심각: LEAK: ByteBuf.release() was not called before it's garbage-collected. See http://netty.io/wiki/reference-counted-objects.html for more information.");
	System.out.println("Recent access records:");
	/* 아래 코드를 실행하면 위와 같은 에러가 발생한다.	
	RBatch batch = Redis.redissonMasterSlave.createBatch();
	String key = "keyZ";
	int loop = 1000;
	long start = System.currentTimeMillis(); 
	try {
		for (int i=0; i<loop; i++) {
			batch.getBucket(key+i).setAsync("value"+i);
		}
	} catch (Exception e) {
		System.out.println(e);
	}
	System.out.println("Cluster Pipeline set elapsed time(ms) -> "+(System.currentTimeMillis() - start));
	*/ 
}

COUNTKEYSINSLOT -> 해당하는 메소드 없음.

// CLUSTER COUNTKEYSINSLOT slot -> return Long
protected void clusterCountKeysInSlot() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("CLUSTER COUNTKEYSINSLOT slot -> 해당하는 메소드 없음. Redisson 3.5.7 (2018.01.28)");
}

Cluster Info

// CLUSTER INFO -> return String
protected void clusterInfo() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("CLUSTER INFO");
	String connClusterNode1 = "redis://127.0.0.1:7000";
	try {
		ClusterNode node = Redis.redissonCluster.getClusterNodesGroup().getNode(connClusterNode1);
		Map<String, String> info = node.clusterInfo();
		System.out.println("cluster info -> "+info.toString());
	} catch (Exception e) {
		System.out.println(e);
	}
}

SHUTDOWN in cluster -> 해당하는 메소드 없음.

// SHUTDOWN 
protected void clusterShutdown() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("SHUTDOWN -> 해당하는 메소드 없음. Redisson 3.5.7 (2018.01.28)");
}

<< Sentinel	Cluster

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