Tudo o que o sgcMQ faz, mapeado nos sete componentes cliente e nas especificações que eles implementam. Cada recurso funciona igual no Delphi e no C++ Builder, e toda licença entrega o código-fonte completo. Clique em um componente para abrir a página dele, com uso e exemplos.
3.1.1 e 5.0
0.9.1 e 1.0
Protocolo de rede nativo
1.0 / 1.1 / 1.2
TCP puro e TLS
Delphi 7 a 13, C++ Builder
O sgcMQ é autossuficiente. Ele já vem com o runtime sgcWebSockets Core embutido, portanto não é um complemento e não há licença base para comprar.
Transporte: TCP puro e TLS. O sgcMQ se conecta por TCP puro e TLS. Se você precisar rodar o protocolo sobre WebSocket, por exemplo MQTT sobre WebSocket ou AMQP sobre WebSocket, isso exige um pacote sgcWebSockets, que fornece o cliente WebSocket.
Todos os recursos das tabelas abaixo são acessados pelo transporte TCP puro TsgcTCPClient, que o sgcMQ já entrega na caixa.
Quatro famílias de protocolos, registradas na página de paleta SGC MQ.
| Componente | Classe | Família | Descrição |
|---|---|---|---|
| MQTT Client | TsgcWSPClient_MQTT | MQTT | Publicação e assinatura em MQTT 3.1.1 e 5.0: QoS 0/1/2, mensagens retidas, Last Will and Testament, sessões e propriedades do MQTT 5. |
| AMQP 0.9.1 Client | TsgcWSPClient_AMQP | AMQP | Canais, exchanges, filas e vínculos, consumidores, confirmações, QoS de prefetch e transações. |
| AMQP 1.0 Client | TsgcWSPClient_AMQP1 | AMQP | Sessões, links de envio e recebimento, controle de fluxo por crédito, autenticação SASL e utilitários de token CBS do Azure. |
| Kafka Client | TsgcWSPClient_Kafka | Kafka | Produtor com acks e gzip, grupos de consumidores com rebalanceamento e commit de offsets, administração de tópicos. |
| STOMP Client | TsgcWSPClient_STOMP | STOMP | Frames STOMP 1.0/1.1/1.2: SEND, SUBSCRIBE, ACK, NACK, recibos, heartbeat e transações. |
| STOMP RabbitMQ Client | TsgcWSPClient_STOMP_RabbitMQ | STOMP | STOMP ajustado para o RabbitMQ: utilitários de fila, tópico, exchange, fila externa e fila temporária, sobre TCP ou TLS. |
| STOMP ActiveMQ Client | TsgcWSPClient_STOMP_ActiveMQ | STOMP | STOMP ajustado para o Apache ActiveMQ, com utilitários de fila e tópico mais uma propriedade ActiveMQ_Options. |
O protocolo de publicação e assinatura da IoT, com toda a mecânica de qualidade de serviço exposta em vez de escondida.
| Recurso | 3.1.1 | 5.0 | Observações |
|---|---|---|---|
| Seleção da versão do protocolo | ✓ | ✓ | MQTTVersion aceita mqtt311 ou mqtt5. |
| QoS 0, 1 e 2 | ✓ | ✓ | A troca de QoS 2 é exposta como OnMQTTPubRec, OnMQTTPubRel e OnMQTTPubComp, e não engolida. |
| Mensagens retidas | ✓ | ✓ | O sinalizador de retenção é o quarto argumento de Publish. |
| Last Will and Testament | ✓ | ✓ | LastWillTestament carrega tópico, mensagem, QoS e retenção. |
| Assinaturas com curinga | ✓ | ✓ | + para um nível, # para o resto da árvore. |
| Sessões | ✓ | ✓ | O argumento Session de OnMQTTConnect informa se o broker retomou uma sessão. |
| Publicar e aguardar | ✓ | ✓ | PublishAndWait bloqueia até o broker confirmar o pacote. |
| Publicar um stream | ✓ | ✓ | Publish tem uma sobrecarga TStream para cargas binárias. |
| Códigos e nomes de motivo | — | ✓ | O MQTT 5 retorna um código de motivo numérico e o nome dele no CONNACK e no DISCONNECT. |
| Propriedades de CONNECT | — | ✓ | ConnectProperties define expiração de sessão, receive maximum, tamanho máximo de pacote e máximo de aliases de tópico. |
| Aliases de tópico | — | ✓ | Um inteiro curto substitui um nome longo de tópico na rede, resolvido automaticamente nos pacotes de entrada. |
| Propriedades de usuário | — | ✓ | Pares chave/valor arbitrários viajam com CONNECT, PUBLISH, SUBSCRIBE e DISCONNECT. |
| Assinaturas compartilhadas | — | ✓ | Assine $share/<group>/<topic> para distribuir as entregas entre um grupo de clientes. |
| Autenticação aprimorada | — | ✓ | O ciclo do pacote AUTH por meio de Auth e OnMQTTAuth, para esquemas de desafio e resposta. |
| Keep-alive | ✓ | ✓ | HeartBeat aciona o PINGREQ, com OnMQTTPing disparado na resposta. |
Dois protocolos que compartilham o nome e nada mais, então o sgcMQ entrega um componente separado para cada um em vez de fingir que uma única API serve para os dois.
| Recurso | AMQP 0.9.1 | AMQP 1.0 | Observações |
|---|---|---|---|
| Componente | TsgcWSPClient_AMQP | TsgcWSPClient_AMQP1 | Formato de rede diferente, modelo de objetos diferente, componente diferente. |
| Unidade de multiplexação | Canal | Sessão | OpenChannel contra CreateSession. |
| Declaração da topologia | DeclareExchange, DeclareQueue, BindQueue | — | O AMQP 1.0 endereça nós no broker em vez de declará-los. |
| Envio | PublishMessage(channel, exchange, routingKey, body) | SendMessage(session, link, text) | Chave de roteamento no 0.9.1, endereço de destino no 1.0. |
| Recebimento | Consume e depois OnAMQPBasicDeliver | CreateReceiverLink e depois OnAMQPMessage | Os dois funcionam por push assim que estabelecidos. |
| Confirmação | AckMessage / RejectMessage | OnAMQPMessageSentAck | O 0.9.1 confirma uma delivery tag, o 1.0 liquida uma entrega. |
| Controle de fluxo | prefetch com SetQoS, EnableChannel / DisableChannel | Baseado em crédito (CreditSize, WindowSize) | Os dois impedem que um produtor rápido sobrecarregue um consumidor lento. |
| Transações | SelectTransaction, CommitTransaction, RollbackTransaction | — | A classe tx do 0.9.1, exposta por canal. |
| Manutenção de filas | PurgeQueue, DeleteQueue, DeleteExchange, UnBindQueue | CloseLink, CloseSession | Cada um com uma variante bloqueante ...Ex que aguarda a resposta do broker. |
| Reentrega | Recover / RecoverAsync | — | Peça ao broker que reentregue mensagens não confirmadas. |
| Autenticação | OnAMQPAuthentication, OnAMQPChallenge | Authentication.AuthType, OnAMQPSASLAuthentication | O 1.0 oferece SASL ANONYMOUS, PLAIN e EXTERNAL. |
| Utilitários de nuvem | — | CreateCBSLink, PutCBSToken, CreateAzureCbsSasToken, CreateAzureCbsJWT | Claims-Based Security para Azure Service Bus e Event Hubs. |
| Vitalidade | HeartBeat | Ping, AMQPOptions.IdleTimeout | Negociada com o broker na conexão. |
| Ajuste da conexão | AMQPOptions.VirtualHost, MaxChannels, MaxFrameSize, Locale | AMQPOptions.ContainerId, ChannelMax, MaxFrameSize, MaxLinksPerSession | Enviado no handshake de abertura e negociado com o broker. |
| Prefetch | SetQoS(channel, prefetchSize, prefetchCount, global) | AMQPOptions.CreditSize | Quantas mensagens não confirmadas o broker pode manter em trânsito. |
| Inspeção de frames | — | OnAMQPBeforeReadFrame, OnAMQPBeforeWriteFrame | Veja ou reescreva os frames brutos antes de serem processados ou enviados. |
O protocolo binário do Kafka implementado em Object Pascal, sem proxy REST na frente e sem librdkafka por baixo.
| Recurso | API | Observações |
|---|---|---|
| Produzir um registro | Produce(topic, value, key, partition) | A chave e a partição são opcionais. ProduceBytes aceita TBytes para as duas. |
| Produzir um lote | ProduceMessages(topic, partition, messages) | Retorna a resposta de produção do broker para o lote inteiro. |
| Garantia de entrega | KafkaOptions.Producer.Acks | kafkaAcksNone, kafkaAcksLeader ou kafkaAcksAll. |
| Compressão | KafkaOptions.Producer.Compression | kafkaCompressionNone ou kafkaCompressionGzip. |
| Consumir | Subscribe([topics]) e depois Poll(timeoutMs) | Poll retorna uma lista TsgcKafkaMessages e também dispara OnKafkaMessage a cada registro. |
| Grupos de consumidores | KafkaOptions.Consumer.GroupId | A descoberta do coordenador, a entrada, a sincronização e o heartbeat são tratados para você. OnKafkaRebalance informa mudanças de atribuição. |
| Política de offset | KafkaOptions.Consumer.OffsetReset | kafkaOffsetEarliest ou kafkaOffsetLatest quando não há offset confirmado. |
| Confirmar offsets | CommitSync, CommitOffset(topic, partition, offset) | Ou defina Consumer.AutoCommit com AutoCommitIntervalMs. |
| Ler uma partição diretamente | FetchMessages(topic, partition, offset, maxBytes) | Ignora completamente o grupo de consumidores. |
| Consulta de offset | GetEarliestOffset, GetLatestOffset, GetCommittedOffset | Por tópico e por partição. |
| Ajuste do fetch | Consumer.MinBytes, MaxBytes, MaxPartitionBytes, MaxWaitMs | Equilibre latência contra tamanho do lote. |
| Administração de tópicos | CreateTopic, DeleteTopic, GetMetadata | Número de partições e fator de replicação na criação. |
| Administração de grupos | ListGroups, DescribeGroups | Inspecione grupos de consumidores a partir das suas próprias ferramentas. |
| Sondagem de recursos do broker | GetApiVersions | Pergunte ao broker quais versões da API do protocolo ele suporta. |
| SASL | kafkaSaslNone, kafkaSaslPlain | Autenticação SASL/PLAIN com nome de usuário e senha. |
Um cliente genérico mais dois descendentes específicos de broker, que transformam as convenções de destino do RabbitMQ e do ActiveMQ em métodos nomeados.
| Recurso | STOMP | RabbitMQ | ActiveMQ | Observações |
|---|---|---|---|---|
| Enviar um frame | Send | PublishEx | PublishEx | Destino, corpo, tipo de conteúdo e transação opcional. |
| Assinar | Subscribe(id, destination) | SubscribeEx | SubscribeEx | Os descendentes acrescentam argumentos de durabilidade, exclusividade e modo de confirmação. |
| Utilitários de fila | — | SubscribeQueue, PublishQueue, UnSubscribeQueue | SubscribeQueue, PublishQueue, UnSubscribeQueue | O prefixo de destino /queue/, encapsulado. |
| Utilitários de tópico | — | SubscribeTopic, PublishTopic, UnSubscribeTopic | SubscribeTopic, PublishTopic, UnSubscribeTopic | O prefixo de destino /topic/, encapsulado. |
| Utilitários de exchange | — | SubscribeExchange, PublishExchange | — | O destino /exchange/ do RabbitMQ com um padrão de roteamento. |
| Filas externas | — | SubscribeQueueOutside, PublishQueueOutside | — | O /amq/queue/ do RabbitMQ, para filas declaradas em outro lugar. |
| Filas temporárias de resposta | — | SubscribeTemporaryQueue, PublishTemporaryQueue | — | O padrão de requisição e resposta /temp-queue/ do RabbitMQ. |
| Confirmar | ACK / NACK | ✓ | ✓ | Modo de confirmação escolhido por assinatura (ackAuto e afins). |
| Transações | BeginTransaction, CommitTransaction, AbortTransaction | ✓ | ✓ | Agrupe vários frames SEND e ACK em uma única unidade atômica. |
| Recibos | OnSTOMPReceipt | OnRabbitMQReceipt | OnActiveMQReceipt | O broker confirma um frame que processou. |
| Evento de mensagem | OnSTOMPMessage | OnRabbitMQMessage | OnActiveMQMessage | Entrega o destino, o corpo e os cabeçalhos do frame. |
| Heartbeat | HeartBeat, Ping | ✓ | ✓ | Negociado no frame CONNECT, nos dois sentidos. |
| Negociação de versão | Versions.V1_0, V1_1, V1_2 | ✓ | ✓ | Anuncie as versões que você aceita e o broker escolhe uma. |
| Host virtual | Options.VirtualHost | ✓ | ✓ | Enviado como o cabeçalho host no CONNECT. |
| Extensões do broker | — | — | ActiveMQ_Options | Cabeçalhos específicos do ActiveMQ, expostos como propriedade publicada. |
Todo componente de protocolo se conecta a um TsgcTCPClient pela propriedade Client. Esse único transporte dá a você TCP puro e TLS sem mudar o código do protocolo.
| Área | Detalhe |
|---|---|
| TCP puro | Atribua um TsgcTCPClient a Client e o protocolo roda direto sobre o socket, na porta nativa do broker. |
| WebSocket | Não está no sgcMQ. Um transporte WebSocket, por exemplo MQTT sobre WebSocket ou Web-STOMP, precisa do cliente WebSocket que vem com o sgcWebSockets. |
| TLS | TLSOptions no transporte, com TLSOptions.IOHandler escolhendo OpenSSL para builds multiplataforma ou SChannel no Windows. |
| Certificados de cliente | TLS mútuo pelas mesmas TLSOptions, a partir de um arquivo PEM, de um pacote PKCS#12 ou do repositório de certificados do Windows. |
| Proxies | Suporte a proxy HTTP CONNECT no transporte, então um broker atrás de um proxy corporativo fica acessível. |
| Reconexão | O WatchDog no transporte reconecta depois de uma queda do link, com intervalo e número de tentativas configuráveis. |
| IPv6 | Suportado pelo transporte, então um endereço de broker IPv6 não precisa de configuração extra. |
| Threads | A leitura roda na própria thread. Ajuste as configurações de notificação do transporte para levar os eventos à thread principal em código VCL e FMX. |
Protocolos publicados, e o mesmo código-fonte em todos os compiladores compatíveis.
| Área | Detalhe |
|---|---|
| MQTT | OASIS MQTT 3.1.1 e MQTT 5.0. |
| AMQP 0.9.1 | A especificação AMQP 0-9-1: canais, exchanges, filas, vínculos e a classe basic. |
| AMQP 1.0 | OASIS AMQP 1.0, também publicada como ISO/IEC 19464. |
| Kafka | O protocolo de rede do Apache Kafka sobre TCP, incluindo o formato de lote de registros v2. |
| STOMP | STOMP 1.0, 1.1 e 1.2. |
| WebSocket | Não incluído. Um transporte WebSocket exige o sgcWebSockets, que fornece o cliente WebSocket. |
| TLS | TLS 1.2 e TLS 1.3 por OpenSSL, ou o SChannel do Windows. |
| Compiladores | Delphi e C++ Builder 7 até 13. |
| Plataformas | Win32, Win64, Linux64, macOS, iOS e Android. |
| Licenciamento | Autônomo. O runtime sgcWebSockets Core vem embutido e o código-fonte completo está incluído. |