STOMP 与 RabbitMQ

通过 WebSocket 上的 STOMP 将您的 Delphi 应用程序连接到 RabbitMQ。发布消息、订阅队列,并与企业级消息基础设施集成。

TsgcWSPClient_STOMP_RabbitMQ

针对 RabbitMQ Web-STOMP 插件优化的 STOMP 1.0 / 1.1 / 1.2 客户端。支持主题、队列、外部声明队列、临时回复队列和事务。

组件类

TsgcWSPClient_STOMP_RabbitMQ

协议

STOMP 1.2(通过 RabbitMQ Web-STOMP)

支持平台

Windows, macOS, Linux, iOS, Android

版本

Professional / Enterprise

放置组件,配置属性,即刻运行

与 TsgcWebSocketClient 配对,设置 Authentication 和 Options 中的虚拟主机,订阅 /topic/ /queue/ /amq/queue/ 或 /temp-queue/ 目标地址。

uses
  sgcWebSocket, sgcWebSocket_Protocol_STOMP_RabbitMQ_Client;

var
  WSClient: TsgcWebSocketClient;
  STOMP: TsgcWSPClient_STOMP_RabbitMQ;
begin
  WSClient := TsgcWebSocketClient.Create(nil);
  WSClient.Host := 'rabbit.example.com';
  WSClient.Port := 15674;
  WSClient.Options.Parameters := '/ws';

  STOMP := TsgcWSPClient_STOMP_RabbitMQ.Create(nil);
  STOMP.Client := WSClient;
  STOMP.Authentication.Enabled  := True;
  STOMP.Authentication.UserName := 'guest';
  STOMP.Authentication.Password := 'guest';

  STOMP.OnSTOMPConnected := STOMPConnected;
  STOMP.OnSTOMPMessage   := STOMPMessage;

  WSClient.Active := True;
end;

内部功能

8 个已发布属性、25 个方法、6 个事件 — 摘自组件参考文档。

连接

已发布属性:ClientBrokerVersions

消息传递

事件:OnRabbitMQMessageOnRabbitMQReceipt

可靠性

已发布属性:HeartBeat

安全性

已发布属性:Authentication

生命周期

事件:OnRabbitMQConnectedOnRabbitMQDisconnectedOnRabbitMQError

高级功能

方法:WriteData

规范与参考资料

该组件实现的协议权威来源。

文档与示例

直达组件参考文档、获取即用示例项目并下载试用版。

示例项目 — Demos\Protocols\STOMP\RabbitMQ 即用示例项目,包含在 sgcWebSockets 包中 — 请从下方下载试用版。
技术文档(PDF) 功能介绍、快速入门、Delphi 与 C++ Builder 代码示例及原始参考资料 — 仅限此组件。
用户手册(PDF) 涵盖库中每个组件的综合手册。

准备好连接 RabbitMQ 了吗?

下载免费试用版,几分钟内即可与 RabbitMQ 集成。