一种消息和任务队列——beanstalkd

• 优先级（priority）：job可以有0~2^32个优先级，0代表最高优先级，beanstalkd使用最大最小堆处理job的优先级排序，因此reserve命令的时间复杂度是O(logN)；
• 延时（delay），有两种方式可以执行延时任务：producer发布任务时指定延时；或者当任务处理完毕后, consumer再次将任务放入队列延时执行 (RELEASE with <delay>)；
• 超时重发（time-to-run），Beanstalkd 把job返回给consumer以后：consumer必须在预设的 TTR (time-to-run) 时间内发送 delete / release/ bury 改变任务状态；否则 Beanstalkd 会认为消息处理失败，然后把job交给另外的消费者节点执行。如果consumer预计在 TTR (time-to-run) 时间内无法完成任务, 也可以发送 touch 命令, 它的作用是让 Beanstalkd 从系统时间重新计算 TTR ；
• 任务预留（buried），如果job因为某些原因无法执行, consumer可以把任务置为 buried 状态让 Beanstalkd 保留这些任务。管理员可以通过 peek buried 命令查询被保留的任务，并且进行人工干预。简单的, kick <n> 能够一次性把 n 条被保留的任务踢回队列。

 put            reserve               delete
  -----> [READY] ---------> [RESERVED] --------> *poof*

print beanstalk.tubes()     # default
print beanstalk.using()     # default 

beanstalk.use(‘queue1‘)
print beanstalk.using()     # queue1

beanstalk.use(‘queue2‘)     # queue2
print beanstalk.using()

print beanstalk.tubes()     # default, queue2

如上面的例子，在最后的tubes()命令打印所有tube的时候，并没有看到queue1，这是因为没有任何client 在using或者watching的tube会自动消失。

可以使用watch命令让client同时处理多个tube，而不用担心tube会被销毁：

print beanstalk.tubes()     # default
print beanstalk.using()     # default

beanstalk.use(‘queue1‘)
beanstalk.watch(‘queue1‘)
print beanstalk.using()     # queue1

beanstalk.use(‘queue2‘)     # queue2
print beanstalk.using()

print beanstalk.tubes()     # default, queue1, queue2
print beanstalk.watching()  # default, queue1

watch的tube如果不存在，会被自动创建，可以用ignore命令取消关注tube：

put with delay               release with delay
  ----------------> [DELAYED] <------------.
                        |                   |
                        | (time passes)     |
                        |                   |
   put                  v     reserve       |       delete
  -----------------> [READY] ---------> [RESERVED] --------> *poof*
                       ^  ^                |  |
                       |   \  release      |  |
                       |    `-------------‘   |
                       |                      |
                       | kick                 |
                       |                      |
                       |       bury           |
                    [BURIED] <---------------‘
                       |
                       |  delete
                        `--------> *poof*

# pruducer
beanstalk.put(‘hello‘, delay=10)
beanstalk.put(‘world‘)

# consumer
job1=beanstalk.reserve()
print "job1: " + job1.body  # World
job1.delete()

job2=beanstalk.reserve(timeout=0) 
print "job2: " + job2.body  # Error,

put命令也支持优先级参数：

# pruducer
beanstalk.put(‘hello‘, priority=10)
beanstalk.put(‘world‘, priority=9)

# consumer
job1=beanstalk.reserve()
print "job1: " + job1.body  # world
job1.delete()

job2=beanstalk.reserve(timeout=0) 
print "job2: " + job2.body  # hello
job2.delete()

release命令可以释放job回队列：