Questo documento fornisce una panoramica di una sottoscrizione pull, del relativo flusso di lavoro e delle proprietà associate.
In una sottoscrizione pull, il client sottoscrittore richiede i messaggi al server Pub/Sub.
La modalità pull può utilizzare una delle due API di servizio, Pull o StreamingPull. Per eseguire l'API scelta, puoi selezionare una libreria client di alto livello fornita da Google o una libreria client di basso livello generata automaticamente. Puoi anche scegliere tra l'elaborazione dei messaggi asincrona e sincrona.
Prima di iniziare
Prima di leggere questo documento, assicurati di acquisire familiarità con quanto segue:
Come funziona Pub/Sub e i diversi termini di Pub/Sub.
I diversi tipi di abbonamenti supportati da Pub/Sub e il motivo per cui potresti utilizzare una sottoscrizione pull.
Flusso di lavoro della sottoscrizione pull
Per una sottoscrizione pull, il client sottoscrittore avvia richieste a un server Pub/Sub per recuperare i messaggi. Il client sottoscrittore utilizza una delle seguenti API:
La maggior parte dei client sottoscrittori non effettua queste richieste direttamente. I client si affidano invece alla libreria client di alto livello fornita da Google Cloud, che esegue internamente le richieste di pull dei flussi di dati e recapita i messaggi in modo asincrono. Per un client sottoscrittore che necessita di un maggiore controllo sulle modalità di pull dei messaggi, Pub/Sub utilizza una libreria gRPC di basso livello generata automaticamente. Questa libreria effettua le richieste di pull o in modalità flusso direttamente. Queste richieste possono essere sincrone o asincrone.
Le due immagini seguenti mostrano il flusso di lavoro tra il client di un sottoscrittore e una sottoscrizione pull.
![Flusso di messaggi per una sottoscrizione pull](https://cloud.google.com/static/pubsub/images/subscriber_pull.png?authuser=3&hl=it)
![Flusso di messaggi per una sottoscrizione
streamingPull](https://cloud.google.com/static/pubsub/images/subscriber_streamingpull.png?authuser=3&hl=it)
Flusso di lavoro pull
Il flusso di lavoro pull è il seguente e fa riferimento alla Figura 1:
- Il client sottoscrittore chiama esplicitamente il metodo
pull
, che richiede i messaggi da consegnare. Questa richiesta è l'PullRequest
come mostrato nell'immagine. Il server Pub/Sub risponde con zero o più messaggi e ID di conferma. Una risposta con zero messaggi o un errore non indica necessariamente che non ci sono messaggi disponibili da ricevere. Questa risposta è
PullResponse
, come mostrato nell'immagine.Il client del sottoscrittore chiama esplicitamente il metodo
acknowledge
. Il client utilizza l'ID di conferma restituito per confermare che il messaggio è stato elaborato e non deve essere recapitato di nuovo.
Per una singola richiesta di pull in modalità flusso, un client sottoscrittore può restituire più risposte a causa della connessione aperta. Al contrario, viene restituita una sola risposta per ogni richiesta di pull.
Proprietà di una sottoscrizione pull
Le proprietà che configuri per una sottoscrizione pull determinano il modo in cui scrivi i messaggi nella sottoscrizione. Per ulteriori informazioni, consulta la sezione sulle proprietà dell'abbonamento.
API di servizio Pub/Sub
La sottoscrizione pull Pub/Sub può utilizzare una delle due API seguenti per recuperare i messaggi:
- Pull
- StreamingPull
Usa le RPC unary Acknowledge e EditAckDeadline quando ricevi messaggi con queste API. Le due API Pub/Sub sono descritte nelle schede seguenti.
API StreamingPull
Ove possibile, le librerie client di Pub/Sub utilizzano StreamingPull per la velocità effettiva massima e la latenza più bassa. Anche se non potrai mai utilizzare direttamente l'API StreamingPull, è importante sapere in cosa differisce dall'API Pull.
L'API StreamingPull si basa su una connessione bidirezionale permanente per ricevere più messaggi non appena diventano disponibili. Di seguito è riportato il flusso di lavoro:
Il client invia una richiesta al server per stabilire una connessione. Se viene superata la quota di connessioni, il server restituisce un errore di risorsa esaurita. La libreria client esegue un nuovo tentativo automatico per gli errori relativi al superamento della quota.
Se non si verificano errori o se la quota di connessione è di nuovo disponibile, il server invia continuamente i messaggi al client connesso.
Se o quando viene superata la quota di velocità effettiva, il server smette di inviare messaggi. Tuttavia, la connessione non si interrompe. Quando la quota di velocità effettiva sarà di nuovo sufficiente, il flusso riprende.
Il client o il server alla fine chiude la connessione.
L'API StreamingPull mantiene una connessione aperta. I server Pub/Sub chiudono ripetutamente la connessione dopo un periodo di tempo per evitare una connessione fissa a lunga esecuzione. La libreria client riapre automaticamente una connessione StreamingPull.
I messaggi vengono inviati alla connessione quando sono disponibili. L'API StreamingPull riduce quindi al minimo la latenza e massimizza la velocità effettiva per i messaggi.
Scopri di più sui metodi REST StreamingPull: StreamingPullRequest e StreamingPullResponse.
Scopri di più sui metodi RPC StreamingPull: StreamingPullRequest e StreamingPullResponse.
API pull
Questa API è una RPC unaria tradizionale basata su un modello di richiesta e risposta. Una singola risposta pull corrisponde a una singola richiesta di pull. Di seguito è riportato il flusso di lavoro:
Il client invia una richiesta di messaggi al server. Se viene superata la quota di velocità effettiva, il server restituisce un errore di esaurimento delle risorse.
Se non si verificano errori o se la quota di velocità effettiva è di nuovo disponibile, il server risponde con zero o più messaggi e ID di conferma.
Quando si utilizza l'API Pull unary, una risposta senza messaggi o con un errore non indica necessariamente che non ci sono messaggi disponibili da ricevere.
L'utilizzo dell'API Pull non garantisce una bassa latenza e un'elevata velocità effettiva dei messaggi. Per ottenere una velocità effettiva elevata e una bassa latenza con l'API Pull, devi avere più richieste simultanee in sospeso. Le nuove richieste vengono create quando le vecchie richieste ricevono una risposta. L'architettura di una soluzione di questo tipo è soggetta a errori e difficile da mantenere. Per questi casi d'uso, ti consigliamo di usare l'API StreamingPull.
Usa l'API Pull anziché l'API StreamingPull solo se hai bisogno di un controllo rigoroso su quanto segue:
- Il numero di messaggi che il client del sottoscrittore può elaborare
- La memoria e le risorse del client
Puoi utilizzare questa API anche quando il tuo sottoscrittore è un proxy tra Pub/Sub e un altro servizio che opera in modo più orientato al pull.
Scopri di più sui metodi REST pull: Metodo: projects.subscriptions.pull.
Scopri di più sui metodi RPC pull: PullRequest e PullResponse.
Tipi di modalità di elaborazione dei messaggi
Scegli una delle seguenti modalità pull per i client sottoscrittori.
Modalità pull asincrona
La modalità pull asincrona disaccoppia la ricezione dei messaggi dall'elaborazione dei messaggi in un client sottoscrittore. Questa è la modalità predefinita per la maggior parte dei client sottoscritti. La modalità pull asincrono può utilizzare l'API StreamingPull o l'API Pull unary. Il pull asincrono può anche utilizzare la libreria client di alto livello o la libreria client di basso livello generata automaticamente.
Puoi scoprire di più sulle librerie client più avanti in questo documento.
Modalità pull sincrono
In modalità pull sincrona, la ricezione e l'elaborazione dei messaggi avvengono in sequenza e non sono disaccoppiate tra loro. Di conseguenza, in modo simile alle API StreamingPull e unary Pull, l'elaborazione asincrona offre una latenza inferiore e una velocità effettiva superiore rispetto all'elaborazione sincrona.
Utilizza la modalità pull sincrona solo per applicazioni in cui bassa latenza e velocità effettiva elevata non sono i fattori più importanti rispetto ad altri requisiti. Ad esempio, un'applicazione potrebbe essere limitata all'uso del solo modello di programmazione sincrona. Oppure, un'applicazione con vincoli delle risorse potrebbe richiedere un controllo più preciso su memoria, rete o CPU. In questi casi, utilizza la modalità sincrona con l'API Pull unary.
Librerie client di Pub/Sub
Pub/Sub offre una libreria client di alto livello e una di basso livello generata automaticamente.
Libreria client Pub/Sub di alto livello
La libreria client di alto livello offre opzioni per controllare le scadenze di conferma utilizzando la gestione del leasing. Queste opzioni sono più granulari rispetto alla configurazione delle scadenze di conferma utilizzando la console o l'interfaccia a riga di comando a livello di abbonamento. La libreria client di alto livello implementa anche il supporto per funzionalità quali la consegna ordinata, la consegna "exactly-once" e il controllo del flusso.
Consigliamo di utilizzare il pull asincrono e l'API StreamingPull con la libreria client di alto livello. Non tutti i linguaggi supportati da Google Cloud supportano anche l'API Pull nella libreria client di alto livello.
Per utilizzare le librerie client di alto livello, consulta Librerie client di Pub/Sub.
Libreria client Pub/Sub generata automaticamente di basso livello
È disponibile una libreria client di basso livello nei casi in cui devi usare direttamente l'API Pul. Puoi utilizzare l'elaborazione sincrona o asincrona con la libreria client di basso livello. Quando utilizzi la libreria client di basso livello generata automaticamente, devi programmare manualmente funzionalità come consegna ordinata, distribuzione "exactly-once", controllo del flusso e gestione del leasing.
Puoi utilizzare il modello di elaborazione sincrona quando utilizzi la libreria client di basso livello generata automaticamente per tutte le lingue supportate. Potresti usare la libreria client generata automaticamente di basso livello e il pull sincrono nei casi in cui l'utilizzo diretto dell'API Pull ha senso. Ad esempio, potresti avere una logica dell'applicazione esistente che si basa su questo modello.
Per utilizzare direttamente le librerie client di basso livello generate automaticamente, consulta la panoramica delle API Pub/Sub.
Esempi di codice della libreria client
StreamingPull e esempi di codice della libreria client di alto livello
C++
Prima di provare questo esempio, segui le istruzioni per la configurazione di C++ nella Guida rapida: utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Pub/Sub C++.
C#
Prima di provare questo esempio, segui le istruzioni per la configurazione di C# nella Guida rapida: utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API C# Pub/Sub.
Go
Prima di provare questo esempio, segui le istruzioni di configurazione di Go in Guida rapida: utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Pub/Sub Go.
Java
Prima di provare questo esempio, segui le istruzioni di configurazione di Java in Guida rapida: utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Java Pub/Sub.
Node.js
Prima di provare questo esempio, segui le istruzioni di configurazione di Node.js in Guida rapida: utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Node.js Pub/Sub.
Node.js
Prima di provare questo esempio, segui le istruzioni di configurazione di Node.js in Guida rapida: utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Node.js Pub/Sub.
Python
Prima di provare questo esempio, segui le istruzioni di configurazione di Python in Guida rapida: utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Python Pub/Sub.
Ruby
Prima di provare questo esempio, segui le istruzioni di configurazione di Ruby in Guida rapida: utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Ruby Pub/Sub.
Recuperare gli attributi personalizzati utilizzando la libreria client di alto livello
Gli esempi riportati di seguito mostrano come eseguire il pull dei messaggi in modo asincrono e recuperare gli attributi personalizzati dai metadati.
C++
Prima di provare questo esempio, segui le istruzioni per la configurazione di C++ nella Guida rapida: utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Pub/Sub C++.
C#
Prima di provare questo esempio, segui le istruzioni per la configurazione di C# nella Guida rapida: utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API C# Pub/Sub.
Go
Prima di provare questo esempio, segui le istruzioni di configurazione di Go in Guida rapida: utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Pub/Sub Go.
Java
Prima di provare questo esempio, segui le istruzioni di configurazione di Java in Guida rapida: utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Java Pub/Sub.
Node.js
Prima di provare questo esempio, segui le istruzioni di configurazione di Node.js in Guida rapida: utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Node.js Pub/Sub.
Python
Prima di provare questo esempio, segui le istruzioni di configurazione di Python in Guida rapida: utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Python Pub/Sub.
Ruby
Prima di provare questo esempio, segui le istruzioni di configurazione di Ruby in Guida rapida: utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Ruby Pub/Sub.
Gestire gli errori utilizzando la libreria client di alto livello
Gli esempi riportati di seguito mostrano come gestire gli errori che si verificano durante la sottoscrizione ai messaggi.
C++
Prima di provare questo esempio, segui le istruzioni per la configurazione di C++ nella Guida rapida: utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Pub/Sub C++.
Go
Prima di provare questo esempio, segui le istruzioni di configurazione di Go in Guida rapida: utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Pub/Sub Go.
Java
Prima di provare questo esempio, segui le istruzioni di configurazione di Java in Guida rapida: utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Java Pub/Sub.
Node.js
Prima di provare questo esempio, segui le istruzioni di configurazione di Node.js in Guida rapida: utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Node.js Pub/Sub.
Python
Prima di provare questo esempio, segui le istruzioni di configurazione di Python in Guida rapida: utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Python Pub/Sub.
Ruby
Prima di provare questo esempio, segui le istruzioni di configurazione di Go in Guida rapida: utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Pub/Sub Go.
Esempi di codice di pull unari
Ecco un codice campione per il pull e l'accettazione di un numero fisso di messaggi.
C++
Prima di provare questo esempio, segui le istruzioni per la configurazione di C++ nella Guida rapida: utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Pub/Sub C++.
C#
Prima di provare questo esempio, segui le istruzioni per la configurazione di C# nella Guida rapida: utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API C# Pub/Sub.
Java
Prima di provare questo esempio, segui le istruzioni di configurazione di Java in Guida rapida: utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Java Pub/Sub.
Node.js
Prima di provare questo esempio, segui le istruzioni di configurazione di Node.js in Guida rapida: utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Node.js Pub/Sub.
PHP
Prima di provare questo esempio, segui le istruzioni di configurazione di Node.js in Guida rapida: utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Node.js Pub/Sub.
Ruby
Prima di provare questo esempio, segui le istruzioni di configurazione di Ruby in Guida rapida: utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Ruby Pub/Sub.
Protocollo
Richiesta:
POST https://pubsub.googleapis.com/v1/projects/myproject/subscriptions/mysubscription:pull
{
"returnImmediately": "false",
"maxMessages": "1"
}
Risposta:
200 OK
{
"receivedMessages": [{
"ackId": "dQNNHlAbEGEIBERNK0EPKVgUWQYyODM2LwgRHFEZDDsLRk1SK...",
"message": {
"data": "SGVsbG8gQ2xvdWQgUHViL1N1YiEgSGVyZSBpcyBteSBtZXNzYWdlIQ==",
"messageId": "19917247034"
}
}]
}
Richiesta:
POST https://pubsub.googleapis.com/v1/projects/myproject/subscriptions/mysubscription:acknowledge
{
"ackIds": [
"dQNNHlAbEGEIBERNK0EPKVgUWQYyODM2LwgRHFEZDDsLRk1SK..."
]
}
Python
Prima di provare questo esempio, segui le istruzioni di configurazione di Python in Guida rapida: utilizzo delle librerie client. Per ulteriori informazioni, consulta la documentazione di riferimento dell'API Python Pub/Sub.
Pub/Sub consegna un elenco di messaggi. Se l'elenco contiene più messaggi, Pub/Sub li ordina con la stessa chiave di ordinamento. Di seguito sono riportate alcune importanti avvertenze:
L'impostazione di un valore per
max_messages
nella richiesta non garantisce la restituzione dimax_messages
, anche se il backlog contiene un numero elevato di messaggi. L'API Pull di Pub/Sub potrebbe restituire meno dimax_messages
per ridurre la latenza di recapito dei messaggi subito disponibili per la consegna.Una risposta pull che arriva con 0 messaggi non deve essere utilizzata come indicatore che non ci sono messaggi nel backlog. È possibile ottenere una risposta con 0 messaggi e avere una richiesta successiva che restituisce messaggi.
Per ottenere una bassa latenza di consegna dei messaggi con la modalità pull unario, è essenziale avere molte richieste di pull simultaneamente in sospeso. Con l'aumento della velocità effettiva dell'argomento, sono necessarie più richieste di pull. In generale, la modalità StreamingPull è preferibile per le applicazioni sensibili alla latenza.
Quote e limiti
Sia le connessioni pull che StreamingPull sono soggette a quote e limiti. Per ulteriori informazioni, consulta Quote e limiti di Pub/Sub.
Passaggi successivi
Crea una sottoscrizione pull per l'argomento.
Crea o modifica una sottoscrizione con gcloud CLI.
Crea o modifica un abbonamento con le API REST.
Crea o modifica una sottoscrizione con le API RPC.