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

https://blog.csdn.net/u011784767/article/details/74587043

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

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

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

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

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

我们这里要利用两个列表类型的命令：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 void main(String[] args) {
        String key = "yujie_test_list";
        initList(key,9);
        printList(key,"原始列表数据");
        List<String> 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<String> list = client.lrange(key, 0, -1);
        System.out.println(message+ " : " + list.toString());
    }
    
    @SuppressWarnings("unchecked")
    public static List<String> getListMultValueAfterDel(String key,int start, int end){
        List<Object> list = null;
        List<String> listStr = new ArrayList<String>();
        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<String>)list.get(0);    
            } catch (Exception e) {
                // TODO: handle exception
                System.out.println(e);
            }            
        } else {
            return Collections.emptyList();
        }
        return listStr;
    }
    
}    

输出结果：

--------------------- 
作者：英雄郑旺 
来源：CSDN 
原文：https://blog.csdn.net/u011784767/article/details/74587043 
版权声明：本文为博主原创文章，转载请附上博文链接！