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)

向特定客户端发送消息。默认执行忽略了会话和广播。