![]() |
Chilkat • HOME • Android™ • AutoIt • C • C# • C++ • Chilkat2-Python • CkPython • Classic ASP • DataFlex • Delphi DLL • Go • Java • Node.js • Objective-C • PHP Extension • Perl • PowerBuilder • PowerShell • PureBasic • Ruby • SQL Server • Swift • Tcl • Unicode C • Unicode C++ • VB.NET • VBScript • Visual Basic 6.0 • Visual FoxPro • Xojo Plugin
(Unicode C) Subscribe to Multiple Bitfinex Tickers on One ConnectionSubscribes to multiple ticker symbols on the public Bitfinex websocket ticker channel and receives ticker updates.
#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 json1; BOOL finalFrame; HCkJsonObjectW json2; BOOL receivedFinalFrame; int numUpdatesReceived; const wchar_t *receivedText; // 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 api.bitfinex.com success = CkRestW_Connect(rest,L"api.bitfinex.com",443,TRUE,FALSE); CkWebSocketW_UseConnection(ws,rest); CkWebSocketW_AddClientHeaders(ws); responseBody = CkRestW_fullRequestNoBody(rest,L"GET",L"/ws"); 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; } // After connecting, the bitfinex websocket server will send // an info message that contains the actual version of the websocket stream. // Receive that message.. 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); return; } // We should get this: // {"event":"info","version":1.1,"platform":{"status":1}} wprintf(L"%s\n",CkWebSocketW_getFrameData(ws)); // Subscribe to the BTCUSD ticker feed. // See https://docs.bitfinex.com/docs for more information. json1 = CkJsonObjectW_Create(); CkJsonObjectW_AppendString(json1,L"event",L"subscribe"); CkJsonObjectW_AppendString(json1,L"channel",L"ticker"); CkJsonObjectW_AppendString(json1,L"pair",L"BTCUSD"); finalFrame = TRUE; success = CkWebSocketW_SendFrame(ws,CkJsonObjectW_emit(json1),finalFrame); // Subscribe to the ETHUSD ticker feed. json2 = CkJsonObjectW_Create(); CkJsonObjectW_AppendString(json2,L"event",L"subscribe"); CkJsonObjectW_AppendString(json2,L"channel",L"ticker"); CkJsonObjectW_AppendString(json2,L"pair",L"ETHUSD"); success = CkWebSocketW_SendFrame(ws,CkJsonObjectW_emit(json2),finalFrame); // Begin reading the ticker feed. // / This will include a single confirmation response for each subscription. // We'll just read the 1st 5 updates and then exit.. receivedFinalFrame = FALSE; numUpdatesReceived = 0; while (numUpdatesReceived < 7) { 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(json1); CkJsonObjectW_Dispose(json2); return; } // The responses we desire are in Text frames, where the opcode = 1. if (CkWebSocketW_getFrameOpcodeInt(ws) == 1) { receivedText = CkWebSocketW_getFrameData(ws); wprintf(L"%s\n",receivedText); // Should receive a line of text such as this: // [2751,7349,36.34269559,7349.1,41.01777063,-116.2,-0.0156,7349.1,22188.26055319,7560,7270.5] // Initially, a single confirmation response for each subscription would be received, such as this: // {"event":"subscribed","channel":"ticker","chanId":810,"pair":"BTCUSD"} numUpdatesReceived = numUpdatesReceived + 1; } } // This is sample output: // You can see that the 1st message received is the subscription confirmation for the BTCUSD subscribe request. // The next message is a BTCUSD ticker update. // The next message is the confirmation for the ETHUSD subscription. // The next message is an ETHUSD update. // The BTCUSD channel ID is "537", and the ETHUSD channel ID is "700". The channel IDs are provided in the // subscription confirmation messages. Each ticker update begins with the channel ID.. // {"event":"subscribed","channel":"ticker","chanId":537,"pair":"BTCUSD"} // [537,6457.9,79.59102302,6458,22.49395741,-24.1,-0.0037,6457.9,13644.52820029,6540,6370.76958739] // {"event":"subscribed","channel":"ticker","chanId":700,"pair":"ETHUSD"} // [700,496.9,247.24493326,496.92,284.09636979,-2.47,-0.0049,496.9,74154.05945261,502.85,486.96] // [537,"hb"] // [700,"hb"] // [700,496.92,233.34338276,496.93,431.78867277,-2.45,-0.0049,496.92,74167.99173586,502.85,486.96] // 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(json1); CkJsonObjectW_Dispose(json2); 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(json1); CkJsonObjectW_Dispose(json2); return; } wprintf(L"Success.\n"); CkWebSocketW_Dispose(ws); CkRestW_Dispose(rest); CkJsonObjectW_Dispose(json1); CkJsonObjectW_Dispose(json2); } |
© 2000-2025 Chilkat Software, Inc. All Rights Reserved.