抛出，问题

最近项目最简单的一个技术上的需求：

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

长轮询，其实说起来很简单，就是发起请求的http请求，服务端把请求挂住，直到此时执行这个通知或者有需要返回的内容，才返回。Apollo配置中心配置的使用更新。

但有这样一种情况，某个服务端得到消息，但前端与服务端的连接消息恰好此时，就无法通知到前端。

所以需要把服务端的消费消息下来，保证前端发起长轮询的时候，我们要保存消息。

说，订阅业务方的消息，并且消息之间的消息，并且可以将任何消息都可以服务到我们之间。处理后才能给到前端。

想，方案

Apollo 的机制是所有的功能数据库写入更改。每次请求，实现会数据库获取是否有数据。

考虑到实际的业务场景，业务时效性的实际消息，其实是我们现在用的消息。

要考虑轻量级，我第一选择的就是 Redis Lists，利用其可以实现的特性，所以综合考虑最终采用 Redis 作为消息的存储模型。

，优化代码

Redis's Lists 的字符串链表数据按插入简单顺序示例。

使用这个特性，我们可以得到（先进先出）的数据结构，配合命令rpush+实现lpop或者lpush+ rpop。

不管是lpop什么rpop，列表都弹出一个数据，但是无法达到我们的需求一次获取多个。

网上搜索了相关的解决方案，再结合官网的命令。

得出一种比较有效的方案：lrange+ ltrim+pipeline

lrange 和 ltrim 是 Redis Lists 的指令

lrange mylist 0  5

表示从结果开始（下标为0，到下标为5的元素）。

ltrim mylist 0  5

ltrim 的含义是只保留指定范围的元素，其英文是，只保留列表下为 0 - 5 的元素，其他的设施被删除。

那如果要删掉前6条数据，就可能需要这样写：

ltrim mylist 5 - 1

负数开始表示（右）。

按说，lrange+实现从List获取多个元素的效果，为什么还需要用上管道实现呢？ltrim

这里其实有一个很可能有一些潜在的问题，这两个任务之间有两个任务，有其他任务在执行这个任务执行的时候，其实是列出里面的数据已经不对了。

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

很多人可能会因为平时的业务上也有可能发生。

先来看看 Redis Pipelining 的定义

可以实现请求/响应服务器，以便即使客户端尚未读取旧响应，它也能够处理新请求。这样就可以向服务器发送多个命令，而无需等待回复，最后一步即可读取回复。

这被称为流水线技术，并且是一种广泛使用了几十年的技术。例如，许多 POP3 协议实现已经支持此功能，从而大大加快了从服务器下载新电子邮件的过程。

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

显然，最明显的将提高一个客户端和服务器的队列的优势。几个命令作为一个请求中，和每个请求的一个集合，效率是提高的。

PS：这种方式，为什么要获取多个列表数据的类似思路的。前端长轮询获取数据结果的时候，要返回多个数据。

话不多说，直接贴上示例代码：

@自动连线
RedisTemplate< String , Object > redisTemplate;

公共 无效运行（）抛出异常{
    System.out.println( "开始......" );
    字符串键 = “键：列表”；
    整数= 5 ;
     _ // 每次获取5个
    List< Object objects = redisTemplate.executePipelined( new RedisCallback< Object >() {

        @覆盖
        公共 对象doInRedis（RedisConnection 连接）抛出 DataAccessException {
            connection.lRange(key.getBytes(StandardCharsets.UTF_8), 0 , number - 1 );
            connection.lTrim(key.getBytes(StandardCharsets.UTF_8), number , -1 );
            返回 空值；
        }
    });
    System.out.println(Arrays.toString(objects.toArray()));
    System.out.println( "结束......" );
}

redisTemplate 提供了一种类型的方法：

• 执行流水线（RedisCallback 行动）
• 执行流水线（会话回调 会议）

这实现的都差不多，近期 SessionCallback 比 RedisCallck 的应用程序更友好一下，接下来的语句更能发挥作用，更接近与命令命令。