Clients

Lettuce Lists

Redis Developer Course	Redis Technical Support	Redis Enterprise Server

Lists

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

LettuceListCmd.java
import java.util.List; import java.util.Scanner; public class LettuceListCmd { Scanner scanner = new Scanner(System.in); Util util = new Util(); public LettuceListCmd() { while(true) { System.out.println("1:LPUSH 2:LPOP 3:LRANGE 4:LLEN 5:LREM\n"); System.out.println("선택(exit:99)> "); String input = scanner.nextLine(); int i = util.checkInt(input); switch (i) { case 1: lpush(); break; case 2: lpop(); break; case 3: lrange(); break; case 4: llen(); break; case 5: lrem(); break; case 99: break; default: System.out.println("잘못 선택했습니다. 다시 선택하세요. "); } if (i==99) break; } } // LPUSH key value1 [value2 ...] // 이 명령은 version 1.0.0 부터 사용할 수 있다. public void lpush() { System.out.println("LPUSH key value1 [value2 ...]"); String input = scanner.nextLine(); String[] cmd = util.split(input); if (cmd[0].equalsIgnoreCase("LPUSH") == false) return; String cmd2[] = util.split(input.substring(cmd[0].length()+cmd[2].length()+2)); try { Long ret = Main.syncCmd.lpush(cmd[1], cmd2); System.out.println("LPUSH -> "+ret); } catch (Exception e) { System.out.println(e.getMessage()); return; } } // LPOP key [count] // 이 명령은 version 1.0.0 부터 사용할 수 있다. // COUNT 옵션은 버전 6.2에서 추가되었습니다. public void lpop() { System.out.println("LPOP key [count]"); String input = scanner.nextLine(); String[] cmd = util.split(input); if (cmd[0].equalsIgnoreCase("LPOP") == false) return; try { if (cmd.length == 2) { String ret = Main.syncCmd.lpop(cmd[1]); System.out.println("LPOP -> "+ret); } else { long count = util.checkLong(cmd[2]); List<String> ret = Main.syncCmd.lpop(cmd[1], count); System.out.println("LPOP -> "+ret.toString()); } } catch (Exception e) { System.out.println(e.getMessage()); return; } } // LRANGE key start stop // 이 명령은 version 1.0.0 부터 사용할 수 있다. public void lrange() { System.out.println("LRANGE key start stop"); String input = scanner.nextLine(); String[] cmd = util.split(input); if (cmd[0].equalsIgnoreCase("LRANGE") == false) return; if (cmd.length != 4) return; long start = util.checkLong(cmd[2]); long stop = util.checkLong(cmd[3]); try { List<String> ret = Main.syncCmd.lrange(cmd[1], start, stop); System.out.println("LRANGE -> "+ret); } catch (Exception e) { System.out.println(e.getMessage()); return; } } // LLEN key // 이 명령은 version 1.1.0 부터 사용할 수 있다. public void llen() { System.out.println("LLEN key"); String input = scanner.nextLine(); String[] cmd = util.split(input); if (cmd[0].equalsIgnoreCase("LLEN") == false) return; if (cmd.length != 2) return; try { Long ret = Main.syncCmd.llen(cmd[1]); System.out.println("LLEN -> "+ret); } catch (Exception e) { System.out.println(e.getMessage()); return; } } // LREM key count value // count // 양수: 왼쪽부터 삭제 // 음수: 오른쪽부터 삭제 // 0: 모두 삭제 public void lrem() { System.out.println("LREM key count value"); String input = scanner.nextLine(); String[] cmd = util.split(input); if (cmd[0].equalsIgnoreCase("LREM") == false) return; if (cmd.length != 4) return; long count = util.checkLong(cmd[2]); try { Long ret = Main.syncCmd.lrem(cmd[1], count, cmd[3]); System.out.println("LREM -> "+ret); } catch (Exception e) { System.out.println(e.getMessage()); return; } } }

Lettuce-4.4.2, Redis-4.0.6 Example

Class 변수로 선언

String key = "mylist";
long idx = 1;
long idxLindex = 0;
long idxLset = 0;
boolean linsertBoolean = true;

LPUSH

// LPUSH key value [value ...] -> return Long
protected void lpush() {
	try {
		long retLong = Redis.syncCmd.lpush(key, "value"+idx);
		System.out.println("lpush "+key+" value"+idx+" -> " +retLong);
		long retLong2 = Redis.syncCmd.lpush(key, "value1", "value2", "value3");
		System.out.println("lpush -> " +retLong2);
		// "", null 도 모두 저장된다.
		long retLong3 = Redis.syncCmd.lpush(key, "value1", "value2", "value3", "", "", null, null);
		System.out.println("lpush -> " +retLong3);
		String list[] = new String[10];
		list[0] = "A"; list[5] = "B";  
		long retLong4 = Redis.syncCmd.lpush(key, list);
		System.out.println("lpush "+key+" -> " +retLong4);
		idx++;
	} catch (Exception e) {
		System.out.println(e);
	}
}

RPOP

// RPOP key -> return String
protected void rpop() {
	try {
		String retString = Redis.syncCmd.rpop(key);
		System.out.println("rpop "+key+" -> " +retString);
	} catch (Exception e) {
		System.out.println(e);
	}
}

LPOP

// LPOP key -> return String
protected void lpop() {
	try {
		String retString = Redis.syncCmd.lpop(key);
		System.out.println("lpop "+key+" -> " +retString);
	} catch (Exception e) {
		System.out.println(e);
	}
}

RPUSH

// RPUSH key value [value ...] -> return Long
protected void rpush() {
	try {
		long retLong = Redis.syncCmd.rpush(key, "value"+idx);
		System.out.println("rpush "+key+" value"+idx+" -> " +retLong);
		long retLong2 = Redis.syncCmd.rpush("key", "value1", "value2", "value3");
		System.out.println("rpush -> " +retLong2);
		idx++;
	} catch (Exception e) {
		System.out.println(e);
	}
}

LRANGE

// LRANGE key start stop -> return List<String>
protected void lrange() {
	try {
		List<String> list = Redis.syncCmd.lrange(key, 0, -1);
		System.out.println("lrange key 0 -1");
		int no = 1;
		for (String v: list) {
			System.out.println(no+") "+v);
			no++;
		}
	} catch (Exception e) {
		System.out.println(e);
	}
}

LLEN

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

LINDEX

// LINDEX key index -> return String
protected void lindex() {
	try {
		String retString = Redis.syncCmd.lindex(key, idxLindex);
		System.out.println("lindex "+key+" "+idxLindex+" -> "+retString);
		idxLindex++;
	} catch (Exception e) {
		System.out.println(e);
	}
}

LSET

// LSET key index value -> return String
protected void lset() {
	try {
		String retString = Redis.syncCmd.lset(key, idxLset, "value_LSET"+idxLset);
		System.out.println("lset "+key+" value_LSET"+idxLset+" -> "+retString);
		idxLset++;
	} catch (Exception e) {
		System.out.println(e);
	}
}

LINSERT

BEFORE(X), AFTER(Y)가 교대로 적용된다.

// LINSERT key BEFORE|AFTER pivot value -> return Long
protected void linsert() {
	try {
		// true: BEFORE, false: AFTER
		long retLong = Redis.syncCmd.linsert(key, linsertBoolean, "value2", "value"+((linsertBoolean) ? "X" : "Y"));
		System.out.println("linsert "+key+" "+((linsertBoolean) ? "BEFORE" : "AFTER")+" value2 value"+((linsertBoolean) ? "X" : "Y")+" -> "+retLong);
	} catch (Exception e) {
		System.out.println(e);
	}
	if (linsertBoolean)  linsertBoolean = false; else linsertBoolean = true;
}

LREM

// LREM key count value -> return Long
protected void lrem() {
	try {
		long retLong = Redis.syncCmd.lrem(key, 0, "valueX");
		System.out.println("lrem "+key+" 0 valueX -> "+retLong);
	} catch (Exception e) {
		System.out.println(e);
	}
}

LTRIM

// LTRIM key start stop -> return String
protected void ltrim() {
	try {
		String retString = Redis.syncCmd.ltrim(key, 1, 3);
		System.out.println("ltrim "+key+" 1 3 -> "+retString);
	} catch (Exception e) {
		System.out.println(e);
	}
}

RPOPLPUSH

// RPOPLPUSH source_key destination_key -> return String
protected void rpoplpush() {
	try {
		String retString = Redis.syncCmd.rpoplpush(key, "destkey");
		System.out.println("rpoplpush "+key+" destkey -> "+retString);
		List<String> list = Redis.syncCmd.lrange("destkey", 0, -1);
		System.out.println("lrange destkey 0 -1");
		int no = 1;
		for (String v: list) {
			System.out.println(no+") "+v);
			no++;
		}
	} catch (Exception e) {
		System.out.println(e);
	}
}

LPUSHX

// LPUSHX key value -> return Long
protected void lpushx() {
	String list[] = new String[1];
	list[0] = "value"+idx;
	try {
		long retLong = Redis.syncCmd.lpushx(key, list);
		// Redis.syncCmd.lpushx("key", "value1", "value2", "value3");
		System.out.println("lpushx "+key+" "+list[0]+" -> " +retLong);
		idx++;
	} catch (Exception e) {
		System.out.println(e);
	}
}

RPUSHX

// RPUSHX key value -> return Long
protected void rpushx() {
	String list[] = new String[1];
	list[0] = "value"+idx;
	try {
		long retLong = Redis.syncCmd.rpushx(key, list);
		// Redis.syncCommands.rpushx("key", "value1", "value2", "value3");
		System.out.println("rpushx "+key+" "+list[0]+" -> " +retLong);
		idx++;
	} catch (Exception e) {
		System.out.println(e);
	}
}

BLPOP

// Async command: blpop, brpop, brpoplpush는 async mode를 사용해야 한다. 
// sync mode를 사용하면 timeout이 지나면 에러가 발생한다.
// 대기동안 blocking이 발생한다. 화면에서 다른 동작을 할 수 없다.
// BLPOP key [key ...] timeout -> return RedisFuture<KeyValue<String, String>>
protected void blpop () {
	try {
		RedisFuture<KeyValue<String, String>> ret = Redis.asyncCmd.blpop(0, key);
		// Redis.asyncCmd.blpop(0, "key1", "key2");
		// String list[] = new String[10];
		// Redis.asyncCmd.blpop(0, list);
		System.out.println("blpop "+key+" -> "+ret.get().value);
	} catch (Exception e) {
		System.out.println(e);
	}
}

BLPOP

// BLPOP key [key ...] timeout -> return RedisFuture<KeyValue<String, String>>
protected void brpop () {
	try {
		RedisFuture<KeyValue<String, String>> ret = Redis.asyncCmd.brpop(0, key);
		System.out.println("brpop "+key+" -> "+ret.get().value);
	} catch (Exception e) {
		System.out.println(e);
	}
}

BRPOPLPUSH

// BRPOPLPUSH source destination timeout -> return RedisFuture<String>
protected void brpoplpush  () {
	try {
		RedisFuture<String> ret = Redis.asyncCmd.brpoplpush(0, key, "destkey");
		System.out.println("brpoplpush "+key+" -> "+ret.get().toString());
	} catch (Exception e) {
		System.out.println(e);
	}
}

<< Strings	Lists	Sets >>

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