AMQP 1.0 协议
高级消息传递的 OASIS 标准。从 Delphi 连接到 Azure Service Bus、Apache Qpid 及任何符合 AMQP 1.0 规范的代理。
高级消息传递的 OASIS 标准。从 Delphi 连接到 Azure Service Bus、Apache Qpid 及任何符合 AMQP 1.0 规范的代理。
AMQP 1.0 子协议客户端 — 会话、发送方和接收方链接、用于 Azure Service Bus 的基于声明的安全令牌，支持 WebSocket 或原始 TCP 传输。
TsgcWSPClient_AMQP1
Windows, macOS, Linux, iOS, Android
Professional / Enterprise
创建会话，然后创建发送方/接收方链接，即可收发消息。CBS 辅助函数封装了 Azure Service Bus SAS / OAuth 认证。
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;5 个已发布属性、12 个方法、14 个事件 — 摘自组件参考文档。
已发布属性：Client、Broker、Guid。
事件：OnAMQPMessage、OnAMQPMessageSent、OnAMQPMessageSentAck。
事件：OnAMQPSASLAuthentication。
方法：CreateSession、CloseSession。
事件：OnAMQPConnect、OnAMQPDisconnect、OnAMQPClose。
方法：WriteData。
该组件实现的协议权威来源。