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

更新時(shí)間：2021年03月25日 14:19:04 作者：熱帶魚2020

這篇文章主要介紹了redis 獲取 list 中的所有元素操作，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過來看看吧

一種方法是用 lrange( key, 0, -1 )。這種方法不會(huì)影響 redis list 中的數(shù)據(jù)。

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

另一種方法是用 while + lpop 。這種方法會(huì)將 redis list 中的數(shù)據(jù)都彈出來，redis list 就變成空的了。

List<String> list = new ArrayList<>();
String st = jedis.lpop( key );
while ( st != null ) {
  list.add( st );
  
  st = jedis.lpop( key );
}

這兩種方法獲得的 List<String> list 中的元素的順序是一樣的。

補(bǔ)充：redis列表類型list如何一次返回多個(gè)值并刪除這些值

redis的列表類型list是一個(gè)常用的數(shù)據(jù)類型，但是這個(gè)類型并不支持一次性返回多個(gè)值并刪除這些已經(jīng)返回的值。

其實(shí)我們可以通過redis的事務(wù)，來完成這個(gè)一次性返回多個(gè)值并刪除這些已經(jīng)返回的值的需求。

redis中的事務(wù)就是一組命令的集合，這些命令要么全部執(zhí)行，要么全都不執(zhí)行。redis事務(wù)的原理就是一次性將命令都發(fā)給服務(wù)端，

當(dāng)服務(wù)接收到exec命令之后，按照事務(wù)中命令的順序依次執(zhí)行事務(wù)中的命令。exec命令的返回值就是事務(wù)中依次執(zhí)行的命令返回值的集合，返回值的順序和命令的執(zhí)行順序相同。如果在發(fā)送exec命令前，客戶端和服務(wù)端失去連接，這時(shí)redis會(huì)清空這個(gè)事務(wù)隊(duì)列。

介紹完這些原理，我們?cè)賮砜纯慈绾瓮瓿梢淮涡苑祷囟鄠€(gè)值并刪除這些已經(jīng)返回的值的需求。

我們這里要利用兩個(gè)列表類型的命令：lrange和ltrim

lrange key start end // 從左邊依次返回key的[start,end] 的所有值，注意返回結(jié)果包含兩端的值。

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

我們這里舉例測(cè)試：

我們構(gòu)造了一個(gè)名為yujie_list的列表類型數(shù)據(jù)結(jié)構(gòu)，從左邊依次壓入：0 1 2 3 4 5 6 7 8 9

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

接下來我們測(cè)試lrange和ltrim命令如下圖：

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

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

好了原理講完了，接下來我們上代碼：

RedisUtil是一個(gè)工具類，用于連接redis服務(wù)端。

/**
 * 連接redis服務(wù)的工具類
 * @author yujie.wang3
 *
 */
public final class RedisUtil {  
  //Redis服務(wù)器IP
  private static String ADDR = "10.4.36.93";
  
  //Redis的端口號(hào)
  private static int PORT = 6379;  
  
  //可用連接實(shí)例的最大數(shù)目，默認(rèn)值為8；
  //如果賦值為-1，則表示不限制；如果pool已經(jīng)分配了maxActive個(gè)jedis實(shí)例，則此時(shí)pool的狀態(tài)為exhausted(耗盡)。
  private static int MAX_ACTIVE = 100;
  
  //控制一個(gè)pool最多有多少個(gè)狀態(tài)為idle(空閑的)的jedis實(shí)例，默認(rèn)值也是8。
  private static int MAX_IDLE = 20;
  
  //等待可用連接的最大時(shí)間，單位毫秒，默認(rèn)值為-1，表示永不超時(shí)。如果超過等待時(shí)間，則直接拋出JedisConnectionException；
  private static int MAX_WAIT = 10000;
  
  private static int TIMEOUT = 10000;
  
  //在borrow一個(gè)jedis實(shí)例時(shí)，是否提前進(jìn)行validate操作；如果為true，則得到的jedis實(shí)例均是可用的；
  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實(shí)例
   * @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);
    }
  }
}

測(cè)試類如下：

/**
 * 一次返回多個(gè)列表值并刪除返回值測(cè)試類
 * @author yujie.wang
 *
 */
public class RedisTest {
 
 public static void main(String[] args) {
 String key = "yujie_test_list";
 initList(key,9);
 printList(key,"原始列表數(shù)據(jù)");
 List<String> listResult = getListMultValueAfterDel(key,0,3);
 System.out.println("一次返回并刪除數(shù)據(jù)："+listResult.toString());
 printList(key,"刪除之后列表數(shù)據(jù)");
 }
 
 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)的返回結(jié)果
  listStr = (ArrayList<String>)list.get(0); 
  } catch (Exception e) {
  // TODO: handle exception
  System.out.println(e);
  }  
 } else {
  return Collections.emptyList();
 }
 return listStr;
 }
 
}

輸出結(jié)果：