Lettuce Async

Redis Developer Course	Redis Technical Support	Redis Enterprise Server

Lettuce Async

Lettuce-6.1.7, Redis-7.0.2 Example
Lettuce-4.4.2, Redis-4.0.6 Example

Lettuce-6.1.7, Redis-7.0.2 Example

LettuceAsyncCmd.java
import java.sql.Timestamp; import java.util.ArrayList; import java.util.List; import java.util.Scanner; import io.lettuce.core.RedisFuture; public class LettuceAsyncCmd { Scanner scanner = new Scanner(System.in); Util util = new Util(); int loop = 10000; public LettuceAsyncCmd() { while(true) { System.out.println("1:SET 2:GET 3:SET(Sync) 4:SET(Async) \n"); System.out.println("선택(exit:99)> "); String input = scanner.nextLine(); int i = util.checkInt(input); switch (i) { case 1: set(); break; case 2: get(); break; case 3: setSync(); break; case 4: setAsync(); break; case 99: break; default: System.out.println("잘못 선택했습니다. 다시 선택하세요. "); } if (i==99) break; } } public void set() { System.out.println("SET key value"); String input = scanner.nextLine(); String[] cmd = util.split(input); if (cmd[0].equalsIgnoreCase("SET") == false) return; if (cmd.length != 3) return; try { RedisFuture<String> ret = Main.asyncCmd.set(cmd[1], cmd[2]); ret.thenAccept(r -> { System.out.println("SET -> "+r.toString()); }); } catch (Exception e) { System.out.println(e.getMessage()); return; } } public void get() { System.out.println("GET key"); String input = scanner.nextLine(); String[] cmd = util.split(input); if (cmd[0].equalsIgnoreCase("GET") == false) return; if (cmd.length != 2) return; try { RedisFuture<String> ret = Main.asyncCmd.get(cmd[1]); ret.thenAccept(r -> { System.out.println("GET -> "+r.toString()); }); } catch (Exception e) { System.out.println(e.getMessage()); return; } } public void setSync() { System.out.println("SET Sync Test "+loop+" times --------------"); long startTime = System.currentTimeMillis(); System.out.println("Start time: "+new Timestamp(startTime)); for (int i=0; i<loop; i++) { Main.syncCmd.set("keyTestSync"+i, "valueTestSync"+i); } System.out.println("SET Sync elapsed time(ms) -> "+(System.currentTimeMillis() - startTime)); } public void setAsync() { System.out.println("SET Async Test "+loop+" times --------------"); long startTime = System.currentTimeMillis(); System.out.println("Start time: "+new Timestamp(startTime)); for (int i=0; i<loop; i++) { Main.asyncCmd.set("keyTestAsync"+i, "valueTestAsync"+i); } System.out.println("SET Async elapsed time(ms) -> "+(System.currentTimeMillis() - startTime)); } protected void setPipeline() { System.out.println("SET Pipeline & Async Test "+loop+" times --------------"); long startTime = System.currentTimeMillis(); System.out.println("Start time: "+new Timestamp(startTime)); List<RedisFuture<?>> futures = new ArrayList<RedisFuture<?>>(); for (int i=0; i<loop; i++) { futures.add(Main.asyncCmd.set("keyTestPipe-" + i, "valueTestPipe-" + i)); } System.out.println("SET Pipeline elapsed time(ms) -> "+(System.currentTimeMillis() - startTime)); } }

Lettuce-4.4.2, Redis-4.0.6 Example

Lettuce Async로 구현한 Redis 대표 명령들

Async SET, GET

// Async SET, GET
// 비동기 SET, GET 명령을 실행후 for loop를 돌면서 결과가 언제 오는지 확인한다.
protected void asyncSetGet() {
	System.out.println("SET 명령 실행: "+new Timestamp(System.currentTimeMillis()));
	RedisFuture<String> future1 = Redis.asyncCmd.set("key", "value-ex6");
	future1.thenAccept(new Consumer<String>() {
			@Override
			public void accept(String value) {
					System.out.println("SET 명령 Return: "+value);
			}
	});			
	
	System.out.println("GET 명령 실행: "+new Timestamp(System.currentTimeMillis()));
	RedisFuture<String> future2 = Redis.asyncCmd.get("key");
	future2.thenAccept(new Consumer<String>() {
			@Override
			public void accept(String value) {
					System.out.println("GET 명령 Return: "+value);
			}
	});		
	
	for (int i = 0; i < 100; i++) {
		System.out.println("For Loop-"+i+" "+new Timestamp(System.currentTimeMillis()));
	}
}

Strings 대표 명령들

// 람다(lambda)식으로 표헌한 명령
// SET
protected void set() {
	long idx2 = idx++;
	RedisFuture<String> future = Redis.asyncCmd.set(key+idx2, value+idx2);
	future.thenAccept(v -> System.out.println("SET "+key+idx2+" "+value+idx2+" -> "+v));
}

// GET
protected void get() {
	long idx2 = random.nextInt(10);
	RedisFuture<String> future = Redis.asyncCmd.get(key+idx2);
	future.thenAccept(v -> System.out.println("GET "+key+idx2+" -> "+v));
}

// DEL
protected void del() {
	long idx2 = random.nextInt(10);
	RedisFuture<Long> future = Redis.asyncCmd.del(key+idx2);
	future.thenAccept(v -> System.out.println("DEL "+key+idx2+" -> "+v));
}

// INCR
protected void incr() {
	RedisFuture<Long> future = Redis.asyncCmd.incr("page");
	future.thenAccept(v -> System.out.println("INCR page -> "+v));
}

Lists 대표 명령들

// LPUSH
protected void lpush() {
	idx++;
	RedisFuture<Long> future = Redis.asyncCmd.lpush(mylist, "ele-"+idx);
	future.thenAccept(v -> System.out.println("LPUSH "+mylist+" ele"+idx+" -> "+v));
}

// RPOP
protected void rpop() {
	RedisFuture<String> future = Redis.asyncCmd.rpop(mylist);
	future.thenAccept(v -> System.out.println("RPOP "+mylist+" -> "+v));
}

// LRANGE
protected void lrange() {
	RedisFuture<List<String>> future = Redis.asyncCmd.lrange(mylist, 0, -1);
	future.thenAccept(v -> v.forEach(System.out::println));
}

Sets 대표 명령들

// SADD
protected void sadd() {
	idx++;
	RedisFuture<Long> future = Redis.asyncCmd.sadd(myset, "mem"+idx);
	future.thenAccept(v -> System.out.println("SADD "+myset+" mem"+idx+" -> "+v));
}

// SREM
protected void srem() {
	idx = random.nextInt(10);
	RedisFuture<Long> future = Redis.asyncCmd.srem(myset, "mem"+idx);
	future.thenAccept(v -> System.out.println("SREM "+myset+" mem"+idx+" -> "+v));
}

// SMEMBERS
protected void smembers() {
	RedisFuture<Set<String>> future = Redis.asyncCmd.smembers(myset);
	future.thenAccept(v -> v.forEach(System.out::println));
}

ZSets 대표 명령들

// ZADD
protected void zadd() {
	idx++;
	RedisFuture<Long> future = Redis.asyncCmd.zadd(myzset, idx, "mem"+idx);
	future.thenAccept(v -> System.out.println("ZADD "+myzset+" mem"+idx+" -> "+v));
}

// ZREM
protected void zrem() {
	idx = random.nextInt(10);
	RedisFuture<Long> future = Redis.asyncCmd.zrem(myzset, "mem"+idx);
	future.thenAccept(v -> System.out.println("ZREM "+myzset+" mem"+idx+" -> "+v));
}

// ZRANGE
protected void zrange() {
	System.out.println("zrange");
	RedisFuture<List<String>> future = Redis.asyncCmd.zrange(myzset, 0, -1);
	future.thenAccept(v -> v.forEach(System.out::println));
	System.out.println("zrangeWithScore");
	RedisFuture<List<ScoredValue<String>>> future2 = Redis.asyncCmd.zrangeWithScores(myzset, 0, -1);
	future2.thenAccept(v -> v.forEach(System.out::println));
}

Hashes 대표 명령들

// HSET
protected void hset() {
	idx++;
	RedisFuture<Boolean> future = Redis.asyncCmd.hset(myhash, "field"+idx, "value"+idx);
	future.thenAccept(v -> System.out.println("HSET "+"field"+idx+" value"+idx+" -> "+v));
}

// HDEL
protected void hdel() {
	idx = random.nextInt(10);
	RedisFuture<Long> future = Redis.asyncCmd.hdel(myhash, "field"+idx);
	future.thenAccept(v -> System.out.println("HDEL field"+idx+" -> "+v));
}

// HGETALL
protected void hgetall() {
	RedisFuture<Map<String, String>> future = Redis.asyncCmd.hgetall(myhash);
	future.thenAccept(v -> v.entrySet().forEach(System.out::println));
}

성능 테스트:Sync, Async, Pipeline

protected void setSync() {
	int loop = 100000;
	System.out.println("SET Sync Test "+loop+" times --------------");
	long startTime = System.currentTimeMillis();
	System.out.println("Start time: "+new Timestamp(startTime));
	for (int i=0; i<loop; i++) {
		Redis.syncCmd.set("keyTestSync"+i, "valueTestSync"+i);
	}
	System.out.println("SET Sync elapsed time(ms) -> "+(System.currentTimeMillis() - startTime)); 
}

protected void setAsync() {
	int loop = 100000;
	System.out.println("SET Async Test "+loop+" times --------------");
	long startTime = System.currentTimeMillis();
	System.out.println("Start time: "+new Timestamp(startTime));
	for (int i=0; i<loop; i++) {
		Redis.asyncCmd.set("keyTestAsync"+i, "valueTestAsync"+i);
	}
	System.out.println("SET Async elapsed time(ms) -> "+(System.currentTimeMillis() - startTime)); 
}

protected void setPipeline() {
	int loop = 100000;
	System.out.println("SET Pipeline & Async Test "+loop+" times --------------");
	long startTime = System.currentTimeMillis();
	System.out.println("Start time: "+new Timestamp(startTime));
	List<RedisFuture <?>> futures = new ArrayList<RedisFuture <?>>();
	for (int i=0; i<100000; i++) {
			futures.add(Redis.asyncCmd.set("keyTestPipe-" + i, "valueTestPipe-" + i));
	}
	System.out.println("SET Pipeline elapsed time(ms) -> "+(System.currentTimeMillis() - startTime)); 
}

에러 처리

// Error handling
protected void errorHandling() {
	long idx2 = random.nextInt(10);
	try {
		RedisFuture<String> future = Redis.asyncCmd.get(key+idx2);
		future.handleAsync(new BiFunction<String, Throwable, String>() {
				@Override
				public String apply(String value, Throwable throwable) {
						if(throwable != null) {
							return "Get Error";
						}
						return value;
				}
		}).thenAccept(v -> System.out.println("GET "+key+idx2+" -> "+v));
	} catch (Exception e) {
		System.out.println("Redis Async GET Error!!!!!!!!!");
		System.out.println(e);
		return;
	}
}

<< Common Keys	Async	Reactive >>

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