サーバーからクライアントに市場データを配信するクライアント サーバー アプリケーションがあります。今、私は 2 つの問題に固執しています: 1. コールバックのパフォーマンスが悪い。1 秒あたり最大 1.5K のコールバックを達成しました。これは私のサーバーバインディングです:
<netTcpBinding>
<binding name="Net_Tcp_Binding" receiveTimeout="10:00:00" sendTimeout="00:00:30"
maxConnections="100">
<readerQuotas maxArrayLength="2147483647" />
<security mode="None" />
</binding>
</netTcpBinding>
およびサービス契約 (データの 95% は MarketDepthUpdate および EntityUpdate を使用して配信されます) :
namespace TradePlatform.DataDeliveryContracts.ServiceContracts
public interface ITradeServiceCallback
{
[OperationContract(IsOneWay = true)]
void InstrumentUpdate(InstrumentInfo instrument);
[OperationContract(IsOneWay = true)]
void OrderUpdate(OrderInfo order);
[OperationContract(IsOneWay = true)]
void OrderFailedUpdate(OrderFailInfo orderFailed);
[OperationContract(IsOneWay = true)]
void MyTradeUpdate(MyTradeInfo myTrade);
[OperationContract(IsOneWay = true)]
void TradeUpdate(TradeInfo trade);
[OperationContract(IsOneWay = true)]
void PortfolioUpdate(DSPortfolioInfo portfolio);
[OperationContract(IsOneWay = true)]
void PositionUpdate(PositionInfo position);
[OperationContract(IsOneWay = true)]
void MarketDepthUpdate(MarketDepthShortInfo marketDepth);
[OperationContract(IsOneWay = true)]
void DisconnectUser();
[OperationContract(IsOneWay = true)]
void UserUpdate(UserInfo user);
[OperationContract(IsOneWay = true)]
void FileUpdate(FileDataInfo file);
[OperationContract(IsOneWay = true)]
void SimulationDataUpdate(SimulationModeData simulationData);
[OperationContract(IsOneWay = true)]
void MessageUpdate(MessageId message, params object[] parameters);
[OperationContract(IsOneWay = true)]
void EntityUpdate(DataUpdateInfo updateInfo);
[OperationContract(IsOneWay = true)]
void Ping();
}
そして、これはクライアントです:
NetTcpBinding binding = new NetTcpBinding
{
Security = { Mode = SecurityMode.None },
MaxReceivedMessageSize = 2147483647
};
binding.ReaderQuotas = new XmlDictionaryReaderQuotas();
binding.ReaderQuotas.MaxArrayLength = 2147483647;
binding.ReceiveTimeout = new TimeSpan(0, 10, 0);
binding.SendTimeout = new TimeSpan(0, 10, 0);