W systemie FIFO Qeueing, jaki jest najlepszy sposób implementacji wiadomości priorytetowych?

Question

W przypadku oprogramowania pośredniego zorientowanego na komunikaty, które nie obsługuje spójnie wiadomości priorytetowych (takich jak AMQP), jaki jest najlepszy sposób na wdrożenie priorytetu zużycia, gdy kolejki mają tylko semantykę FIFO ? Ogólnym przypadkiem użycia byłby system, w którym konsumenci otrzymują wiadomości o wyższym priorytecie przed wiadomościami o niższym priorytecie, gdy duży zaległości wiadomości istnieją w kolejce (ach).

Answer 1

Biorąc pod uwagę tylko obsługę FIFO dla danej pojedynczej kolejki, będziesz oczywiście musiał wprowadzić wiele kolejek, pośrednika lub mieć bardziej złożonego konsumenta.

Kilka kolejek może być obsługiwanych na kilka sposobów. Producent i konsument mogli zgodzić się na dwie kolejki między nimi, jedną dla zadań o wysokim priorytecie i jedną dla zadań drugoplanowych.

Jeśli producent jest ograniczony do pojedynczej kolejki, ale masz kontrolę nad konsumentem, rozważ wprowadzenie na ścieżce routera typu "fan-out". Więc producent-> Router jest pojedynczą kolejką, a router ma następnie dwie kolejki do konsumenta.

Innym sposobem na rozwiązanie tego problemu, który prawdopodobnie nie jest idealny, jest nakłonienie klienta do przewinięcia wątku do przodu w kolejce, a następnie wysłanie pracy wewnętrznie. Coś jak powyższa wersja routera, ale w jednej aplikacji. Ma to wadę polegającą na tym, że w aplikacji znajduje się wiele wiadomości podczas lotu, co może komplikować odzyskiwanie w przypadku awarii.

Nie zapomnij rozważyć, jak głodować skutecznie zdarzenia o niskim priorytecie, niezależnie od tego, czym one są, jeśli niektóre z nich powinny być przetwarzane, nawet jeśli nadal mają miejsce zdarzenia o wyższym priorytecie.