Redis最新排队查询实践指南的核心结论
最新实践表明，利用Redis的Sorted Set和Stream数据结构，结合简单的Lua脚本或Stream消费者组，可以高效实现公平、有序且可查询的排队系统。
为什么Sorted Set适合基础排队查询
Sorted Set（有序集合）是Redis中一个功能强大的数据结构，它天然适合需要按顺序处理任务的场景。你可以将每个任务作为一个成员（member）放入集合，并用一个时间戳或者递增的序号作为它的分数（score）。这样，所有任务就自动按照分数大小排好了队。当需要查询队列状态时，使用`ZRANGE`命令可以轻松获取指定范围内的任务，`ZSCORE`命令可以查询特定任务的位置。这种方式的优点是查询速度快，操作直观。比如，在电商秒杀系统中，可以用它来暂存用户下单请求，并按到达顺序公平处理。
Stream数据结构带来的高级功能
Redis Stream是专门为消息流和事件日志设计的数据结构，它比简单的列表更强大。每条消息都有一个唯一的、递增的ID。你可以使用`XADD`命令向流添加消息，然后用`XREAD`命令来按顺序读取消息。更棒的是，Stream支持消费者组（Consumer Group），允许多个客户端同时从流中读取，并且每条消息只会被其中一个消费者处理，这完美解决了分布式系统中的负载均衡问题。对于需要追踪处理历史、防止消息丢失的场景，Stream是比列表更好的选择。
如何选择合适的队列类型
选择哪种方式，主要看你的具体需求。如果你的排队逻辑很简单，只关心谁先来谁后到，并且需要快速查询队列长度或特定任务的位置，那么Sorted Set就足够了。如果你的系统更复杂，比如需要多个工作器（Worker）并行处理任务，并且要确保每个任务只被处理一次，还希望能记录处理历史，那么Stream配合消费者组是更专业的选择。在资源使用上，Stream通常会占用更多内存，但提供了更强的可靠性保证。
优化排队的三个实用技巧
首先，避免大Key。无论是Sorted Set还是Stream，都不要让单个队列无限制增长。可以设置一个最大长度，或者定期将已处理完成的老数据转移到其他存储（如数据库）中。其次，善用Lua脚本。Redis允许你将多个命令打包成一个Lua脚本来执行，这能保证原子性。比如，你可以写一个脚本，先检查队列状态，然后弹出并处理任务，整个过程不会被其他客户端打断。最后，别忘了监控。通过Redis的命令监控或INFO命令，密切关注队列的积压情况（pending消息数量）、内存使用量等关键指标，以便及时发现问题。
一个简单的代码示例
这里展示一个使用Sorted Set实现基础排队和查询的Python代码片段。假设我们有一个任务处理队列。```python import redis import time r = redis.Redis(host='localhost', port=6379) # 添加任务到队列，使用时间戳作为分数 task_id = 'task_123' score = time.time() r.zadd('my_queue', {task_id: score}) print(f'任务 {task_id} 已加入队列') # 查询队列中最早的前10个任务 first_tasks = r.zrange('my_queue', 0, 9, withscores=True) print('队列前10个任务：', first_tasks) # 处理一个任务（取出并删除） task_to_process = r.zpopmin('my_queue') # 弹出分数最小的任务 if task_to_process: print(f'正在处理任务: {task_to_process[0]}') ``` 这段代码演示了最基本的入队、查询和出队操作。
常见问题与解答（FAQ）
问：Redis队列和专业的消息队列（如RabbitMQ、Kafka）相比，有什么优缺点？
答：Redis队列的优点是部署简单、速度快、延迟极低，并且可以直接利用Redis的其他数据结构功能。缺点是它没有像专业MQ那样提供持久化、复杂路由、死信队列等企业级特性的深度支持。如果你的场景对速度要求极高，且队列逻辑相对简单，Redis是很好的选择。如果需要高可靠性和复杂的消息模式，则应考虑专业MQ。
问：使用Redis Stream时，如果消费者崩溃了，消息会丢失吗？
答：通常不会。在消费者组模式下，当消费者读取一条消息后，这条消息会处于“待处理”（pending）状态。消费者需要在处理完成后发送`XACK`命令来确认。如果消费者崩溃，没有发送确认，经过一段时间（可通过`XPENDING`命令查看），这条消息可以被其他消费者重新认领和处理。因此，消息本身得到了保护。
问：如何清理Redis Stream或Sorted Set中已经处理完的旧数据？
答：对于Stream，可以使用`XTRIM`命令来限制流的长度，例如`XTRIM mystream MAXLEN 1000`会只保留最近的大约1000条消息。对于Sorted Set，可以使用`ZREMRANGEBYRANK`命令删除排名在指定范围外的成员，例如`ZREMRANGEBYRANK myqueue 0 -100`会保留排名最后的100个成员（即最新的任务）。更常见的做法是定期将已确认处理完毕的数据移除或归档。
本文所提及的实践内容，参考了Redis官方文档关于Sorted Set和Stream的说明，并结合了常见的应用场景总结而成。具体命令和详细参数请以官方最新文档为准。