Alles wat sgcMQ doet, uitgesplitst over de zeven clientcomponenten en de specificaties die ze implementeren. Elke mogelijkheid werkt hetzelfde in Delphi en C++ Builder, en elke licentie bevat de volledige broncode. Klik op een component voor de eigen pagina met gebruik en voorbeelden.
3.1.1 en 5.0
0.9.1 en 1.0
Native wireprotocol
1.0 / 1.1 / 1.2
Gewoon TCP en TLS
Delphi 7 tot 13, C++ Builder
sgcMQ is zelfstandig. De sgcWebSockets Core-runtime wordt meegeleverd, dus het is geen add-on en er is geen basislicentie die je moet kopen.
Transport: gewoon TCP en TLS. sgcMQ verbindt via gewoon TCP en TLS. Wil je het protocol over WebSocket draaien, bijvoorbeeld MQTT over WebSocket of AMQP over WebSocket, dan heb je een sgcWebSockets-pakket nodig, dat de WebSocket-client levert.
Elke mogelijkheid in de tabellen hieronder loopt over de kale TCP-drager TsgcTCPClient, die sgcMQ standaard meelevert.
Vier protocolfamilies, geregistreerd op de paletpagina SGC MQ.
| Component | Klasse | Familie | Beschrijving |
|---|---|---|---|
| MQTT Client | TsgcWSPClient_MQTT | MQTT | MQTT 3.1.1 en 5.0 publish/subscribe: QoS 0/1/2, retained messages, Last Will and Testament, sessies en MQTT 5-properties. |
| AMQP 0.9.1 Client | TsgcWSPClient_AMQP | AMQP | Channels, exchanges, wachtrijen en bindings, consumers, bevestigingen, prefetch-QoS en transacties. |
| AMQP 1.0 Client | TsgcWSPClient_AMQP1 | AMQP | Sessies, sender- en receiverlinks, kredietgebaseerde flow control, SASL-authenticatie en helpers voor Azure CBS-tokens. |
| Kafka Client | TsgcWSPClient_Kafka | Kafka | Producer met acks en gzip, consumergroepen met rebalance en offset-commits, topicbeheer. |
| STOMP Client | TsgcWSPClient_STOMP | STOMP | STOMP 1.0/1.1/1.2-frames: SEND, SUBSCRIBE, ACK, NACK, receipts, heart-beating en transacties. |
| STOMP RabbitMQ Client | TsgcWSPClient_STOMP_RabbitMQ | STOMP | STOMP afgestemd op RabbitMQ: helpers voor queue, topic, exchange, externe queue en tijdelijke queue, via TCP of TLS. |
| STOMP ActiveMQ Client | TsgcWSPClient_STOMP_ActiveMQ | STOMP | STOMP afgestemd op Apache ActiveMQ, met helpers voor queue en topic plus een ActiveMQ_Options-eigenschap. |
Het publish/subscribe-protocol van IoT, waarbij de volledige quality-of-service-machinerie zichtbaar is in plaats van verborgen.
| Mogelijkheid | 3.1.1 | 5.0 | Opmerkingen |
|---|---|---|---|
| Protocolversie kiezen | ✓ | ✓ | MQTTVersion accepteert mqtt311 of mqtt5. |
| QoS 0, 1 en 2 | ✓ | ✓ | De QoS 2-uitwisseling wordt zichtbaar gemaakt als OnMQTTPubRec, OnMQTTPubRel en OnMQTTPubComp, niet weggemoffeld. |
| Retained messages | ✓ | ✓ | De retain-vlag is het vierde argument van Publish. |
| Last Will and Testament | ✓ | ✓ | LastWillTestament bevat topic, bericht, QoS en retain. |
| Wildcard-abonnementen | ✓ | ✓ | + voor één niveau, # voor de rest van de boom. |
| Sessies | ✓ | ✓ | Het argument Session van OnMQTTConnect meldt of de broker er een heeft hervat. |
| Publiceren en wachten | ✓ | ✓ | PublishAndWait blokkeert totdat de broker het pakket bevestigt. |
| Een stream publiceren | ✓ | ✓ | Publish heeft een TStream-overload voor binaire payloads. |
| Reason codes en namen | — | ✓ | MQTT 5 geeft bij CONNACK en DISCONNECT een numerieke reason code en de bijbehorende naam terug. |
| CONNECT-properties | — | ✓ | ConnectProperties stelt session expiry, receive maximum, maximale pakketgrootte en topic alias maximum in. |
| Topic-aliassen | — | ✓ | Een kort geheel getal vervangt een lange topicnaam op de lijn, en wordt bij binnenkomende pakketten automatisch weer omgezet. |
| User properties | — | ✓ | Willekeurige sleutel/waarde-paren reizen mee met CONNECT, PUBLISH, SUBSCRIBE en DISCONNECT. |
| Gedeelde abonnementen | — | ✓ | Abonneer je op $share/<group>/<topic> om afleveringen over een groep clients te verdelen. |
| Uitgebreide authenticatie | — | ✓ | De heen-en-weerreis van het AUTH-pakket via Auth en OnMQTTAuth, voor challenge/response-schema's. |
| Keep-alive | ✓ | ✓ | HeartBeat stuurt PINGREQ aan, waarbij OnMQTTPing bij het antwoord wordt aangeroepen. |
Twee protocollen die alleen een naam delen en verder niets, dus sgcMQ levert voor elk een apart component in plaats van te doen alsof één API voor beide past.
| Mogelijkheid | AMQP 0.9.1 | AMQP 1.0 | Opmerkingen |
|---|---|---|---|
| Component | TsgcWSPClient_AMQP | TsgcWSPClient_AMQP1 | Ander wireformaat, ander objectmodel, ander component. |
| Eenheid van multiplexen | Channel | Session | OpenChannel tegenover CreateSession. |
| Topologie declareren | DeclareExchange, DeclareQueue, BindQueue | — | AMQP 1.0 adresseert nodes op de broker in plaats van ze te declareren. |
| Verzenden | PublishMessage(channel, exchange, routingKey, body) | SendMessage(session, link, text) | Routing key bij 0.9.1, doeladres bij 1.0. |
| Ontvangen | Consume en daarna OnAMQPBasicDeliver | CreateReceiverLink en daarna OnAMQPMessage | Beide werken push-gebaseerd zodra ze zijn opgezet. |
| Bevestiging | AckMessage / RejectMessage | OnAMQPMessageSentAck | 0.9.1 bevestigt een delivery tag, 1.0 settelt een delivery. |
| Flow control | SetQoS-prefetch, EnableChannel / DisableChannel | Kredietgebaseerd (CreditSize, WindowSize) | Beide voorkomen dat een snelle producer een trage consumer overspoelt. |
| Transacties | SelectTransaction, CommitTransaction, RollbackTransaction | — | De tx-klasse van 0.9.1, per channel beschikbaar. |
| Onderhoud van wachtrijen | PurgeQueue, DeleteQueue, DeleteExchange, UnBindQueue | CloseLink, CloseSession | Elk met een blokkerende ...Ex-variant die op het antwoord van de broker wacht. |
| Opnieuw afleveren | Recover / RecoverAsync | — | Vraag de broker om onbevestigde berichten opnieuw af te leveren. |
| Authenticatie | OnAMQPAuthentication, OnAMQPChallenge | Authentication.AuthType, OnAMQPSASLAuthentication | 1.0 biedt SASL ANONYMOUS, PLAIN en EXTERNAL. |
| Cloudhelpers | — | CreateCBSLink, PutCBSToken, CreateAzureCbsSasToken, CreateAzureCbsJWT | Claims-Based Security voor Azure Service Bus en Event Hubs. |
| Verbinding levend houden | HeartBeat | Ping, AMQPOptions.IdleTimeout | Wordt bij het verbinden met de broker onderhandeld. |
| Verbinding afstemmen | AMQPOptions.VirtualHost, MaxChannels, MaxFrameSize, Locale | AMQPOptions.ContainerId, ChannelMax, MaxFrameSize, MaxLinksPerSession | Wordt in de openingshandshake verstuurd en met de broker onderhandeld. |
| Prefetch | SetQoS(channel, prefetchSize, prefetchCount, global) | AMQPOptions.CreditSize | Hoeveel onbevestigde berichten de broker onderweg mag hebben. |
| Frames inspecteren | — | OnAMQPBeforeReadFrame, OnAMQPBeforeWriteFrame | Bekijk of herschrijf ruwe frames voordat ze worden verwerkt of verstuurd. |
Het binaire Kafka-protocol geïmplementeerd in Object Pascal, zonder REST-proxy ervoor en zonder librdkafka eronder.
| Mogelijkheid | API | Opmerkingen |
|---|---|---|
| Een record produceren | Produce(topic, value, key, partition) | Key en partition zijn optioneel. ProduceBytes neemt voor beide TBytes. |
| Een batch produceren | ProduceMessages(topic, partition, messages) | Geeft het produce-antwoord van de broker voor de hele batch terug. |
| Afleveringsgarantie | KafkaOptions.Producer.Acks | kafkaAcksNone, kafkaAcksLeader of kafkaAcksAll. |
| Compressie | KafkaOptions.Producer.Compression | kafkaCompressionNone of kafkaCompressionGzip. |
| Consumeren | Subscribe([topics]) en daarna Poll(timeoutMs) | Poll geeft een TsgcKafkaMessages-lijst terug en roept daarnaast per record OnKafkaMessage aan. |
| Consumergroepen | KafkaOptions.Consumer.GroupId | Het vinden van de coördinator, join, sync en heartbeat worden voor je afgehandeld. OnKafkaRebalance meldt wijzigingen in de toewijzing. |
| Offsetbeleid | KafkaOptions.Consumer.OffsetReset | kafkaOffsetEarliest of kafkaOffsetLatest wanneer er geen vastgelegde offset is. |
| Offsets vastleggen | CommitSync, CommitOffset(topic, partition, offset) | Of stel Consumer.AutoCommit in met AutoCommitIntervalMs. |
| Een partitie rechtstreeks lezen | FetchMessages(topic, partition, offset, maxBytes) | Slaat de consumergroep volledig over. |
| Offsets opzoeken | GetEarliestOffset, GetLatestOffset, GetCommittedOffset | Per topic en partitie. |
| Fetch afstemmen | Consumer.MinBytes, MaxBytes, MaxPartitionBytes, MaxWaitMs | Weeg latency af tegen batchgrootte. |
| Topicbeheer | CreateTopic, DeleteTopic, GetMetadata | Aantal partities en replicatiefactor bij het aanmaken. |
| Groepsbeheer | ListGroups, DescribeGroups | Inspecteer consumergroepen vanuit je eigen tooling. |
| Mogelijkheden van de broker opvragen | GetApiVersions | Vraag de broker welke protocol-API-versies hij ondersteunt. |
| SASL | kafkaSaslNone, kafkaSaslPlain | SASL/PLAIN-authenticatie met gebruikersnaam en wachtwoord. |
Eén generieke client plus twee brokerspecifieke afgeleiden die de destination-conventies van RabbitMQ en ActiveMQ omzetten in methodes met een eigen naam.
| Mogelijkheid | STOMP | RabbitMQ | ActiveMQ | Opmerkingen |
|---|---|---|---|---|
| Een frame versturen | Send | PublishEx | PublishEx | Destination, body, contenttype en optionele transactie. |
| Abonneren | Subscribe(id, destination) | SubscribeEx | SubscribeEx | De afgeleiden voegen argumenten voor durable, exclusive en ack-mode toe. |
| Queue-helpers | — | SubscribeQueue, PublishQueue, UnSubscribeQueue | SubscribeQueue, PublishQueue, UnSubscribeQueue | De destination-prefix /queue/, ingepakt. |
| Topic-helpers | — | SubscribeTopic, PublishTopic, UnSubscribeTopic | SubscribeTopic, PublishTopic, UnSubscribeTopic | De destination-prefix /topic/, ingepakt. |
| Exchange-helpers | — | SubscribeExchange, PublishExchange | — | De /exchange/-destination van RabbitMQ met een routingpatroon. |
| Externe wachtrijen | — | SubscribeQueueOutside, PublishQueueOutside | — | De /amq/queue/ van RabbitMQ, voor wachtrijen die elders zijn gedeclareerd. |
| Tijdelijke antwoordwachtrijen | — | SubscribeTemporaryQueue, PublishTemporaryQueue | — | Het request/reply-patroon /temp-queue/ van RabbitMQ. |
| Bevestigen | ACK / NACK | ✓ | ✓ | Ack-modus per abonnement gekozen (ackAuto en verwanten). |
| Transacties | BeginTransaction, CommitTransaction, AbortTransaction | ✓ | ✓ | Bundel meerdere SEND- en ACK-frames tot één atomaire eenheid. |
| Receipts | OnSTOMPReceipt | OnRabbitMQReceipt | OnActiveMQReceipt | De broker bevestigt een frame dat hij heeft verwerkt. |
| Bericht-event | OnSTOMPMessage | OnRabbitMQMessage | OnActiveMQMessage | Levert de destination, de body en de frameheaders. |
| Heart-beating | HeartBeat, Ping | ✓ | ✓ | Onderhandeld in het CONNECT-frame, in beide richtingen. |
| Versie-onderhandeling | Versions.V1_0, V1_1, V1_2 | ✓ | ✓ | Geef aan welke versies je accepteert, de broker kiest er een. |
| Virtual host | Options.VirtualHost | ✓ | ✓ | Wordt bij CONNECT als de host-header verstuurd. |
| Brokeruitbreidingen | — | — | ActiveMQ_Options | ActiveMQ-specifieke headers, beschikbaar als published property. |
Elk protocolcomponent koppelt zich via de eigenschap Client aan een TsgcTCPClient. Die ene drager geeft je gewoon TCP en TLS zonder dat je de protocolcode aanpast.
| Gebied | Detail |
|---|---|
| Gewoon TCP | Wijs een TsgcTCPClient toe aan Client en het protocol loopt rechtstreeks over de socket, op de eigen poort van de broker. |
| WebSocket | Zit niet in sgcMQ. Een WebSocket-drager, bijvoorbeeld MQTT over WebSocket of Web-STOMP, vereist de WebSocket-client die bij sgcWebSockets wordt geleverd. |
| TLS | TLSOptions op de drager, waarbij TLSOptions.IOHandler kiest tussen OpenSSL voor platformonafhankelijke builds of SChannel op Windows. |
| Clientcertificaten | Mutual TLS via dezelfde TLSOptions, vanuit een PEM-bestand, een PKCS#12-bundel of het certificaatarchief van Windows. |
| Proxy's | Ondersteuning voor HTTP CONNECT-proxy's op de drager, zodat een broker achter een bedrijfsproxy bereikbaar is. |
| Opnieuw verbinden | WatchDog op de drager maakt na een verbroken verbinding opnieuw verbinding, met een instelbaar interval en aantal pogingen. |
| IPv6 | Ondersteund door de drager, dus een IPv6-brokeradres vraagt geen extra configuratie. |
| Threading | Het lezen draait op een eigen thread. Stel de notify-instellingen van de drager in om events voor VCL- en FMX-code naar de hoofdthread te sturen. |
Gepubliceerde protocollen, en dezelfde broncode voor elke ondersteunde compiler.
| Gebied | Detail |
|---|---|
| MQTT | OASIS MQTT 3.1.1 en MQTT 5.0. |
| AMQP 0.9.1 | De AMQP 0-9-1-specificatie: channels, exchanges, wachtrijen, bindings en de basic class. |
| AMQP 1.0 | OASIS AMQP 1.0, ook gepubliceerd als ISO/IEC 19464. |
| Kafka | Het Apache Kafka-wireprotocol over TCP, inclusief het v2 record batch-formaat. |
| STOMP | STOMP 1.0, 1.1 en 1.2. |
| WebSocket | Niet inbegrepen. Een WebSocket-drager vereist sgcWebSockets, dat de WebSocket-client levert. |
| TLS | TLS 1.2 en TLS 1.3 via OpenSSL, of Windows SChannel. |
| Compilers | Delphi en C++ Builder 7 tot en met 13. |
| Platforms | Win32, Win64, Linux64, macOS, iOS en Android. |
| Licenties | Standalone. De sgcWebSockets Core-runtime is meegeleverd en de volledige broncode is inbegrepen. |