Dois componentes cliente AMQP nativos para Delphi e C++Builder: TsgcWSPClient_AMQP fala AMQP 0.9.1 com o RabbitMQ, com exchanges, filas, bindings e confirmações de consumo, e TsgcWSPClient_AMQP1 fala OASIS AMQP 1.0 com Azure Service Bus, Apache Qpid e qualquer broker compatível, sobre um transporte WebSocket ou TCP puro.
AMQP 0.9.1 e AMQP 1.0 compartilham o nome, mas são protocolos de fio diferentes. O sgcWebSockets implementa cada um nativamente, então você escolhe o componente que combina com seu broker.
Um cliente AMQP Delphi conecta sua aplicação VCL ou FMX a brokers de mensageria corporativos. O AMQP 0.9.1 é a versão amplamente implantada usada pelo RabbitMQ: você declara exchanges e filas, faz o binding com routing keys, publica com basic.publish e consome com basic.consume, com transações e confirms por cima. O AMQP 1.0 é o padrão OASIS usado por Azure Service Bus e Apache Qpid: um protocolo simétrico de links construído sobre sessões, sender links e receiver links, com helpers de token Claims-Based-Security para a autenticação SAS e OAuth do Azure Service Bus.
Ambos os componentes se acoplam a um TsgcWebSocketClient pela propriedade Client e rodam sobre um transporte WebSocket ou TCP puro, então o mesmo código alcança um broker nas portas AMQP padrão ou tunela pela porta 443 através de infraestrutura só-HTTP.
TsgcWSPClient_AMQP: exchanges, filas, bindings, transações
TsgcWSPClient_AMQP1: sessões, sender e receiver links, tokens CBS
Transporte WebSocket ou TCP puro, TLS opcional em ambos
Windows, macOS, Linux, iOS, Android. Do Delphi 7 ao Delphi 13
Cada operação do protocolo é um método, cada notificação do broker é um evento.
DeclareExchange, DeclareQueue e BindQueue constroem a topologia de roteamento do RabbitMQ a partir do código: roteamento direct, fanout e topic com escopo por canal via OpenChannel.
PublishMessage envia para uma exchange com uma routing key; Consume assina uma fila e as entregas chegam pelo evento OnAMQPBasicDeliver.
CreateSession abre uma sessão AMQP 1.0, depois CreateSenderLink e CreateReceiverLink se anexam a um endereço de nó. As transferências entrantes chegam por OnAMQPMessage.
Helpers de Claims-Based-Security encapsulam o fluxo de tokens SAS / OAuth do Azure Service Bus, então autenticar contra um namespace vira configuração de propriedades em vez de uma troca CBS construída à mão.
OnAMQPMessageSent e OnAMQPMessageSentAck informam quando uma transferência saiu do cliente e quando o broker a deu como settled.
Os desafios de autenticação aparecem pelos eventos OnAMQPSASLAuthentication (1.0) e OnAMQPAuthentication / OnAMQPChallenge (0.9.1).
O cliente 0.9.1 publica uma propriedade HeartBeat para que conexões ociosas fiquem vivas através de proxies e timeouts do broker.
OnAMQPConnect, OnAMQPDisconnect, OnAMQPClose e OnAMQPException mantêm a aplicação informada do estado do protocolo.
Os dois clientes AMQP estão incluídos em todas as edições do sgcWebSockets, da Standard à Enterprise e All-Access, e na biblioteca .NET.
Emparelhe o componente AMQP com um TsgcWebSocketClient, conecte, depois declare / anexe e pronto.
uses
sgcWebSocket, sgcWebSocket_Protocol_AMQP_Client, sgcAMQP_Classes;
var
WSClient: TsgcWebSocketClient;
AMQP: TsgcWSPClient_AMQP;
begin
WSClient := TsgcWebSocketClient.Create(nil);
WSClient.Host := 'broker.example.com';
WSClient.Port := 15674;
WSClient.Options.Parameters := '/ws';
AMQP := TsgcWSPClient_AMQP.Create(nil);
AMQP.Client := WSClient;
AMQP.OnAMQPConnect := AMQPConnect;
AMQP.OnAMQPBasicDeliver := AMQPBasicDeliver;
WSClient.Active := True;
end;
procedure TForm1.AMQPConnect(Sender: TObject);
begin
AMQP.OpenChannel('ch1');
AMQP.DeclareExchange('ch1', 'orders', 'direct');
AMQP.DeclareQueue('ch1', 'orders_in');
AMQP.BindQueue('ch1', 'orders_in', 'orders', 'create');
AMQP.Consume('ch1', 'orders_in');
// Publish a message
AMQP.PublishMessage('ch1', 'orders', 'create', '{"id":42}');
end;uses
sgcWebSocket, sgcWebSocket_Protocol_AMQP1_Client, sgcAMQP1_Classes;
var
WSClient: TsgcWebSocketClient;
AMQP1: TsgcWSPClient_AMQP1;
oSession: TsgcAMQP1Session;
oSender: TsgcAMQP1SenderLink;
begin
WSClient := TsgcWebSocketClient.Create(nil);
WSClient.Host := 'broker.example.com';
WSClient.Port := 5673;
AMQP1 := TsgcWSPClient_AMQP1.Create(nil);
AMQP1.Client := WSClient;
AMQP1.OnAMQPConnect := AMQPConnect;
AMQP1.OnAMQPMessage := AMQPMessage;
AMQP1.OnAMQPSessionOpen := AMQPSessionOpen;
AMQP1.OnAMQPLinkOpen := AMQPLinkOpen;
WSClient.Active := True;
oSession := AMQP1.CreateSession;
oSender := AMQP1.CreateSenderLink(oSession, '/queue/orders');
// Receivers handle pushed deliveries through OnAMQPMessage
AMQP1.CreateReceiverLink(oSession, '/queue/orders');
end;#include "sgcWebSocket.hpp"
#include "sgcWebSocket_Protocol_AMQP_Client.hpp"
TsgcWebSocketClient* WSClient = new TsgcWebSocketClient(NULL);
WSClient->Host = "broker.example.com";
WSClient->Port = 15674;
WSClient->Options->Parameters = "/ws";
TsgcWSPClient_AMQP* AMQP = new TsgcWSPClient_AMQP(NULL);
AMQP->Client = WSClient;
AMQP->OnAMQPConnect = AMQPConnect;
AMQP->OnAMQPBasicDeliver = AMQPBasicDeliver;
WSClient->Active = true;
// In the OnAMQPConnect handler:
AMQP->OpenChannel("ch1");
AMQP->DeclareExchange("ch1", "orders", "direct");
AMQP->DeclareQueue("ch1", "orders_in");
AMQP->BindQueue("ch1", "orders_in", "orders", "create");
AMQP->Consume("ch1", "orders_in");
AMQP->PublishMessage("ch1", "orders", "create", "{\"id\":42}");Escolha pelo broker, não pelo número da versão. Se o outro lado é o RabbitMQ, use o componente AMQP 0.9.1: ele mapeia um-para-um o modelo do RabbitMQ de exchanges, filas e bindings. Se o outro lado é Azure Service Bus, Apache Qpid ou outro broker que anuncia o padrão OASIS, use o componente AMQP 1.0 e seu modelo de sessões / links.
Os dois vêm no mesmo pacote, então ambientes mistos funcionam bem: uma aplicação pode manter uma conexão 0.9.1 com o RabbitMQ e uma conexão 1.0 com o Azure Service Bus lado a lado, cada uma no seu próprio transporte TsgcWebSocketClient.
Referência completa do TsgcWSPClient_AMQP: propriedades, métodos, eventos e o projeto demo.
Referência completa do TsgcWSPClient_AMQP1: sessões, links e autenticação CBS.
Quando escolher AMQP em vez de MQTT, WebSocket, SSE ou HTTP/2 push.
O modelo de roteamento do AMQP 0.9.1 explicado com código Delphi.
Padrões de publicação e opções de entrega a partir do cliente Delphi.
Tokens Claims-Based-Security contra o Azure Service Bus sobre AMQP 1.0.