Clients

Lettuce Strings

Redis Developer Course	Redis Technical Support	Redis Enterprise Server

Strings

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

LettuceStringCmd.java
import java.util.HashMap; import java.util.List; import java.util.Scanner; import io.lettuce.core.KeyValue; import io.lettuce.core.SetArgs; public class LettuceStringCmd { Scanner scanner = new Scanner(System.in); Util util = new Util(); public LettuceStringCmd() { while(true) { System.out.println("1:SET 2:GET 3:INCR 4:DECR 5:MSET 6:MGET\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: incr(); break; case 4: decr(); break; case 5: mset(); break; case 6: mget(); break; case 99: break; default: System.out.println("잘못 선택했습니다. 다시 선택하세요. "); } if (i==99) break; } } // SET key value [NX|XX] [EX 초] [PX 밀리초] [EXAT timestamp] [PXAT milliseconds-timestamp] [KEEPTTL] [GET] // version 1.0.0 부터 사용할 수 있습니다. // NX, XX, EX, PX 옵션은 버전 2.6.12에서 추가되었습니다. // KEEPTTL 옵션은 버전 6.0에서 추가되었습니다. // EXAT, PXAT, GET 옵션은 버전 6.2에서 추가되었습니다. public void set() { // NX: 키가 없을 경우에만 저장 -> insert only // XX: 키가 이미 있을 경우에만 저장 -> update only // EX: 지정한 seconds 이후에 키가 지워짐. // PX: 지정한 milliseconds 이후에 키가 지워짐. // KEEPTTL: TTL을 유지함. System.out.println("SET key value [NX|XX] [EX 초] [PX 밀리초] [EXAT timestamp] [PXAT milliseconds-timestamp] [KEEPTTL] [GET]"); String input = scanner.nextLine(); String[] cmd = util.split(input); if (cmd[0].equalsIgnoreCase("SET") == false) return; SetArgs args = new SetArgs(); if (cmd.length > 3) { if (cmd[3].equalsIgnoreCase("NX")) { args.nx(); } else if (cmd[3].equalsIgnoreCase("XX")) { args.xx(); } else if (cmd[3].equalsIgnoreCase("EX")) { if (cmd.length > 4) { long ex = util.checkLong(cmd[4]); args.ex(ex); } } else if (cmd[3].equalsIgnoreCase("PX")) { if (cmd.length > 4) { long px = util.checkLong(cmd[4]); args.px(px); } } } try { String ret = Main.syncCmd.set(cmd[1], cmd[2], args); System.out.println(ret); } catch (Exception e) { System.out.println(e.getMessage()); return; } } public void set(String key, String value) { try { String ret = Main.syncCmd.set(key, value); System.out.println(ret); } catch (Exception e) { System.out.println(e.getMessage()); return; } } public void setArgs(String key, String value, long ex) { SetArgs args = new SetArgs(); args.ex(ex); try { String ret = Main.syncCmd.set(key, value, args); System.out.println(ret); } catch (Exception e) { System.out.println(e.getMessage()); return; } } // GET key // 이 명령은 version 1.0.0 부터 사용할 수 있다. 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 { String ret = Main.syncCmd.get(cmd[1]); System.out.println("GET -> "+ret); } catch (Exception e) { System.out.println(e.getMessage()); return; } } public void get(String key) { try { String ret = Main.syncCmd.get(key); System.out.println(ret); } catch (Exception e) { System.out.println(e.getMessage()); return; } } // INCR key // 이 명령은 version 1.0.0 부터 사용할 수 있다. public void incr() { System.out.println("INCR key"); String input = scanner.nextLine(); String[] cmd = util.split(input); if (cmd[0].equalsIgnoreCase("INCR") == false) return; if (cmd.length != 2) return; try { Long ret = Main.syncCmd.incr(cmd[1]); System.out.println("INCR -> "+ret); } catch (Exception e) { System.out.println(e.getMessage()); return; } } // DECR key // 이 명령은 version 1.0.0 부터 사용할 수 있다. public void decr() { System.out.println("DECR key"); String input = scanner.nextLine(); String[] cmd = util.split(input); if (cmd[0].equalsIgnoreCase("DECR") == false) return; if (cmd.length != 2) return; try { Long ret = Main.syncCmd.decr(cmd[1]); System.out.println("DECR -> "+ret); } catch (Exception e) { System.out.println(e.getMessage()); return; } } // MSET key1 value1 [key2 value2 ...] // 이 명령은 version 1.0.1 부터 사용할 수 있다. public void mset() { System.out.println("MSET key1 value1 [key2 value2 ...]"); String input = scanner.nextLine(); String[] cmd = util.split(input); if (cmd[0].equalsIgnoreCase("MSET") == false) return; if (cmd.length < 3 || cmd.length % 2 == 0) return; HashMap<String,String> msetMap = new HashMap<String,String>(); for (int i=1; i<cmd.length; i++) msetMap.put(cmd[i], cmd[++i]); try { String ret = Main.syncCmd.mset(msetMap); System.out.println("MSET -> "+ret); } catch (Exception e) { System.out.println(e.getMessage()); return; } } // MGET key1 [key2 ...] // 이 명령은 version 1.0.0 부터 사용할 수 있다. public void mget() { System.out.println("MGET key1 [key2 ...]"); String input = scanner.nextLine(); String[] cmd = util.split(input); if (cmd[0].equalsIgnoreCase("MGET") == false) return; if (cmd.length < 2) return; String cmd2[] = util.split(input.substring(cmd[0].length()+1)); try { List<KeyValue<String,String>> ret = Main.syncCmd.mget(cmd2); System.out.println("MGET -> "+ret.toString()); } catch (Exception e) { System.out.println(e.getMessage()); return; } } }

Lettuce-4.4.2, Redis-4.0.6 Example

Class 변수로 선언

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

SET

// SET key value [NX|XX] [EX seconds] [PX milliseconds] -> return String(OK)
protected void set() {
	try {
		String ret = Redis.syncCmd.set(key+idx, "value"+idx);
		System.out.println("set key"+idx+" value"+idx+" -> "+ret);
		idx++;
		// Options
		// NX: 키가 없을 경우에만 저장 -> insert only
		// XX: 키가 이미 있을 경우에만 저장 -> update only
		// EX: 지정한 seconds 이후에 키가 지워짐.
		// PX: 지정한 milliseconds 이후에 키가 지워짐.
		SetArgs args = new SetArgs();
		args.ex(10);
		String ret2 = Redis.syncCmd.set(key+idx, "value"+idx, args);
		System.out.println("set key"+idx+" value"+idx+" EX 10-> "+ret2);
		idx++;
	} catch (Exception e) {
		System.out.println(e);
	}
}

DEL

// DEL key [key ...] -> return Long
protected void del() {
	try {
		Long count = Redis.syncCmd.del(key+idx);
		System.out.println("del key"+idx+" -> "+count);
		idx++;
		// multi key
		Long count2 = Redis.syncCmd.del(key+(idx++), key+(idx++), key+(idx++));
		System.out.println("del -> "+count2+" (multi keys)");
		// Array of keys
		String keys[] = new String[3];
		keys[0] = key+(idx++);
		keys[1] = key+(idx++);
		keys[2] = key+(idx++);
		Long count3 = Redis.syncCmd.del(keys);
		System.out.println("del -> "+count3+" (Array)");
	} catch (Exception e) {
		System.out.println(e);
	}
}

GET

// GET key -> return String(value)
protected void get() {
	try {
		String ret = Redis.syncCmd.get(key+idx);
		System.out.println("get key"+idx+" -> "+ret);
	} catch (Exception e) {
		System.out.println(e);
	}
}

INCR

// INCR key -> return Long
// OBJECT refcount key: 0 ~ 9999, 미리 만들어 놓은 숫자 사용. 1) 메모리 절약, 2) 성능 향상
protected void incr() {
	try {
		Long ret = Redis.syncCmd.incr(key);
		System.out.println("incr key -> "+ret);
	} catch (Exception e) {
		System.out.println(e);
	}
}

DECR

// DECR key -> return Long
protected void decr() {
	try {
		Long ret = Redis.syncCmd.decr(key);
		System.out.println("decr key -> "+ret);
	} catch (Exception e) {
		System.out.println(e);
	}
}

INCRBY

// INCRBY key increment(long) -> return Long
protected void incrby() {
	long incr = random.nextInt(10);
	try {
		Long ret = Redis.syncCmd.incrby(key, incr);
		System.out.println("incrby key "+incr+" -> "+ret);
	} catch (Exception e) {
		System.out.println(e);
	}
}

DECRBY

// DECRBY key decrement(long) -> return Long
protected void decrby() {
	long decr = random.nextInt(10);
	try {
		Long ret = Redis.syncCmd.decrby(key, decr);
		System.out.println("decrby key "+decr+" -> "+ret);
	} catch (Exception e) {
		System.out.println(e);
	}
}

INCRBYFLOAT

// INCRBYFLOAT key increment -> return Double
protected void incrbyfloat() {
	double incr = random.nextDouble() * 10.0;
	try {
		Double ret = Redis.syncCmd.incrbyfloat(key, incr);
		System.out.println("incrbyfloat key "+incr+" -> "+ret);
	} catch (Exception e) {
		System.out.println(e);
	}
}

SETNX

// SETNX key value -> return Boolean
protected void setnx() {
	try {
		Redis.syncCmd.del(key);
		Boolean ret = Redis.syncCmd.setnx(key, "Hello");
		System.out.println("setnx key Hello -> "+ret);
		Boolean ret2 = Redis.syncCmd.setnx(key, "Redis");
		System.out.println("setnx key Redis -> "+ret2);
	} catch (Exception e) {
		System.out.println(e);
	}
}

SETEX

// SETEX key seconds value -> return String
protected void setex() {
	try {
		String ret = Redis.syncCmd.setex(key, 10, "Hello");
		System.out.println("setex key 10 Hello -> "+ret);
	} catch (Exception e) {
		System.out.println(e);
	}
}

PSETEX

// PSETEX key milliseconds value -> return String
protected void psetex() {
	try {
		String ret = Redis.syncCmd.psetex(key, 10000, "Hello");
		System.out.println("psetex key 10000 Hello -> "+ret);
	} catch (Exception e) {
		System.out.println(e);
	}
}

MSET

// MSET key value [key value ...] -> return String
protected void mset() {
	try {
		Map<String, String> map = new HashMap<String, String>();
		for (int i=0; i<10; i++) {
			map.put("key"+i, "value"+i);
		}
		String ret = Redis.syncCmd.mset(map);
		System.out.println("mset -> " +ret);
	} catch (Exception e) {
		System.out.println(e);
	}
}

MGET

// MGET key [key ...] -> return List<String>
protected void mget() {
	try {
		String keys[] = new String[10];
		for (int i=0; i<10; i++) {
			keys[i] = "key"+i;
		}
		List<String> list = Redis.syncCmd.mget(keys);
		System.out.println("mget -> " +list.toString());
	} catch (Exception e) {
		System.out.println(e);
	}
}

MSETNX

// MSETNX key value [key value ...] -> return Boolean
protected void msetnx() {
	// msetnx: 키가 하나라도 있으면 실패
	try {
		Map<String, String> map = new HashMap<String, String>();
		for (int i=10; i<20; i++) {
			map.put("key"+i, "value"+i);
		}
		Boolean ret = Redis.syncCmd.msetnx(map);
		System.out.println("msetnx -> " +ret);
	} catch (Exception e) {
		System.out.println(e);
	}
}

APPEND

// APPEND key value -> return Long
// 메모리 더 사용, debug sdslen key, memory usage key
protected void append() {
	try {
		Long len = Redis.syncCmd.append(key, "value");
		System.out.println("append -> " +len);
	} catch (Exception e) {
		System.out.println(e);
	}
}

STRLEN

// STRLEN key -> return Long
protected void strlen() {
	try {
		Long len = Redis.syncCmd.strlen(key);
		System.out.println("strlen key -> " +len);
	} catch (Exception e) {
		System.out.println(e);
	}
}

SETRANGE

// SETRANGE key offset value -> return Long
protected void setrange() {
	try {
		Long len = Redis.syncCmd.setrange(key, 10, "Redis");
		System.out.println("setrange key 10 Redis -> " +len);
	} catch (Exception e) {
		System.out.println(e);
	}
}

GETRANGE

// GETRANGE key start end -> return String
protected void getrange() {
	try {
		String value = Redis.syncCmd.getrange(key, 10, 14);
		System.out.println("getrange key 10 15 -> " +value);
	} catch (Exception e) {
		System.out.println(e);
	}
}

GETSET

// GETSET key value -> return String
protected void getset() {
	try {
		// getset 원자적 실행
		String value = Redis.syncCmd.getset(key, "0");
		System.out.println("getset key 0 -> " +value);
	} catch (Exception e) {
		System.out.println(e);
	}
}

SETBIT

// Bit operations
// SETBIT key offset value -> return Long
protected void setbit() {
	try {
		Redis.syncCmd.set(key, "A");
		Long ret = Redis.syncCmd.setbit(key, 6, 1);
		String value = Redis.syncCmd.get(key);
		System.out.println("setbit key 6 1 -> " +ret+", get key -> "+value);
	} catch (Exception e) {
		System.out.println(e);
	}
}

GETBIT

// GETBIT key offset -> return Long
protected void getbit() {
	try {
		Long ret1 = Redis.syncCmd.getbit(key, 6);
		Long ret2 = Redis.syncCmd.getbit(key, 7);
		System.out.println("getbit key 6 -> " +ret1+", getbit key 7 -> "+ret2);
	} catch (Exception e) {
		System.out.println(e);
	}
}

BITOP

// BITOP operation destkey key [key ...] -> return Long
protected void bitop() {
	try {
		Redis.syncCmd.set("key1", "A");
		Redis.syncCmd.set("key2", "B");
		// bitop AND
		Long ret1 = Redis.syncCmd.bitopAnd("destkey", "key1", "key2");
		String value1 = Redis.syncCmd.get("destkey");
		System.out.println("bitop AND destkey key1 key2 -> "+ret1+", destkey -> "+value1);
		// bitop OR
		Long ret2 = Redis.syncCmd.bitopOr("destkey", "key1", "key2");
		String value2 = Redis.syncCmd.get("destkey");
		System.out.println("bitop OR destkey key1 key2 -> "+ret2+", destkey -> "+value2);
		// bitop XOR
		Long ret3 = Redis.syncCmd.bitopXor("destkey", "key1", "key2");
		String value3 = Redis.syncCmd.get("destkey");
		System.out.println("bitop XOR destkey key1 key2 -> "+ret3+", destkey -> "+value3);
		// bitop NOT
		Long ret4 = Redis.syncCmd.bitopNot("destkey", "key1"); 
		String value4 = Redis.syncCmd.get("destkey");
		System.out.println("bitop NOT destkey key1 -> "+ret4+", destkey -> "+value4);
	} catch (Exception e) {
		System.out.println(e);
	}
}

BITCOUNT

// BITCOUNT key [start end] -> return Long
protected void bitcount() {
	try {
		Redis.syncCmd.set(key, "ABC");
		Long count1 = Redis.syncCmd.bitcount(key); 
		Long count2 = Redis.syncCmd.bitcount(key, 1, 2);
		System.out.println("bitcount key -> "+count1+", bitcount key 1 2 -> "+count2);
	} catch (Exception e) {
		System.out.println(e);
	}
}

BITPOS

// BITPOS key bit [start [end]] -> return Long
protected void bitpos() {
	try {
		Redis.syncCmd.set(key, "ABC");
		Long count1 = Redis.syncCmd.bitpos(key, false);
		Long count2 = Redis.syncCmd.bitpos(key, true);
		Long count3 = Redis.syncCmd.bitpos(key, true, 2);
		System.out.println("bitpos key 0 -> "+count1+", bitpos key 1 -> "+count2+", bitpos key 1 2 -> "+count3);
	} catch (Exception e) {
		System.out.println(e);
	}
}

<< Lettuce Introduction	Strings	Lists >>

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