Coda
Un servizio di messaggistica serverless
Oracle Cloud Infrastructure (OCI) Queue è un servizio che consente di abilitare la comunicazione asincrona (disaccoppiata) in modo serverless. OCI Queue gestisce volumi elevati di dati transazionali che richiedono un'elaborazione indipendente senza perdita o duplicazione. Il servizio utilizza endpoint aperti standard (STOMP e OpenAPI-defined REST) per comunicare con ogni client.
Perché scegliere OCI Queue?
-
Disaccoppiamento delle applicazioni
OCI Queue consente il disaccoppiamento dei servizi tramite la connettività asincrona. Ciò garantisce che i componenti possano ridimensionarsi in modo indipendente e che i design siano pronti al futuro, in modo che quando nuovi componenti sono creati, essi possano pubblicare o iscriversi alla coda in modo trasparente.
-
Elaborazione affidabile ed equa dei messaggi
OCI Queue garantisce che un messaggio continui fino a quando non arriva alla scadenza o viene eliminato. Il servizio garantisce che il messaggio viene consegnato almeno una volta all'applicazione consumer. I messaggi possono essere consumati da un canale casuale all'interno di una coda per aumentare l'equità di elaborazione e proteggere dai vicini "rumorosi".
-
Ridimensionamento automatico
OCI Queue gestisce le fluttuazioni della domanda di servizio in modo trasparente. Ciò significa che OCI Queue può assimilare qualsiasi volume di messaggi in un breve periodo di tempo (gestendo i picchi di carico) e consentire un'elaborazione più lenta dei messaggi con un numero limitato di clienti.
-
Standard aperti
OCI Queue è molto semplice ed efficiente da usare perché supporta standard aperti, tra cui API RESTful (con una specifica OpenAPI) e il protocollo STOMP standard del settore.
Funzioni di OCI Queue
OCI Queue possiede le seguenti funzioni:
- Scalabilità: OCI Queue gestisce i picchi di traffico imprevisti aggiungendo automaticamente risorse in base alla domanda e distribuendo il carico di lavoro ai consumatori disponibili.
- Throughput elevato: OCI Queue può supportare un numero pressoché illimitato di transazioni al secondo per ogni azione API.
- Consegna at-least-once: La consegna di un messaggio al cliente è garantita almeno una volta, a meno che il messaggio non venga eliminato o scada.
- Ordinazione a massimo sforzo: I messaggi vengono consegnati ai consumatori nella stessa sequenza in cui vengono ricevuti dai produttori. Talvolta, tuttavia, i messaggi potrebbero essere consegnati in un ordine diverso per evitare di aggiungere latenza per la correzione degli ordini.
- Blocco dei messaggi: Un messaggio viene bloccato per evitare doppie letture durante l'elaborazione di un consumer o fino al termine del periodo di visibilità.
- Batching dei messaggi: Invia, ricevi, aggiorna o elimina messaggi in batch contenenti fino a 20 messaggi per ottimizzare i costi.
- Tentativi di consegna e code dead-letter: Puoi definire il numero di tentativi di consegna di un messaggio. Se non è possibile utilizzare correttamente un messaggio, si può inviare a una dead-letter-queue (DLQ). Le DLQ ti permettono di isolare i messaggi per favorire la risoluzione dei problemi.
- Efficienza nell'elaborazione dei messaggi: i messaggi possono essere pubblicati e utilizzati da un canale casuale, aumentando così l'equità e proteggendoli da improvvisi picchi di volume.
- Selezione dei messaggi: i messaggi possono essere consegnati ai consumatori interessati a ricevere solo determinati tipi di messaggi o quelli provenienti da un producer specifico.
- Destinazioni effimere: i canali abilitano un pattern di messaggistica di risposta alle richieste inviando messaggi su canali temporanei di breve durata in una coda. I canali vengono creati immediatamente senza richiedere chiamate API di creazione o eliminazione esplicite.
- Cifratura: I messaggi vengono cifrati end-to-end.
- Protocollo STOMP: STOMP è un protocollo aperto progettato per la messaggistica in grado di aumentare l'efficienza poiché l'autenticazione e l'autorizzazione vengono eseguite una volta per connessione anziché per richiesta HTTP.
- API REST: OCI Queue può essere utilizzato con le API REST vere, supportate con una specifica OpenAPI.
