TsgcWebSocketHTTPServer方法 › Broadcast

Broadcast 方法

向所有已连接的客户端发送相同的 WebSocket 消息,可选择按频道、协议或连接 GUID 列表进行过滤。

重载

重载 1

语法

procedure Broadcast(const aMessage: string; const aChannel: string = ''; const aProtocol: string = ''; const Exclude: String = ''; const Include: String = '');

参数

名称类型描述
aMessageconst string以 WebSocket 文本帧形式投递给每个匹配客户端的文本负载。
aChannelconst string当非空时,消息仅发送给订阅了给定频道的客户端。
aProtocolconst string当非空时,消息仅发送给使用给定 WebSocket 子协议的客户端。
Excludeconst String此广播应跳过的连接 GUID 的逗号分隔列表。
Includeconst String以逗号分隔的连接 GUID 列表,将广播限制在该子集内;为空时忽略。

备注

此重载将文本帧发送到 HTTP 服务器托管的每个与提供的过滤器匹配的活跃 WebSocket 连接。过滤器以 AND 语义组合:只有当连接满足每个非空过滤器时才接收消息,当其 GUID 出现在 Exclude 中时永远不会接收。纯 HTTP/HTTP2 请求被忽略,因为 Broadcast 仅针对完成了 WebSocket 握手的客户端。当 LoadBalancer 启用时,调用将在集群中转发,使远程节点也将消息传递给其本地客户端。调用在调用方的线程上运行,并在帧交给每个套接字后返回;每个连接的写入错误通过 OnException 报告,而不会中止广播。

示例


oServer.Broadcast('Hello From Server');

重载 2

语法

procedure Broadcast(aStream: TStream; const aChannel: string = ''; const aProtocol: string = ''; const Exclude: String = ''; const Include: String = ''; const aSize: Integer = 0; const aStreaming: TwsStreaming = stmNone);

参数

名称类型描述
aStreamTStream源流,其内容作为 WebSocket 二进制帧投递给每个匹配的客户端。调用方保留流的所有权。
aChannelconst string当非空时,消息仅发送给订阅了给定频道的客户端。
aProtocolconst string当非空时,消息仅发送给使用给定 WebSocket 子协议的客户端。
Excludeconst String此广播应跳过的连接 GUID 的逗号分隔列表。
Includeconst String以逗号分隔的连接 GUID 列表,将广播限制在该子集内;为空时忽略。
aSizeconst Integer可选的分片大小(字节);大于零时,每个客户端以该大小的分片接收流。使用 0(默认值)将整个流作为单个帧发送。
aStreamingconst TwsStreaming分片传输的流模式(stmNonestmStartstmContinuestmFinish)。默认为 stmNone,发送完整的独立消息。

备注

此重载将流内容作为二进制帧广播到 HTTP 服务器托管的所有通过通道、协议、Include 和 Exclude 过滤器的 WebSocket 连接。流从其当前位置读取;服务器不获取所有权,因此调用方必须在 Broadcast 返回之前保持流有效。当启用 LoadBalancer 时,二进制负载将转发到其他节点,以便它们向本地客户端重新投递。使用 aSizeaStreaming 将超大负载作为多个 WebSocket 片段而非一个超大帧进行流式传输。

示例


oStream := TMemoryStream.Create;
try
  oStream.LoadFromFile('payload.bin');
  oServer.Broadcast(oStream);
finally
  oStream.Free;
end;

返回方法