FixServer

FixServer

public FixServer(IAuthorization authorization, ITransactionIdStorage transactionIdStorage, string licenseFeatureId, Type componentType)

fixServer = FixServer(authorization, transactionIdStorage, licenseFeatureId, componentType)

初始化了 & ##FixServer+#的新实例.

authorization

客户认证.

transactionIdStorage

交易和请求识别资料存储。

licenseFeatureId

LicenseFeatureId

componentType

ComponentTimestamp

FixServer

public FixServer(IAuthorization authorization, ITransactionIdStorage transactionIdStorage, string licenseFeatureId, DateTime componentTimestamp, IMessageConverter converter)

fixServer = FixServer(authorization, transactionIdStorage, licenseFeatureId, componentTimestamp, converter)

初始化了 & ##FixServer+#的新实例.

authorization

客户认证.

transactionIdStorage

交易和请求识别资料存储。

licenseFeatureId

LicenseFeatureId

componentTimestamp

ComponentTimestamp

converter

消息转换器。

Authorization

public IAuthorization Authorization { get; }

value = fixServer.Authorization

客户认证.

ComponentTimestamp

public DateTime ComponentTimestamp { get; }

value = fixServer.ComponentTimestamp

组件时间戳。

Converter

public IMessageConverter Converter { get; }

value = fixServer.Converter

FIX QQ StockSharp 信件转换器 。

LicenseFeatureId

public string LicenseFeatureId { get; }

value = fixServer.LicenseFeatureId

许可特性 ID 将作为登录回复发送 。

SendOutHeartbeats

public bool SendOutHeartbeats { get; set; }

value = fixServer.SendOutHeartbeats
fixServer.SendOutHeartbeats = value

通过发送消息的频道发送心跳.

TransactionIdStorage

public ITransactionIdStorage TransactionIdStorage { get; }

value = fixServer.TransactionIdStorage

CreateCondition

protected virtual OrderCondition CreateCondition()

result = fixServer.CreateCondition()

以创造出秩序条件.

返回值: 秩序条件。

CreateSubscription

protected override FixServerSubscription CreateSubscription(ClientFixSession session, string requestId, ServerSubscription subscription, MessageTypes type)

result = fixServer.CreateSubscription(session, requestId, subscription, type)

CreateTransactionId

private long CreateTransactionId(ClientFixSession session, string requestId)

result = fixServer.CreateTransactionId(session, requestId)

生成新的请求标识符 。

session

届会。

requestId

请求识别符。

返回值: 交易身份证明。

GetSessionKey

protected override string GetSessionKey(ClientFixSession session)

result = fixServer.GetSessionKey(session)

IsStubSubscription

protected override bool IsStubSubscription(FixServerSubscription subscription)

result = fixServer.IsStubSubscription(subscription)

Load

public override void Load(SettingsStorage storage)

fixServer.Load(storage)

装入设置 。

storage

设置存储 。

OnClearListenerState

protected override void OnClearListenerState()

fixServer.OnClearListenerState()

清除协议特定听众状态(停止听众等).

OnProcess

protected virtual IAsyncEnumerable<Message> OnProcess(FixSession session, string msgType, IFixReader reader, CancellationToken cancellationToken)

result = fixServer.OnProcess(session, msgType, reader, cancellationToken)

接收到的信息正在处理时,该方法就称为.

OnStartListeners

protected override void OnStartListeners(CancellationToken cancellationToken)

fixServer.OnStartListeners(cancellationToken)

Start protocol-specific listeners (TCP, etc.). Add tasks to _backgroundTasks.

PostInitCondition

protected virtual void PostInitCondition(char ordType, OrderCondition condition)

fixServer.PostInitCondition(ordType, condition)

定单条件最终初始化.

ordType

秩序类型。

condition

秩序条件。

ProcessInMessage

protected override void ProcessInMessage(Message message, CancellationToken cancellationToken)

fixServer.ProcessInMessage(message, cancellationToken)

处理发送到订阅客户端的消息和路径 。

ProcessLogout

protected override void ProcessLogout(ClientFixSession session)

fixServer.ProcessLogout(session)

ReadOrderConditionAsync

protected virtual ValueTask<bool> ReadOrderConditionAsync(IFixServerSerializer serializer, FixTags tag, Func<OrderCondition> getCondition, CancellationToken cancellationToken)

result = fixServer.ReadOrderConditionAsync(serializer, tag, getCondition, cancellationToken)

读取命令条件 * * * OrderCondition * * * * 。

serializer

IFixServerSerializer

tag

标记。

getCondition

函数返回命令条件 。

cancellationToken

CancellationToken

返回值: 数据是否被成功处理 。

Save

public override void Save(SettingsStorage storage)

fixServer.Save(storage)

保存设置 。

storage

设置存储 。

ScheduleSessionWork

protected override void ScheduleSessionWork(ClientFixSession session, ServerSubscription subscription, string requestId, Func<ClientFixSession, string, CancellationToken, ValueTask<bool>> handler)

fixServer.ScheduleSessionWork(session, subscription, requestId, handler)

TryGetRequestId

private static string TryGetRequestId(ClientFixSession session, long transactionId)

result = FixServer.TryGetRequestId(session, transactionId)

获取请求标识符 。

session

开会

transactionId

交易身份证明。

返回值: 请求识别符。

TryResolveTransactionId

internal static bool TryResolveTransactionId(ISessionTransactionIdStorage storage, string requestId, long transactionId)

result = FixServer.TryResolveTransactionId(storage, requestId, transactionId)

将客户端请求ID解析为服务器交易 ID 。

storage

会话交易 id 存储 。

requestId

请求识别符 。

transactionId

解决的交易ID。

返回值: 如果交易ID解决;否则,

WriterFixOrderConditionAsync

protected virtual ValueTask WriterFixOrderConditionAsync(IFixServerSerializer serializer, OrderCondition condition, CancellationToken cancellationToken)

result = fixServer.WriterFixOrderConditionAsync(serializer, condition, cancellationToken)

以顺序条件(sync servation)记录数据.

serializer

IFixServerSerializer

condition

订单条件(e.g., stop-和algo-订单参数).

cancellationToken

取消的代币。