Sto creando un'API per pubblicare e consumare messaggi da RabbitMQ. Nel mio attuale design, l'editore farà una richiesta POST. La mia API indirizzerà la richiesta POST allo scambio. In questo modo, l'editore non deve conoscere l'indirizzo del server, il nome dello scambio ecc. Durante la pubblicazione.
Ora la parte del consumatore è dove non sono sicuro di come procedere.
All'inizio non ci saranno code. Quando un nuovo utente desidera iscriversi a un ARGOMENTO, creerò una coda e la collegherò allo scambio. Ho bisogno di aiuto con le risposte a poche domande -
-
Una volta creata una coda per il consumatore, qual è il passo successivo per consentire al consumatore di ricevere messaggi da quella coda?
-
Faccio chiedere al consumatore una serie di messaggi (ad esempio 50 messaggi) dalla coda. Quindi, una volta ricevuta una richiesta dal consumatore, invierò i successivi 50 messaggi dalla coda. Se non ricevo un ack, reinserisco i 50 messaggi in coda. Non è costoso in termini di apertura e chiusura della connessione tra il consumatore e la mia API?
Se esiste un approccio migliore, si prega di suggerire
O dovrei semplicemente fornire ai consumatori dettagli per connettersi alla coda e lasciarli consumare da lì?