当前位置: 首页 > 后端技术 > Python

kombu创建优先级队列,支持消息优先级

时间:2023-03-26 12:16:29 Python

rabbitmq的队列默认不支持优先级。要支持消息的消费优先级,必须使用rabbitmq中的“优先级队列”。队列中的消息没有优先级,只会先进先出。甚至在发布的时候,把优先级放在消息上也是一个噱头Queues支持消息优先级优先级。创建队列时,指定x-max-priority。您可能想知道为什么有x-max-priority而没有x-min-priority,对吗?是的,没有任何原因,就是太奇怪了!fromkombuimportExchange,Queueapp.conf.task_queues=[Queue('tasks',Exchange('tasks'),routing_key='tasks',queue_arguments={'x-max-priority':10},]使用上面的代码,可以创建一个支持优先级的队列,看队列的特性,有个Pri,说明这个东西已经支持优先级了,rabbitmq的消息优先级和优先级队列有什么区别?是一样的参考文档:kombudocAdvancedTopicsHowtousepriorityincelerytask.apply_asynchttps://www.cnblogs.com/zipon/p/11321061.html