Wszystko, co robi sgcMQ, rozpisane na siedem komponentów klienckich i specyfikacje, które implementują. Każda funkcja działa tak samo w Delphi i C++ Builder, a każda licencja zawiera pełny kod źródłowy. Kliknij komponent, aby przejść na jego stronę z opisem użycia i przykładami.
3.1.1 i 5.0
0.9.1 i 1.0
Natywny protokół sieciowy
1.0 / 1.1 / 1.2
Zwykły TCP i TLS
Delphi od 7 do 13, C++ Builder
sgcMQ jest samowystarczalny. Jest dostarczany z dołączonym środowiskiem uruchomieniowym sgcWebSockets Core, więc nie jest dodatkiem i nie ma licencji bazowej do kupienia.
Transport: zwykły TCP i TLS. sgcMQ łączy się przez zwykły TCP i TLS. Jeśli potrzebujesz uruchomić protokół przez WebSocket, na przykład MQTT przez WebSocket lub AMQP przez WebSocket, wymaga to pakietu sgcWebSockets, który dostarcza klienta WebSocket.
Każda funkcja z poniższych tabel jest osiągana przez surowy nośnik TCP TsgcTCPClient, który sgcMQ dostarcza w zestawie.
Cztery rodziny protokołów, zarejestrowane na stronie palety SGC MQ.
| Komponent | Klasa | Rodzina | Opis |
|---|---|---|---|
| MQTT Client | TsgcWSPClient_MQTT | MQTT | Publikowanie i subskrypcja w MQTT 3.1.1 i 5.0: QoS 0/1/2, wiadomości zachowane, Last Will and Testament, sesje i właściwości MQTT 5. |
| AMQP 0.9.1 Client | TsgcWSPClient_AMQP | AMQP | Kanały, wymiany, kolejki i powiązania, konsumenci, potwierdzenia, QoS prefetch i transakcje. |
| AMQP 1.0 Client | TsgcWSPClient_AMQP1 | AMQP | Sesje, łącza nadawcze i odbiorcze, kontrola przepływu oparta na kredytach, uwierzytelnianie SASL i funkcje pomocnicze tokenów Azure CBS. |
| Kafka Client | TsgcWSPClient_Kafka | Kafka | Producent z acks i gzip, grupy konsumentów z równoważeniem i zatwierdzaniem offsetów, administracja tematami. |
| STOMP Client | TsgcWSPClient_STOMP | STOMP | Ramki STOMP 1.0/1.1/1.2: SEND, SUBSCRIBE, ACK, NACK, potwierdzenia, heart-beating i transakcje. |
| STOMP RabbitMQ Client | TsgcWSPClient_STOMP_RabbitMQ | STOMP | STOMP dostosowany do RabbitMQ: funkcje pomocnicze dla kolejek, tematów, wymian, kolejek zewnętrznych i tymczasowych, przez TCP lub TLS. |
| STOMP ActiveMQ Client | TsgcWSPClient_STOMP_ActiveMQ | STOMP | STOMP dostosowany do Apache ActiveMQ, z funkcjami pomocniczymi dla kolejek i tematów oraz właściwością ActiveMQ_Options. |
Protokół publikowania i subskrypcji świata IoT, z pełnym mechanizmem jakości usługi wystawionym na wierzch, a nie ukrytym.
| Możliwość | 3.1.1 | 5.0 | Uwagi |
|---|---|---|---|
| Wybór wersji protokołu | ✓ | ✓ | MQTTVersion przyjmuje mqtt311 lub mqtt5. |
| QoS 0, 1 i 2 | ✓ | ✓ | Wymiana QoS 2 jest wystawiona jako OnMQTTPubRec, OnMQTTPubRel i OnMQTTPubComp, a nie ukryta. |
| Wiadomości zachowane | ✓ | ✓ | Flaga retain jest czwartym argumentem metody Publish. |
| Last Will and Testament | ✓ | ✓ | LastWillTestament niesie temat, wiadomość, QoS i flagę retain. |
| Subskrypcje z symbolami wieloznacznymi | ✓ | ✓ | + dla jednego poziomu, # dla reszty drzewa. |
| Sesje | ✓ | ✓ | Argument Session zdarzenia OnMQTTConnect informuje, czy broker wznowił sesję. |
| Publikuj i czekaj | ✓ | ✓ | PublishAndWait blokuje do czasu potwierdzenia pakietu przez brokera. |
| Publikowanie strumienia | ✓ | ✓ | Publish ma przeciążenie TStream dla ładunków binarnych. |
| Kody i nazwy przyczyn | — | ✓ | MQTT 5 zwraca numeryczny kod przyczyny i jego nazwę w CONNACK i DISCONNECT. |
| Właściwości CONNECT | — | ✓ | ConnectProperties ustawia wygasanie sesji, maksymalny odbiór, maksymalny rozmiar pakietu i maksymalny alias tematu. |
| Aliasy tematów | — | ✓ | Krótka liczba całkowita zastępuje długą nazwę tematu w transmisji, rozwiązywana automatycznie w pakietach przychodzących. |
| Właściwości użytkownika | — | ✓ | Dowolne pary klucz/wartość podróżują z CONNECT, PUBLISH, SUBSCRIBE i DISCONNECT. |
| Subskrypcje współdzielone | — | ✓ | Subskrybuj $share/<group>/<topic>, aby rozłożyć dostarczanie na grupę klientów. |
| Rozszerzone uwierzytelnianie | — | ✓ | Wymiana pakietu AUTH przez Auth i OnMQTTAuth, dla schematów typu wyzwanie/odpowiedź. |
| Keep-alive | ✓ | ✓ | HeartBeat steruje PINGREQ, a OnMQTTPing jest zgłaszane po otrzymaniu odpowiedzi. |
Dwa protokoły, które łączy tylko nazwa, dlatego sgcMQ dostarcza osobny komponent dla każdego z nich, zamiast udawać, że jedno API pasuje do obu.
| Możliwość | AMQP 0.9.1 | AMQP 1.0 | Uwagi |
|---|---|---|---|
| Komponent | TsgcWSPClient_AMQP | TsgcWSPClient_AMQP1 | Inny format sieciowy, inny model obiektowy, inny komponent. |
| Jednostka multipleksowania | Kanał | Sesja | OpenChannel wobec CreateSession. |
| Deklarowanie topologii | DeclareExchange, DeclareQueue, BindQueue | — | AMQP 1.0 adresuje węzły na brokerze, zamiast je deklarować. |
| Wysyłanie | PublishMessage(channel, exchange, routingKey, body) | SendMessage(session, link, text) | Klucz routingu w 0.9.1, adres docelowy w 1.0. |
| Odbieranie | Consume, a następnie OnAMQPBasicDeliver | CreateReceiverLink, a następnie OnAMQPMessage | Oba działają w trybie push po nawiązaniu połączenia. |
| Potwierdzanie | AckMessage / RejectMessage | OnAMQPMessageSentAck | 0.9.1 potwierdza znacznik dostarczenia, 1.0 rozlicza dostarczenie. |
| Kontrola przepływu | Prefetch przez SetQoS, EnableChannel / DisableChannel | Oparta na kredytach (CreditSize, WindowSize) | Oba mechanizmy chronią wolnego konsumenta przed szybkim producentem. |
| Transakcje | SelectTransaction, CommitTransaction, RollbackTransaction | — | Klasa tx z 0.9.1, wystawiona osobno dla każdego kanału. |
| Utrzymanie kolejek | PurgeQueue, DeleteQueue, DeleteExchange, UnBindQueue | CloseLink, CloseSession | Każda z blokującym wariantem ...Ex, który czeka na odpowiedź brokera. |
| Ponowne dostarczanie | Recover / RecoverAsync | — | Poproś brokera o ponowne dostarczenie niepotwierdzonych wiadomości. |
| Uwierzytelnianie | OnAMQPAuthentication, OnAMQPChallenge | Authentication.AuthType, OnAMQPSASLAuthentication | 1.0 oferuje SASL ANONYMOUS, PLAIN i EXTERNAL. |
| Funkcje pomocnicze dla chmury | — | CreateCBSLink, PutCBSToken, CreateAzureCbsSasToken, CreateAzureCbsJWT | Claims-Based Security dla Azure Service Bus i Event Hubs. |
| Sprawdzanie aktywności | HeartBeat | Ping, AMQPOptions.IdleTimeout | Negocjowane z brokerem przy łączeniu. |
| Strojenie połączenia | AMQPOptions.VirtualHost, MaxChannels, MaxFrameSize, Locale | AMQPOptions.ContainerId, ChannelMax, MaxFrameSize, MaxLinksPerSession | Wysyłane w otwierającym handshake i negocjowane z brokerem. |
| Prefetch | SetQoS(channel, prefetchSize, prefetchCount, global) | AMQPOptions.CreditSize | Ile niepotwierdzonych wiadomości broker może mieć w locie. |
| Inspekcja ramek | — | OnAMQPBeforeReadFrame, OnAMQPBeforeWriteFrame | Podglądaj lub przepisuj surowe ramki, zanim zostaną przetworzone albo wysłane. |
Binarny protokół Kafka zaimplementowany w Object Pascal, bez proxy REST z przodu i bez librdkafka pod spodem.
| Możliwość | API | Uwagi |
|---|---|---|
| Publikowanie rekordu | Produce(topic, value, key, partition) | Klucz i partycja są opcjonalne. ProduceBytes przyjmuje TBytes dla obu. |
| Publikowanie wsadu | ProduceMessages(topic, partition, messages) | Zwraca odpowiedź brokera dla całego wsadu. |
| Gwarancja dostarczenia | KafkaOptions.Producer.Acks | kafkaAcksNone, kafkaAcksLeader lub kafkaAcksAll. |
| Kompresja | KafkaOptions.Producer.Compression | kafkaCompressionNone lub kafkaCompressionGzip. |
| Konsumowanie | Subscribe([topics]), a następnie Poll(timeoutMs) | Poll zwraca listę TsgcKafkaMessages i dodatkowo zgłasza OnKafkaMessage dla każdego rekordu. |
| Grupy konsumentów | KafkaOptions.Consumer.GroupId | Wykrywanie koordynatora, dołączanie, synchronizacja i heartbeat są obsługiwane za ciebie. OnKafkaRebalance raportuje zmiany przydziału. |
| Polityka offsetów | KafkaOptions.Consumer.OffsetReset | kafkaOffsetEarliest lub kafkaOffsetLatest, gdy nie ma zatwierdzonego offsetu. |
| Zatwierdzanie offsetów | CommitSync, CommitOffset(topic, partition, offset) | Albo ustaw Consumer.AutoCommit wraz z AutoCommitIntervalMs. |
| Bezpośredni odczyt partycji | FetchMessages(topic, partition, offset, maxBytes) | Całkowicie omija grupę konsumentów. |
| Wyszukiwanie offsetów | GetEarliestOffset, GetLatestOffset, GetCommittedOffset | Dla każdego tematu i partycji. |
| Strojenie pobierania | Consumer.MinBytes, MaxBytes, MaxPartitionBytes, MaxWaitMs | Wyważ opóźnienie względem rozmiaru wsadu. |
| Administracja tematami | CreateTopic, DeleteTopic, GetMetadata | Liczba partycji i współczynnik replikacji przy tworzeniu. |
| Administracja grupami | ListGroups, DescribeGroups | Sprawdzaj grupy konsumentów z własnych narzędzi. |
| Badanie możliwości brokera | GetApiVersions | Zapytaj brokera, które wersje API protokołu obsługuje. |
| SASL | kafkaSaslNone, kafkaSaslPlain | Uwierzytelnianie SASL/PLAIN nazwą użytkownika i hasłem. |
Jeden klient ogólny plus dwaj potomkowie dostosowani do konkretnych brokerów, którzy zamieniają konwencje adresowania RabbitMQ i ActiveMQ na nazwane metody.
| Możliwość | STOMP | RabbitMQ | ActiveMQ | Uwagi |
|---|---|---|---|---|
| Wysłanie ramki | Send | PublishEx | PublishEx | Miejsce docelowe, treść, typ zawartości i opcjonalna transakcja. |
| Subskrypcja | Subscribe(id, destination) | SubscribeEx | SubscribeEx | Potomkowie dodają argumenty durable, exclusive i tryb potwierdzania. |
| Funkcje pomocnicze kolejek | — | SubscribeQueue, PublishQueue, UnSubscribeQueue | SubscribeQueue, PublishQueue, UnSubscribeQueue | Opakowany prefiks miejsca docelowego /queue/. |
| Funkcje pomocnicze tematów | — | SubscribeTopic, PublishTopic, UnSubscribeTopic | SubscribeTopic, PublishTopic, UnSubscribeTopic | Opakowany prefiks miejsca docelowego /topic/. |
| Funkcje pomocnicze wymian | — | SubscribeExchange, PublishExchange | — | Miejsce docelowe /exchange/ RabbitMQ ze wzorcem routingu. |
| Kolejki zewnętrzne | — | SubscribeQueueOutside, PublishQueueOutside | — | /amq/queue/ RabbitMQ, dla kolejek zadeklarowanych gdzie indziej. |
| Tymczasowe kolejki odpowiedzi | — | SubscribeTemporaryQueue, PublishTemporaryQueue | — | Wzorzec żądanie/odpowiedź /temp-queue/ RabbitMQ. |
| Potwierdzanie | ACK / NACK | ✓ | ✓ | Tryb potwierdzania wybierany osobno dla każdej subskrypcji (ackAuto i pokrewne). |
| Transakcje | BeginTransaction, CommitTransaction, AbortTransaction | ✓ | ✓ | Grupuj kilka ramek SEND i ACK w jedną atomową jednostkę. |
| Potwierdzenia odbioru | OnSTOMPReceipt | OnRabbitMQReceipt | OnActiveMQReceipt | Broker potwierdza przetworzoną ramkę. |
| Zdarzenie wiadomości | OnSTOMPMessage | OnRabbitMQMessage | OnActiveMQMessage | Dostarcza miejsce docelowe, treść i nagłówki ramki. |
| Heart-beating | HeartBeat, Ping | ✓ | ✓ | Negocjowane w ramce CONNECT, w obu kierunkach. |
| Negocjacja wersji | Versions.V1_0, V1_1, V1_2 | ✓ | ✓ | Zgłoś wersje, które akceptujesz, a broker wybierze jedną. |
| Host wirtualny | Options.VirtualHost | ✓ | ✓ | Wysyłany jako nagłówek host w CONNECT. |
| Rozszerzenia brokera | — | — | ActiveMQ_Options | Nagłówki specyficzne dla ActiveMQ, wystawione jako opublikowana właściwość. |
Każdy komponent protokołu podłącza się do TsgcTCPClient przez właściwość Client. Ten jeden nośnik daje ci zwykły TCP i TLS bez zmiany kodu protokołu.
| Obszar | Szczegóły |
|---|---|
| Zwykły TCP | Przypisz TsgcTCPClient do Client, a protokół pobiegnie prosto przez gniazdo, na natywnym porcie brokera. |
| WebSocket | Nie jest częścią sgcMQ. Nośnik WebSocket, na przykład MQTT przez WebSocket lub Web-STOMP, wymaga klienta WebSocket dostarczanego z sgcWebSockets. |
| TLS | TLSOptions na nośniku, gdzie TLSOptions.IOHandler wybiera OpenSSL dla kompilacji wieloplatformowych albo SChannel na Windows. |
| Certyfikaty klienta | Wzajemne TLS przez te same TLSOptions, z pliku PEM, pakietu PKCS#12 albo magazynu certyfikatów Windows. |
| Serwery proxy | Obsługa proxy HTTP CONNECT na nośniku, dzięki czemu broker za firmowym proxy jest osiągalny. |
| Ponowne łączenie | WatchDog na nośniku łączy się ponownie po zerwaniu połączenia, z konfigurowalnym interwałem i liczbą prób. |
| IPv6 | Obsługiwane przez nośnik, więc adres brokera w IPv6 nie wymaga dodatkowej konfiguracji. |
| Wątki | Odczyt działa we własnym wątku. Ustaw opcje powiadomień nośnika, aby przekazywać zdarzenia do głównego wątku w kodzie VCL i FMX. |
Opublikowane protokoły i te same źródła we wszystkich obsługiwanych kompilatorach.
| Obszar | Szczegóły |
|---|---|
| MQTT | OASIS MQTT 3.1.1 i MQTT 5.0. |
| AMQP 0.9.1 | Specyfikacja AMQP 0-9-1: kanały, wymiany, kolejki, powiązania i klasa basic. |
| AMQP 1.0 | OASIS AMQP 1.0, opublikowany także jako ISO/IEC 19464. |
| Kafka | Protokół sieciowy Apache Kafka przez TCP, wraz z formatem wsadu rekordów v2. |
| STOMP | STOMP 1.0, 1.1 i 1.2. |
| WebSocket | Nie jest zawarty. Nośnik WebSocket wymaga sgcWebSockets, który dostarcza klienta WebSocket. |
| TLS | TLS 1.2 i TLS 1.3 przez OpenSSL albo Windows SChannel. |
| Kompilatory | Delphi i C++ Builder od 7 do 13. |
| Platformy | Win32, Win64, Linux64, macOS, iOS i Android. |
| Licencjonowanie | Produkt samodzielny. Środowisko uruchomieniowe sgcWebSockets Core jest dołączone, a pełny kod źródłowy jest w zestawie. |