Browsed by
Tag: beanstalkd

Forward: Beanstalkd usage and example

Forward: Beanstalkd usage and example

origin: https://blog.csdn.net/m_nanle_xiaobudiu/article/details/80466702 一  Beanstalkd 是什么 Beanstalkd,一个高性能、轻量级的分布式内存队列系统 二  Beanstalkd 特性 优先级(priority) 注:优先级就意味 支持任务插队(数字越小,优先级越高,0的优先级最高) 延迟(delay) 注:延迟意味着可以定义任务什么时间才开始被消费,也就实现了定时任务(比如为了增加网站活跃性,增加定时评论,定时点赞功能) 持久化(persistent data) 注:Beanstalkd 支持定时将文件刷到日志文件里,即使beanstalkd宕机,重启之后仍然可以找回文件 预留(buried) 注:Beanstalkd支持把一个任务设置为预留,这样,消费者就无法取出这个任务了,等合适的时机再把这个任务拿出来消费 任务超时重发(time-to-run) 注:消费者必须在指定的时间内处理完这个任务,否则就认为消费者处理失败,任务会被重新放到队列,等待消费 三 管道(tube)与任务(job) 注:生产者生产任务,并根据业务需求将任务放到不同管道中,比如和注册有关的任务放到注册管道中,和订单有关的放到订单管道中 注:任务从进入管道到离开管道一共有5个状态(ready,delayed,reserved,buried,delete) 生产者将任务放到管道中,任务的状态可以是ready(表示任务已经准备好,随时可以被消费者读取),也可以是delayed(任务在被生产者放入管道时,设置了延迟,比如设置了5s延迟,意味着5s之后,这个任务才会变成ready状态,才可以被消费者读取) 消费者消费任务(消费者将处于ready状态的任务读出来后,被读取处理的任务状态变为reserved) 消费者处理完任务后,任务的状态可能是delete(删除,处理成功),可能是buried(预留,意味着先把任务放一边,等待条件成熟还要用),可能是ready,也可能是delayed,需要根据具体业务场景自己进行判断定义 具体示意图:…

Read More Read More