Redis Pipeline原来是这么用的(redis pipeline使用方法)

抛出,问题

最近项目碰到这么一个技术上的需求:

前端通过长轮询的机制(http long polling),获取服务端的消息数据。而服务端是需要订阅所有业务方的业务消息,再通知到给前端。

长轮询,其实简单来说,就是前端发起一个http请求,服务端把当前的请求 hang 住,直到超时或者有需要返回的内容,才return。 Apollo 配置中心就是使用这个机制实现配置的更新通知。

但有这么一种情况,假如服务端消费到消息,但此时前端与服务端的连接刚好断开了,那这个消息就没法通知到前端。

所以,我们得需要把服务端消费的消息保存下来,保证前端的每次发起长轮询的时候,都能拿到消息数据。

如果说,前端能直接订阅业务方的消息队列的话,那其实就没服务端什么关系了。当然,这是不允许的,前端不能连接咱们的消息中间件,并且业务方的消息数据也需要清洗处理后才能给到前端。

思考,方案

Apollo 的实现机制是,所有的配置都会写入数据库。每次请求过来,会去数据库获取是否有数据变更。

考虑到我们实际的业务场景,我们的业务消息其实时候时效性的,也就是说消息如果过期了,那其实也没用了。

要考虑轻量,我第一想到的就是 redis Lists,利用其可以实现队列的特性,所以综合考虑最终采用 Redis 作为消息的存储模型。

Redis Pipeline原来是这么用的(redis pipeline使用方法)

优化,代码

Redis 的 Lists 数据结构,是简单的字符串链表,按插入顺序排序。可以在头部(Left)或者尾部(Right)添元素。

利用这个特性,我们可以实现队列(先进先出)的数据结构,搭配命令 rpush lpop 或者 lpush rpop

但是不管是 lpop 或是 rpop ,列表都只会弹出一个数据,没法达到我们的需求一次获取多个。

网上搜索了一下相关的解决方案,再结合官网的命令文档。

得出一种比较可行的方案: lrange lTrim pipeline

lrange 和 ltrim 是Redis Lists 的指令

lrange mylist 0 5

表示从队列头部(Left)开始取,下标为0,到下标为5的元素。如果是负数的话,表示队列尾部(Right)开始取。

ltrim mylist 0 5

ltrim 的含义是只保留指定范围的元素,上面的意思是,只保留列表下标为 0 – 5 的元素,其他的都会被删掉。

那如果要删掉前6条数据,就可能需要这么写:

ltrim mylist 5 -1

负数表示队列尾部(Right)开始取。

按实现来说, lrange ltrim 就能实现从 List 获取多个元素的效果,为什么还需要用上 pipeline 呢?

其实这里有一个很显然的并发问题,这两个命令对于redis来说, 并不是原子操作 ,假如有其他线程在执行这两个命令的线程之间,删除了队列的一部分数据,那么第二个命令执行的时候,其实是list里面的数据已经是不对了。

而 Redis 的 pipeline 功能,可以解决我们上面说的这个问题。

大部分人可能对pipeline 比较陌生,因为平时业务上也很少用到。

先来看看 Redis Pipelining 的定义

A Request/Response server can be implemented so that it is able to process new requests even if the client hasn't already read the old responses. This way it is possible to send multiple commands to the server without waiting for the replies at all, and finally read the replies in a single step.

This is called pipelining, and is a technique widely in use for many decades. For instance many POP3 protocol implementations already support this feature, dramatically speeding up the process of downloading new emails from the server.

简单来说,它能够支持支持客户端一次发送多个命令,服务端接收到这些命令后,会统一按顺序处理,并且是在一个原子事务里。

显然,Pipelining 最明显的优势在于提高 client 与 server 的交互响应时间。将几个命令放在同一个请求中,和每个命令作为一个请求相比,效率是肯定提高的。

PS:这种方式,跟我为什么要获取多个list 数据的思路类似的。前端长轮询获取数据结果时,要返回多个数据。

话不多说,直接贴上示例代码:

@AutowiredRedisTemplate<String, Object> redisTemplate;public void run() throws Exception { System.out.println("start......"); String key = "key:list"; Integer number = 5; // 每次获取5个 List<Object> objects = redisTemplate.executePipelined(new RedisCallback<Object>() { @Override public Object doInRedis(RedisConnection connection) throws DataAccessException { connection.lRange(key.getBytes(StandardCharsets.UTF_8), 0, number - 1); connection.lTrim(key.getBytes(StandardCharsets.UTF_8), number, -1); return null; } }); System.out.println(Arrays.toString(objects.toArray())); System.out.println("end......");}

redisTemplate 提供了两种类型的方法:

  • executePipelined(RedisCallback action)
  • executePipelined(SessionCallback Session)

这两者实现的功能都差不多,只不过 SessionCallback 比 RedisCallck 封装的更友好一下,后者的话更加底层,用法更加贴近与原生命令。

原文 http://edisonz.cn/archives/redispipeline原来是这么用的

推荐阅读:首次发布!2022年阿里巴巴Java高级架构师面试标准手册(对标P7

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

(0)
上一篇 2023年10月24日 上午8:54
下一篇 2023年10月24日 上午9:04

相关推荐

  • 大额资金进行转私,将严加查处(私对私大额转账监管)

    《税朝朝》专注于园区招商,利用地方性税收奖励扶持政策帮助企业合理合规节税避税! 很多中小型企业都表示税负过重成为他们面临的主要问题。类似商贸业、互联网业业、服务业等,税收就是这些行…

    2022年6月26日
    359
  • 新形势下高校党建和业务工作深度融合的路径(高校党建与业务工作深度融合措施与方法)

    [摘 要]新修订的《中国共产党普通高等学校基层组织工作条例》对高校党建和业务工作深度融合提出了明确要求。本文分析了高校党建和业务工作深度融合的重要意义,提出促进高校党建和业务工作深…

    科研百科 2023年10月16日
    286
  • 青葱守护弊端

    青葱守护弊端 青葱,是自然界中一种美丽的植物,它的茎和叶青翠欲滴,充满了生机和活力。在人类的生活中,青葱也扮演着重要的角色,被人们用来烹饪、调味、药用等方面。然而,青葱的保护和管理…

    科研百科 2024年11月6日
    0
  • 单机版档案管理系统优势及应用场景(单机版档案管理软件)

    本文介绍了单机版档案管理系统的概念、优势、应用场景、开发流程和注意事项,并探讨了该技术的未来趋势,旨在帮助您更好地了解和选择单机版档案管理系统开发服务。 1.单机版档案管理系统概述…

    科研百科 2024年3月9日
    127
  • 大学生科研项目心得体会总结(大学生科研项目心得体会)

    大学生科研项目心得体会 近年来,随着科技的不断发展,大学生科研项目成为了学生们学习科研技能、提高综合素质的重要途径。作为一名大学生科研项目的参与者,我深刻地体会到了科研项目的重要性…

    科研百科 2024年8月3日
    50
  • 高中学校党建引领学校高质量发展

    高中学校党建引领学校高质量发展 近年来,随着教育改革的不断深入和高中学校党建的不断推进,高中学校党建已成为教育改革的重要一环。高中学校党建的成功与否,直接关系到学校的发展方向和教学…

    科研百科 2024年10月25日
    1
  • 什么是 重大科研项目

    什么是重大科研项目? 重大科研项目是指那些具有重要科学意义、经济和社会价值,并且需要投入大量人力、物力、财力和时间进行深入研究的科研项目。这些项目通常涉及到人类生命、健康、环境、能…

    科研百科 2025年2月24日
    0
  • 立项背景怎么写

    立项背景怎么写 立项背景是项目启动时需要考虑的一个重要因素,它决定了项目的意义、目的和可行性。在写立项背景时,需要清晰地阐述项目的背景和动机,说明为什么这个项目是必要的,以及它如何…

    科研百科 2024年10月1日
    24
  • 科研项目考评

    科研项目考评:评估项目成果与质量的关键 科研项目考评是评估项目成果和教学质量的重要环节。通过对项目的考评,可以了解项目的实际进展和成果,及时发现问题并改进,同时也可以评估学生的学习…

    科研百科 2025年2月20日
    0
  • 科研项目套现方法

    科研项目套现方法 科研项目的套现是许多研究人员和企业梦寐以求的目标。套现项目可以带来巨大的经济收益,同时也可以提高研究人员和企业的知名度和声誉。然而,套现项目也面临着许多挑战,例如…

    科研百科 2025年3月3日
    0