Problema di progettazione dell'elaborazione simultanea MSMQ

Question

Ho un servizio Windows scritto in C# che legge da MSMQ e basato sul tipo di messaggio che assegna ad agenti che elaborano quel messaggio in un thread di lavoro. L'applicazione si avvia senza agenti e vengono creati in modo dinamico in fase di esecuzione, come i messaggi arrivano nella MSMQ

Ecco una figura di base di come funziona:

Se il thread di lavoro agente è occupato a fare il lavoro il messaggio viene accodato alla sua coda locale. Fin qui tutto bene. Ma se per qualche motivo se il servizio viene interrotto, il contenuto della coda locale viene perso.

Sto cercando di capire quale potrebbe essere il modo migliore per gestire questo scenario. Al momento le code locali sono System.Concurrent.ConcurrentQueue. Potrei probabilmente usare un db Sql Ce o qualche altra memoria persistente, ma sono preoccupato per le prestazioni. L'altra cosa nella mia mente è leggere da MSMQ solo quando gli agenti sono pronti per elaborare il messaggio, ma il problema è che non conosco il messaggio che MSMQ conterrà.

Quali possibili approcci posso affrontare in merito a questo problema?

Answer 1

Ho costruito un sistema simile dipendente da Redis. L'idea è che fornisce memoria - accesso rapido ai dati isolato dal resto dell'applicazione, e non si spegne quando il mio servizio funziona. Inoltre, alla fine manterrà i miei dati sul disco, quindi ottengo un buon compromesso tra affidabilità e velocità.

Se lo si progettava in modo che ogni client leggesse dalla propria coda di messaggi che sarebbe ospitata in Redis, è possibile mantenere la coda indipendente dal tempo di inattività del servizio e ogni carico di lavoro ripartito al successivo avvio del servizio.

Answer 2

Perché non è sufficiente creare due nuove code msms per ricevere i messaggi per Agenta e agentb e creare un nuovo agente che (a livello di transazione) preleva il comando dalla coda principale e invia il messaggio alla coda agente corretta?

Answer 3

vostro disegno è fondamentalmente implementa il seguente schema: http://www.eaipatterns.com/MessageDispatcher.html

Tuttavia, invece di utilizzare la messaggistica reale si sceglie di implementare il dispatcher nel codice multithread.

Piuttosto, ogni agent di elaborazione deve essere un processo autonomo con la propria coda di messaggi fisici. Questo è ciò che fornirà la durata del messaggio in caso di guasto. Consente inoltre di ridimensionare semplicemente ospitando più istanze dell'agente di elaborazione.