Alles, was sgcMQ kann, aufgeschlüsselt nach den sieben Client-Komponenten und den Spezifikationen, die sie umsetzen. Jede Funktion arbeitet in Delphi und C++ Builder identisch, und jede Lizenz enthält den vollständigen Quellcode. Klicke auf eine Komponente, um ihre eigene Seite mit Nutzung und Beispielen zu öffnen.
3.1.1 und 5.0
0.9.1 und 1.0
Natives Wire-Protokoll
1.0 / 1.1 / 1.2
Reines TCP und TLS
Delphi 7 bis 13, C++ Builder
sgcMQ ist eigenständig. Die sgcWebSockets Core Runtime ist bereits mitgeliefert, es ist also kein Add-on und du musst keine Basislizenz kaufen.
Transport: reines TCP und TLS. sgcMQ verbindet sich über reines TCP und TLS. Wenn du das Protokoll über WebSocket betreiben musst, zum Beispiel MQTT über WebSocket oder AMQP über WebSocket, benötigst du dafür ein sgcWebSockets Paket, das den WebSocket-Client bereitstellt.
Jede Funktion in den Tabellen unten wird über den reinen TCP-Träger TsgcTCPClient erreicht, den sgcMQ von Haus aus mitbringt.
Vier Protokollfamilien, registriert auf der Palettenseite SGC MQ.
| Komponente | Klasse | Familie | Beschreibung |
|---|---|---|---|
| MQTT-Client | TsgcWSPClient_MQTT | MQTT | Publish/Subscribe mit MQTT 3.1.1 und 5.0: QoS 0/1/2, Retained Messages, Last Will and Testament, Sessions und MQTT-5-Eigenschaften. |
| AMQP 0.9.1 Client | TsgcWSPClient_AMQP | AMQP | Channels, Exchanges, Queues und Bindings, Consumer, Bestätigungen, Prefetch-QoS und Transaktionen. |
| AMQP 1.0 Client | TsgcWSPClient_AMQP1 | AMQP | Sessions, Sender- und Receiver-Links, kreditbasierte Flusskontrolle, SASL-Authentifizierung und Helfer für Azure-CBS-Token. |
| Kafka-Client | TsgcWSPClient_Kafka | Kafka | Producer mit Acks und gzip, Consumer Groups mit Rebalance und Offset-Commits, Topic-Verwaltung. |
| STOMP-Client | TsgcWSPClient_STOMP | STOMP | Frames für STOMP 1.0/1.1/1.2: SEND, SUBSCRIBE, ACK, NACK, Receipts, Heart-Beating und Transaktionen. |
| STOMP-RabbitMQ-Client | TsgcWSPClient_STOMP_RabbitMQ | STOMP | STOMP, abgestimmt auf RabbitMQ: Helfer für Queue, Topic, Exchange, externe Queues und temporäre Queues, über TCP oder TLS. |
| STOMP-ActiveMQ-Client | TsgcWSPClient_STOMP_ActiveMQ | STOMP | STOMP, abgestimmt auf Apache ActiveMQ, mit Helfern für Queue und Topic sowie einer Eigenschaft ActiveMQ_Options. |
Das Publish/Subscribe-Protokoll des IoT, mit der kompletten Quality-of-Service-Maschinerie offengelegt statt versteckt.
| Funktion | 3.1.1 | 5.0 | Hinweise |
|---|---|---|---|
| Protokollversion wählen | ✓ | ✓ | MQTTVersion nimmt mqtt311 oder mqtt5 entgegen. |
| QoS 0, 1 und 2 | ✓ | ✓ | Der QoS-2-Austausch wird als OnMQTTPubRec, OnMQTTPubRel und OnMQTTPubComp sichtbar gemacht, nicht verschluckt. |
| Retained Messages | ✓ | ✓ | Das Retain-Flag ist das vierte Argument von Publish. |
| Last Will and Testament | ✓ | ✓ | LastWillTestament transportiert Topic, Nachricht, QoS und Retain. |
| Wildcard-Subscriptions | ✓ | ✓ | + für eine Ebene, # für den Rest des Baums. |
| Sessions | ✓ | ✓ | Das Argument Session von OnMQTTConnect meldet, ob der Broker eine fortgesetzt hat. |
| Publizieren und warten | ✓ | ✓ | PublishAndWait blockiert, bis der Broker das Paket bestätigt. |
| Einen Stream publizieren | ✓ | ✓ | Publish hat eine TStream-Überladung für binäre Payloads. |
| Reason Codes und Namen | — | ✓ | MQTT 5 liefert bei CONNACK und DISCONNECT einen numerischen Reason Code samt Namen zurück. |
| CONNECT-Eigenschaften | — | ✓ | ConnectProperties setzt Session Expiry, Receive Maximum, maximale Paketgröße und Topic Alias Maximum. |
| Topic-Aliase | — | ✓ | Eine kurze Ganzzahl ersetzt auf der Leitung einen langen Topic-Namen und wird bei eingehenden Paketen automatisch aufgelöst. |
| User Properties | — | ✓ | Beliebige Schlüssel/Wert-Paare reisen mit CONNECT, PUBLISH, SUBSCRIBE und DISCONNECT mit. |
| Shared Subscriptions | — | ✓ | Abonniere $share/<group>/<topic>, um Zustellungen auf eine Gruppe von Clients zu verteilen. |
| Erweiterte Authentifizierung | — | ✓ | Der Roundtrip des AUTH-Pakets über Auth und OnMQTTAuth, für Challenge/Response-Verfahren. |
| Keep-Alive | ✓ | ✓ | HeartBeat treibt PINGREQ an, bei der Antwort wird OnMQTTPing ausgelöst. |
Zwei Protokolle, die sich einen Namen teilen und sonst nichts. Deshalb liefert sgcMQ für jedes eine eigene Komponente, statt so zu tun, als passe eine API auf beide.
| Funktion | AMQP 0.9.1 | AMQP 1.0 | Hinweise |
|---|---|---|---|
| Komponente | TsgcWSPClient_AMQP | TsgcWSPClient_AMQP1 | Anderes Wire-Format, anderes Objektmodell, andere Komponente. |
| Multiplexing-Einheit | Channel | Session | OpenChannel gegenüber CreateSession. |
| Topologie-Deklaration | DeclareExchange, DeclareQueue, BindQueue | — | AMQP 1.0 adressiert Knoten auf dem Broker, statt sie zu deklarieren. |
| Senden | PublishMessage(channel, exchange, routingKey, body) | SendMessage(session, link, text) | Routing Key bei 0.9.1, Zieladresse bei 1.0. |
| Empfangen | Consume, dann OnAMQPBasicDeliver | CreateReceiverLink, dann OnAMQPMessage | Beide arbeiten Push-basiert, sobald sie einmal stehen. |
| Bestätigung | AckMessage / RejectMessage | OnAMQPMessageSentAck | 0.9.1 bestätigt ein Delivery Tag, 1.0 schließt eine Zustellung ab. |
| Flusskontrolle | SetQoS-Prefetch, EnableChannel / DisableChannel | Kreditbasiert (CreditSize, WindowSize) | Beide verhindern, dass ein schneller Producer einen langsamen Consumer überrollt. |
| Transaktionen | SelectTransaction, CommitTransaction, RollbackTransaction | — | Die tx-Klasse von 0.9.1, pro Channel verfügbar. |
| Queue-Pflege | PurgeQueue, DeleteQueue, DeleteExchange, UnBindQueue | CloseLink, CloseSession | Jeweils mit einer blockierenden ...Ex-Variante, die auf die Antwort des Brokers wartet. |
| Erneute Zustellung | Recover / RecoverAsync | — | Bitte den Broker, unbestätigte Nachrichten erneut zuzustellen. |
| Authentifizierung | OnAMQPAuthentication, OnAMQPChallenge | Authentication.AuthType, OnAMQPSASLAuthentication | 1.0 bietet SASL ANONYMOUS, PLAIN und EXTERNAL. |
| Cloud-Helfer | — | CreateCBSLink, PutCBSToken, CreateAzureCbsSasToken, CreateAzureCbsJWT | Claims-Based Security für Azure Service Bus und Event Hubs. |
| Verbindungsprüfung | HeartBeat | Ping, AMQPOptions.IdleTimeout | Wird beim Verbinden mit dem Broker ausgehandelt. |
| Verbindungs-Tuning | AMQPOptions.VirtualHost, MaxChannels, MaxFrameSize, Locale | AMQPOptions.ContainerId, ChannelMax, MaxFrameSize, MaxLinksPerSession | Wird im Eröffnungs-Handshake gesendet und mit dem Broker ausgehandelt. |
| Prefetch | SetQoS(channel, prefetchSize, prefetchCount, global) | AMQPOptions.CreditSize | Wie viele unbestätigte Nachrichten der Broker gleichzeitig unterwegs haben darf. |
| Frame-Inspektion | — | OnAMQPBeforeReadFrame, OnAMQPBeforeWriteFrame | Rohe Frames ansehen oder umschreiben, bevor sie verarbeitet oder gesendet werden. |
Das binäre Kafka-Protokoll in Object Pascal implementiert, ohne REST-Proxy davor und ohne librdkafka darunter.
| Funktion | API | Hinweise |
|---|---|---|
| Einen Record produzieren | Produce(topic, value, key, partition) | Key und Partition sind optional. ProduceBytes nimmt für beides TBytes. |
| Einen Batch produzieren | ProduceMessages(topic, partition, messages) | Liefert die Produce-Antwort des Brokers für den gesamten Batch. |
| Zustellgarantie | KafkaOptions.Producer.Acks | kafkaAcksNone, kafkaAcksLeader oder kafkaAcksAll. |
| Komprimierung | KafkaOptions.Producer.Compression | kafkaCompressionNone oder kafkaCompressionGzip. |
| Konsumieren | Subscribe([topics]), dann Poll(timeoutMs) | Poll liefert eine TsgcKafkaMessages-Liste und löst zusätzlich OnKafkaMessage pro Record aus. |
| Consumer Groups | KafkaOptions.Consumer.GroupId | Coordinator-Discovery, Join, Sync und Heartbeat werden für dich erledigt. OnKafkaRebalance meldet Änderungen der Zuordnung. |
| Offset-Strategie | KafkaOptions.Consumer.OffsetReset | kafkaOffsetEarliest oder kafkaOffsetLatest, wenn kein committeter Offset vorliegt. |
| Offsets committen | CommitSync, CommitOffset(topic, partition, offset) | Oder setze Consumer.AutoCommit zusammen mit AutoCommitIntervalMs. |
| Eine Partition direkt lesen | FetchMessages(topic, partition, offset, maxBytes) | Umgeht die Consumer Group vollständig. |
| Offsets abfragen | GetEarliestOffset, GetLatestOffset, GetCommittedOffset | Pro Topic und Partition. |
| Fetch-Tuning | Consumer.MinBytes, MaxBytes, MaxPartitionBytes, MaxWaitMs | Wäge Latenz gegen Batch-Größe ab. |
| Topic-Verwaltung | CreateTopic, DeleteTopic, GetMetadata | Partitionsanzahl und Replikationsfaktor beim Anlegen. |
| Gruppenverwaltung | ListGroups, DescribeGroups | Untersuche Consumer Groups aus deinem eigenen Werkzeug heraus. |
| Broker-Fähigkeiten abfragen | GetApiVersions | Frage den Broker, welche Protokoll-API-Versionen er unterstützt. |
| SASL | kafkaSaslNone, kafkaSaslPlain | Authentifizierung mit Benutzername und Passwort über SASL/PLAIN. |
Ein generischer Client plus zwei broker-spezifische Nachfahren, die die Destination-Konventionen von RabbitMQ und ActiveMQ in benannte Methoden übersetzen.
| Funktion | STOMP | RabbitMQ | ActiveMQ | Hinweise |
|---|---|---|---|---|
| Einen Frame senden | Send | PublishEx | PublishEx | Destination, Body, Content-Type und optionale Transaktion. |
| Abonnieren | Subscribe(id, destination) | SubscribeEx | SubscribeEx | Die Nachfahren ergänzen Argumente für Durable, Exclusive und Ack-Modus. |
| Queue-Helfer | — | SubscribeQueue, PublishQueue, UnSubscribeQueue | SubscribeQueue, PublishQueue, UnSubscribeQueue | Das Destination-Präfix /queue/, gekapselt. |
| Topic-Helfer | — | SubscribeTopic, PublishTopic, UnSubscribeTopic | SubscribeTopic, PublishTopic, UnSubscribeTopic | Das Destination-Präfix /topic/, gekapselt. |
| Exchange-Helfer | — | SubscribeExchange, PublishExchange | — | Die /exchange/-Destination von RabbitMQ mit einem Routing-Muster. |
| Externe Queues | — | SubscribeQueueOutside, PublishQueueOutside | — | Die /amq/queue/-Destination von RabbitMQ, für anderswo deklarierte Queues. |
| Temporäre Antwort-Queues | — | SubscribeTemporaryQueue, PublishTemporaryQueue | — | Das Request/Reply-Muster /temp-queue/ von RabbitMQ. |
| Bestätigen | ACK / NACK | ✓ | ✓ | Der Ack-Modus wird pro Subscription gewählt (ackAuto und Verwandte). |
| Transaktionen | BeginTransaction, CommitTransaction, AbortTransaction | ✓ | ✓ | Fasse mehrere SEND- und ACK-Frames zu einer atomaren Einheit zusammen. |
| Receipts | OnSTOMPReceipt | OnRabbitMQReceipt | OnActiveMQReceipt | Der Broker bestätigt einen Frame, den er verarbeitet hat. |
| Nachrichten-Ereignis | OnSTOMPMessage | OnRabbitMQMessage | OnActiveMQMessage | Liefert Destination, Body und die Frame-Header. |
| Heart-Beating | HeartBeat, Ping | ✓ | ✓ | Im CONNECT-Frame ausgehandelt, in beide Richtungen. |
| Versionsaushandlung | Versions.V1_0, V1_1, V1_2 | ✓ | ✓ | Gib die Versionen an, die du akzeptierst, der Broker wählt eine davon. |
| Virtueller Host | Options.VirtualHost | ✓ | ✓ | Wird bei CONNECT als host-Header gesendet. |
| Broker-Erweiterungen | — | — | ActiveMQ_Options | ActiveMQ-spezifische Header, als published Property verfügbar. |
Jede Protokollkomponente hängt sich über ihre Eigenschaft Client an einen TsgcTCPClient. Dieser eine Träger liefert dir reines TCP und TLS, ohne dass du den Protokollcode änderst.
| Bereich | Detail |
|---|---|
| Reines TCP | Weise Client einen TsgcTCPClient zu, und das Protokoll läuft direkt über den Socket, auf dem nativen Port des Brokers. |
| WebSocket | Nicht in sgcMQ enthalten. Ein WebSocket-Träger, zum Beispiel MQTT über WebSocket oder Web-STOMP, benötigt den WebSocket-Client, der mit sgcWebSockets geliefert wird. |
| TLS | TLSOptions auf dem Träger, wobei TLSOptions.IOHandler OpenSSL für plattformübergreifende Builds oder SChannel unter Windows auswählt. |
| Client-Zertifikate | Mutual TLS über dieselben TLSOptions, aus einer PEM-Datei, einem PKCS#12-Bundle oder dem Windows-Zertifikatspeicher. |
| Proxys | Unterstützung für HTTP-CONNECT-Proxys auf dem Träger, damit auch ein Broker hinter einem Firmen-Proxy erreichbar ist. |
| Reconnect | WatchDog auf dem Träger verbindet nach einem Abbruch neu, mit konfigurierbarem Intervall und konfigurierbarer Versuchsanzahl. |
| IPv6 | Vom Träger unterstützt, eine IPv6-Broker-Adresse braucht also keine zusätzliche Konfiguration. |
| Threading | Das Lesen läuft in einem eigenen Thread. Setze die Notify-Einstellungen des Trägers, um Ereignisse für VCL- und FMX-Code auf den Haupt-Thread zu marshallen. |
Veröffentlichte Protokolle, und derselbe Quellcode über jeden unterstützten Compiler hinweg.
| Bereich | Detail |
|---|---|
| MQTT | OASIS MQTT 3.1.1 und MQTT 5.0. |
| AMQP 0.9.1 | Die Spezifikation AMQP 0-9-1: Channels, Exchanges, Queues, Bindings und die basic-Klasse. |
| AMQP 1.0 | OASIS AMQP 1.0, auch veröffentlicht als ISO/IEC 19464. |
| Kafka | Das Wire-Protokoll von Apache Kafka über TCP, einschließlich des Record-Batch-Formats v2. |
| STOMP | STOMP 1.0, 1.1 und 1.2. |
| WebSocket | Nicht enthalten. Ein WebSocket-Träger erfordert sgcWebSockets, das den WebSocket-Client bereitstellt. |
| TLS | TLS 1.2 und TLS 1.3 über OpenSSL oder Windows SChannel. |
| Compiler | Delphi und C++ Builder 7 bis 13. |
| Plattformen | Win32, Win64, Linux64, macOS, iOS und Android. |
| Lizenzierung | Eigenständig. Die sgcWebSockets Core Runtime ist mitgeliefert und der vollständige Quellcode ist enthalten. |