DATAREDIS-268 - Add support for 'CLIENT LIST'.

'RedisConnection' and 'RedisTemplate' have been extended by 'clientList' retrieving client informations from redis. 'RedisClientInfo' provides access via specified getters as well as an more general approach directly using the keys (like 'qubuf').

The operation is available for 'jedis', 'lettuce' and 'srp'.

Original Pull Request: #53

Author: christophstrobl

docs/src/reference/docbook/appendix/appendix-command-reference.xml

@@ -25,7 +25,7 @@
 				<row><entry><code>BRPOPLPUSH</code></entry><entry>X</entry></row>
 				<row><entry><code>CLIENT GETNAME</code></entry><entry>-</entry></row>
 				<row><entry><code>CLIENT KILL</code></entry><entry>-</entry></row>
-				<row><entry><code>CLIENT LIST</code></entry><entry>-</entry></row>
+				<row><entry><code>CLIENT LIST</code></entry><entry>X</entry></row>
 				<row><entry><code>CLIENT SETNAME</code></entry><entry>-</entry></row>
 				<row><entry><code>CONFIG GET</code></entry><entry>X</entry></row>
 				<row><entry><code>CONFIG RESETSTAT</code></entry><entry>X</entry></row>

src/main/java/org/springframework/data/redis/connection/DefaultStringRedisConnection.java

@@ -32,6 +32,7 @@
 import org.springframework.data.redis.connection.convert.ListConverter;
 import org.springframework.data.redis.connection.convert.MapConverter;
 import org.springframework.data.redis.connection.convert.SetConverter;
+import org.springframework.data.redis.core.types.RedisClientInfo;
 import org.springframework.data.redis.serializer.RedisSerializer;
 import org.springframework.data.redis.serializer.StringRedisSerializer;
 import org.springframework.util.Assert;
@@ -2191,6 +2192,11 @@ public Long time() {
 		return this.delegate.time();
 	}
 
+	@Override
+	public List<RedisClientInfo> clientList() {
+		return this.delegate.clientList();
+	}
+
 	/**
 	 * Specifies if pipelined and tx results should be deserialized to Strings. If false, results of
 	 * {@link #closePipeline()} and {@link #exec()} will be of the type returned by the underlying connection

src/main/java/org/springframework/data/redis/connection/RedisServerCommands.java

@@ -18,6 +18,8 @@
 import java.util.List;
 import java.util.Properties;
 
+import org.springframework.data.redis.core.types.RedisClientInfo;
+
 /**
  * Server-specific commands supported by Redis.
  * 
@@ -161,4 +163,13 @@ public enum ShutdownOption {
 	 * @since 1.1
 	 */
 	Long time();
+
+	/**
+	 * Request information and statistics about connected clients.
+	 * 
+	 * @return {@link List} of {@link RedisClientInfo} objects.
+	 * @since 1.3
+	 * @see http://redis.io/commands/client-list
+	 */
+	List<RedisClientInfo> clientList();
 }

src/main/java/org/springframework/data/redis/connection/StringRedisConnection.java

@@ -22,6 +22,7 @@
 
 import org.springframework.data.redis.core.RedisCallback;
 import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.data.redis.core.types.RedisClientInfo;
 import org.springframework.data.redis.serializer.RedisSerializer;
 
 /**
@@ -292,4 +293,10 @@ public interface StringTuple extends Tuple {
 	<T> T eval(String script, ReturnType returnType, int numKeys, String... keysAndArgs);
 
 	<T> T evalSha(String scriptSha1, ReturnType returnType, int numKeys, String... keysAndArgs);
+
+	/**
+	 * @see RedisConnection#clientList()
+	 * @since 1.3
+	 */
+	List<RedisClientInfo> clientList();
 }

src/main/java/org/springframework/data/redis/connection/convert/StringToRedisClientInfoConverter.java

@@ -0,0 +1,52 @@
+/*
+ * Copyright 2014 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.springframework.data.redis.connection.convert;
+
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
+
+import org.springframework.core.convert.converter.Converter;
+import org.springframework.data.redis.core.types.RedisClientInfo;
+import org.springframework.data.redis.core.types.RedisClientInfo.RedisClientInfoBuilder;
+
+/**
+ * {@link Converter} implementation to create one {@link RedisClientInfo} per line entry in given {@link String} array.
+ * 
+ * <pre>
+ * ## sample of single line
+ * addr=127.0.0.1:60311 fd=6 name= age=4059 idle=0 flags=N db=0 sub=0 psub=0 multi=-1 qbuf=0 qbuf-free=32768 obl=0 oll=0 omem=0 events=r cmd=client
+ * </pre>
+ * 
+ * @author Christoph Strobl
+ * @since 1.3
+ */
+public class StringToRedisClientInfoConverter implements Converter<String[], List<RedisClientInfo>> {
+
+	@Override
+	public List<RedisClientInfo> convert(String[] lines) {
+
+		if (lines == null) {
+			return Collections.emptyList();
+		}
+		List<RedisClientInfo> infos = new ArrayList<RedisClientInfo>(lines.length);
+		for (String line : lines) {
+			infos.add(RedisClientInfoBuilder.fromString(line));
+		}
+		return infos;
+	}
+
+}

src/main/java/org/springframework/data/redis/connection/jedis/JedisConnection.java

@@ -42,6 +42,7 @@
 import org.springframework.data.redis.connection.Subscription;
 import org.springframework.data.redis.connection.convert.Converters;
 import org.springframework.data.redis.connection.convert.TransactionResultConverter;
+import org.springframework.data.redis.core.types.RedisClientInfo;
 import org.springframework.util.Assert;
 import org.springframework.util.ObjectUtils;
 import org.springframework.util.ReflectionUtils;
@@ -2808,6 +2809,15 @@ public Long time() {
 		return Converters.toTimeMillis(serverTimeInformation.get(0), serverTimeInformation.get(1));
 	}
 
+	@Override
+	public List<RedisClientInfo> clientList() {
+
+		if (isQueueing() || isPipelined()) {
+			throw new UnsupportedOperationException("'CLIENT LIST' is not supported in in pipeline / multi mode.");
+		}
+		return JedisConverters.toListOfRedisClientInformation(this.jedis.clientList());
+	}
+
 	/**
 	 * Specifies if pipelined results should be converted to the expected data type. If false, results of
 	 * {@link #closePipeline()} and {@link #exec()} will be of the type returned by the Jedis driver

src/main/java/org/springframework/data/redis/connection/jedis/JedisConverters.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2013 the original author or authors.
+ * Copyright 2013-2014 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -15,6 +15,8 @@
  */
 package org.springframework.data.redis.connection.jedis;
 
+import java.util.Collections;
+import java.util.List;
 import java.util.Map;
 import java.util.Set;
 
@@ -31,7 +33,10 @@
 import org.springframework.data.redis.connection.convert.ListConverter;
 import org.springframework.data.redis.connection.convert.MapConverter;
 import org.springframework.data.redis.connection.convert.SetConverter;
+import org.springframework.data.redis.connection.convert.StringToRedisClientInfoConverter;
+import org.springframework.data.redis.core.types.RedisClientInfo;
 import org.springframework.util.Assert;
+import org.springframework.util.StringUtils;
 
 import redis.clients.jedis.BinaryClient.LIST_POSITION;
 import redis.clients.jedis.BitOP;
@@ -42,6 +47,7 @@
  * Jedis type converters
  * 
  * @author Jennifer Hickey
+ * @author Christoph Strobl
  */
 abstract public class JedisConverters extends Converters {
 
@@ -51,6 +57,7 @@ abstract public class JedisConverters extends Converters {
 	private static final MapConverter<String, byte[]> STRING_MAP_TO_BYTE_MAP;
 	private static final SetConverter<redis.clients.jedis.Tuple, Tuple> TUPLE_SET_TO_TUPLE_SET;
 	private static final Converter<Exception, DataAccessException> EXCEPTION_CONVERTER = new JedisExceptionConverter();
+	private static final Converter<String[], List<RedisClientInfo>> STRING_TO_CLIENT_INFO_CONVERTER = new StringToRedisClientInfoConverter();
 
 	static {
 		STRING_TO_BYTES = new Converter<String, byte[]>() {
@@ -114,6 +121,19 @@ public static String toString(byte[] source) {
 		return source == null ? null : SafeEncoder.encode(source);
 	}
 
+	/**
+	 * @param source
+	 * @return
+	 * @since 1.3
+	 */
+	public static List<RedisClientInfo> toListOfRedisClientInformation(String source) {
+
+		if (!StringUtils.hasText(source)) {
+			return Collections.emptyList();
+		}
+		return STRING_TO_CLIENT_INFO_CONVERTER.convert(source.split("\\r?\\n"));
+	}
+
 	public static DataAccessException toDataAccessException(Exception ex) {
 		return EXCEPTION_CONVERTER.convert(ex);
 	}

src/main/java/org/springframework/data/redis/connection/jredis/JredisConnection.java

@@ -43,6 +43,7 @@
 import org.springframework.data.redis.connection.ReturnType;
 import org.springframework.data.redis.connection.SortParameters;
 import org.springframework.data.redis.connection.Subscription;
+import org.springframework.data.redis.core.types.RedisClientInfo;
 import org.springframework.util.Assert;
 import org.springframework.util.ObjectUtils;
 import org.springframework.util.ReflectionUtils;
@@ -1185,4 +1186,9 @@ public <T> T evalSha(String scriptSha1, ReturnType returnType, int numKeys, byte
 	public Long time() {
 		throw new UnsupportedOperationException("The 'TIME' command is not supported by the JRedis driver.");
 	}
+
+	@Override
+	public List<RedisClientInfo> clientList() {
+		throw new UnsupportedOperationException();
+	}
 }

src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnection.java

@@ -49,6 +49,7 @@
 import org.springframework.data.redis.connection.Subscription;
 import org.springframework.data.redis.connection.convert.Converters;
 import org.springframework.data.redis.connection.convert.TransactionResultConverter;
+import org.springframework.data.redis.core.types.RedisClientInfo;
 import org.springframework.util.Assert;
 import org.springframework.util.ClassUtils;
 import org.springframework.util.ObjectUtils;
@@ -2903,6 +2904,21 @@ public Long time() {
 		return Converters.toTimeMillis(new String(result.get(0)), new String(result.get(1)));
 	}
 
+	@Override
+	public List<RedisClientInfo> clientList() {
+
+		if (isPipelined()) {
+			throw new UnsupportedOperationException("Cannot be called in pipeline mode.");
+		}
+		if (isQueueing()) {
+			transaction(new LettuceTxResult(getAsyncConnection().clientList(),
+					LettuceConverters.stringToRedisClientListConverter()));
+			return null;
+		}
+
+		return LettuceConverters.toListOfRedisClientInformation(getConnection().clientList());
+	}
+
 	/**
 	 * Specifies if pipelined and transaction results should be converted to the expected data type. If false, results of
 	 * {@link #closePipeline()} and {@link #exec()} will be of the type returned by the Lettuce driver

src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConverters.java

@@ -16,6 +16,7 @@
 package org.springframework.data.redis.connection.lettuce;
 
 import java.util.ArrayList;
+import java.util.Collections;
 import java.util.Date;
 import java.util.LinkedHashSet;
 import java.util.List;
@@ -30,7 +31,10 @@
 import org.springframework.data.redis.connection.SortParameters;
 import org.springframework.data.redis.connection.SortParameters.Order;
 import org.springframework.data.redis.connection.convert.Converters;
+import org.springframework.data.redis.connection.convert.StringToRedisClientInfoConverter;
+import org.springframework.data.redis.core.types.RedisClientInfo;
 import org.springframework.util.Assert;
+import org.springframework.util.StringUtils;
 
 import com.lambdaworks.redis.KeyValue;
 import com.lambdaworks.redis.ScoredValue;
@@ -53,6 +57,8 @@ abstract public class LettuceConverters extends Converters {
 	private static final Converter<ScoredValue<byte[]>, Tuple> SCORED_VALUE_TO_TUPLE;
 	private static final Converter<Exception, DataAccessException> EXCEPTION_CONVERTER = new LettuceExceptionConverter();
 
+	private static final Converter<String[], List<RedisClientInfo>> STRING_TO_LIST_OF_CLIENT_INFO = new StringToRedisClientInfoConverter();
+
 	static {
 		DATE_TO_LONG = new Converter<Date, Long>() {
 			public Long convert(Date source) {
@@ -102,6 +108,20 @@ public Tuple convert(ScoredValue<byte[]> source) {
 		};
 	}
 
+	public static Converter<String, List<RedisClientInfo>> stringToRedisClientListConverter() {
+		return new Converter<String, List<RedisClientInfo>>() {
+
+			@Override
+			public List<RedisClientInfo> convert(String source) {
+				if (!StringUtils.hasText(source)) {
+					return Collections.emptyList();
+				}
+
+				return STRING_TO_LIST_OF_CLIENT_INFO.convert(source.split("\\r?\\n"));
+			}
+		};
+	}
+
 	public static Converter<Date, Long> dateToLong() {
 		return DATE_TO_LONG;
 	}
@@ -214,4 +234,8 @@ public static SortArgs toSortArgs(SortParameters params) {
 		}
 		return args;
 	}
+
+	public static List<RedisClientInfo> toListOfRedisClientInformation(String clientList) {
+		return stringToRedisClientListConverter().convert(clientList);
+	}
 }

src/main/java/org/springframework/data/redis/connection/srp/SrpConnection.java

@@ -40,6 +40,7 @@
 import org.springframework.data.redis.connection.ReturnType;
 import org.springframework.data.redis.connection.SortParameters;
 import org.springframework.data.redis.connection.Subscription;
+import org.springframework.data.redis.core.types.RedisClientInfo;
 import org.springframework.util.Assert;
 
 import redis.Command;
@@ -2222,6 +2223,19 @@ public Long time() {
 		return SrpConverters.toTimeAsLong(reply.data());
 	}
 
+	@Override
+	public List<RedisClientInfo> clientList() {
+		if (isQueueing()) {
+			throw new UnsupportedOperationException();
+		}
+		if (isPipelined()) {
+			pipeline(new SrpGenericResult(pipeline.client_list(), SrpConverters.replyToListOfRedisClientInfo()));
+			return null;
+		}
+
+		return SrpConverters.toListOfRedisClientInformation(this.client.client_list());
+	}
+
 	private List<Object> closeTransaction() {
 		List<Object> results = Collections.emptyList();
 		if (txTracker != null) {