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

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

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

另一种方法是用 while + lpop 。这种方法会将 redis list 中的数据都弹出来,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 中的元素的顺序是一样的。

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

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;
 }

} 

输出结果:

以上为个人经验,希望能给大家一个参考,也希望大家多多支持我们。如有错误或未考虑完全的地方,望不吝赐教。

时间: 2021-03-24

Python操作redis实例小结【String、Hash、List、Set等】

本文实例总结了Python操作redis方法.分享给大家供大家参考,具体如下: 这里介绍详细使用 1.String 操作 redis中的String在在内存中按照一个name对应一个value来存储 set() #在Redis中设置值,默认不存在则创建,存在则修改 r.set('name', 'zhangsan') '''参数: set(name, value, ex=None, px=None, nx=False, xx=False) ex,过期时间(秒) px,过期时间(毫秒) nx,如果设

解决Spring session(redis存储方式)监听导致创建大量redisMessageListenerContailner-X线程问题

待解决的问题 Spring session(redis存储方式)监听导致创建大量redisMessageListenerContailner-X线程 解决办法 为spring session添加springSessionRedisTaskExecutor线程池. /** * 用于spring session,防止每次创建一个线程 * @return */ @Bean public ThreadPoolTaskExecutor springSessionRedisTaskExecutor(){ T

Redis List列表的详细介绍

Redis List列表的详细介绍 Redis列表是简单的字符串列表,按照插入顺序排序.你可以添加一个元素导列表的头部(左边)或者尾部(右边) 一个列表最多可以包含 232 - 1 个元素 (4294967295, 每个列表超过40亿个元素). 实例 redis 127.0.0.1:6379> LPUSH runoobkey redis (integer) 1 redis 127.0.0.1:6379> LPUSH runoobkey mongodb (integer) 2 redis 127

详解Redis中的List类型

本系列将和大家分享Redis分布式缓存,本章主要简单介绍下Redis中的List类型,以及如何使用Redis解决博客数据分页.生产者消费者模型和发布订阅等问题. Redis List的实现为一个双向链表,即可以支持反向查找和遍历,更方便操作,不过带来了部分额外的内存开销,Redis内部的很多实现,包括发送缓冲队列等也都是用这个数据结构. List类型主要用于队列和栈,先进先出,后进先出等. 存储形式:key--LinkList<value> 首先先给大家Show一波Redis中与List类型相

redis源码分析教程之压缩链表ziplist详解

前言 压缩列表(ziplist)是由一系列特殊编码的内存块构成的列表,它对于Redis的数据存储优化有着非常重要的作用.这篇文章总结一下redis中使用非常多的一个数据结构压缩链表ziplist.该数据结构在redis中说是无处不在也毫不过分,除了链表以外,很多其他数据结构也是用它进行过渡的,比如前面文章提到的SortedSet.下面话不多说了,来一起看看详细的介绍吧. 一.压缩链表ziplist数据结构简介 首先从整体上看下ziplist的结构,如下图: 压缩链表ziplist结构图 可以看出

Volley源码之使用方式和使用场景详解

概述 Volley是Google在2013年推出的一个网络库,用于解决复杂网络环境下网络请求问题.刚推出的时候是非常火的,现在该项目的变动已经很少了.项目库地址为https://android.googlesource.com/platform/frameworks/volley 通过提交历史可以看到,最后一次修改距离今天已经有一段时间了.而volley包的release版本也已经很久没有更新了. author JeffDavidson<jpd@google.com> SunMar1316:3

Nginx源码研究之nginx限流模块详解

高并发系统有三把利器:缓存.降级和限流: 限流的目的是通过对并发访问/请求进行限速来保护系统,一旦达到限制速率则可以拒绝服务(定向到错误页).排队等待(秒杀).降级(返回兜底数据或默认数据): 高并发系统常见的限流有:限制总并发数(数据库连接池).限制瞬时并发数(如nginx的limit_conn模块,用来限制瞬时并发连接数).限制时间窗口内的平均速率(nginx的limit_req模块,用来限制每秒的平均速率): 另外还可以根据网络连接数.网络流量.CPU或内存负载等来限流. 1.限流算法 最

Ubuntu Docker 源码编译(1.9.1 )详解

Ubuntu Docker 源码编译: 网上对Ubuntu Docker 源码编译的资料有很多,但是对于具体如何操作,和命令的实现不是多细致,经过我一番折腾,终于把源码编译搞定,这里记录下,以便以后使用参考, 一.系统环境 Ubuntu14.04 desktop 64位 二.安装Docker(Docker内编译Docker) $ sudo apt-get update $ sudo apt-get install wget $ wget -qO- https://get.docker.com/

centos7环境下源码安装mysql5.7.16的方法详解

本文实例讲述了centos7环境下源码安装mysql5.7.16的方法.分享给大家供大家参考,具体如下: 一.下载源码包 下载mysql源码包 http://mirrors.sohu.com/mysql/MySQL-5.7/mysql-5.7.16.tar.gz 二.安装约定: 用户名:mysql 安装目录:/data/mysql 数据库目录:/data/mysql/data 三.安装准备 1.添加用户 > useradd -s /sbin/nologin mysql 2.建立目录 > mkd

Redis源码解析:集群手动故障转移、从节点迁移详解

一:手动故障转移 Redis集群支持手动故障转移.也就是向从节点发送"CLUSTER  FAILOVER"命令,使其在主节点未下线的情况下,发起故障转移流程,升级为新的主节点,而原来的主节点降级为从节点. 为了不丢失数据,向从节点发送"CLUSTER  FAILOVER"命令后,流程如下: a:从节点收到命令后,向主节点发送CLUSTERMSG_TYPE_MFSTART包:          b:主节点收到该包后,会将其所有客户端置于阻塞状态,也就是在10s的时间内

jQuery 1.9.1源码分析系列(十五)之动画处理

首先需要有队列(queue)的基本知识.见上一章. 相关教程:jQuery下的动画处理总结: http://www.jb51.net/article/42000.htm jQuery 1.9.1源码分析系列(十五)动画处理之缓动动画核心Tween  :http://www.jb51.net/article/75821.htm a.动画入口jQuery.fn.animate函数执行流程详解 ------------------------------------------------------

nginx源码分析线程池详解

nginx源码分析线程池详解 一.前言 nginx是采用多进程模型,master和worker之间主要通过pipe管道的方式进行通信,多进程的优势就在于各个进程互不影响.但是经常会有人问道,nginx为什么不采用多线程模型(这个除了之前一篇文章讲到的情况,别的只有去问作者了,HAHA).其实,nginx代码中提供了一个thread_pool(线程池)的核心模块来处理多任务的.下面就本人对该thread_pool这个模块的理解来跟大家做些分享(文中错误.不足还请大家指出,谢谢) 二.thread_

Java集合框架源码分析之LinkedHashMap详解

LinkedHashMap简介 LinkedHashMap是HashMap的子类,与HashMap有着同样的存储结构,但它加入了一个双向链表的头结点,将所有put到LinkedHashmap的节点一一串成了一个双向循环链表,因此它保留了节点插入的顺序,可以使节点的输出顺序与输入顺序相同. LinkedHashMap可以用来实现LRU算法(这会在下面的源码中进行分析). LinkedHashMap同样是非线程安全的,只在单线程环境下使用. LinkedHashMap源码剖析 LinkedHashM

Java并发系列之ConcurrentHashMap源码分析

我们知道哈希表是一种非常高效的数据结构,设计优良的哈希函数可以使其上的增删改查操作达到O(1)级别.Java为我们提供了一个现成的哈希结构,那就是HashMap类,在前面的文章中我曾经介绍过HashMap类,知道它的所有方法都未进行同步,因此在多线程环境中是不安全的.为此,Java为我们提供了另外一个HashTable类,它对于多线程同步的处理非常简单粗暴,那就是在HashMap的基础上对其所有方法都使用synchronized关键字进行加锁.这种方法虽然简单,但导致了一个问题,那就是在同一时间