Redisson Pipeline

Redis Developer Course	Redis Technical Support	Redis Enterprise Server

Pipeline

Pipeline 기능은 확인할 수 없었다. 대신 Async 기능을 이용했다.

SET Sync

protected void set() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("Set");
	String key = "keyX";
	int loop = 100000;
	long start = System.currentTimeMillis(); 
	try {
		for (int i=0; i<loop; i++) {
			RBinaryStream stream = Redis.redissonMasterSlave.getBinaryStream(key+i);
			String value = "value"+i;
			byte[] bytes = value.getBytes();
			stream.set(bytes);
		}
	} catch (Exception e) {
		System.out.println(e);
	}
	System.out.println("SET elapsed time(ms) -> "+(System.currentTimeMillis() - start)); 
}

SET Async

protected void asyncSet() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("Async Set");
	String key = "keyY";
	int loop = 100000;
	long start = System.currentTimeMillis(); 
	try {
		for (int i=0; i<loop; i++) {
			RBinaryStream stream = Redis.redissonMasterSlave.getBinaryStream(key+i);
			String value = "value"+i;
			byte[] bytes = value.getBytes();
			stream.setAsync(bytes);
		}
	} catch (Exception e) {
		System.out.println(e);
	}
	System.out.println("Async SET elapsed time(ms) -> "+(System.currentTimeMillis() - start)); 
}

SET Batch -> createBatch를 이용했으나 데이터가 저장되지 않았다.

protected void pipelineSet() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("Pipeline(Async) Set");
	RBatch batch = Redis.redissonMasterSlave.createBatch();
	
	String key = "keyZ";
	int loop = 100000;
	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("Pipeline(Async) SET elapsed time(ms) -> "+(System.currentTimeMillis() - start)); 
}

<< Common Keys	Pipeline	Sentinel >>

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