Chilkat HOME .NET Core C# Android™ AutoIt C C# C++ Chilkat2-Python CkPython Classic ASP DataFlex Delphi ActiveX Delphi DLL Go Java Lianja Mono C# Node.js Objective-C PHP ActiveX PHP Extension Perl PowerBuilder PowerShell PureBasic Ruby SQL Server Swift 2 Swift 3,4,5... Tcl Unicode C Unicode C++ VB.NET VBScript Visual Basic 6.0 Visual FoxPro Xojo Plugin
(Unicode C) WebSocket Binance Trade Stream (subscribe and receive updates)Subscribe to a binance trade stream and receive updates. For more information, see https://binance-docs.github.io/apidocs/spot/en/#live-subscribing-unsubscribing-to-streams
#include <C_CkWebSocketW.h> #include <C_CkRestW.h> #include <C_CkJsonObjectW.h> void ChilkatSample(void) { HCkWebSocketW ws; HCkRestW rest; BOOL success; const wchar_t *responseBody; HCkJsonObjectW json; BOOL finalFrame; HCkJsonObjectW jsonTradeData; BOOL receivedFinalFrame; int numTradesReceived; const wchar_t *receivedJson; // This example requires the Chilkat API to have been previously unlocked. // See Global Unlock Sample for sample code. ws = CkWebSocketW_Create(); // For brevity, this example does not check for errors when etablishing the WebSocket connection. // See Establish WebSocket Connection for more complete sample code for making the connection. rest = CkRestW_Create(); // Connect to wss://stream.binance.com:9443 success = CkRestW_Connect(rest,L"stream.binance.com",9443,TRUE,FALSE); if (success == FALSE) { wprintf(L"%s\n",CkRestW_lastErrorText(rest)); CkWebSocketW_Dispose(ws); CkRestW_Dispose(rest); return; } success = CkWebSocketW_UseConnection(ws,rest); if (success == FALSE) { wprintf(L"%s\n",CkWebSocketW_lastErrorText(ws)); CkWebSocketW_Dispose(ws); CkRestW_Dispose(rest); return; } CkWebSocketW_AddClientHeaders(ws); // Raw streams are accessed at /ws/<streamName> responseBody = CkRestW_fullRequestNoBody(rest,L"GET",L"/ws/btcusdt"); if (CkRestW_getLastMethodSuccess(rest) == FALSE) { wprintf(L"%s\n",CkRestW_lastErrorText(rest)); CkWebSocketW_Dispose(ws); CkRestW_Dispose(rest); return; } success = CkWebSocketW_ValidateServerHandshake(ws); if (success != TRUE) { wprintf(L"%s\n",CkWebSocketW_lastErrorText(ws)); wprintf(L"%s\n",responseBody); wprintf(L"%s\n",CkRestW_responseHeader(rest)); CkWebSocketW_Dispose(ws); CkRestW_Dispose(rest); return; } wprintf(L"%s\n",responseBody); wprintf(L"%s\n",CkRestW_responseHeader(rest)); // POST JSON to subscribe to a stream // { // "method": "SUBSCRIBE", // "params": // [ // "btcusdt@aggTrade", // "btcusdt@depth" // ], // "id": 1 // } json = CkJsonObjectW_Create(); CkJsonObjectW_UpdateString(json,L"method",L"SUBSCRIBE"); CkJsonObjectW_UpdateString(json,L"params[0]",L"btcusdt@aggTrade"); CkJsonObjectW_UpdateString(json,L"params[1]",L"btcusdt@depth"); CkJsonObjectW_UpdateInt(json,L"id",1); // Send a full message in a single frame finalFrame = TRUE; success = CkWebSocketW_SendFrame(ws,CkJsonObjectW_emit(json),finalFrame); if (success != TRUE) { wprintf(L"%s\n",CkWebSocketW_lastErrorText(ws)); CkWebSocketW_Dispose(ws); CkRestW_Dispose(rest); CkJsonObjectW_Dispose(json); return; } jsonTradeData = CkJsonObjectW_Create(); CkJsonObjectW_putEmitCompact(jsonTradeData,FALSE); // Begin reading the trade stream response. // We'll just read the 1st 10 updates and then exit.. receivedFinalFrame = FALSE; numTradesReceived = 0; while (numTradesReceived < 5) { success = CkWebSocketW_ReadFrame(ws); if (success != TRUE) { wprintf(L"Failed to receive a frame\n"); wprintf(L"ReadFrame fail reason = %d\n",CkWebSocketW_getReadFrameFailReason(ws)); wprintf(L"%s\n",CkWebSocketW_lastErrorText(ws)); CkWebSocketW_Dispose(ws); CkRestW_Dispose(rest); CkJsonObjectW_Dispose(json); CkJsonObjectW_Dispose(jsonTradeData); return; } // The responses we desire are in Text frames, where the opcode = 1. if (CkWebSocketW_getFrameOpcodeInt(ws) == 1) { receivedJson = CkWebSocketW_getFrameData(ws); CkJsonObjectW_Load(jsonTradeData,receivedJson); wprintf(L"%s\n",CkJsonObjectW_emit(jsonTradeData)); numTradesReceived = numTradesReceived + 1; } } // Close the websocket connection. success = CkWebSocketW_SendClose(ws,TRUE,1000,L"Closing this websocket."); if (success != TRUE) { wprintf(L"%s\n",CkWebSocketW_lastErrorText(ws)); CkWebSocketW_Dispose(ws); CkRestW_Dispose(rest); CkJsonObjectW_Dispose(json); CkJsonObjectW_Dispose(jsonTradeData); return; } // Read the Close response. success = CkWebSocketW_ReadFrame(ws); if (success != TRUE) { wprintf(L"ReadFrame fail reason = %d\n",CkWebSocketW_getReadFrameFailReason(ws)); wprintf(L"%s\n",CkWebSocketW_lastErrorText(ws)); CkWebSocketW_Dispose(ws); CkRestW_Dispose(rest); CkJsonObjectW_Dispose(json); CkJsonObjectW_Dispose(jsonTradeData); return; } wprintf(L"Success.\n"); // The output of the above code is shown here: CkWebSocketW_Dispose(ws); CkRestW_Dispose(rest); CkJsonObjectW_Dispose(json); CkJsonObjectW_Dispose(jsonTradeData); } |
© 2000-2024 Chilkat Software, Inc. All Rights Reserved.