Lettuce Lists

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

Lists

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