IProtocolServer

StockSharp.Server.Core

Gemeinsame Schnittstelle für Protokollserver (FIX, SBE usw.): Bietet einheitliche API für den Betrieb des Servers und Routing-Nachrichten.

Implementiert: ILogReceiver, ILogSource, IDisposable

Eigenschaften

Sessions
public IEnumerable<IMessageListenerSession> Sessions { get; }
value = iProtocolServer.Sessions

Eine Momentaufnahme aller Client-Sitzungen, die derzeit vom Server durchgeführt werden. Nützlich für Tests, die die serverseitige Sitzungsbuchhaltung unabhängig davon überprüfen müssen, was der Client-Adapter zufällig sieht (ein FIX-Adapter verbindet sich beispielsweise nach einem serverseitigen Kick automatisch wieder, so dass das clientseitige DisconnectMessage kein zuverlässiges Signal ist).

State
public ChannelStates State { get; }
value = iProtocolServer.State

Aktueller Server-Status.

Methoden

RunAsync
public IAsyncEnumerable<ValueTuple<IMessageListenerSession, Message>> RunAsync(CancellationToken cancellationToken)
result = iProtocolServer.RunAsync(cancellationToken)

Führen Sie den Server aus und geben Sie eingehende Nachrichten von verbundenen Clients ab.

SendInMessage
public bool SendInMessage(Message message)
result = iProtocolServer.SendInMessage(message)

Senden Sie eine Nachricht vom Servermodul an verbundene Clients.

SendInMessage
public bool SendInMessage(IMessageListenerSession session, Message message)
result = iProtocolServer.SendInMessage(session, message)

Senden Sie eine Nachricht an eine bestimmte Clientsitzung. Standardimplementierung ignoriert Sitzung und Sendungen.