Tutto quello che fa sgcMQ, mappato sui sette componenti client e sulle specifiche che implementano. Ogni funzionalità si comporta allo stesso modo in Delphi e in C++ Builder, e ogni licenza include il codice sorgente completo. Clicca su un componente per la sua pagina dedicata con utilizzo ed esempi.
3.1.1 e 5.0
0.9.1 e 1.0
Protocollo binario nativo
1.0 / 1.1 / 1.2
TCP semplice e TLS
Da Delphi 7 a 13, C++ Builder
sgcMQ è autosufficiente. Viene distribuito con il runtime sgcWebSockets Core incluso, quindi non è un componente aggiuntivo e non c'è nessuna licenza base da comprare.
Trasporto: TCP semplice e TLS. sgcMQ si connette tramite TCP semplice e TLS. Se ti serve far girare il protocollo su WebSocket, per esempio MQTT su WebSocket o AMQP su WebSocket, è necessario un package sgcWebSockets, che fornisce il client WebSocket.
Ogni funzionalità nelle tabelle qui sotto si raggiunge attraverso il vettore TCP grezzo TsgcTCPClient, che sgcMQ include nella confezione.
Quattro famiglie di protocolli, registrate sulla pagina della palette SGC MQ.
| Componente | Classe | Famiglia | Descrizione |
|---|---|---|---|
| MQTT Client | TsgcWSPClient_MQTT | MQTT | Publish/subscribe MQTT 3.1.1 e 5.0: QoS 0/1/2, messaggi retained, Last Will and Testament, sessioni e property di MQTT 5. |
| AMQP 0.9.1 Client | TsgcWSPClient_AMQP | AMQP | Canali, exchange, code e binding, consumer, conferme, prefetch QoS e transazioni. |
| AMQP 1.0 Client | TsgcWSPClient_AMQP1 | AMQP | Sessioni, link sender e receiver, controllo di flusso a credito, autenticazione SASL e funzioni di supporto per i token CBS di Azure. |
| Kafka Client | TsgcWSPClient_Kafka | Kafka | Producer con acks e gzip, consumer group con rebalance e commit degli offset, amministrazione dei topic. |
| STOMP Client | TsgcWSPClient_STOMP | STOMP | Frame STOMP 1.0/1.1/1.2: SEND, SUBSCRIBE, ACK, NACK, ricevute, heart-beating e transazioni. |
| STOMP RabbitMQ Client | TsgcWSPClient_STOMP_RabbitMQ | STOMP | STOMP ottimizzato per RabbitMQ: funzioni di supporto per code, topic, exchange, code esterne e code temporanee, su TCP o TLS. |
| STOMP ActiveMQ Client | TsgcWSPClient_STOMP_ActiveMQ | STOMP | STOMP ottimizzato per Apache ActiveMQ, con funzioni di supporto per code e topic più una proprietà ActiveMQ_Options. |
Il protocollo publish/subscribe dell'IoT, con tutto il meccanismo della qualità del servizio esposto invece che nascosto.
| Funzionalità | 3.1.1 | 5.0 | Note |
|---|---|---|---|
| Scelta della versione del protocollo | ✓ | ✓ | MQTTVersion accetta mqtt311 o mqtt5. |
| QoS 0, 1 e 2 | ✓ | ✓ | Lo scambio QoS 2 emerge come OnMQTTPubRec, OnMQTTPubRel e OnMQTTPubComp, non viene inghiottito. |
| Messaggi retained | ✓ | ✓ | Il flag retain è il quarto argomento di Publish. |
| Last Will and Testament | ✓ | ✓ | LastWillTestament contiene topic, messaggio, QoS e retain. |
| Sottoscrizioni con caratteri jolly | ✓ | ✓ | + per un livello, # per il resto dell'albero. |
| Sessioni | ✓ | ✓ | L'argomento Session di OnMQTTConnect indica se il broker ne ha ripresa una. |
| Pubblicare e attendere | ✓ | ✓ | PublishAndWait blocca finché il broker non conferma il pacchetto. |
| Pubblicare uno stream | ✓ | ✓ | Publish ha un overload TStream per i payload binari. |
| Reason code e nomi | — | ✓ | MQTT 5 restituisce un reason code numerico e il suo nome su CONNACK e DISCONNECT. |
| Property di CONNECT | — | ✓ | ConnectProperties imposta la scadenza della sessione, il receive maximum, la dimensione massima del pacchetto e il numero massimo di alias dei topic. |
| Alias dei topic | — | ✓ | Un intero corto sostituisce sul filo un nome di topic lungo, risolto automaticamente sui pacchetti in entrata. |
| User property | — | ✓ | Coppie chiave/valore arbitrarie viaggiano con CONNECT, PUBLISH, SUBSCRIBE e DISCONNECT. |
| Sottoscrizioni condivise | — | ✓ | Sottoscrivi $share/<group>/<topic> per distribuire le consegne su un gruppo di client. |
| Autenticazione avanzata | — | ✓ | Lo scambio del pacchetto AUTH tramite Auth e OnMQTTAuth, per gli schemi a sfida e risposta. |
| Keep-alive | ✓ | ✓ | HeartBeat pilota il PINGREQ, con OnMQTTPing sollevato alla risposta. |
Due protocolli che condividono un nome e nient'altro, quindi sgcMQ distribuisce un componente separato per ciascuno invece di fingere che una sola API vada bene per entrambi.
| Funzionalità | AMQP 0.9.1 | AMQP 1.0 | Note |
|---|---|---|---|
| Componente | TsgcWSPClient_AMQP | TsgcWSPClient_AMQP1 | Formato binario diverso, modello a oggetti diverso, componente diverso. |
| Unità di multiplexing | Canale | Sessione | OpenChannel contro CreateSession. |
| Dichiarazione della topologia | DeclareExchange, DeclareQueue, BindQueue | — | AMQP 1.0 indirizza i nodi sul broker invece di dichiararli. |
| Invio | PublishMessage(channel, exchange, routingKey, body) | SendMessage(session, link, text) | Routing key sulla 0.9.1, indirizzo di destinazione sulla 1.0. |
| Ricezione | Consume poi OnAMQPBasicDeliver | CreateReceiverLink poi OnAMQPMessage | Entrambi sono basati su push una volta stabiliti. |
| Conferma | AckMessage / RejectMessage | OnAMQPMessageSentAck | La 0.9.1 conferma un delivery tag, la 1.0 definisce una consegna. |
| Controllo di flusso | prefetch con SetQoS, EnableChannel / DisableChannel | Basato su credito (CreditSize, WindowSize) | Entrambi impediscono a un producer veloce di sommergere un consumer lento. |
| Transazioni | SelectTransaction, CommitTransaction, RollbackTransaction | — | La classe tx della 0.9.1, esposta per canale. |
| Manutenzione delle code | PurgeQueue, DeleteQueue, DeleteExchange, UnBindQueue | CloseLink, CloseSession | Ognuna con una variante bloccante ...Ex che attende la risposta del broker. |
| Riconsegna | Recover / RecoverAsync | — | Chiedi al broker di riconsegnare i messaggi senza conferma. |
| Autenticazione | OnAMQPAuthentication, OnAMQPChallenge | Authentication.AuthType, OnAMQPSASLAuthentication | La 1.0 offre SASL ANONYMOUS, PLAIN ed EXTERNAL. |
| Supporto per il cloud | — | CreateCBSLink, PutCBSToken, CreateAzureCbsSasToken, CreateAzureCbsJWT | Claims-Based Security per Azure Service Bus ed Event Hubs. |
| Liveness | HeartBeat | Ping, AMQPOptions.IdleTimeout | Negoziata con il broker alla connessione. |
| Regolazione della connessione | AMQPOptions.VirtualHost, MaxChannels, MaxFrameSize, Locale | AMQPOptions.ContainerId, ChannelMax, MaxFrameSize, MaxLinksPerSession | Inviata nell'handshake iniziale e negoziata con il broker. |
| Prefetch | SetQoS(channel, prefetchSize, prefetchCount, global) | AMQPOptions.CreditSize | Quanti messaggi senza conferma il broker può avere in volo. |
| Ispezione dei frame | — | OnAMQPBeforeReadFrame, OnAMQPBeforeWriteFrame | Osserva o riscrivi i frame grezzi prima che vengano elaborati o inviati. |
Il protocollo binario di Kafka implementato in Object Pascal, senza nessun proxy REST davanti e senza librdkafka sotto.
| Funzionalità | API | Note |
|---|---|---|
| Produrre un record | Produce(topic, value, key, partition) | Chiave e partizione sono facoltative. ProduceBytes accetta TBytes per entrambe. |
| Produrre un batch | ProduceMessages(topic, partition, messages) | Restituisce la risposta di produzione del broker per l'intero batch. |
| Garanzia di consegna | KafkaOptions.Producer.Acks | kafkaAcksNone, kafkaAcksLeader o kafkaAcksAll. |
| Compressione | KafkaOptions.Producer.Compression | kafkaCompressionNone o kafkaCompressionGzip. |
| Consumare | Subscribe([topics]) poi Poll(timeoutMs) | Poll restituisce una lista TsgcKafkaMessages e solleva anche OnKafkaMessage per ogni record. |
| Consumer group | KafkaOptions.Consumer.GroupId | La scoperta del coordinatore, il join, la sincronizzazione e gli heartbeat sono gestiti per te. OnKafkaRebalance segnala i cambi di assegnazione. |
| Politica degli offset | KafkaOptions.Consumer.OffsetReset | kafkaOffsetEarliest o kafkaOffsetLatest quando non c'è nessun offset confermato. |
| Confermare gli offset | CommitSync, CommitOffset(topic, partition, offset) | Oppure imposta Consumer.AutoCommit con AutoCommitIntervalMs. |
| Leggere una partizione direttamente | FetchMessages(topic, partition, offset, maxBytes) | Aggira del tutto il consumer group. |
| Ricerca degli offset | GetEarliestOffset, GetLatestOffset, GetCommittedOffset | Per topic e partizione. |
| Regolazione del fetch | Consumer.MinBytes, MaxBytes, MaxPartitionBytes, MaxWaitMs | Bilancia la latenza contro la dimensione del batch. |
| Amministrazione dei topic | CreateTopic, DeleteTopic, GetMetadata | Numero di partizioni e fattore di replica alla creazione. |
| Amministrazione dei gruppi | ListGroups, DescribeGroups | Ispeziona i consumer group dai tuoi strumenti. |
| Sondaggio delle capability del broker | GetApiVersions | Chiedi al broker quali versioni delle API del protocollo supporta. |
| SASL | kafkaSaslNone, kafkaSaslPlain | Autenticazione SASL/PLAIN con nome utente e password. |
Un client generico più due discendenti specifici per broker che trasformano le convenzioni di destinazione di RabbitMQ e ActiveMQ in metodi con un nome.
| Funzionalità | STOMP | RabbitMQ | ActiveMQ | Note |
|---|---|---|---|---|
| Inviare un frame | Send | PublishEx | PublishEx | Destinazione, corpo, content type e transazione facoltativa. |
| Sottoscrivere | Subscribe(id, destination) | SubscribeEx | SubscribeEx | I discendenti aggiungono gli argomenti durable, exclusive e modalità di ack. |
| Funzioni per le code | — | SubscribeQueue, PublishQueue, UnSubscribeQueue | SubscribeQueue, PublishQueue, UnSubscribeQueue | Il prefisso di destinazione /queue/, incapsulato. |
| Funzioni per i topic | — | SubscribeTopic, PublishTopic, UnSubscribeTopic | SubscribeTopic, PublishTopic, UnSubscribeTopic | Il prefisso di destinazione /topic/, incapsulato. |
| Funzioni per gli exchange | — | SubscribeExchange, PublishExchange | — | La destinazione /exchange/ di RabbitMQ con un pattern di routing. |
| Code esterne | — | SubscribeQueueOutside, PublishQueueOutside | — | Il /amq/queue/ di RabbitMQ, per le code dichiarate altrove. |
| Code di risposta temporanee | — | SubscribeTemporaryQueue, PublishTemporaryQueue | — | Lo schema richiesta/risposta /temp-queue/ di RabbitMQ. |
| Confermare | ACK / NACK | ✓ | ✓ | Modalità di ack scelta per ogni sottoscrizione (ackAuto e simili). |
| Transazioni | BeginTransaction, CommitTransaction, AbortTransaction | ✓ | ✓ | Raggruppa più frame SEND e ACK in un'unica unità atomica. |
| Ricevute | OnSTOMPReceipt | OnRabbitMQReceipt | OnActiveMQReceipt | Il broker conferma un frame che ha elaborato. |
| Evento del messaggio | OnSTOMPMessage | OnRabbitMQMessage | OnActiveMQMessage | Consegna la destinazione, il corpo e gli header del frame. |
| Heart-beating | HeartBeat, Ping | ✓ | ✓ | Negoziato nel frame CONNECT, in entrambe le direzioni. |
| Negoziazione della versione | Versions.V1_0, V1_1, V1_2 | ✓ | ✓ | Dichiara le versioni che accetti, il broker ne sceglie una. |
| Virtual host | Options.VirtualHost | ✓ | ✓ | Inviato come header host sul CONNECT. |
| Estensioni del broker | — | — | ActiveMQ_Options | Header specifici di ActiveMQ, esposti come proprietà pubblicata. |
Ogni componente di protocollo si collega a un TsgcTCPClient tramite la sua proprietà Client. Quell'unico vettore ti dà TCP semplice e TLS senza cambiare il codice del protocollo.
| Ambito | Dettaglio |
|---|---|
| TCP semplice | Assegna un TsgcTCPClient a Client e il protocollo gira direttamente sul socket, sulla porta nativa del broker. |
| WebSocket | Non incluso in sgcMQ. Un vettore WebSocket, per esempio MQTT su WebSocket o Web-STOMP, richiede il client WebSocket distribuito con sgcWebSockets. |
| TLS | TLSOptions sul vettore, con TLSOptions.IOHandler che sceglie OpenSSL per le build multipiattaforma oppure SChannel su Windows. |
| Certificati client | TLS mutuo attraverso le stesse TLSOptions, da un file PEM, un bundle PKCS#12 o l'archivio certificati di Windows. |
| Proxy | Supporto per i proxy HTTP CONNECT sul vettore, così un broker dietro a un proxy aziendale resta raggiungibile. |
| Riconnessione | WatchDog sul vettore si riconnette dopo una caduta del collegamento, con intervallo e numero di tentativi configurabili. |
| IPv6 | Supportato dal vettore, quindi un indirizzo di broker IPv6 non richiede nessuna configurazione aggiuntiva. |
| Threading | La lettura gira su un thread dedicato. Imposta le opzioni di notifica del vettore per far arrivare gli eventi sul thread principale nel codice VCL e FMX. |
Protocolli pubblicati, e lo stesso sorgente su ogni compilatore supportato.
| Ambito | Dettaglio |
|---|---|
| MQTT | OASIS MQTT 3.1.1 e MQTT 5.0. |
| AMQP 0.9.1 | La specifica AMQP 0-9-1: canali, exchange, code, binding e la classe basic. |
| AMQP 1.0 | OASIS AMQP 1.0, pubblicata anche come ISO/IEC 19464. |
| Kafka | Il protocollo binario di Apache Kafka su TCP, incluso il formato record batch v2. |
| STOMP | STOMP 1.0, 1.1 e 1.2. |
| WebSocket | Non incluso. Un vettore WebSocket richiede sgcWebSockets, che fornisce il client WebSocket. |
| TLS | TLS 1.2 e TLS 1.3 tramite OpenSSL, oppure SChannel di Windows. |
| Compilatori | Delphi e C++ Builder dalla versione 7 alla 13. |
| Piattaforme | Win32, Win64, Linux64, macOS, iOS e Android. |
| Licenze | Autonomo. Il runtime sgcWebSockets Core è incluso e il codice sorgente completo fa parte della fornitura. |