En un sistema FIFO Qeueing, ¿cuál es la mejor manera de implementar mensajería de prioridad

Question

Para middleware orientado a mensajes que no admite mensajes de prioridad consistentemente (como AMQP) cuál es la mejor manera de implementar el consumo prioritario cuando las colas solo tienen semántica FIFO ? El caso de uso general sería un sistema en el que los consumidores reciben mensajes de mayor prioridad antes de los mensajes de menor prioridad cuando existe un gran retraso de mensajes en cola (s).

Answer 1

Dado que solo se admite FIFO para una cola determinada, por supuesto deberá introducir múltiples colas, un intermediario o un consumidor más complejo.

Se pueden gestionar varias colas de varias formas. El productor y el consumidor podrían acordar tener dos colas entre ellos, uno para alta prioridad y otro para tareas en segundo plano.

Si su productor está restringido a una sola cola, pero tiene control sobre el consumidor, considere la posibilidad de introducir un enrutador de despliegue en la ruta. Entonces productor-> Enrutador es una sola cola, y el enrutador tiene dos colas para el consumidor.

Otra forma de abordarlo, que probablemente sea menos que ideal, sería hacer que el consumidor mueva un hilo al frente de la cola y luego despachar el trabajo internamente. Algo así como la versión anterior del enrutador, pero dentro de una sola aplicación. Esto tiene la desventaja de tener múltiples mensajes en vuelo dentro de su aplicación, lo que puede complicar la recuperación en caso de falla.

No olvide considerar la inanición de los eventos de baja prioridad, sean los que sean, si algunos de ellos se deben procesar incluso si todavía hay eventos de mayor prioridad.