Sono giunto a un punto, nella costruzione di un'architettura orientata ai servizi (in cima a Thrift), che ho bisogno di esporre eventi e permettere agli ascoltatori.
Il mio pensiero iniziale era "creare un EventService" per gestire la pubblicazione e l'iscrizione agli eventi. Tale EventService può utilizzare qualsiasi implementazione desideri per distribuire effettivamente gli eventi. Il mio client esegue automaticamente il roaming delle richieste di servizio agli host di servizio disponibili che vengono determinati utilizzando il rilevamento dei servizi basato su Zookeeper. Quindi, probabilmente utilizzerei JMS all'interno di EventService principalmente per lo scopo dei messaggi persistenti (nel caso in cui un host di servizio per EventService diminuisca prima che possa distribuire il messaggio a tutti i listener disponibili).
Quando ho iniziato a prendere in considerazione ciò, ho iniziato a esaminare le differenze tra code e argomenti. Gli argomenti purtroppo non funzionano per me, perché (almeno per ora), tutti gli ascoltatori devono ricevere il messaggio (anche se erano inattivi al momento in cui l'evento è stato spinto, o non hanno fatto un abbonamento ancora perché non hanno completato l'avvio (durante la distribuzione, per esempio) - i messaggi dovrebbero essere accodati fino a quando il servizio è disponibile).
Tuttavia, non voglio che EventService sia responsabile della gestione di tutti gli eventi. Non penso che dovrebbe avere il codice per reagire agli eventi al suo interno. Ciascuno dei servizi dovrebbe fare ciò di cui ha bisogno con un determinato evento. Ciò indicherebbe che ogni servizio necessiterebbe di una connessione JMS, che mette in dubbio il valore di avere EventService del tutto (poiché i servizi potrebbero pubblicare e sottoscrivere individualmente direttamente JMS). Tuttavia, accoppia anche tutti i servizi a JMS (quando preferirei che ci fosse un singolo servizio che è responsabile per determinare come distribuire gli eventi).
Quello che avevo pensato era di pubblicare un evento su EventService, che estraeva una configurazione di listener da qualche sorgente di configurazione (database, file flat, per ora irrilevante). Replica il messaggio e reinserisce ciascuno in una coda con informazioni specifiche per quel listener (quindi, se ci sono 3 ascoltatori, 1 evento diventerebbe 3 eventi in JMS). Quindi, un altro thread in EventService (che viene replicato, in esecuzione su più hots) estrarrà dalla coda, tenterà di effettuare la chiamata di servizio al "listener" e restituirà il messaggio alla coda (se il servizio è inattivo), o scartando il messaggio (se l'ascoltatore è stato completato con successo).
tl; dr
Se ho un EventService responsabile della ricezione di eventi e delega delle chiamate di servizio a "listener di eventi" (che sono in realtà solo endpoint su altri servizi), come dovrebbe sapere come creare la chiamata di servizio? Devo creare un oggetto generico "Event" condiviso tra tutti i servizi? Quindi, EventService può semplicemente costruire questo oggetto e passarlo alla chiamata di servizio. O c'è una risposta migliore a questo problema interamente?