0

サーバーからクライアントに市場データを配信するクライアント サーバー アプリケーションがあります。今、私は 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);
4

0 に答える 0