IProtocolServer

StockSharp.Server.Core

Общий интерфейс для серверов протоколов (FIX, SBE и т. д.). Предоставляет унифицированный API для запуска сервера и маршрутизации сообщений.

Реализует: ILogReceiver, ILogSource, IDisposable

Свойства

Sessions

public IEnumerable<IMessageListenerSession> Sessions { get; }

value = iProtocolServer.Sessions

Снимок всех клиентских сессий, проводимых в настоящее время сервером. Полезен для тестов, которые должны проверять учет сеансов на стороне сервера независимо от того, что видит клиентский адаптер (например, FIX-адаптер автоматически подключается после удара на стороне сервера, поэтому клиентская сторона DisconnectMessage не является надежным сигналом).

State

public ChannelStates State { get; }

value = iProtocolServer.State

Текущее состояние сервера.

Методы

RunAsync

public IAsyncEnumerable<ValueTuple<IMessageListenerSession, Message>> RunAsync(CancellationToken cancellationToken)

result = iProtocolServer.RunAsync(cancellationToken)

Запустите сервер и получайте входящие сообщения от подключенных клиентов.

SendInMessage

public bool SendInMessage(Message message)

result = iProtocolServer.SendInMessage(message)

Отправьте сообщение из серверного модуля подключенным клиентам.

SendInMessage

public bool SendInMessage(IMessageListenerSession session, Message message)

result = iProtocolServer.SendInMessage(session, message)

Отправьте сообщение в конкретный клиентский сеанс. Реализация по умолчанию игнорирует сеанс и широковещательные сообщения.