Lettuce ZSets

Redis Developer Course	Redis Technical Support	Redis Enterprise Server

ZSets

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

LettuceZsetCmd.java
import java.util.List; import java.util.Scanner; import io.lettuce.core.Limit; import io.lettuce.core.Range; import io.lettuce.core.Range.Boundary; import io.lettuce.core.ScoredValue; import io.lettuce.core.ZAddArgs; public class LettuceZsetCmd { Scanner scanner = new Scanner(System.in); Util util = new Util(); public LettuceZsetCmd() { while(true) { System.out.println("1:ZADD 2:ZREM 3:ZRANGE 4:ZCARD 5:ZRANGEBYSCORE 6:ZRANGEBYLEX\n"); System.out.println("선택(exit:99)> "); String input = scanner.nextLine(); int i = util.checkInt(input); switch (i) { case 1: zadd(); break; case 2: zrem(); break; case 3: zrange(); break; case 4: zcard(); break; case 5: zrangebyscore(); break; case 6: zrangebylex(); break; case 99: break; default: System.out.println("잘못 선택했습니다. 다시 선택하세요. "); } if (i==99) break; } } // ZADD key [NX|XX] [GT|LT] [CH] [INCR] score member [score member ...] // 이 명령은 version 1.2.0 부터 사용할 수 있습니다. // 버전 2.4 이후 부터 member를 여러 개 입력할 수 있습니다. // 버전 3.0.2 [NX|XX] [CH] [INCR] 추가 // NX: 멤버가 이미 있으면 업데이트하지 않고 없을 경우에만 추가한다. // XX: 이미 존재하는 멤버에 스코어를 업데이트한다. // CH: 스코어를 업데이트한 경우에만 업데이트한 멤버수를 리턴한다. // 스코어가 같으면 0을 리턴하고, 다르면 업데이트하고 1을 리턴한다. 리턴 값에만 영향을 미치는 옵션이다. // INCR: 스코어를 주어진 값만큼 증가시킨다. // 버전 6.2 [GT|LT] 추가 // LT: 새 스코어가 현재 스크오 보다 적은 경우에만 기존 요소를 업데이트 합니다. // GT: 새 스코어가 현재 스크오 보다 큰 경우에만 기존 요소를 업데이트 합니다. @SuppressWarnings("unchecked") public void zadd() { System.out.println("ZADD key [NX|XX] [GT|LT] [CH] [INCR] score1 member1 [score2 member2 ...]"); String input = scanner.nextLine(); String[] cmd = util.split(input); if (cmd[0].equalsIgnoreCase("ZADD") == false) return; if (cmd.length < 4) return; ZAddArgs args = new ZAddArgs(); // option이 없을 경우 if (cmd.length % 2 == 0) { ScoredValue<String>[] list = new ScoredValue[(cmd.length-2)/2]; for (int i=2, j=0; i<cmd.length; i++, j++) { Double d = util.checkDouble(cmd[i]); list[j] = ScoredValue.just(d, cmd[++i]); } try { Long ret = Main.syncCmd.zadd(cmd[1], list); System.out.println("ZADD -> "+ret); } catch (Exception e) { System.out.println(e.getMessage()); return; } } else { // option이 있을 경우 switch (cmd[2].toUpperCase()) { case "NX": args.nx(); break; case "XX": args.xx(); break; case "GT": args.gt(); break; case "LT": args.lt(); break; case "CH": args.ch(); break; } ScoredValue<String>[] list = new ScoredValue[(cmd.length-3)/2]; for (int i=3, j=0; i<cmd.length; i++, j++) { Double d = util.checkDouble(cmd[i]); list[j] = ScoredValue.just(d, cmd[++i]); } try { Long ret = Main.syncCmd.zadd(cmd[1], args, list); System.out.println("ZADD -> "+ret); } catch (Exception e) { System.out.println(e.getMessage()); return; } } } // ZREM key member1 [member2 ...] // 이 명령은 version 1.2.0 부터 사용할 수 있다. // 버전 2.4 이후 부터 member를 여러개 지정할 수 있다. public void zrem() { System.out.println("ZREM key member1 [member2 ...]"); String input = scanner.nextLine(); String[] cmd = util.split(input); if (cmd[0].equalsIgnoreCase("ZREM") == false) return; if (cmd.length < 3) return; String cmd2[] = util.split(input.substring(cmd[0].length()+cmd[1].length()+2)); try { Long ret = Main.syncCmd.zrem(cmd[1], cmd2); System.out.println("ZREM -> "+ret); } catch (Exception e) { System.out.println(e.getMessage()); return; } } // ZRANGE key start stop [REV] [[BYSCORE|BYLEX] [LIMIT offset count]] [withscores] // 이 명령은 version 1.2.0 부터 사용할 수 있습니다. // REV, BYSCORE|BYLEX, LIMIT offset count 옵션은 버전 6.2부터 사용할 수 있습니다. public void zrange() { System.out.println("ZRANGE key start stop [REV] [[BYSCORE|BYLEX] [LIMIT offset count]] [withscores]"); String input = scanner.nextLine(); String[] cmd = util.split(input); if (cmd[0].equalsIgnoreCase("ZRANGE") == false) return; if (cmd.length < 4) return; if (cmd.length == 4) { long start = util.checkLong(cmd[2]); long stop = util.checkLong(cmd[3]); try { List<String> ret = Main.syncCmd.zrange(cmd[1], start, stop); System.out.println("ZRANGE -> "+ret.toString()); } catch (Exception e) { System.out.println(e.getMessage()); return; } } else { // cmd.length > 4 if (cmd[4].equalsIgnoreCase("WITHSCORES")) { long start = util.checkLong(cmd[2]); long stop = util.checkLong(cmd[3]); try { List<ScoredValue<String>> ret = Main.syncCmd.zrangeWithScores(cmd[1], start, stop); System.out.println("ZRANGE -> "+ret.toString()); } catch (Exception e) { System.out.println(e.getMessage()); return; } } else if (cmd[4].equalsIgnoreCase("BYSCORE")) { try { Range<Number> range = makeRangeByScore(cmd[2], cmd[3]); List<String> ret = Main.syncCmd.zrangebyscore(cmd[1], range); System.out.println("ZRANGE -> "+ret.toString()); } catch (Exception e) { System.out.println(e.getMessage()); return; } } else if (cmd[4].equalsIgnoreCase("BYLEX")) { try { Range<String> range = makeRangeByLex(cmd[2], cmd[3]); List<String> ret = Main.syncCmd.zrangebylex(cmd[1], range); System.out.println("ZRANGE -> "+ret.toString()); } catch (Exception e) { System.out.println(e.getMessage()); return; } } } } // ZCARD key // 이 명령은 version 1.2.0 부터 사용할 수 있다. public void zcard() { System.out.println("ZCARD key"); String input = scanner.nextLine(); String[] cmd = util.split(input); if (cmd[0].equalsIgnoreCase("ZCARD") == false) return; if (cmd.length != 2) return; try { Long ret = Main.syncCmd.zcard(cmd[1]); System.out.println("ZCARD -> "+ret); } catch (Exception e) { System.out.println(e.getMessage()); return; } } // ZRANGEBYSCORE key min max [withscores] [limit offset count] // 이 명령은 version 1.2.0 부터 사용할 수 있습니다. // 버전 2.0.0 부터 withscores 옵션을 사용할 수 있습니다. public void zrangebyscore() { System.out.println("ZRANGEBYSCORE key min max [withscores] [limit offset count]"); String input = scanner.nextLine(); String[] cmd = util.split(input); if (cmd[0].equalsIgnoreCase("ZRANGEBYSCORE") == false) return; if (cmd.length < 4) return; Range<Number> range = makeRangeByScore(cmd[2], cmd[3]); if (cmd.length == 4) { try { List<String> ret = Main.syncCmd.zrangebyscore(cmd[1], range); System.out.println("ZRANGEBYSCORE -> "+ret.toString()); } catch (Exception e) { System.out.println(e.getMessage()); return; } } else { if (cmd[4].equalsIgnoreCase("LIMIT")) { try { long offset = util.checkLong(cmd[5]); long count = util.checkLong(cmd[6]); Limit limit = Limit.create(offset, count); List<String> ret = Main.syncCmd.zrangebyscore(cmd[1], range, limit); System.out.println("ZRANGEBYSCORE -> "+ret.toString()); } catch (Exception e) { System.out.println(e.getMessage()); return; } } } } // ZRANGEBYLEX key min max [limit offset count] // 이 명령은 version 2.8.9 부터 사용할 수 있습니다. public void zrangebylex() { System.out.println("ZRANGEBYLEX key min max [limit offset count]"); String input = scanner.nextLine(); String[] cmd = util.split(input); if (cmd[0].equalsIgnoreCase("ZRANGEBYLEX") == false) return; if (cmd.length < 4) return; Range<String> range = makeRangeByLex(cmd[2], cmd[3]); try { List<String> ret = Main.syncCmd.zrangebylex(cmd[1], range); System.out.println("ZRANGEBYLEX -> "+ret.toString()); } catch (Exception e) { System.out.println(e.getMessage()); return; } } //------------------------------------------------------------------------- // by score: -inf, +inf, ( 제외, 입력하지 않으면 포함. public Range<Number> makeRangeByScore(String smin, String smax) { Range<Number> range = null; if (smin.equalsIgnoreCase("-INF")) { if (smax.equalsIgnoreCase("+INF")) { range = Range.unbounded(); } else { if (smax.substring(0, 1).equals("(")) { // excluding double max = util.checkDouble(smax.substring(1)); if (max == Double.MIN_VALUE) return range; range = Range.from(Boundary.unbounded(), Boundary.excluding(max)); } else { // including double max = util.checkDouble(smax); if (max == Double.MIN_VALUE) return range; range = Range.from(Boundary.unbounded(), Boundary.including(max)); } } } else { if (smin.substring(0, 1).equals("(")) { // excluding double min = util.checkDouble(smin.substring(1)); if (min == Double.MIN_VALUE) return range; if (smax.equalsIgnoreCase("+INF")) { // unbounded range = Range.from(Boundary.excluding(min), Boundary.unbounded()); } else { if (smax.substring(0, 1).equals("(")) { // excluding double max = util.checkDouble(smax.substring(1)); if (max == Double.MIN_VALUE) return range; range = Range.from(Boundary.excluding(min), Boundary.excluding(max)); } else { // including double max = util.checkDouble(smax); if (max == Double.MIN_VALUE) return range; range = Range.from(Boundary.excluding(min), Boundary.including(max)); } } } else { // including double min = util.checkDouble(smin); if (min == Double.MIN_VALUE) return range; if (smax.equalsIgnoreCase("+INF")) { // unbounded range = Range.from(Boundary.including(min), Boundary.unbounded()); } else { if (smax.substring(0, 1).equals("(")) { // excluding double max = util.checkDouble(smax.substring(1)); if (max == Double.MIN_VALUE) return range; range = Range.from(Boundary.including(min), Boundary.excluding(max)); } else { // including double max = util.checkDouble(smax); if (max == Double.MIN_VALUE) return range; range = Range.from(Boundary.including(min), Boundary.including(max)); } } } } return range; } // by lex public Range<String> makeRangeByLex(String smin, String smax) { Range<String> range = null; if (smin.equalsIgnoreCase("-")) { if (smax.equalsIgnoreCase("+")) { range = Range.unbounded(); } else { if (smax.substring(0, 1).equals("(")) { // excluding range = Range.from(Boundary.unbounded(), Boundary.excluding(smax.substring(1))); } else if (smax.substring(0, 1).equals("[")) { // including range = Range.from(Boundary.unbounded(), Boundary.including(smax.substring(1))); } else { return range; } } } else { if (smin.substring(0, 1).equals("(")) { // excluding if (smax.equalsIgnoreCase("+")) { // unbounded range = Range.from(Boundary.excluding(smin.substring(1)), Boundary.unbounded()); } else { if (smax.substring(0, 1).equals("(")) { // excluding range = Range.from(Boundary.excluding(smin.substring(1)), Boundary.excluding(smax.substring(1))); } else if (smax.substring(0, 1).equals("[")) { // including range = Range.from(Boundary.excluding(smin.substring(1)), Boundary.including(smax.substring(1))); } else { return range; } } } else { // including if (smax.equalsIgnoreCase("+")) { // unbounded range = Range.from(Boundary.including(smin.substring(1)), Boundary.unbounded()); } else { if (smax.substring(0, 1).equals("(")) { // excluding range = Range.from(Boundary.including(smin.substring(1)), Boundary.excluding(smax.substring(1))); } else if (smax.substring(0, 1).equals("[")) { // including range = Range.from(Boundary.including(smin.substring(1)), Boundary.including(smax.substring(1))); } else { return range; } } } } return range; } }

Lettuce-4.4.2, Redis-4.0.6 Example

Class 변수로 선언

String key = "myzset";
long idx = 1;

ZADD

// ZADD key [NX|XX] [CH] [INCR] score member [score member ...] -> return long or double
// add된 member 개수 리턴
protected void zadd() {
	try {
		Redis.syncCmd.del(key);
		long count = Redis.syncCmd.zadd(key, 60d, "경기");
		System.out.println("zadd "+key+" 60 경기 -> "+count);
		long count2 = Redis.syncCmd.zadd(key, 20d, "서울", 40d, "부산");
		System.out.println("zadd "+key+" 20 서울 40 부산 -> "+count2);
		ScoredValue<String> sv = new ScoredValue<String>(100d, "대전");
		long count3 = Redis.syncCmd.zadd(key, sv);
		System.out.println("zadd "+key+" 100 대전 -> "+count3+" (ScoredValue)");
		// NX, XX, CH 있음. INCR은 별도 명령으로 있음. 왜냐하면 return data type이 다르기 때문.
		// CH : score를 변경했을 경우 1을 리턴
		ZAddArgs args = new ZAddArgs().nx();
		long count4 = Redis.syncCmd.zadd(key, args, 80d, "전라");
		System.out.println("zadd "+key+" NX 80 전라 -> "+count4);
		// INCR : return double, 변경된 score
		double score = Redis.syncCmd.zaddincr(key, 20d, "대전");
		System.out.println("zadd "+key+" incr 30 대전 -> "+score);
	} catch (Exception e) {
		System.out.println(e);
	}
}

ZREM

// ZREM key member [member] -> return long
protected void zrem() {
	try {
		long count = Redis.syncCmd.zrem(key, "서울");
		System.out.println("zrem "+key+" 서울 -> "+count);
		long count2 = Redis.syncCmd.zrem(key, "경기", "부산");
		System.out.println("zrem "+key+" 경기 부산 -> "+count2);
		String list[] = new String[2];
		list[0] = "전라";
		list[1] = "대전";
		long count3 = Redis.syncCmd.zrem(key, list);
		System.out.println("zrem "+key+" 전라 대전 -> "+count3+" (Array)");
	} catch (Exception e) {
		System.out.println(e);
	}
}

ZRANGE

// ZRANGE key start stop [withscores] -> return List<String> or List<ScoredValue<String>> or long
protected void zrange() {
	try {
		List<String> list = Redis.syncCmd.zrange(key, 0, -1);
		System.out.println("zrange "+key+" 0 -1 -> "+list.toString());
		// WithScores
		List<ScoredValue<String>> list2 = Redis.syncCmd.zrangeWithScores(key, 0, -1);
		System.out.println("zrange "+key+" 0 -1 withscores");
		for (ScoredValue<String> sv: list2) {
			System.out.println(sv.score+" "+sv.value);
		}
		// ValueStreamingChannel
		long count = Redis.syncCmd.zrange(new ValueStreamingChannel<String>() {
			@Override
			public void onValue(String member) {
				System.out.println("zrange (ValueStreamingChannel) -> " +member);
			}
		}, key, 0, -1);
		System.out.println("zrange "+key+" 0 -1 -> return: "+count);
		// ScoredValueStreamingChannel
		long count2 = Redis.syncCmd.zrangeWithScores(new ScoredValueStreamingChannel<String>() {
			@Override
			public void onValue(ScoredValue<String> member) {
				System.out.println("zrange (ValueStreamingChannel) -> " +member.score+" "+member.value);
			}
		}, key, 0, -1);
		System.out.println("zrange "+key+" 0 -1 withscores -> return: "+count2);
	} catch (Exception e) {
		System.out.println(e);
	}
}

ZCARD

// ZCARD key -> return long
protected void zcard() {
	try {
		Long count = Redis.syncCmd.zcard(key);
		System.out.println("zcard "+key+" -> "+count);
	} catch (Exception e) {
		System.out.println(e);
	}
}

ZRANGEBYSCORE

// ZRANGEBYSCORE key min max [withscores] [limit offset count] -> return List<String> or List<ScoredValue<String>>
protected void zrangebyscore() {
	try {
		List<String> list = Redis.syncCmd.zrangebyscore(key, 0, 200);	// deprecated
		System.out.println("zrangebyscore "+key+" 0 200 -> "+list.toString()+" (deprecated)");
		List<String> list2 = Redis.syncCmd.zrangebyscore(key, "-inf", "+inf");	// deprecated
		System.out.println("zrangebyscore "+key+" -inf +inf -> "+list2.toString()+" (deprecated)");
		List<String> list3 = Redis.syncCmd.zrangebyscore(key, "(20", "(120");	// deprecated
		System.out.println("zrangebyscore "+key+" (20 (120 -> "+list3.toString()+" (deprecated)");
		// Range
		Range<Double> range = Range.create(0d, 200d);
		List<String> list4 = Redis.syncCmd.zrangebyscore(key, range);
		System.out.println("zrangebyscore "+key+" 0 200 -> "+list4.toString()+" (Range)");
		// Range -inf +inf -> INFINITY value
		Range<Double> range2 = Range.create(Double.NEGATIVE_INFINITY, Double.POSITIVE_INFINITY);
		List<String> list5 = Redis.syncCmd.zrangebyscore(key, range2);
		System.out.println("zrangebyscore "+key+" -inf +inf -> "+list5.toString()+" (Range INFINITY value)");
		// Range -inf +inf -> unbounded()
		Range<Double> rangeUnbound = Range.unbounded();
		List<String> list6 = Redis.syncCmd.zrangebyscore(key, rangeUnbound);
		System.out.println("zrangebyscore "+key+" Range.unbounded() -> "+list6.toString()+" (Range unbounded)");
		// Range excluding/including
		Range<Double> range4 = Range.from(Boundary.excluding(20d), Boundary.excluding(120d));
		List<String> list7 = Redis.syncCmd.zrangebyscore(key, range4);
		System.out.println("zrangebyscore "+key+" Range.excluding() -> "+list7.toString()+" (Range excluding/including)");
		// Limit
		Limit limit = Limit.create(1, 3);
		List<String> list8 = Redis.syncCmd.zrangebyscore(key, rangeUnbound, limit);
		System.out.println("zrangebyscore "+key+" Limit 1 3 -> "+list8.toString()+" (Range Limit)");
		// withscores
		List<ScoredValue<String>> list9 = Redis.syncCmd.zrangebyscoreWithScores(key, rangeUnbound);
		for (ScoredValue<String> sv: list9) {
			System.out.println("zrangebyscore "+key+" withscores -> "+sv.score+" "+sv.value);
		}			
		// ValueStreamingChannel
		long count = Redis.syncCmd.zrangebyscore(new ValueStreamingChannel<String>() {
			@Override
			public void onValue(String member) {
				System.out.println("zrange (ValueStreamingChannel) -> "+member);
			}
		}, key, rangeUnbound);
		System.out.println("zrange (ValueStreamingChannel) -> "+count+" (count)");
		// ScoredValueStreamingChannel
		long count2 = Redis.syncCmd.zrangebyscoreWithScores(new ScoredValueStreamingChannel<String>() {
			@Override
			public void onValue(ScoredValue<String> member) {
				System.out.println("zrange (ScoredValueStreamingChannel) -> " +member.score+" "+member.value);
			}
		}, key, rangeUnbound);
		System.out.println("zrange (ScoredValueStreamingChannel) -> "+count2+" (count)");
	} catch (Exception e) {
		System.out.println(e);
	}
}

ZRANGEBYLEX

// ZRANGEBYLEX key min max [limit offset count] -> return List<String>
protected void zrangebylex() {
	try {
		Redis.syncCmd.del(key);
		long count = Redis.syncCmd.zadd(key, 0d, "경기", 0d, "서울", 0d, "부산", 0d, "대전", 0d, "전라");
		System.out.println("zadd "+key+" -> "+count);
		// including
		Range<String> range = Range.from(Boundary.including("경기"), Boundary.including("전라"));
		List<String> list = Redis.syncCmd.zrangebylex(key, range);
		System.out.println("zrangebylex "+key+" [경기 [전라 -> "+list.toString());
		// excluding
		Range<String> range2 = Range.from(Boundary.excluding("경기"), Boundary.excluding("전라"));
		List<String> list2 = Redis.syncCmd.zrangebylex(key, range2);
		System.out.println("zrangebylex "+key+" (경기 (전라 -> "+list2.toString());
		// Limit offset count
		Limit limit = Limit.create(0, 1);
		List<String> list3 = Redis.syncCmd.zrangebylex(key, range2, limit);
		System.out.println("zrangebylex "+key+" (경기 (전라 limit 0 1 -> "+list3.toString());
		// No withscores
		// No ValueStreamingChannel
	} catch (Exception e) {
		System.out.println(e);
	}
}

ZREMRANGEBYRANK

// ZREMRANGEBYRANK key start stop -> return long
protected void zremrangebyrank() {
	try {
		// del
		Redis.syncCmd.del(key);
		// zadd
		long count = Redis.syncCmd.zadd(key, 20d, "서울", 40d, "부산", 60d, "경기", 80d, "전라", 100d, "대전");
		System.out.println("zadd "+key+" -> "+count);
		// zrange
		List<ScoredValue<String>> list = Redis.syncCmd.zrangeWithScores(key, 0, -1);
		System.out.println("zrange "+key+" 0 -1 withscores -> "+list.size());
		for (ScoredValue<String> sv: list) {
			System.out.println(sv.score+" "+sv.value);
		}
		// zremrangebyrank
		long count2 = Redis.syncCmd.zremrangebyrank(key, 1, 3);
		System.out.println("zremrangebyrank "+key+" 1 3 -> "+count2);
		// zrange
		List<ScoredValue<String>> list2 = Redis.syncCmd.zrangeWithScores(key, 0, -1);
		System.out.println("zrange "+key+" 0 -1 withscores -> "+list2.size());
		for (ScoredValue<String> sv: list2) {
			System.out.println(sv.score+" "+sv.value);
		}
	} catch (Exception e) {
		System.out.println(e);
	}
}

ZREMRANGEBYSCORE

// ZREMRANGEBYSCORE key min max -> return long
protected void zremrangebyscore() {
	try {
		// del
		Redis.syncCmd.del(key);
		// zadd
		long count = Redis.syncCmd.zadd(key, 20d, "서울", 40d, "부산", 60d, "경기", 80d, "전라", 100d, "대전");
		System.out.println("zadd "+key+" -> "+count);
		// zrange : before
		List<ScoredValue<String>> list = Redis.syncCmd.zrangeWithScores(key, 0, -1);
		System.out.println("zrange "+key+" 0 -1 withscores -> "+list.size());
		for (ScoredValue<String> sv: list) {
			System.out.println(sv.score+" "+sv.value);
		}
		// zremrangebyscore
		Range<Double> range = Range.from(Boundary.including(40d), Boundary.including(80d));
		Long count2 = Redis.syncCmd.zremrangebyscore(key, range);
		System.out.println("zremrangebyscore "+key+" 40 80 -> "+count2+" (including)");
		// zrange : after
		List<ScoredValue<String>> list2 = Redis.syncCmd.zrangeWithScores(key, 0, -1);
		System.out.println("zrange "+key+" 0 -1 withscores -> "+list2.size());
		for (ScoredValue<String> sv: list2) {
			System.out.println(sv.score+" "+sv.value);
		}
	} catch (Exception e) {
		System.out.println(e);
	}
}

ZREMRANGEBYLEX

// ZREMRANGEBYLEX key min max -> return long
protected void zremrangebylex() {
	try {
		// del
		Redis.syncCmd.del(key);
		// zadd
		long count = Redis.syncCmd.zadd(key, 0d, "서울", 0d, "부산", 0d, "경기", 0d, "전라", 0d, "대전");
		System.out.println("zadd "+key+" -> "+count);
		// zrange : before
		List<ScoredValue<String>> list = Redis.syncCmd.zrangeWithScores(key, 0, -1);
		System.out.println("zrange "+key+" 0 -1 withscores -> "+list.size());
		for (ScoredValue<String> sv: list) {
			System.out.println(sv.score+" "+sv.value);
		}
		// zremrangebylex
		Range<String> range = Range.from(Boundary.including("대전"), Boundary.including("서울"));
		Long count2 = Redis.syncCmd.zremrangebylex(key, range);
		System.out.println("zremrangebylex "+key+" 대전 서울 -> "+count2+" (including)");
		// zrange : after
		List<ScoredValue<String>> list2 = Redis.syncCmd.zrangeWithScores(key, 0, -1);
		System.out.println("zrange "+key+" 0 -1 withscores -> "+list2.size());
		for (ScoredValue<String> sv: list2) {
			System.out.println(sv.score+" "+sv.value);
		}
	} catch (Exception e) {
		System.out.println(e);
	}
}

ZREVRANGE

// ZREVRANGE key start stop [withscores] -> return List<String> or List<ScoredValue<String>>
protected void zrevrange() {
	try {
		// del
		Redis.syncCmd.del(key);
		// zadd
		long count = Redis.syncCmd.zadd(key, 20d, "서울", 40d, "부산", 60d, "경기", 80d, "전라", 100d, "대전");
		System.out.println("zadd "+key+" -> "+count);
		// zrevrange
		List<ScoredValue<String>> list = Redis.syncCmd.zrevrangeWithScores(key, 0, -1);
		System.out.println("zrevrange "+key+" 0 -1 withscores -> "+list.size());
		for (ScoredValue<String> sv: list) {
			System.out.println(sv.score+" "+sv.value);
		}
		// ScoredValueStreamingChannel
		long count2 = Redis.syncCmd.zrevrangeWithScores(new ScoredValueStreamingChannel<String>() {
			@Override
			public void onValue(ScoredValue<String> member) {
				System.out.println("zrevrange (ValueStreamingChannel) -> " +member.score+" "+member.value);
			}
		}, key, 0, -1);
		System.out.println("zrevrange "+key+" 0 -1 withscores -> return: "+count2);
	} catch (Exception e) {
		System.out.println(e);
	}
}

ZREVRANGEBYSCORE

// ZREVRANGEBYSCORE key max min [withscores] [limit offset count] -> return List<String> or List<ScoredValue<String>>
protected void zrevrangebyscore() {
	try {
		// del
		Redis.syncCmd.del(key);
		// zadd
		long count = Redis.syncCmd.zadd(key, 20d, "서울", 40d, "부산", 60d, "경기", 80d, "전라", 100d, "대전");
		System.out.println("zadd "+key+" -> "+count);
		// range: min max 순서로 지정해야 함.
		Range<Double> range = Range.from(Boundary.including(40d), Boundary.including(80d));
		// zrevrangebyscore
		List<ScoredValue<String>> list = Redis.syncCmd.zrevrangebyscoreWithScores(key, range);
		System.out.println("zrevrangebyscore "+key+" 80 40 withscores -> "+list.size());
		for (ScoredValue<String> sv: list) {
			System.out.println(sv.score+" "+sv.value);
		}
		// Limit offset count
		Limit limit = Limit.create(1, 2);
		List<ScoredValue<String>> list2 = Redis.syncCmd.zrevrangebyscoreWithScores(key, range, limit);
		System.out.println("zrevrangebyscore "+key+" 80 40 limit 1 2 withscores -> "+list2.size());
		for (ScoredValue<String> sv: list2) {
			System.out.println(sv.score+" "+sv.value);
		}
		// ScoredValueStreamingChannel
		long count2 = Redis.syncCmd.zrevrangebyscoreWithScores(new ScoredValueStreamingChannel<String>() {
			@Override
			public void onValue(ScoredValue<String> member) {
				System.out.println("zrevrangebyscore (ValueStreamingChannel) -> " +member.score+" "+member.value);
			}
		}, key, range);
		System.out.println("zrevrangebyscore "+key+" 80 40 withscores -> return: "+count2);
		
	} catch (Exception e) {
		System.out.println(e);
	}
}

ZREVRANGEBYLEX

// ZREVRANGEBYLEX key max min [limit offset count] -> return List<String> or List<ScoredValue<String>>
protected void zrevrangebylex() {
	try {
		// del
		Redis.syncCmd.del(key);
		// zadd
		long count = Redis.syncCmd.zadd(key, 0d, "경기", 0d, "대전", 0d, "부산", 0d, "서울", 0d, "전라");
		System.out.println("zadd "+key+" -> "+count);
		Range<String> range = Range.unbounded();
		List<String> list = Redis.syncCmd.zrevrangebylex(key, range);
		System.out.println("zrevrangebylex "+key+" + - -> "+list.size());
		for (String v: list) {
			System.out.println(v);
		}
		// range: min max 순서로 지정해야 함. 원래 순서와 다름.  [ 포함 including, ( 미포함 excluding
		Range<String> range2 = Range.from(Boundary.including("대전"), Boundary.including("서울"));
		// zrevrangebylex
		List<String> list2 = Redis.syncCmd.zrevrangebylex(key, range2);
		System.out.println("zrevrangebylex "+key+" [서울 [대전 -> "+list2.size());
		for (String v: list2) {
			System.out.println(v);
		}
		// Limit offset count
		Limit limit = Limit.create(1, 2);
		List<String> list3 = Redis.syncCmd.zrevrangebylex(key, range2, limit);
		System.out.println("zrevrangebylex "+key+" [서울 [대전 limit 1 2 -> "+list3.size());
		for (String v: list3) {
			System.out.println(v);
		}
		// No withscores
		// No ValueStreamingChannel
	} catch (Exception e) {
		System.out.println(e);
	}
}

ZRANK

// ZRANK key member -> return long
protected void zrank() {
	try {
		Long index = Redis.syncCmd.zrank(key, "대전");
		System.out.println("ZRANK "+key+" 대전 -> "+index);
		Long index2 = Redis.syncCmd.zrank(key, "서울");
		System.out.println("ZRANK "+key+" 서울 -> "+index2);
	} catch (Exception e) {
		System.out.println(e);
	}
}

ZREVRANK

// ZREVRANK key member -> return long
protected void zrevrank() {
	try {
		Long index = Redis.syncCmd.zrevrank(key, "대전");
		System.out.println("ZREVRANK "+key+" 대전 -> "+index);
		Long index2 = Redis.syncCmd.zrevrank(key, "서울");
		System.out.println("ZREVRANK "+key+" 서울 -> "+index2);
	} catch (Exception e) {
		System.out.println(e);
	}
}

ZSCORE

// ZSCORE key member -> return double
protected void zscore() {
	try {
		Double score = Redis.syncCmd.zscore(key, "대전");
		System.out.println("ZSCORE "+key+" 대전 -> "+score);
		Double score2 = Redis.syncCmd.zscore(key, "서울");
		System.out.println("ZSCORE "+key+" 서울 -> "+score2);
	} catch (Exception e) {
		System.out.println(e);
	}
}

ZINCRBY

// ZINCRBY key increment member -> return double
protected void zincrby() {
	long time = System.currentTimeMillis(); 
	String key = "daily_views";
	String mem = new SimpleDateFormat("yyyyMMdd").format(time);		
	try {
		Double score = Redis.syncCmd.zincrby(key, 1, mem);
		System.out.println("ZINCRBY "+key+" 1 "+mem+" -> "+score);
		Double score2 = Redis.syncCmd.zincrby(key, 1, mem);
		System.out.println("ZINCRBY "+key+" 1 "+mem+" -> "+score2);
	} catch (Exception e) {
		System.out.println(e);
	}
}

ZUNIONSTORE

// ZUNIONSTORE dest_key numkeys src_key [src_key ...] [WEIGHTS weight [weight ...]] [AGGREGATE SUM|MIN|MAX] -> return long
protected void zunionstore() {
	String srcKey1 = "myzset1";
	String srcKey2 = "myzset2";
	String destKey = "dest_key";
	try {
		Redis.syncCmd.del(destKey, srcKey1, srcKey2);
		Redis.syncCmd.zadd(srcKey1, 1d, "A", 2d, "B", 3d, "C");
		Redis.syncCmd.zadd(srcKey2, 4d, "B", 5d, "C", 6d, "D");
		List<ScoredValue<String>> list1 = Redis.syncCmd.zrangeWithScores(srcKey1, 0, -1);
		System.out.println("zrange "+srcKey1+" 0 -1 -> "+list1.toString());
		List<ScoredValue<String>> list2 = Redis.syncCmd.zrangeWithScores(srcKey2, 0, -1);
		System.out.println("zrange "+srcKey2+" 0 -1 -> "+list2.toString());
		// zunionstore: numkeys는 넣지 않음.
		Long count = Redis.syncCmd.zunionstore(destKey, srcKey1, srcKey2);
		System.out.println("ZUNIONSTORE "+destKey+" "+srcKey1+" "+srcKey2+" -> "+count);
		List<ScoredValue<String>> list3 = Redis.syncCmd.zrangeWithScores(destKey, 0, -1);
		System.out.println("zrange "+destKey+" 0 -1 -> "+list3.toString());
		// Aggregate sum/min/max (defatul: sum)
		ZStoreArgs args = new ZStoreArgs().max();
		Long count2 = Redis.syncCmd.zunionstore(destKey, args, srcKey1, srcKey2);
		System.out.println("ZUNIONSTORE "+destKey+" "+srcKey1+" "+srcKey2+" aggregate max -> "+count2);
		List<ScoredValue<String>> list4 = Redis.syncCmd.zrangeWithScores(destKey, 0, -1);
		System.out.println("zrange "+destKey+" 0 -1 -> "+list4.toString());
		// weights
		args.weights(2d, 3d).sum();
		Long count3 = Redis.syncCmd.zunionstore(destKey, args, srcKey1, srcKey2);
		System.out.println("ZUNIONSTORE "+destKey+" "+srcKey1+" "+srcKey2+" weights 2 3 -> "+count3);
		List<ScoredValue<String>> list5 = Redis.syncCmd.zrangeWithScores(destKey, 0, -1);
		System.out.println("zrange "+destKey+" 0 -1 -> "+list5.toString());
	} catch (Exception e) {
		System.out.println(e);
	}
}

ZINTERSTORE

// ZINTERSTORE dest_key numkeys src_key [src_key ...] [WEIGHTS weight [weight ...]] [AGGREGATE SUM|MIN|MAX] -> return long
protected void zinterstore() {
	String srcKey1 = "myzset1";
	String srcKey2 = "myzset2";
	String destKey = "dest_key";
	try {
		Redis.syncCmd.del(destKey, srcKey1, srcKey2);
		Redis.syncCmd.zadd(srcKey1, 1d, "A", 2d, "B", 3d, "C");
		Redis.syncCmd.zadd(srcKey2, 4d, "B", 5d, "C", 6d, "D");
		List<ScoredValue<String>> list1 = Redis.syncCmd.zrangeWithScores(srcKey1, 0, -1);
		System.out.println("zrange "+srcKey1+" 0 -1 -> "+list1.toString());
		List<ScoredValue<String>> list2 = Redis.syncCmd.zrangeWithScores(srcKey2, 0, -1);
		System.out.println("zrange "+srcKey2+" 0 -1 -> "+list2.toString());
		// zunionstore: numkeys는 넣지 않음.
		Long count = Redis.syncCmd.zinterstore(destKey, srcKey1, srcKey2);
		System.out.println("ZINTERSTORE "+destKey+" "+srcKey1+" "+srcKey2+" -> "+count);
		List<ScoredValue<String>> list3 = Redis.syncCmd.zrangeWithScores(destKey, 0, -1);
		System.out.println("zrange "+destKey+" 0 -1 -> "+list3.toString());
		// Aggregate sum/min/max (defatul: sum)
		ZStoreArgs args = new ZStoreArgs().max();
		Long count2 = Redis.syncCmd.zinterstore(destKey, args, srcKey1, srcKey2);
		System.out.println("ZINTERSTORE "+destKey+" "+srcKey1+" "+srcKey2+" aggregate max -> "+count2);
		List<ScoredValue<String>> list4 = Redis.syncCmd.zrangeWithScores(destKey, 0, -1);
		System.out.println("zrange "+destKey+" 0 -1 -> "+list4.toString());
		// weights
		args.weights(2d, 3d).sum();
		Long count3 = Redis.syncCmd.zinterstore(destKey, args, srcKey1, srcKey2);
		System.out.println("ZINTERSTORE "+destKey+" "+srcKey1+" "+srcKey2+" weights 2 3 -> "+count3);
		List<ScoredValue<String>> list5 = Redis.syncCmd.zrangeWithScores(destKey, 0, -1);
		System.out.println("zrange "+destKey+" 0 -1 -> "+list5.toString());
	} catch (Exception e) {
		System.out.println(e);
	}
}

ZSCAN

// ZSCAN key cursor [MATCH pattern] [COUNT count] -> return ScoredValueScanCursor<String>
// zscan은 항상 withscores이다.
protected void zscan() {
	String p = "_XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX";
	try {
		Redis.syncCmd.del(key);
		for (int i=65; i<91; i++) {
			Redis.syncCmd.zadd(key, (double) i, (Character.toString((char) i)+p));
		}
		// limit
		ScanArgs args = new ScanArgs().limit(5);
		ScoredValueScanCursor<String> zset = Redis.syncCmd.zscan(key, args);
		System.out.println("zscan "+key+" limit 5-> "+zset.getValues().size()+" (size)");
		for (ScoredValue<String> sv: zset.getValues()) {
			System.out.println(sv.score+" -> "+sv.value);				
		}
		System.out.println("nextCursor -> "+zset.getCursor());

		System.out.println("-------------------------------------------------------------------------");
		System.out.println("do-while loop");
		ScoredValueScanCursor<String> zset3 = new ScoredValueScanCursor<String>();
		zset3.setCursor("0");
		do {
			zset3 = Redis.syncCmd.zscan(key, zset3);
			System.out.println("zscan "+key+" -> size: "+zset3.getValues().size());
			for (ScoredValue<String> sv: zset3.getValues()) {
				System.out.println(sv.score+" "+sv.value);
			}
			System.out.println("nextCursor -> "+zset3.getCursor()+", Finish: "+zset3.isFinished());

		} while (zset3.isFinished() == false);

		System.out.println("-------------------------------------------------------------------------");
		System.out.println("match F*");
		// match
		args.match("F*");
		ScoredValueScanCursor<String> zset2 = Redis.syncCmd.zscan(key, args);
		System.out.println("zscan "+key+" match F* -> "+zset2.getValues().size()+" (size)");
		for (ScoredValue<String> sv: zset2.getValues()) {
			System.out.println(sv.score+" -> "+sv.value);				
		}

		System.out.println("-------------------------------------------------------------------------");
		System.out.println("ScoredValueStreamingChannel, do-while loop");
		ScanCursor cursor = new ScanCursor();
		cursor.setCursor("0");
		StreamScanCursor stream = null;
		// match
		args.match("F*");
		do {
			stream = Redis.syncCmd.zscan(new ScoredValueStreamingChannel<String>() {
				@Override
				public void onValue(ScoredValue<String> member) {
					System.out.println("zscan (ScoredValueStreamingChannel) -> " +member.score+" "+member.value);
				}
			}, key, cursor, args);
			System.out.println("nextCursor -> "+ stream.getCursor());
			cursor.setCursor(stream.getCursor());
		} while (stream.isFinished() == false);
	} catch (Exception e) {
		System.out.println(e);
	}
}

<< Sets	ZSets	Hashes >>

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