Disque 源码分析 代码重用 服务器状态 队列 任务 节点与集群 命令执行流程 结论 Disque 源码分析 本文将对 Disque 的核心数据结构进行介绍，并在最后通过分析 ADDJOB 命令的实现来帮助大家了解 Disque 的运作原理。 因为时间关系，本章只介绍了 Disque 源码中最重点的部分，并且只对集群和命令的运作...

ACKJOB ACKJOB ACKJOB jobid1 jobid2 ... jobidN 通过给定任务 ID ，向节点告知任务已经被执行。 接收到 ACK 消息的节点会将该消息复制至多个节点，并尝试对任务和来自集群的 ACK 消息进行垃圾回收操作，从而释放被占用的内存。 disque > GETJOB FROM greet...

客户端 客户端 Disque 在源码中附带了命令行客户端程序 disque ，通过这个程序可以以交互的形式向 Disque 发送命令： $ ./ disque 127.0 . 0.1 : 7711 > PING PONG 另外你也可以使用以下编程语言的客户端来操作 Disque ： Ruby 客户端 https://rub...

Disque 使用教程（DisqueBook.com） 安装与运行 命令文档 集群文档 设计文档 关于本文档 通过捐款支持本文档 Disque 使用教程（DisqueBook.com） Disque 是一个内存储存的分布式任务队列实现，它由 Redis 的作者 Salvatore Sanfilippo (@antirez )开发，目前正处...

搭建单节点集群 搭建单节点集群 Disque 以集群模式运行，每个服务器都是集群中的一个节点，用户可以运行任意数量的节点，只要确保每个节点的端口号不同即可。 在默认情况下，运行 Disque 服务器程序 disque-server 将启动一个端口号为 7711 的 Disque 节点： $ ./ disque - server 528 :...

安装方法 安装方法 以下是下载、编译并安装 Disque 的完整步骤： 执行命令 git clone https://github.com/antirez/disque.git ，使用 Git 克隆 Disque 的项目文件夹。 执行 cd disque 命令，切换至 Disque 的项目文件夹。 执行 make 命令，编译 Disque...

QLEN QLEN QLEN < queue - name > 返回队列目前存放的任务数量。 disque > QLEN greeting -- 空队列 ( integer ) 0   disque > ADDJOB greeting "hello wo...

GETJOB GETJOB GETJOB [ TIMEOUT < ms - timeout >] [ COUNT <count> ] FROM queue1 queue2 ... queueN 从给定的队列里面取出可用的任务，或者在超时时间达到时，返回 NULL 。 在默认情况下，命令每次最多只会返回一个任务，但使用 ...

搭建多节点集群 搭建多节点集群 因为每个 Disque 节点都会将自己的配置信息储存在 disque-server 运行的文件夹里面，而同一个文件夹只能有一份这样的配置信息，所以如果我们打算同时运行多个节点，那么就必须在不同的文件夹里面运行 disque-server ，并为每个节点指定不同的端口。 假设我们现在打算运行三个 Disque 节点...

QPEEK QPEEK QPEEK <qname> <count> 在不取出任务的情况下，从队列里面返回指定数量的任务： 当 count 为正数时，命令会按照任务入队的时间，以从旧到新的顺序返回任务（和 GETJOB 命令一样，尽可能地维持一个先进先出的顺序）。 当 count 为负数时，命令以从新到旧的顺序返回任务。 ...