Przejdź do treści

Nawiąż połączenie

Możesz połączyć się z proxy cTrader Open API za pomocą protokołu TCP lub protokołu WebSocket. Ten przewodnik obejmuje obie te opcje.

Korzystanie z TCP

Użycie SSL

Połączenie klienta TCP musi używać SSL, w przeciwnym razie nie będziesz w stanie połączyć się ani wchodzić w interakcje z API.

Możesz nawiązać połączenie w następujący sposób, korzystając z oficjalnych SDK cTrader Open API.

1
2
_client = new OpenClient("live1.p.ctrader.com", 5035, TimeSpan.FromSeconds(10), useWebSocket: false);
await _client.Connect()

Metoda OpenClient.Connect() wywołuje metodę OpenClient.ConnectTcp().

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
private async Task ConnectTcp()
{
    _tcpClient = new TcpClient
    {
        LingerState = new LingerOption(enable: true, 10)
    };
    await _tcpClient.ConnectAsync(Host, Port).ConfigureAwait(continueOnCapturedContext: false);
    _sslStream = new SslStream(_tcpClient.GetStream(), leaveInnerStreamOpen: false);
    await _sslStream.AuthenticateAsClientAsync(Host).ConfigureAwait(continueOnCapturedContext: false);
    Task.Run(delegate
    {
        ReadTcp(_cancellationTokenSource.Token);
    });
}

Klient Python Open API automatycznie próbuje nawiązać połączenie podczas inicjalizacji.

1
client = Client("live1.p.ctrader.com", 5035, TcpProtocol)

Przez WebSocket

Podczas łączenia się za pośrednictwem protokołu WebSocket host i port są takie same jak podczas łączenia się za pośrednictwem protokołu TCP.

Oto jak oficjalne SDK cTrader Open API nawiązują połączenie przez WebSocket.

1
2
_client = new OpenClient("live1.p.ctrader.com", 5035, TimeSpan.FromSeconds(10), useWebSocket: true);
await _client.Connect()

Metoda OpenClient.Connect() wywołuje metodę OpenClient.ConnectWebSocket().

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
private async Task ConnectWebScoket()
{
    DefaultInterpolatedStringHandler defaultInterpolatedStringHandler = new DefaultInterpolatedStringHandler(7, 2);
    defaultInterpolatedStringHandler.AppendLiteral("wss://");
    defaultInterpolatedStringHandler.AppendFormatted(Host);
    defaultInterpolatedStringHandler.AppendLiteral(":");
    defaultInterpolatedStringHandler.AppendFormatted(Port);
    Uri url = new Uri(defaultInterpolatedStringHandler.ToStringAndClear());
    _websocketClient = new WebsocketClient(url, () => new ClientWebSocket())
    {
        IsTextMessageConversionEnabled = false,
        ReconnectTimeout = null,
        IsReconnectionEnabled = false,
        ErrorReconnectTimeout = null
    };
    _webSocketMessageReceivedDisposable = _websocketClient.MessageReceived.Select((ResponseMessage msg) => ProtoMessage.Parser.ParseFrom(msg.Binary)).Subscribe(new Action<ProtoMessage>(OnNext));
    _webSocketDisconnectionHappenedDisposable = _websocketClient.DisconnectionHappened.Subscribe(new Action<DisconnectionInfo>(OnWebSocketDisconnectionHappened));
    await _websocketClient.StartOrFail();
}

SDK Pythona nie obsługuje standardu WebSocket.

Aby zobaczyć przykład aplikacji internetowej .NET Blazor, która używa standardu WebSocket do nawiązywania i utrzymywania połączenia, kliknij tutaj.

Najlepsze praktyki

Oto kilka wytycznych, o których należy pamiętać podczas łączenia się z cTrader Open API:

  • Co najwyżej powinieneś(-naś) utworzyć dwa połączenia: jedno dla kont demo i jedno dla kont rzeczywistych. Każde połączenie może obsługiwać nieograniczoną liczbę kont określonego typu.
  • Po nawiązaniu połączenia należy przejść przez proces autoryzacji aplikacji. Jeśli wyślesz jakiekolwiek komunikaty przed autoryzacją aplikacji, otrzymasz błąd.
  • Aby utrzymać połączenie aktywne, wysyłaj zdarzenie heartbeat (ProtoHeartbeatEvent) co 10 sekund.
  • Użyj kolejki komunikatów do wysyłania i odbierania danych, aby uniknąć jednoczesnych zdarzeń wysyłania i odbierania.