Tout ce que fait sgcMQ, réparti sur les sept composants clients et les spécifications qu'ils implémentent. Chaque capacité fonctionne de la même façon en Delphi et en C++ Builder, et chaque licence est livrée avec le code source complet. Clique sur un composant pour ouvrir sa page dédiée avec son utilisation et des exemples.
3.1.1 et 5.0
0.9.1 et 1.0
Protocole binaire natif
1.0 / 1.1 / 1.2
TCP simple et TLS
Delphi 7 à 13, C++ Builder
sgcMQ est autonome. Il est livré avec le runtime sgcWebSockets Core inclus, ce n'est donc pas un complément et il n'y a aucune licence de base à acheter.
Transport : TCP simple et TLS. sgcMQ se connecte en TCP simple et en TLS. Si tu as besoin de faire tourner le protocole sur WebSocket, par exemple MQTT sur WebSocket ou AMQP sur WebSocket, cela nécessite un package sgcWebSockets, qui fournit le client WebSocket.
Toutes les capacités des tableaux ci-dessous passent par le support de transport TCP brut TsgcTCPClient, que sgcMQ livre dans la boîte.
Quatre familles de protocoles, enregistrées sur la page de palette SGC MQ.
| Composant | Classe | Famille | Description |
|---|---|---|---|
| Client MQTT | TsgcWSPClient_MQTT | MQTT | Publication et abonnement MQTT 3.1.1 et 5.0 : QoS 0/1/2, messages retenus, Last Will and Testament, sessions et propriétés MQTT 5. |
| Client AMQP 0.9.1 | TsgcWSPClient_AMQP | AMQP | Canaux, exchanges, files d'attente et liaisons, consommateurs, acquittements, QoS de prélecture et transactions. |
| Client AMQP 1.0 | TsgcWSPClient_AMQP1 | AMQP | Sessions, liens émetteurs et récepteurs, contrôle de flux par crédits, authentification SASL et utilitaires de jetons CBS pour Azure. |
| Client Kafka | TsgcWSPClient_Kafka | Kafka | Producteur avec acquittements et gzip, groupes de consommateurs avec rééquilibrage et validation des offsets, administration des topics. |
| Client STOMP | TsgcWSPClient_STOMP | STOMP | Trames STOMP 1.0/1.1/1.2 : SEND, SUBSCRIBE, ACK, NACK, accusés de réception, heart-beating et transactions. |
| Client STOMP RabbitMQ | TsgcWSPClient_STOMP_RabbitMQ | STOMP | STOMP réglé pour RabbitMQ : utilitaires de file d'attente, topic, exchange, file externe et file temporaire, en TCP ou TLS. |
| Client STOMP ActiveMQ | TsgcWSPClient_STOMP_ActiveMQ | STOMP | STOMP réglé pour Apache ActiveMQ, avec des utilitaires de files d'attente et de topics, plus une propriété ActiveMQ_Options. |
Le protocole de publication et d'abonnement de l'IoT, avec toute la mécanique de qualité de service exposée plutôt que cachée.
| Capacité | 3.1.1 | 5.0 | Notes |
|---|---|---|---|
| Choix de la version du protocole | ✓ | ✓ | MQTTVersion accepte mqtt311 ou mqtt5. |
| QoS 0, 1 et 2 | ✓ | ✓ | L'échange QoS 2 est exposé via OnMQTTPubRec, OnMQTTPubRel et OnMQTTPubComp, pas escamoté. |
| Messages retenus | ✓ | ✓ | L'indicateur de rétention est le quatrième argument de Publish. |
| Last Will and Testament | ✓ | ✓ | LastWillTestament porte le topic, le message, la QoS et la rétention. |
| Abonnements avec jokers | ✓ | ✓ | + pour un niveau, # pour le reste de l'arborescence. |
| Sessions | ✓ | ✓ | L'argument Session d'OnMQTTConnect indique si le broker en a repris une. |
| Publier et attendre | ✓ | ✓ | PublishAndWait bloque jusqu'à ce que le broker acquitte le paquet. |
| Publier un flux | ✓ | ✓ | Publish possède une surcharge TStream pour les charges utiles binaires. |
| Codes et noms de raison | — | ✓ | MQTT 5 renvoie un code de raison numérique et son nom sur CONNACK et DISCONNECT. |
| Propriétés CONNECT | — | ✓ | ConnectProperties règle l'expiration de session, le maximum en réception, la taille maximale de paquet et le maximum d'alias de topics. |
| Alias de topics | — | ✓ | Un entier court remplace un nom de topic long sur le fil, résolu automatiquement sur les paquets entrants. |
| Propriétés utilisateur | — | ✓ | Des paires clé/valeur arbitraires voyagent avec CONNECT, PUBLISH, SUBSCRIBE et DISCONNECT. |
| Abonnements partagés | — | ✓ | Abonne-toi à $share/<group>/<topic> pour répartir les livraisons sur un groupe de clients. |
| Authentification enrichie | — | ✓ | L'aller-retour du paquet AUTH via Auth et OnMQTTAuth, pour les schémas défi/réponse. |
| Keep-alive | ✓ | ✓ | HeartBeat pilote PINGREQ, avec OnMQTTPing déclenché à la réponse. |
Deux protocoles qui partagent un nom et rien d'autre, sgcMQ livre donc un composant distinct pour chacun plutôt que de prétendre qu'une seule API convient aux deux.
| Capacité | AMQP 0.9.1 | AMQP 1.0 | Notes |
|---|---|---|---|
| Composant | TsgcWSPClient_AMQP | TsgcWSPClient_AMQP1 | Format binaire différent, modèle d'objets différent, composant différent. |
| Unité de multiplexage | Canal | Session | OpenChannel face à CreateSession. |
| Déclaration de topologie | DeclareExchange, DeclareQueue, BindQueue | — | AMQP 1.0 adresse des nœuds sur le broker au lieu de les déclarer. |
| Envoi | PublishMessage(channel, exchange, routingKey, body) | SendMessage(session, link, text) | Clé de routage en 0.9.1, adresse cible en 1.0. |
| Réception | Consume puis OnAMQPBasicDeliver | CreateReceiverLink puis OnAMQPMessage | Les deux fonctionnent en push une fois établis. |
| Acquittement | AckMessage / RejectMessage | OnAMQPMessageSentAck | 0.9.1 acquitte une étiquette de livraison, 1.0 règle une livraison. |
| Contrôle de flux | Prélecture SetQoS, EnableChannel / DisableChannel | Par crédits (CreditSize, WindowSize) | Les deux empêchent un producteur rapide de submerger un consommateur lent. |
| Transactions | SelectTransaction, CommitTransaction, RollbackTransaction | — | La classe tx de 0.9.1, exposée par canal. |
| Maintenance des files | PurgeQueue, DeleteQueue, DeleteExchange, UnBindQueue | CloseLink, CloseSession | Chacune avec une variante bloquante ...Ex qui attend la réponse du broker. |
| Relivraison | Recover / RecoverAsync | — | Demander au broker de relivrer les messages non acquittés. |
| Authentification | OnAMQPAuthentication, OnAMQPChallenge | Authentication.AuthType, OnAMQPSASLAuthentication | 1.0 propose SASL ANONYMOUS, PLAIN et EXTERNAL. |
| Utilitaires cloud | — | CreateCBSLink, PutCBSToken, CreateAzureCbsSasToken, CreateAzureCbsJWT | Claims-Based Security pour Azure Service Bus et Event Hubs. |
| Maintien en vie | HeartBeat | Ping, AMQPOptions.IdleTimeout | Négocié avec le broker à la connexion. |
| Réglage de la connexion | AMQPOptions.VirtualHost, MaxChannels, MaxFrameSize, Locale | AMQPOptions.ContainerId, ChannelMax, MaxFrameSize, MaxLinksPerSession | Envoyé dans la poignée de main d'ouverture et négocié avec le broker. |
| Prélecture | SetQoS(channel, prefetchSize, prefetchCount, global) | AMQPOptions.CreditSize | Combien de messages non acquittés le broker peut avoir en vol. |
| Inspection des trames | — | OnAMQPBeforeReadFrame, OnAMQPBeforeWriteFrame | Voir ou réécrire les trames brutes avant leur traitement ou leur envoi. |
Le protocole binaire de Kafka implémenté en Object Pascal, sans proxy REST devant ni librdkafka en dessous.
| Capacité | API | Notes |
|---|---|---|
| Produire un enregistrement | Produce(topic, value, key, partition) | La clé et la partition sont facultatives. ProduceBytes accepte des TBytes pour les deux. |
| Produire un lot | ProduceMessages(topic, partition, messages) | Renvoie la réponse de production du broker pour tout le lot. |
| Garantie de livraison | KafkaOptions.Producer.Acks | kafkaAcksNone, kafkaAcksLeader ou kafkaAcksAll. |
| Compression | KafkaOptions.Producer.Compression | kafkaCompressionNone ou kafkaCompressionGzip. |
| Consommer | Subscribe([topics]) puis Poll(timeoutMs) | Poll renvoie une liste TsgcKafkaMessages et déclenche aussi OnKafkaMessage par enregistrement. |
| Groupes de consommateurs | KafkaOptions.Consumer.GroupId | La découverte du coordinateur, l'adhésion, la synchronisation et le heartbeat sont pris en charge pour toi. OnKafkaRebalance signale les changements d'affectation. |
| Politique d'offset | KafkaOptions.Consumer.OffsetReset | kafkaOffsetEarliest ou kafkaOffsetLatest lorsqu'aucun offset n'est validé. |
| Valider les offsets | CommitSync, CommitOffset(topic, partition, offset) | Ou active Consumer.AutoCommit avec AutoCommitIntervalMs. |
| Lire une partition directement | FetchMessages(topic, partition, offset, maxBytes) | Contourne entièrement le groupe de consommateurs. |
| Consultation des offsets | GetEarliestOffset, GetLatestOffset, GetCommittedOffset | Par topic et par partition. |
| Réglage de la récupération | Consumer.MinBytes, MaxBytes, MaxPartitionBytes, MaxWaitMs | Arbitrer entre latence et taille de lot. |
| Administration des topics | CreateTopic, DeleteTopic, GetMetadata | Nombre de partitions et facteur de réplication à la création. |
| Administration des groupes | ListGroups, DescribeGroups | Inspecter les groupes de consommateurs depuis tes propres outils. |
| Sonde des capacités du broker | GetApiVersions | Demander au broker quelles versions d'API du protocole il prend en charge. |
| SASL | kafkaSaslNone, kafkaSaslPlain | Authentification SASL/PLAIN par nom d'utilisateur et mot de passe. |
Un client générique plus deux descendants propres à un broker, qui transforment les conventions de destination de RabbitMQ et d'ActiveMQ en méthodes nommées.
| Capacité | STOMP | RabbitMQ | ActiveMQ | Notes |
|---|---|---|---|---|
| Envoyer une trame | Send | PublishEx | PublishEx | Destination, corps, type de contenu et transaction facultative. |
| S'abonner | Subscribe(id, destination) | SubscribeEx | SubscribeEx | Les descendants ajoutent les arguments durable, exclusive et mode d'acquittement. |
| Utilitaires de files d'attente | — | SubscribeQueue, PublishQueue, UnSubscribeQueue | SubscribeQueue, PublishQueue, UnSubscribeQueue | Le préfixe de destination /queue/, encapsulé. |
| Utilitaires de topics | — | SubscribeTopic, PublishTopic, UnSubscribeTopic | SubscribeTopic, PublishTopic, UnSubscribeTopic | Le préfixe de destination /topic/, encapsulé. |
| Utilitaires d'exchanges | — | SubscribeExchange, PublishExchange | — | La destination /exchange/ de RabbitMQ avec un motif de routage. |
| Files externes | — | SubscribeQueueOutside, PublishQueueOutside | — | Le /amq/queue/ de RabbitMQ, pour des files déclarées ailleurs. |
| Files de réponse temporaires | — | SubscribeTemporaryQueue, PublishTemporaryQueue | — | Le motif requête/réponse /temp-queue/ de RabbitMQ. |
| Acquitter | ACK / NACK | ✓ | ✓ | Mode d'acquittement choisi par abonnement (ackAuto et compagnie). |
| Transactions | BeginTransaction, CommitTransaction, AbortTransaction | ✓ | ✓ | Regrouper plusieurs trames SEND et ACK en une unité atomique. |
| Accusés de réception | OnSTOMPReceipt | OnRabbitMQReceipt | OnActiveMQReceipt | Le broker confirme une trame qu'il a traitée. |
| Événement de message | OnSTOMPMessage | OnRabbitMQMessage | OnActiveMQMessage | Livre la destination, le corps et les en-têtes de la trame. |
| Heart-beating | HeartBeat, Ping | ✓ | ✓ | Négocié dans la trame CONNECT, dans les deux sens. |
| Négociation de version | Versions.V1_0, V1_1, V1_2 | ✓ | ✓ | Annonce les versions que tu acceptes, le broker en choisit une. |
| Hôte virtuel | Options.VirtualHost | ✓ | ✓ | Envoyé comme en-tête host sur CONNECT. |
| Extensions du broker | — | — | ActiveMQ_Options | En-têtes propres à ActiveMQ, exposés comme propriété publiée. |
Chaque composant de protocole s'attache à un TsgcTCPClient via sa propriété Client. Ce seul support de transport te donne le TCP simple et le TLS sans changer le code du protocole.
| Domaine | Détail |
|---|---|
| TCP simple | Assigne un TsgcTCPClient à Client et le protocole tourne directement sur le socket, sur le port natif du broker. |
| WebSocket | Pas dans sgcMQ. Un support WebSocket, par exemple MQTT sur WebSocket ou Web-STOMP, nécessite le client WebSocket livré avec sgcWebSockets. |
| TLS | TLSOptions sur le support de transport, avec TLSOptions.IOHandler qui choisit OpenSSL pour les compilations multiplateformes ou SChannel sous Windows. |
| Certificats client | TLS mutuel via les mêmes TLSOptions, depuis un fichier PEM, un conteneur PKCS#12 ou le magasin de certificats de Windows. |
| Proxys | Prise en charge du proxy HTTP CONNECT sur le support de transport, un broker derrière un proxy d'entreprise reste donc joignable. |
| Reconnexion | WatchDog sur le support de transport reconnecte après une coupure, avec un intervalle et un nombre de tentatives configurables. |
| IPv6 | Pris en charge par le support de transport, une adresse de broker IPv6 ne demande donc aucune configuration supplémentaire. |
| Threads | La lecture tourne sur son propre thread. Règle les paramètres de notification du support de transport pour rapatrier les événements sur le thread principal, en VCL comme en FMX. |
Des protocoles publiés, et le même source sur chaque compilateur pris en charge.
| Domaine | Détail |
|---|---|
| MQTT | OASIS MQTT 3.1.1 et MQTT 5.0. |
| AMQP 0.9.1 | La spécification AMQP 0-9-1 : canaux, exchanges, files d'attente, liaisons et la classe basic. |
| AMQP 1.0 | OASIS AMQP 1.0, également publié sous la référence ISO/IEC 19464. |
| Kafka | Le protocole binaire d'Apache Kafka sur TCP, y compris le format de lot d'enregistrements v2. |
| STOMP | STOMP 1.0, 1.1 et 1.2. |
| WebSocket | Non inclus. Un support WebSocket nécessite sgcWebSockets, qui fournit le client WebSocket. |
| TLS | TLS 1.2 et TLS 1.3 via OpenSSL, ou SChannel de Windows. |
| Compilateurs | Delphi et C++ Builder 7 à 13. |
| Plateformes | Win32, Win64, Linux64, macOS, iOS et Android. |
| Licence | Autonome. Le runtime sgcWebSockets Core est inclus et le code source complet est fourni. |