TsgcWebSocketHTTPServer › Methoden › Broadcast
Sendet dieselbe WebSocket-Nachricht an alle verbundenen Clients, optional gefiltert nach Kanal, Protokoll oder Verbindungs-GUID-Liste.
procedure Broadcast(const aMessage: string; const aChannel: string = ''; const aProtocol: string = ''; const Exclude: String = ''; const Include: String = '');
| Name | Typ | Beschreibung |
|---|---|---|
aMessage | const string | Text-Payload, die jedem übereinstimmenden Client als WebSocket-Text-Frame zugestellt wird. |
aChannel | const string | Wenn nicht leer, wird die Nachricht nur an Clients gesendet, die den angegebenen Kanal abonniert haben. |
aProtocol | const string | Wenn nicht leer, wird die Nachricht nur an Clients gesendet, die das angegebene WebSocket-Subprotokoll verwenden. |
Exclude | const String | Kommagetrennte Liste von Verbindungs-GUIDs, die von diesem Broadcast übersprungen werden müssen. |
Include | const String | Durch Kommas getrennte Liste von Verbindungs-GUIDs, die den Broadcast auf diese Teilmenge beschränkt; wird ignoriert, wenn leer. |
Diese Überladung sendet einen Text-Frame an jede aktive WebSocket-Verbindung, die vom HTTP-Server gehostet wird und die bereitgestellten Filter erfüllt. Filter werden mit UND-Semantik kombiniert: eine Verbindung empfängt die Nachricht nur, wenn sie jeden nicht leeren Filter erfüllt, und wird nie erreicht, wenn ihre GUID in Exclude erscheint. Reine HTTP/HTTP2-Anforderungen werden ignoriert, da Broadcast nur Clients anvisiert, die den WebSocket-Handshake abgeschlossen haben. Wenn LoadBalancer aktiviert ist, wird der Aufruf über den Cluster weitergeleitet, sodass Remote-Knoten die Nachricht ebenfalls an ihre lokalen Clients zustellen. Der Aufruf läuft im Thread des Aufrufers und kehrt zurück, sobald die Frames an jeden Socket übergeben wurden; Schreibfehler pro Verbindung werden über OnException gemeldet, ohne den Broadcast abzubrechen.
oServer.Broadcast('Hello From Server');
procedure Broadcast(aStream: TStream; const aChannel: string = ''; const aProtocol: string = ''; const Exclude: String = ''; const Include: String = ''; const aSize: Integer = 0; const aStreaming: TwsStreaming = stmNone);
| Name | Typ | Beschreibung |
|---|---|---|
aStream | TStream | Quell-Stream, dessen Inhalt jedem passenden Client als WebSocket-Binär-Frame zugestellt wird. Der Aufrufer bleibt Eigentümer des Streams. |
aChannel | const string | Wenn nicht leer, wird die Nachricht nur an Clients gesendet, die den angegebenen Kanal abonniert haben. |
aProtocol | const string | Wenn nicht leer, wird die Nachricht nur an Clients gesendet, die das angegebene WebSocket-Subprotokoll verwenden. |
Exclude | const String | Kommagetrennte Liste von Verbindungs-GUIDs, die von diesem Broadcast übersprungen werden müssen. |
Include | const String | Durch Kommas getrennte Liste von Verbindungs-GUIDs, die den Broadcast auf diese Teilmenge beschränkt; wird ignoriert, wenn leer. |
aSize | const Integer | Optionale Fragmentgröße in Bytes; bei einem Wert größer als null erhält jeder Client den Stream in Fragmente dieser Größe aufgeteilt. Verwenden Sie 0 (Standard), um den gesamten Stream als einzelnen Frame zu senden. |
aStreaming | const TwsStreaming | Streaming-Modus für die fragmentierte Übertragung (stmNone, stmStart, stmContinue, stmFinish). Standard ist stmNone, was eine vollständige eigenständige Nachricht sendet. |
Diese Überladung sendet den Stream-Inhalt als binären Frame an jede WebSocket-Verbindung, die vom HTTP-Server gehostet wird und die Filter für Kanal, Protokoll, Include und Exclude besteht. Der Stream wird von seiner aktuellen Position aus gelesen; der Server übernimmt nicht den Besitz, sodass der Aufrufer den Stream am Leben halten muss, bis Broadcast zurückkehrt. Wenn LoadBalancer aktiviert ist, wird die binäre Nutzlast an andere Knoten weitergeleitet, damit diese sie erneut an ihre lokalen Clients ausliefern können. Verwenden Sie aSize zusammen mit aStreaming, um sehr große Nutzlasten als mehrere WebSocket-Fragmente anstatt als einen übergroßen Frame zu streamen.
oStream := TMemoryStream.Create;
try
oStream.LoadFromFile('payload.bin');
oServer.Broadcast(oStream);
finally
oStream.Free;
end;