In questa pagina viene spiegato come ricevere messaggi dalle sottoscrizioni Lite. Puoi ricevere messaggi con la libreria client Pub/Sub Lite per Java.
Le sottoscrizioni Lite connettono gli argomenti Lite alle applicazioni degli abbonati; i sottoscrittori ricevono messaggi dalle sottoscrizioni Lite. I sottoscrittori ricevono ogni messaggio inviato dalle applicazioni del publisher all'argomento Lite, inclusi i messaggi inviati dagli editori prima della creazione della sottoscrizione Lite.
Prima di ricevere messaggi da una sottoscrizione Lite, crea un argomento Lite, crea una sottoscrizione Lite per l'argomento Lite e pubblica messaggi nell'argomento Lite.
Ricezione di messaggi
Per ricevere messaggi da una sottoscrizione Lite, richiedi messaggi dalla sottoscrizione Lite. La libreria client si connette automaticamente alle partizioni nell'argomento Lite associato alla sottoscrizione Lite. Se vengono confermati più client abbonati, i messaggi verranno distribuiti tra tutti i client. Il numero di partizioni nell'argomento determina il numero massimo di client sottoscrittori che possono connettersi contemporaneamente a una sottoscrizione.
I sottoscrittori potrebbero impiegare fino a un minuto per l'inizializzazione e la ricezione dei messaggi. Dopo l'inizializzazione, i messaggi vengono ricevuti con una latenza minima.
Il seguente esempio mostra come ricevere messaggi dalle sottoscrizioni Lite:
gcloud
Questo comando richiede Python 3.6 o versioni successive e l'installazione del pacchetto Python grpcio. Per gli utenti di MacOS, Linux e Cloud Shell, esegui:
sudo pip3 install grpcio
export CLOUDSDK_PYTHON_SITEPACKAGES=1
Per ricevere messaggi, utilizza il comando gcloud pubsub lite-subscriptions Subscribe:
gcloud pubsub lite-subscriptions subscribe SUBSCRIPTION_ID \
--location=LITE_LOCATION \
--auto-ack
Sostituisci quanto segue:
- SUBSCRIPTION_ID: l'ID della sottoscrizione Lite
- LITE_LOCATION: la località della sottoscrizione Lite
Go
Prima di eseguire questo esempio, segui le istruzioni per la configurazione di Go in Librerie client di Pub/Sub Lite.
Java
Prima di eseguire questo esempio, segui le istruzioni di configurazione Java in Librerie client di Pub/Sub Lite.
Python
Prima di eseguire questo esempio, segui le istruzioni di configurazione di Python in Librerie client di Pub/Sub Lite.
La libreria client stabilisce connessioni di streaming bidirezionali a ciascuna partizione nell'argomento Lite.
Il sottoscrittore richiede le connessioni alle partizioni.
Il servizio Pub/Sub Lite recapita i messaggi al sottoscrittore.
Dopo che il sottoscrittore ha elaborato il messaggio, deve accettare il messaggio. La libreria client elabora e conferma in modo asincrono i messaggi in un callback. Per limitare il numero di messaggi non confermati che il sottoscrittore può archiviare in memoria, configura le impostazioni di controllo del flusso.
Se più sottoscrittori ricevono messaggi dalla stessa sottoscrizione Lite, il servizio Pub/Sub Lite connette ciascun sottoscrittore a una stessa proporzione di partizioni. Ad esempio, se due sottoscrittori utilizzano la stessa sottoscrizione Lite e la sottoscrizione Lite è collegata a un argomento Lite con due partizioni, ogni sottoscrittore riceve messaggi da una delle partizioni.
Conferma dei messaggi
Per confermare un messaggio, invia una conferma alla sottoscrizione Lite.
Go
Per inviare una conferma, utilizza il metodo Message.Ack()
.
Java
Per inviare una conferma, utilizza il metodo AckReplyConsumer.ack()
.
Python
Per inviare una conferma, utilizza il metodo Message.ack()
.
I sottoscrittori devono confermare la ricezione di ogni messaggio. I sottoscrittori ricevono per primo il messaggio non confermato meno recente, seguito da ogni messaggio successivo. Se un sottoscrittore salta un messaggio, conferma i messaggi successivi e poi si riconnette, riceve il messaggio non confermato e ogni messaggio confermato successivo.
Le sottoscrizioni Lite non hanno una scadenza di conferma e il servizio Pub/Sub Lite non consegna nuovamente i messaggi non confermati su una connessione di streaming aperta.
Utilizzo del controllo del flusso
Dopo che il servizio Pub/Sub Lite consegna i messaggi ai sottoscrittori, i sottoscrittori archiviano i messaggi non confermati in memoria. Puoi limitare il numero di messaggi in sospeso che gli abbonati possono archiviare in memoria utilizzando le impostazioni di controllo del flusso. Le impostazioni di controllo del flusso si applicano a ogni partizione da cui un sottoscrittore riceve messaggi.
Puoi configurare le seguenti impostazioni di controllo del flusso:
- Dimensioni del messaggio eccezionali. La dimensione massima, in byte, dei messaggi in sospeso. Le dimensioni massime devono essere maggiori di quelle del messaggio più grande.
- Numero di messaggi. Il numero massimo di messaggi in sospeso.
Le dimensioni di un messaggio sono indicate nel campo size_bytes
.
Puoi configurare le impostazioni del controllo del flusso con la libreria client.
Go
Per configurare le impostazioni di controllo del flusso, passa ReceiveSettings
durante la chiamata a pscompat.NewSubscriberClientWithSettings
. Puoi impostare i seguenti parametri in ReceiveSettings
:
MaxOutstandingMessages
MaxOutstandingBytes
Per un esempio, consulta questo esempio di controllo del flusso.
Java
Per configurare le impostazioni di controllo del flusso, utilizza i seguenti metodi nella classe FlowControlRequest.Builder
:
Python
Per configurare le impostazioni del controllo del flusso, imposta i seguenti parametri nella classe FlowControlSettings
:
bytes_outstanding
messages_outstanding
Ad esempio, se il numero massimo di messaggi è 100 e il sottoscrittore si connette a 10 partizioni, il sottoscrittore non può ricevere più di 100 messaggi da nessuna delle 10 partizioni. Il numero totale di messaggi in sospeso potrebbe essere maggiore di 100, ma il sottoscrittore non può archiviare più di 100 messaggi da ogni partizione.