Todo lo que hace sgcMQ, repartido entre los siete componentes cliente y las especificaciones que implementan. Cada capacidad funciona igual en Delphi y en C++ Builder, y todas las licencias incluyen el código fuente completo. Haz clic en un componente para ver su propia página con uso y ejemplos.
3.1.1 y 5.0
0.9.1 y 1.0
Protocolo de red nativo
1.0 / 1.1 / 1.2
TCP plano y TLS
Delphi 7 a 13, C++ Builder
sgcMQ es autónomo. Se entrega con el runtime sgcWebSockets Core incluido, así que no es un complemento y no hay ninguna licencia base que comprar.
Transporte: TCP plano y TLS. sgcMQ se conecta sobre TCP plano y TLS. Si necesitas ejecutar el protocolo sobre WebSocket, por ejemplo MQTT sobre WebSocket o AMQP sobre WebSocket, hace falta un paquete sgcWebSockets, que es el que aporta el cliente WebSocket.
Todas las capacidades de las tablas siguientes se alcanzan a través del portador TCP en crudo TsgcTCPClient, que sgcMQ incluye de serie.
Cuatro familias de protocolos, registradas en la página de paleta SGC MQ.
| Componente | Clase | Familia | Descripción |
|---|---|---|---|
| MQTT Client | TsgcWSPClient_MQTT | MQTT | Publicación/suscripción MQTT 3.1.1 y 5.0: QoS 0/1/2, mensajes retenidos, Last Will and Testament, sesiones y propiedades de MQTT 5. |
| AMQP 0.9.1 Client | TsgcWSPClient_AMQP | AMQP | Canales, exchanges, colas y bindings, consumidores, confirmaciones, QoS de prefetch y transacciones. |
| AMQP 1.0 Client | TsgcWSPClient_AMQP1 | AMQP | Sesiones, enlaces emisores y receptores, control de flujo basado en créditos, autenticación SASL y utilidades de token CBS de Azure. |
| Kafka Client | TsgcWSPClient_Kafka | Kafka | Productor con acks y gzip, grupos de consumidores con rebalanceo y commit de offsets, administración de topics. |
| STOMP Client | TsgcWSPClient_STOMP | STOMP | Frames STOMP 1.0/1.1/1.2: SEND, SUBSCRIBE, ACK, NACK, recibos, heart-beating y transacciones. |
| STOMP RabbitMQ Client | TsgcWSPClient_STOMP_RabbitMQ | STOMP | STOMP afinado para RabbitMQ: utilidades de cola, topic, exchange, cola externa y cola temporal, sobre TCP o TLS. |
| STOMP ActiveMQ Client | TsgcWSPClient_STOMP_ActiveMQ | STOMP | STOMP afinado para Apache ActiveMQ, con utilidades de cola y topic más una propiedad ActiveMQ_Options. |
El protocolo de publicación/suscripción del IoT, con toda la maquinaria de calidad de servicio expuesta en lugar de oculta.
| Capacidad | 3.1.1 | 5.0 | Notas |
|---|---|---|---|
| Selección de versión del protocolo | ✓ | ✓ | MQTTVersion acepta mqtt311 o mqtt5. |
| QoS 0, 1 y 2 | ✓ | ✓ | El intercambio de QoS 2 se expone como OnMQTTPubRec, OnMQTTPubRel y OnMQTTPubComp, no se oculta. |
| Mensajes retenidos | ✓ | ✓ | El flag de retención es el cuarto argumento de Publish. |
| Last Will and Testament | ✓ | ✓ | LastWillTestament lleva topic, mensaje, QoS y retención. |
| Suscripciones con comodines | ✓ | ✓ | + para un nivel, # para el resto del árbol. |
| Sesiones | ✓ | ✓ | El argumento Session de OnMQTTConnect indica si el broker ha reanudado una. |
| Publicar y esperar | ✓ | ✓ | PublishAndWait se bloquea hasta que el broker confirma el paquete. |
| Publicar un stream | ✓ | ✓ | Publish tiene una sobrecarga TStream para payloads binarios. |
| Códigos de motivo y nombres | — | ✓ | MQTT 5 devuelve un código de motivo numérico y su nombre en CONNACK y DISCONNECT. |
| Propiedades de CONNECT | — | ✓ | ConnectProperties fija la caducidad de sesión, el máximo de recepción, el tamaño máximo de paquete y el máximo de alias de topic. |
| Alias de topic | — | ✓ | Un entero corto sustituye a un nombre de topic largo en la red, y se resuelve automáticamente en los paquetes entrantes. |
| Propiedades de usuario | — | ✓ | Pares clave/valor arbitrarios viajan con CONNECT, PUBLISH, SUBSCRIBE y DISCONNECT. |
| Suscripciones compartidas | — | ✓ | Suscríbete a $share/<group>/<topic> para repartir las entregas entre un grupo de clientes. |
| Autenticación mejorada | — | ✓ | El viaje de ida y vuelta del paquete AUTH mediante Auth y OnMQTTAuth, para esquemas de desafío/respuesta. |
| Keep-alive | ✓ | ✓ | HeartBeat gobierna PINGREQ, y OnMQTTPing se dispara con la respuesta. |
Dos protocolos que comparten el nombre y nada más, así que sgcMQ trae un componente distinto para cada uno en vez de fingir que una sola API vale para ambos.
| Capacidad | AMQP 0.9.1 | AMQP 1.0 | Notas |
|---|---|---|---|
| Componente | TsgcWSPClient_AMQP | TsgcWSPClient_AMQP1 | Formato de red distinto, modelo de objetos distinto, componente distinto. |
| Unidad de multiplexación | Canal | Sesión | OpenChannel frente a CreateSession. |
| Declaración de topología | DeclareExchange, DeclareQueue, BindQueue | — | AMQP 1.0 direcciona nodos del broker en lugar de declararlos. |
| Envío | PublishMessage(channel, exchange, routingKey, body) | SendMessage(session, link, text) | Routing key en 0.9.1, dirección de destino en 1.0. |
| Recepción | Consume y luego OnAMQPBasicDeliver | CreateReceiverLink y luego OnAMQPMessage | Ambos funcionan por push una vez establecidos. |
| Confirmación | AckMessage / RejectMessage | OnAMQPMessageSentAck | 0.9.1 confirma una etiqueta de entrega, 1.0 liquida una entrega. |
| Control de flujo | Prefetch con SetQoS, EnableChannel / DisableChannel | Basado en créditos (CreditSize, WindowSize) | Ambos evitan que un productor rápido desborde a un consumidor lento. |
| Transacciones | SelectTransaction, CommitTransaction, RollbackTransaction | — | La clase tx de 0.9.1, expuesta por canal. |
| Mantenimiento de colas | PurgeQueue, DeleteQueue, DeleteExchange, UnBindQueue | CloseLink, CloseSession | Cada una con una variante bloqueante ...Ex que espera la respuesta del broker. |
| Reentrega | Recover / RecoverAsync | — | Pide al broker que reentregue los mensajes sin confirmar. |
| Autenticación | OnAMQPAuthentication, OnAMQPChallenge | Authentication.AuthType, OnAMQPSASLAuthentication | 1.0 ofrece SASL ANONYMOUS, PLAIN y EXTERNAL. |
| Utilidades cloud | — | CreateCBSLink, PutCBSToken, CreateAzureCbsSasToken, CreateAzureCbsJWT | Claims-Based Security para Azure Service Bus y Event Hubs. |
| Comprobación de actividad | HeartBeat | Ping, AMQPOptions.IdleTimeout | Se negocia con el broker al conectar. |
| Ajuste de la conexión | AMQPOptions.VirtualHost, MaxChannels, MaxFrameSize, Locale | AMQPOptions.ContainerId, ChannelMax, MaxFrameSize, MaxLinksPerSession | Se envían en el handshake de apertura y se negocian con el broker. |
| Prefetch | SetQoS(channel, prefetchSize, prefetchCount, global) | AMQPOptions.CreditSize | Cuántos mensajes sin confirmar puede tener el broker en vuelo. |
| Inspección de frames | — | OnAMQPBeforeReadFrame, OnAMQPBeforeWriteFrame | Consulta o reescribe los frames en crudo antes de procesarlos o enviarlos. |
El protocolo binario de Kafka implementado en Object Pascal, sin proxy REST delante ni librdkafka debajo.
| Capacidad | API | Notas |
|---|---|---|
| Producir un registro | Produce(topic, value, key, partition) | La clave y la partición son opcionales. ProduceBytes acepta TBytes para ambas. |
| Producir un lote | ProduceMessages(topic, partition, messages) | Devuelve la respuesta de producción del broker para todo el lote. |
| Garantía de entrega | KafkaOptions.Producer.Acks | kafkaAcksNone, kafkaAcksLeader o kafkaAcksAll. |
| Compresión | KafkaOptions.Producer.Compression | kafkaCompressionNone o kafkaCompressionGzip. |
| Consumir | Subscribe([topics]) y luego Poll(timeoutMs) | Poll devuelve una lista TsgcKafkaMessages y además dispara OnKafkaMessage por cada registro. |
| Grupos de consumidores | KafkaOptions.Consumer.GroupId | El descubrimiento del coordinador, el join, el sync y el heartbeat se gestionan por ti. OnKafkaRebalance informa de los cambios de asignación. |
| Política de offsets | KafkaOptions.Consumer.OffsetReset | kafkaOffsetEarliest o kafkaOffsetLatest cuando no hay ningún offset confirmado. |
| Confirmar offsets | CommitSync, CommitOffset(topic, partition, offset) | O activa Consumer.AutoCommit con AutoCommitIntervalMs. |
| Leer una partición directamente | FetchMessages(topic, partition, offset, maxBytes) | Se salta por completo el grupo de consumidores. |
| Consulta de offsets | GetEarliestOffset, GetLatestOffset, GetCommittedOffset | Por topic y partición. |
| Ajuste del fetch | Consumer.MinBytes, MaxBytes, MaxPartitionBytes, MaxWaitMs | Equilibra la latencia frente al tamaño del lote. |
| Administración de topics | CreateTopic, DeleteTopic, GetMetadata | Número de particiones y factor de replicación al crearlos. |
| Administración de grupos | ListGroups, DescribeGroups | Inspecciona los grupos de consumidores desde tus propias herramientas. |
| Sondeo de capacidades del broker | GetApiVersions | Pregunta al broker qué versiones de la API del protocolo admite. |
| SASL | kafkaSaslNone, kafkaSaslPlain | Autenticación SASL/PLAIN con usuario y contraseña. |
Un cliente genérico más dos descendientes específicos de broker que convierten las convenciones de destino de RabbitMQ y ActiveMQ en métodos con nombre.
| Capacidad | STOMP | RabbitMQ | ActiveMQ | Notas |
|---|---|---|---|---|
| Enviar un frame | Send | PublishEx | PublishEx | Destino, cuerpo, tipo de contenido y transacción opcional. |
| Suscribirse | Subscribe(id, destination) | SubscribeEx | SubscribeEx | Los descendientes añaden argumentos de durabilidad, exclusividad y modo de ack. |
| Utilidades de cola | — | SubscribeQueue, PublishQueue, UnSubscribeQueue | SubscribeQueue, PublishQueue, UnSubscribeQueue | El prefijo de destino /queue/, ya encapsulado. |
| Utilidades de topic | — | SubscribeTopic, PublishTopic, UnSubscribeTopic | SubscribeTopic, PublishTopic, UnSubscribeTopic | El prefijo de destino /topic/, ya encapsulado. |
| Utilidades de exchange | — | SubscribeExchange, PublishExchange | — | El destino /exchange/ de RabbitMQ con un patrón de enrutamiento. |
| Colas externas | — | SubscribeQueueOutside, PublishQueueOutside | — | El /amq/queue/ de RabbitMQ, para colas declaradas en otro sitio. |
| Colas de respuesta temporales | — | SubscribeTemporaryQueue, PublishTemporaryQueue | — | El patrón petición/respuesta /temp-queue/ de RabbitMQ. |
| Confirmar | ACK / NACK | ✓ | ✓ | Modo de ack elegido por suscripción (ackAuto y compañía). |
| Transacciones | BeginTransaction, CommitTransaction, AbortTransaction | ✓ | ✓ | Agrupa varios frames SEND y ACK en una única unidad atómica. |
| Recibos | OnSTOMPReceipt | OnRabbitMQReceipt | OnActiveMQReceipt | El broker confirma un frame que ha procesado. |
| Evento de mensaje | OnSTOMPMessage | OnRabbitMQMessage | OnActiveMQMessage | Entrega el destino, el cuerpo y las cabeceras del frame. |
| Heart-beating | HeartBeat, Ping | ✓ | ✓ | Se negocia en el frame CONNECT, en ambos sentidos. |
| Negociación de versión | Versions.V1_0, V1_1, V1_2 | ✓ | ✓ | Anuncia las versiones que aceptas y el broker elige una. |
| Virtual host | Options.VirtualHost | ✓ | ✓ | Se envía como cabecera host en CONNECT. |
| Extensiones del broker | — | — | ActiveMQ_Options | Cabeceras específicas de ActiveMQ, expuestas como propiedad publicada. |
Cada componente de protocolo se engancha a un TsgcTCPClient mediante su propiedad Client. Ese único portador te da TCP plano y TLS sin cambiar el código del protocolo.
| Área | Detalle |
|---|---|
| TCP plano | Asigna un TsgcTCPClient a Client y el protocolo corre directamente sobre el socket, en el puerto nativo del broker. |
| WebSocket | No está en sgcMQ. Un portador WebSocket, por ejemplo MQTT sobre WebSocket o Web-STOMP, necesita el cliente WebSocket que se entrega con sgcWebSockets. |
| TLS | TLSOptions en el portador, con TLSOptions.IOHandler para elegir OpenSSL en compilaciones multiplataforma o SChannel en Windows. |
| Certificados de cliente | TLS mutuo con las mismas TLSOptions, desde un archivo PEM, un paquete PKCS#12 o el almacén de certificados de Windows. |
| Proxies | Soporte de proxy HTTP CONNECT en el portador, para llegar a un broker que está detrás de un proxy corporativo. |
| Reconexión | WatchDog en el portador reconecta tras una caída del enlace, con intervalo y número de intentos configurables. |
| IPv6 | Compatible en el portador, así que una dirección de broker IPv6 no necesita configuración adicional. |
| Hilos | La lectura corre en su propio hilo. Ajusta las opciones de notificación del portador para llevar los eventos al hilo principal en código VCL y FMX. |
Protocolos publicados, y el mismo código fuente en todos los compiladores compatibles.
| Área | Detalle |
|---|---|
| MQTT | OASIS MQTT 3.1.1 y MQTT 5.0. |
| AMQP 0.9.1 | La especificación AMQP 0-9-1: canales, exchanges, colas, bindings y la clase basic. |
| AMQP 1.0 | OASIS AMQP 1.0, publicada también como ISO/IEC 19464. |
| Kafka | El protocolo de red de Apache Kafka sobre TCP, incluido el formato de lote de registros v2. |
| STOMP | STOMP 1.0, 1.1 y 1.2. |
| WebSocket | No incluido. Un portador WebSocket requiere sgcWebSockets, que es quien aporta el cliente WebSocket. |
| TLS | TLS 1.2 y TLS 1.3 mediante OpenSSL, o SChannel en Windows. |
| Compiladores | Delphi y C++ Builder 7 a 13. |
| Plataformas | Win32, Win64, Linux64, macOS, iOS y Android. |
| Licencias | Producto independiente. Lleva incluido el runtime sgcWebSockets Core y el código fuente completo. |