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

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

list<string> list = new arraylist<>();

string st = jedis.lpop( key );

while ( st != null ) {

   list.add( st );

   st = jedis.lpop( key );

}

/**

  * 连接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;

  }

}