Delphi 中的实时通信——选择您的协议

为什么有这个页面

一个库，六种实时协议

sgcWebSockets 在包内提供每个主流的 Delphi 实时客户端和服务器——因此问题不再是"我可以在 Pascal 中做到这一点吗？"，而变成"哪种协议适合这项工作？"

"Delphi 中的实时通信"是一个伞形术语——实际上它涵盖了六种根本不同的网络原语，每种都有不同的延迟、顺序、扇出、NAT 穿越和基础设施特性。错误选择会浪费数月：您交付了一个轮询 REST 循环，遇到可扩展性瓶颈，改装 WebSocket 层，然后发现 MQTT 本应是更好的选择，因为您的流量本质上是发布/订阅。本页是简短而有主见的指南。

决策矩阵

用一张表选择协议

扫描各行；绿色最多的那一列胜出。

需求	WebSocket	SSE	HTTP/2 推送	MQTT	AMQP	WebRTC
双向	是	否（仅服务器→客户端）	否	是（发布/订阅）	是（发布/订阅）	是（对等）
扇出广播	服务器实现	仅按客户端	仅按流	原生（主题）	原生（交换机）	否（1:1）
浏览器支持	是	是	是	通过 WebSocket	通过 WebSocket	是
通过企业代理	通过 wss://443	是（看起来像 HTTP）	是	通过 WSS	通过 WSS	通常（TURN）
保证投递	应用级	应用级	应用级	QoS 1/2	已确认	SCTP 可靠
低带宽设备	中等	低	中等	极佳	中等	中等
P2P / NAT 穿越	否（服务器）	否	否	否（代理）	否（代理）	是（ICE）
端到端加密	TLS 逐跳	TLS 逐跳	TLS 逐跳	TLS 逐跳	TLS 逐跳	DTLS-SRTP 端到端
服务器可在 Delphi 中运行	是	是	是	使用外部代理	使用外部代理	是（信令 + STUN/TURN）

建议

简短版

WebSocket

默认选择。双向、开销低、在每个浏览器中工作。适用于实时仪表板、聊天、协作编辑、自定义应用协议。组件 →

Server-Sent Events

当流量是仅服务器 → 客户端且您希望最简单的模型时选择：一个流式传输文本的长期 HTTP 响应。每个浏览器中内置，无需库。SSE →

HTTP/2 推送

用于与主文档一起主动发送子资源（CSS、JS、JSON）——节省一次往返。不是通用的"推送"通道。HTTP/2 →

MQTT

面向 IoT、遥测、移动状态、联网车辆的发布/订阅。QoS 1/2、保留消息、遗嘱、极小的线开销。需要代理。MQTT →

AMQP

企业消息：持久队列、交换机、路由键、死信处理、RabbitMQ / Azure Service Bus / IBM MQ。当您需要丰富路由时选择，而非 MQTT。AMQP →

WebRTC

带 NAT 穿越的直接点对点——用于协作的数据通道，最终是音频/视频。E2E 加密 P2P 的唯一选择。WebRTC →

代码片段

每个看起来是什么样的

使用每个协议进行连接的最小可行 Delphi 代码片段——相同的库，相同的组件模式。

WebSocket

WS := TsgcWebSocketClient.Create(nil);
WS.URL := 'wss://echo.websocket.events';
WS.OnMessage := DoMessage;
WS.Active := True;
WS.WriteData('hello');

Server-Sent Events

SSE := TsgcWSPClient_SSE.Create(nil);
SSE.URL := 'https://stream.example.com/events';
SSE.OnEvent := DoEvent;
SSE.Active := True;

MQTT

MQTT := TsgcWSPClient_MQTT.Create(nil);
MQTT.Client := WSClient;
MQTT.OnMQTTPublish := DoMqttPublish;
WSClient.Active := True;
MQTT.Subscribe('sensors/+/temperature', mtqsAtLeastOnce);

AMQP

AMQP := TsgcWSPClient_AMQP.Create(nil);
AMQP.Client := WSClient;
AMQP.OnAMQPMessage := DoAmqpMessage;
WSClient.Active := True;
AMQP.Consume('orders');

HTTP/2 多路复用 GET

H2 := TsgcHTTP2Client.Create(nil);
H2.Host := 'api.example.com';
H2.Port := 443;
H2.TLS  := True;
H2.OnResponse := DoResponse;
H2.Connect;
for i := 1 to 10 do H2.Get(Format('/items/%d', [i]));

WebRTC 数据通道

RTC := TsgcWSPClient_WebRTC.Create(nil);
RTC.Client := WSSignal;
RTC.IceServers.Add.URL := 'stun:stun.l.google.com:19302';
RTC.OnDataChannelMessage := DoP2PMessage;
WSSignal.Active := True;
RTC.CreateDataChannel('chat', True, True);
RTC.CreateOffer;

陷阱