redis 获取 list 中的所有元素操作

redis 获取 list 中的所有元素操作

一种方法是用 lrange( key, 0, -1 )。这种方法不会影响 redis list 中的数据。

List list = jedis.lrange( key, 0, -1 );

另一种方法是用 while + lpop 。这种方法会将 redis list 中的数据都弹出来，redis list 就变成空的了。

List list = new ArrayList<>();

String st = jedis.lpop( key );

while ( st != null ) {

list.add( st );

st = jedis.lpop( key );

}

这两种方法获得的 List list 中的元素的顺序是一样的。

补充：redis列表类型list如何一次返回多个值并删除这些值

redis的列表类型list是一个常用的数据类型，但是这个类型并不支持一次性返回多个值并删除这些已经返回的值。

其实我们可以通过redis的事务，来完成这个一次性返回多个值并删除这些已经返回的值的需求。

redis中的事务就是一组命令的集合，这些命令要么全部执行，要么全都不执行。redis事务的原理就是一次性将命令都发给服务端，

当服务接收到exec命令之后，按照事务中命令的顺序依次执行事务中的命令。exec命令的返回值就是事务中依次执行的命令返回值的集合，返回值的顺序和命令的执行顺序相同。如果在发送exec命令前，客户端和服务端失去连接，这时redis会清空这个事务队列。

介绍完这些原理，我们再来http://看看如何完成一次性返回多个值并删除这些已经返回的值的需求。

我们这里要利用两个列表类型的命令：lrange和ltrim

lrange key start end // 从左边依次返回key的[start,end] 的所有值，注意返回结果包含两端的值。

ltrim key start end //删除指定索引之外的所有元素，注意删除之后保留的元素包含两端的start和end索引值。

我们这里举例测试：

我们构造了一个名为yujie_list的列表类型数据结构，从左边依次压入：0 1 2 3 4 5 6 7 8 9

最后从左到右依次列出列表中的所有元素如上图所示。

接下来我们测试lrange和ltrim命令如下图：

我们使用lrange yujie_list 0 3命令，从左到右依次列出从索引0到索引3的元素，注意包含了索引0 值为9和索引3值为6的元素。

我们使用ltrim yujie_list 4 -1命令，删除索引4到最右端之外的所有元素，注意删除的元素不包含索引4职位5的元素。

好了原理讲完了，接下来我们上代码：

RedisUtil是一个工具类，用于连接redis服务端。

/**

* 连接redis服务的工具类

* @author yujie.wang3

*

*/

public final class RedisUtil {

//Redis服务器IP

private static String ADDR = "10.4.36.93";

//Redis的端口号

private static int PORT = 6379;

//可用连接实例的最大数目，默认值为8；

//如果赋值为-1，则表示不限制；如果pool已经分配了maxActive个jedis实例，则此时pool的状态为exhausted(耗尽)。

private static int MAX_ACTIVE = 100;

//控制一个pool最多有多少个状态为idle(空闲的)的jedis实例，默认值也是8。

private static int MAX_IDLE = 20;

//等待可用连接的最大时间，单位毫秒，默认值为-1，表示永不超时。如果超过等待时间，则直接抛出JedisConnectionException；

private static int MAX_WAIT = 10000;

private static int TIMEOUT = 10000;

//在borrow一个jedis实例时，是否提前进行validate操作；如果为true，则得到的jedis实例均是可用的；

private static boolean TEST_ON_BORROW = true;

private static JedisPool jedisPool = null;

/**

* 初始化Redis连接池

*/

static {

try {

JedisPoolConfig config = new JedisPoolConfig();

config.setMaxActive(MAX_ACTIVE);

config.setMaxIdle(MAX_IDLE);

config.setMaxWait(MAX_WAIT);

config.setTestOnBorrow(TEST_ON_BORROW);

jedisPool = new JedisPool(config, ADDR, PORT);

} catch (Exception e) {

e.printStackTrace();

}

}

/**

* 获取Jedis实例

* @return

*/

public synchronized static Jedis getJedis() {

try {

if (jedisPool != null) {

Jedis resource = jedisPool.getResource();

return resource;

} else {

return null;

}

} catch (Exception e) {

e.printStackTrace();

return null;

}

}

/**

* 释放jedis资源

* @param jedis

*/

public static void returnResource(final Jedis jedis) {

if (jedis != null) {

jedisPool.returnResource(jedis);

}

}

}

测试类如下：

/**

* 一次返回多个列表值并删除返回值测试类

* @author yujie.wang

*

*/

public class RedisTest {

public static voiyPlExud main(String[] args) {

String key = "yujie_test_list";

initList(key,9);

printList(key,"原始列表数据");

List listResult = getListMultValueAfterDel(key,0,3);

System.out.println("一次返回并删除数据："+listResult.toString());

printList(key,"删除之后列表数据");

}

public static void initList(String key,int maxValue){

Jedis client = RedisUtil.getJedis();

for(int i = 0;i <= maxValue; i++){

client.lpush(key, String.valueOf(i));

}

System.out.println("初始化列表："+ key + "完毕");

}

public static void printList(String key,String message){

Jedis client = RedisUtil.getJedis();

List list = client.lrange(key, 0, -1);

System.out.println(message+ " : " + list.toString());

}

@SuppressWarnings("unchecked")

public static List getListMultValueAfterDel(String key,int start, int end){

List

List listStr = new ArrayList();

try {

Jedis jedis = RedisUtil.getJedis();

Transaction ts = jedis.multi();

ts.lrange(key, start, end);

ts.ltrim(key, end+1, -1);

list = ts.exec();

RedisUtil.returnResource(jedis);

} catch (Exception e) {

// TODO: handle exception

System.out.println(e);

}

if(list != null && !list.isEmpty()){

try {

//获得命令lrange(key, start, end)的返回结果

listStr = (ArrayList)list.get(0);

} catch (Exception e) {

// TODO: handle exception

System.out.println(e);

}

} else {

return Collections.emptyList();

}

return listStr;

}

}

输出结果：

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。