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 collegano gli argomenti Lite alle applicazioni dei sottoscrittori. iscritti Ricevere messaggi dalle sottoscrizioni Lite. I sottoscrittori ricevono ogni messaggio che le applicazioni del publisher inviano all'argomento Lite, inclusi i messaggi che che gli editori inviano prima di creare la sottoscrizione Lite.
Prima di ricevere messaggi da una sottoscrizione Lite, creare un argomento Lite, creare una sottoscrizione Lite per l'argomento Lite, e pubblicare messaggi nell'argomento Lite.
Ricezione di messaggi
Per ricevere messaggi da una sottoscrizione Lite, richiedi i messaggi da Lite abbonamento. La libreria client si connette automaticamente partizioni nell'argomento Lite collegato alla sottoscrizione Lite. Se il client di più sottoscrittori Creata un'istanza, i messaggi verranno distribuiti tra tutti i client. Il numero di partizioni dell'argomento determina il numero massimo di client sottoscrittori che possono collegarsi contemporaneamente a un abbonamento.
L'inizializzazione e l'inizio della ricezione da parte degli sottoscrittori potrebbero richiedere fino a un minuto messaggi. Dopo l'inizializzazione, i messaggi vengono ricevuti con una latenza minima.
L'esempio seguente mostra come ricevere messaggi dalle sottoscrizioni Lite:
gcloud
Questo comando richiede Python 3.6 o versioni successive e il comando grpcio Python pacchetto da installare. Per gli utenti di MacOS, Linux e Cloud Shell, esegui:
sudo pip3 install grpcio
export CLOUDSDK_PYTHON_SITEPACKAGES=1
Per ricevere messaggi, utilizza 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
Vai
Prima di eseguire questo esempio, segui le istruzioni di configurazione di Go in Librerie client Pub/Sub Lite.
Java
Prima di eseguire questo esempio, segui le istruzioni di configurazione di Java in Librerie client Pub/Sub Lite.
Python
Prima di eseguire questo esempio, segui le istruzioni di configurazione di Python in Librerie client Pub/Sub Lite.
La libreria client stabilisce connessioni di flusso bidirezionali tra delle partizioni nell'argomento Lite.
Il sottoscrittore richiede le connessioni alle partizioni.
Il servizio Pub/Sub Lite consegna i messaggi al sottoscrittore.
Dopo che il sottoscrittore elabora il messaggio, quest'ultimo deve Accetta il messaggio. La libreria client elabora e conferma i messaggi in modo asincrono in un callback. Per limitare il il numero di messaggi non confermati che il sottoscrittore può memorizzare in memoria, configurare le impostazioni di controllo del flusso.
Se più sottoscrittori ricevono messaggi dalla stessa sottoscrizione Lite, Il servizio Pub/Sub Lite connette ogni sottoscrittore in egual misura delle partizioni. Ad esempio, se due sottoscrittori usano la stessa sottoscrizione Lite e la sottoscrizione Lite è collegata a un argomento Lite con due partizioni, Il sottoscrittore riceve messaggi da una delle partizioni.
Conferma dei messaggi
Per confermare un messaggio, invia una conferma alla sottoscrizione Lite.
Vai
Per inviare una conferma, utilizza il metodo Message.Ack()
.
Java
Per inviare una conferma, utilizza il
AckReplyConsumer.ack()
.
Python
Per inviare una conferma, utilizza il metodo Message.ack()
.
I sottoscrittori devono confermare ogni messaggio. Gli iscritti ricevono i meno recenti non confermato e seguito da ogni messaggio successivo. Se Il sottoscrittore ignora un messaggio, conferma i messaggi successivi e si riconnette, il sottoscrittore riceve il messaggio non confermato e ogni successivo messaggio confermato.
Le sottoscrizioni Lite non hanno una scadenza di conferma e Il servizio Pub/Sub Lite non recapita nuovamente messaggi non confermati tramite un apri una connessione in streaming.
Utilizzo del controllo del flusso
Una volta che il servizio Pub/Sub Lite consegna i messaggi ai sottoscrittori, I sottoscrittori archiviano messaggi non confermati in memoria. Puoi limitare il numero di messaggi in sospeso che i sottoscrittori possono archiviare in memoria utilizzando il controllo del flusso impostazioni. Le impostazioni di controllo del flusso si applicano a ogni partizione a cui un abbonato riceve messaggi da.
Puoi configurare le seguenti impostazioni di controllo del flusso:
- Eccezionale dimensione del messaggio. La dimensione massima, in byte, messaggi in sospeso. La dimensione massima deve essere maggiore della dimensione del messaggio più grande.
- Numero di messaggi. Il numero massimo di messaggi in sospeso.
Le dimensioni di un messaggio sono
Campo size_bytes
:
Puoi configurare le impostazioni di controllo del flusso con la libreria client.
Vai
Per configurare le impostazioni di controllo del flusso, inserisci 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 del controllo del flusso, utilizza i seguenti metodi nella
FlowControlRequest.Builder
classe:
Python
Per configurare le impostazioni del controllo del flusso, imposta i seguenti parametri nel
FlowControlSettings
classe:
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 una qualsiasi 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 provenienti da ogni partizione.