Lettuce Async

Redis 開発者教育 Redis Developer Course	Redis 定期点検/技術支援 Redis Technical Support	Redis エンタープライズサーバ Redis Enterprise Server

Lettuce Async

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 返事がかかってなれば、メールでお知らせします。