sgcMQ'nun yaptığı her şey, yedi istemci bileşeni ve uyguladıkları belirtimler üzerinden eşlenmiş. Her yetenek Delphi ve C++ Builder'da aynı şekilde çalışır ve her lisans tam kaynak koduyla gelir. Kullanım ve örnekleri içeren kendi sayfası için bir bileşene tıklayın.
3.1.1 ve 5.0
0.9.1 ve 1.0
Yerel hat protokolü
1.0 / 1.1 / 1.2
Düz TCP ve TLS
Delphi 7'den 13'e, C++ Builder
sgcMQ kendi kendine yeter. sgcWebSockets Core çalışma zamanı pakete dahil olarak gelir, bu yüzden bir eklenti değildir ve satın alınacak bir temel lisans yoktur.
Taşıma: düz TCP ve TLS. sgcMQ, düz TCP ve TLS üzerinden bağlanır. Protokolü bunun yerine WebSocket üzerinden çalıştırmanız gerekiyorsa, örneğin WebSocket üzerinden MQTT ya da WebSocket üzerinden AMQP, bu bir sgcWebSockets paketi gerektirir ve WebSocket istemcisini o sağlar.
Aşağıdaki tablolarda yer alan her yeteneğe, sgcMQ'nun kutuda birlikte verdiği ham TCP taşıyıcısı TsgcTCPClient üzerinden erişilir.
SGC MQ palet sayfasına kayıtlı dört protokol ailesi.
| Bileşen | Sınıf | Aile | Açıklama |
|---|---|---|---|
| MQTT İstemcisi | TsgcWSPClient_MQTT | MQTT | MQTT 3.1.1 ve 5.0 yayınlama/abone olma: QoS 0/1/2, saklanan mesajlar, Last Will and Testament, oturumlar ve MQTT 5 özellikleri. |
| AMQP 0.9.1 İstemcisi | TsgcWSPClient_AMQP | AMQP | Kanallar, exchange'ler, kuyruklar ve bağlamalar, tüketiciler, onaylar, prefetch QoS ve işlemler. |
| AMQP 1.0 İstemcisi | TsgcWSPClient_AMQP1 | AMQP | Oturumlar, gönderici ve alıcı bağlantıları, krediye dayalı akış denetimi, SASL kimlik doğrulaması ve Azure CBS token yardımcıları. |
| Kafka İstemcisi | TsgcWSPClient_Kafka | Kafka | Acks ve gzip destekli üretici, yeniden dengeleme ve offset kaydetme özellikli tüketici grupları, konu yönetimi. |
| STOMP İstemcisi | TsgcWSPClient_STOMP | STOMP | STOMP 1.0/1.1/1.2 çerçeveleri: SEND, SUBSCRIBE, ACK, NACK, makbuzlar, kalp atışı ve işlemler. |
| STOMP RabbitMQ İstemcisi | TsgcWSPClient_STOMP_RabbitMQ | STOMP | RabbitMQ için ayarlanmış STOMP: TCP ya da TLS üzerinden kuyruk, konu, exchange, harici kuyruk ve geçici kuyruk yardımcıları. |
| STOMP ActiveMQ İstemcisi | TsgcWSPClient_STOMP_ActiveMQ | STOMP | Apache ActiveMQ için ayarlanmış STOMP; kuyruk ve konu yardımcılarının yanı sıra bir ActiveMQ_Options özelliği. |
IoT'nin yayınlama/abone olma protokolü; hizmet kalitesi mekanizmasının tamamı gizlenmek yerine açığa çıkarılmış.
| Yetenek | 3.1.1 | 5.0 | Notlar |
|---|---|---|---|
| Protokol sürümü seçimi | ✓ | ✓ | MQTTVersion, mqtt311 ya da mqtt5 değerini alır. |
| QoS 0, 1 ve 2 | ✓ | ✓ | QoS 2 alışverişi yutulmaz; OnMQTTPubRec, OnMQTTPubRel ve OnMQTTPubComp olarak açığa çıkarılır. |
| Saklanan mesajlar | ✓ | ✓ | Saklama bayrağı, Publish metodunun dördüncü argümanıdır. |
| Last Will and Testament | ✓ | ✓ | LastWillTestament; konu, mesaj, QoS ve saklama bilgisini taşır. |
| Joker karakterli abonelikler | ✓ | ✓ | Bir düzey için +, ağacın geri kalanı için #. |
| Oturumlar | ✓ | ✓ | OnMQTTConnect olayının Session argümanı, broker'ın bir oturumu devam ettirip ettirmediğini bildirir. |
| Yayınla ve bekle | ✓ | ✓ | PublishAndWait, broker paketi onaylayana kadar bekler. |
| Bir akış yayınlama | ✓ | ✓ | Publish, ikili yükler için bir TStream aşırı yüklemesine sahiptir. |
| Sebep kodları ve adları | — | ✓ | MQTT 5, CONNACK ve DISCONNECT üzerinde sayısal bir sebep kodu ve adını döndürür. |
| CONNECT özellikleri | — | ✓ | ConnectProperties; oturum sona erme süresini, alım üst sınırını, en büyük paket boyutunu ve konu takma adı üst sınırını ayarlar. |
| Konu takma adları | — | ✓ | Hat üzerinde uzun bir konu adının yerini kısa bir tam sayı alır ve gelen paketlerde otomatik olarak çözümlenir. |
| Kullanıcı özellikleri | — | ✓ | İsteğe bağlı anahtar/değer çiftleri CONNECT, PUBLISH, SUBSCRIBE ve DISCONNECT ile birlikte taşınır. |
| Paylaşılan abonelikler | — | ✓ | Teslimatları bir istemci grubuna dağıtmak için $share/<group>/<topic> konusuna abone olun. |
| Gelişmiş kimlik doğrulama | — | ✓ | Soru-cevap şemaları için Auth ve OnMQTTAuth üzerinden AUTH paketi gidiş-dönüşü. |
| Bağlantıyı canlı tutma | ✓ | ✓ | HeartBeat, PINGREQ'i yürütür ve yanıtta OnMQTTPing tetiklenir. |
Adından başka hiçbir ortak yanı olmayan iki protokol; bu yüzden sgcMQ, tek bir API'nin ikisine de uyduğunu varsaymak yerine her biri için ayrı bir bileşen sunar.
| Yetenek | AMQP 0.9.1 | AMQP 1.0 | Notlar |
|---|---|---|---|
| Bileşen | TsgcWSPClient_AMQP | TsgcWSPClient_AMQP1 | Farklı hat biçimi, farklı nesne modeli, farklı bileşen. |
| Çoğullama birimi | Kanal | Oturum | OpenChannel'a karşı CreateSession. |
| Topoloji tanımlama | DeclareExchange, DeclareQueue, BindQueue | — | AMQP 1.0, broker üzerindeki düğümleri tanımlamak yerine adresler. |
| Gönderme | PublishMessage(channel, exchange, routingKey, body) | SendMessage(session, link, text) | 0.9.1'de yönlendirme anahtarı, 1.0'da hedef adres. |
| Alma | Consume, ardından OnAMQPBasicDeliver | CreateReceiverLink, ardından OnAMQPMessage | Kurulduktan sonra ikisi de push tabanlıdır. |
| Onaylama | AckMessage / RejectMessage | OnAMQPMessageSentAck | 0.9.1 bir teslimat etiketini onaylar, 1.0 bir teslimatı sonlandırır. |
| Akış denetimi | SetQoS prefetch, EnableChannel / DisableChannel | Krediye dayalı (CreditSize, WindowSize) | Her ikisi de hızlı bir üreticinin yavaş bir tüketiciyi boğmasını engeller. |
| İşlemler | SelectTransaction, CommitTransaction, RollbackTransaction | — | Kanal başına açığa çıkarılan 0.9.1 tx sınıfı. |
| Kuyruk bakımı | PurgeQueue, DeleteQueue, DeleteExchange, UnBindQueue | CloseLink, CloseSession | Her biri, broker yanıtını bekleyen engelleyici bir ...Ex varyantına sahiptir. |
| Yeniden teslim | Recover / RecoverAsync | — | Broker'dan onaylanmamış mesajları yeniden teslim etmesini isteyin. |
| Kimlik doğrulama | OnAMQPAuthentication, OnAMQPChallenge | Authentication.AuthType, OnAMQPSASLAuthentication | 1.0; SASL ANONYMOUS, PLAIN ve EXTERNAL sunar. |
| Bulut yardımcıları | — | CreateCBSLink, PutCBSToken, CreateAzureCbsSasToken, CreateAzureCbsJWT | Azure Service Bus ve Event Hubs için Claims-Based Security. |
| Canlılık | HeartBeat | Ping, AMQPOptions.IdleTimeout | Bağlantı sırasında broker ile müzakere edilir. |
| Bağlantı ayarları | AMQPOptions.VirtualHost, MaxChannels, MaxFrameSize, Locale | AMQPOptions.ContainerId, ChannelMax, MaxFrameSize, MaxLinksPerSession | Açılış handshake'inde gönderilir ve broker ile müzakere edilir. |
| Prefetch | SetQoS(channel, prefetchSize, prefetchCount, global) | AMQPOptions.CreditSize | Broker'ın aynı anda kaç onaylanmamış mesaj taşıyabileceği. |
| Çerçeve inceleme | — | OnAMQPBeforeReadFrame, OnAMQPBeforeWriteFrame | Ham çerçeveleri işlenmeden ya da gönderilmeden önce görün ya da yeniden yazın. |
Object Pascal ile uygulanmış ikili Kafka protokolü; önde bir REST proxy'si, altta bir librdkafka yok.
| Yetenek | API | Notlar |
|---|---|---|
| Bir kayıt üretme | Produce(topic, value, key, partition) | Anahtar ve bölüm isteğe bağlıdır. ProduceBytes, her ikisi için de TBytes alır. |
| Bir yığın üretme | ProduceMessages(topic, partition, messages) | Tüm yığın için broker'ın üretim yanıtını döndürür. |
| Teslimat garantisi | KafkaOptions.Producer.Acks | kafkaAcksNone, kafkaAcksLeader ya da kafkaAcksAll. |
| Sıkıştırma | KafkaOptions.Producer.Compression | kafkaCompressionNone ya da kafkaCompressionGzip. |
| Tüketme | Subscribe([topics]), ardından Poll(timeoutMs) | Poll, bir TsgcKafkaMessages listesi döndürür ve ayrıca kayıt başına OnKafkaMessage tetikler. |
| Tüketici grupları | KafkaOptions.Consumer.GroupId | Koordinatör keşfi, katılma, senkronizasyon ve kalp atışı sizin yerinize yürütülür. OnKafkaRebalance, atama değişikliklerini bildirir. |
| Offset politikası | KafkaOptions.Consumer.OffsetReset | Kaydedilmiş bir offset yoksa kafkaOffsetEarliest ya da kafkaOffsetLatest. |
| Offset kaydetme | CommitSync, CommitOffset(topic, partition, offset) | Ya da Consumer.AutoCommit'i AutoCommitIntervalMs ile ayarlayın. |
| Bir bölümü doğrudan okuma | FetchMessages(topic, partition, offset, maxBytes) | Tüketici grubunu tamamen atlar. |
| Offset sorgulama | GetEarliestOffset, GetLatestOffset, GetCommittedOffset | Konu ve bölüm başına. |
| Getirme ayarları | Consumer.MinBytes, MaxBytes, MaxPartitionBytes, MaxWaitMs | Gecikmeyi yığın boyutuyla dengeleyin. |
| Konu yönetimi | CreateTopic, DeleteTopic, GetMetadata | Oluştururken bölüm sayısı ve çoğaltma faktörü. |
| Grup yönetimi | ListGroups, DescribeGroups | Tüketici gruplarını kendi araçlarınızdan inceleyin. |
| Broker yetenek yoklaması | GetApiVersions | Broker'a hangi protokol API sürümlerini desteklediğini sorun. |
| SASL | kafkaSaslNone, kafkaSaslPlain | SASL/PLAIN kullanıcı adı ve parola kimlik doğrulaması. |
Tek bir genel istemci ve RabbitMQ ile ActiveMQ hedef kurallarını adlandırılmış metotlara dönüştüren, broker'a özel iki türev bileşen.
| Yetenek | STOMP | RabbitMQ | ActiveMQ | Notlar |
|---|---|---|---|---|
| Bir çerçeve gönderme | Send | PublishEx | PublishEx | Hedef, gövde, içerik türü ve isteğe bağlı işlem. |
| Abone olma | Subscribe(id, destination) | SubscribeEx | SubscribeEx | Türev bileşenler dayanıklı, özel ve ack modu argümanlarını ekler. |
| Kuyruk yardımcıları | — | SubscribeQueue, PublishQueue, UnSubscribeQueue | SubscribeQueue, PublishQueue, UnSubscribeQueue | Sarmalanmış /queue/ hedef öneki. |
| Konu yardımcıları | — | SubscribeTopic, PublishTopic, UnSubscribeTopic | SubscribeTopic, PublishTopic, UnSubscribeTopic | Sarmalanmış /topic/ hedef öneki. |
| Exchange yardımcıları | — | SubscribeExchange, PublishExchange | — | Yönlendirme desenli, RabbitMQ'nun /exchange/ hedefi. |
| Harici kuyruklar | — | SubscribeQueueOutside, PublishQueueOutside | — | Başka bir yerde tanımlanmış kuyruklar için RabbitMQ'nun /amq/queue/ hedefi. |
| Geçici yanıt kuyrukları | — | SubscribeTemporaryQueue, PublishTemporaryQueue | — | RabbitMQ'nun /temp-queue/ istek/yanıt deseni. |
| Onaylama | ACK / NACK | ✓ | ✓ | Abonelik başına seçilen ack modu (ackAuto ve benzerleri). |
| İşlemler | BeginTransaction, CommitTransaction, AbortTransaction | ✓ | ✓ | Birden çok SEND ve ACK çerçevesini tek bir atomik birimde gruplayın. |
| Makbuzlar | OnSTOMPReceipt | OnRabbitMQReceipt | OnActiveMQReceipt | Broker, işlediği bir çerçeveyi onaylar. |
| Mesaj olayı | OnSTOMPMessage | OnRabbitMQMessage | OnActiveMQMessage | Hedefi, gövdeyi ve çerçeve başlıklarını teslim eder. |
| Kalp atışı | HeartBeat, Ping | ✓ | ✓ | CONNECT çerçevesinde, her iki yön için müzakere edilir. |
| Sürüm müzakeresi | Versions.V1_0, V1_1, V1_2 | ✓ | ✓ | Kabul ettiğiniz sürümleri duyurun, broker birini seçsin. |
| Sanal ana bilgisayar | Options.VirtualHost | ✓ | ✓ | CONNECT üzerinde host başlığı olarak gönderilir. |
| Broker uzantıları | — | — | ActiveMQ_Options | Yayımlanmış bir özellik olarak açığa çıkarılan, ActiveMQ'ya özgü başlıklar. |
Her protokol bileşeni, Client özelliği üzerinden bir TsgcTCPClient nesnesine bağlanır. Bu tek taşıyıcı, protokol kodunu değiştirmeden size düz TCP ve TLS sağlar.
| Alan | Ayrıntı |
|---|---|
| Düz TCP | Client özelliğine bir TsgcTCPClient atayın; protokol, broker'ın yerel bağlantı noktasında doğrudan soket üzerinden çalışır. |
| WebSocket | sgcMQ'da yoktur. Bir WebSocket taşıyıcısı, örneğin WebSocket üzerinden MQTT ya da Web-STOMP, sgcWebSockets ile gelen WebSocket istemcisini gerektirir. |
| TLS | Taşıyıcı üzerinde TLSOptions; TLSOptions.IOHandler, çok platformlu derlemeler için OpenSSL'i ya da Windows'ta SChannel'ı seçer. |
| İstemci sertifikaları | Aynı TLSOptions üzerinden karşılıklı TLS; bir PEM dosyasından, bir PKCS#12 paketinden ya da Windows sertifika deposundan. |
| Proxy'ler | Taşıyıcıda HTTP CONNECT proxy desteği; böylece kurumsal bir proxy arkasındaki broker'a erişilebilir. |
| Yeniden bağlanma | Taşıyıcıdaki WatchDog, kopan bir bağlantının ardından yapılandırılabilir bir aralık ve deneme sayısıyla yeniden bağlanır. |
| IPv6 | Taşıyıcı tarafından desteklenir, bu nedenle bir IPv6 broker adresi ek yapılandırma gerektirmez. |
| İş parçacığı yönetimi | Okuma kendi iş parçacığında çalışır. VCL ve FMX kodu için olayları ana iş parçacığına aktarmak üzere taşıyıcının bildirim ayarlarını yapın. |
Yayımlanmış protokoller ve desteklenen her derleyicide aynı kaynak kodu.
| Alan | Ayrıntı |
|---|---|
| MQTT | OASIS MQTT 3.1.1 ve MQTT 5.0. |
| AMQP 0.9.1 | AMQP 0-9-1 belirtimi: kanallar, exchange'ler, kuyruklar, bağlamalar ve basic sınıfı. |
| AMQP 1.0 | ISO/IEC 19464 olarak da yayımlanan OASIS AMQP 1.0. |
| Kafka | v2 kayıt yığını biçimi dahil olmak üzere, TCP üzerinden Apache Kafka hat protokolü. |
| STOMP | STOMP 1.0, 1.1 ve 1.2. |
| WebSocket | Dahil değildir. Bir WebSocket taşıyıcısı, WebSocket istemcisini sağlayan sgcWebSockets ürününü gerektirir. |
| TLS | OpenSSL ya da Windows SChannel üzerinden TLS 1.2 ve TLS 1.3. |
| Derleyiciler | Delphi ve C++ Builder 7'den 13'e. |
| Platformlar | Win32, Win64, Linux64, macOS, iOS ve Android. |
| Lisanslama | Bağımsız. sgcWebSockets Core çalışma zamanı pakete dahildir ve tam kaynak kodu içerilir. |