下载后可任意编辑用 redis 实现支持优先级的消息队列 为什么需要消息队列系统中引入消息队列机制是对系统一个非常大的改善
例如一个 web 系统中,用户做了某项操作后需要发送邮件通知到用户邮箱中
你可以使用同步方式让用户等待邮件发送完成后反馈给用户,但是这样可能会因为网络的不确定性造成用户长时间的等待从而影响用户体验
有些场景下是不可能使用同步方式等待完成的,那些需要后台花费大量时间的操作
例如极端例子,一个在线编译系统任务,后台编译完成需要 30 分钟
这种场景的设计不可能同步等待后在回馈,必须是先反馈用户随后异步处理完成,再等待处理完成后根据情况再此反馈用户与否
另外适用消息队列的情况是那些系统处理能力有限的情况下,先使用队列机制把任务临时存放起来,系统再一个个轮流处理掉排队的任务
这样在系统吞吐量不足的情况下也能稳定的处理掉高并发的任务
消息队列可以用来做排队机制,只要系统需要用到排队机制的地方就可以使用消息队列来作
rabbitmq 的优先级做法 目前成熟的消息队列产品有很多,著名的例如 rabbitmq
它使用起来相对还是比较简单的,功能也相对比较丰富,一般场合下是完全够用的
但是有个很烦人的就是它不支持优先级
例如一个发邮件的任务,某些特权用户希望它的邮件能够更加及时的发送出去,至少比普通用户要优先对待
默认情况下 rabbitmq 是无法处理掉的,扔给 rabbitmq 的任务都是FIFO 先进先出
但是我们可以使用一些变通的技巧来支持这些优先级
创建多个队列,并为 rabbitmq 的消费者设置相应的路由规则
例如默认情况下有这样一个队列,我们拿 list 来模拟 [task1, task2, task3],消费者轮流根据 FIFO 的原则一个个拿出 task 来处理掉
假如有高优先级的任务进来,它也只能跟在最后被处理[task1, task2,