C++ Socket.IO客户端无法接收Coincap.io API消息求助

我来帮你一步步排查这个问题！你已经成功建立连接但收不到消息，结合coincap.io的Socket.IO API特性和socket.io-client-cpp的使用逻辑，大概率是以下几个核心原因导致的，咱们逐一解决：

1. 没有主动订阅目标事件/频道 #

coincap.io的Socket.IO API不会主动推送所有数据，必须由客户端主动发送订阅指令，才能收到对应资产/事件的实时数据。比如你要获取BTC的交易数据，就得在连接成功后发送订阅请求。

在你的connection_listener的on_connected回调里补充订阅逻辑：

void on_connected() {
    std::lock_guard<std::mutex> lock(_lock);
    connect_finish = true;
    _cond.notify_all();
    
    // 按照coincap要求，订阅BTC的trades事件
    handler.socket()->emit("subscribe", "trades", "BTC");
    std::cout << "已订阅BTC交易数据频道" << std::endl;
}

coincap支持的订阅事件包括trades、assets、markets等，具体参数可以参考官方的事件定义。

2. 事件监听的方式不正确 #

你目前的OnMessage回调没有绑定到具体事件上，或者监听范围不对。socket.io-client-cpp中，泛型监听所有事件的写法是socket()->on(sio::event::any, &OnMessage);，但更推荐监听特定事件，这样能精准接收目标数据：

// 专门监听coincap的trades事件
void OnTradesEvent(sio::event &ev) {
    std::lock_guard<std::mutex> lock(_lock);
    std::cout << "收到交易数据:" << std::endl;
    
    // 解析coincap返回的数组格式数据
    if(ev.get_message()->get_flag() == sio::message::flag_array) {
        auto& tradeList = ev.get_message()->get_vector();
        for(auto& tradeMsg : tradeList) {
            if(tradeMsg->get_flag() == sio::message::flag_object) {
                auto& trade = tradeMsg->get_map();
                std::cout << "资产: " << trade.at("base")->get_string() 
                          << " | 价格: " << trade.at("price")->get_string() << std::endl;
            }
        }
    }
}

// 在连接成功后绑定这个回调
h.socket()->on("trades", &OnTradesEvent);

3. 连接配置缺失版本匹配参数 #

coincap.io的Socket.IO服务使用的是v2版本，而socket.io-client-cpp默认可能使用其他版本，版本不兼容会导致无法接收消息。初始化连接时需要明确指定版本：

sio::client::connection_option opts;
opts.set_socket_io_version(2); // 匹配coincap的版本
opts.set_skip_check(true); // 跳过版本检查（如果有兼容问题时启用）
h.connect("wss://ws.coincap.io", opts);

完整可运行示例代码 #

把上述修正点整合后，完整代码如下：

#include "socketio.h"
#include <iostream>
#include <mutex>
#include <condition_variable>
#include <string>

using namespace sio;

std::mutex _lock;
std::condition_variable_any _cond;
bool connect_finish = false;

// 处理trades事件的回调
void OnTradesEvent(sio::event &ev) {
    std::lock_guard<std::mutex> lock(_lock);
    std::cout << "\n收到交易数据:" << std::endl;
    
    if(ev.get_message()->get_flag() == sio::message::flag_array) {
        auto& tradeList = ev.get_message()->get_vector();
        for(auto& tradeMsg : tradeList) {
            if(tradeMsg->get_flag() == sio::message::flag_object) {
                auto& trade = tradeMsg->get_map();
                std::cout << "资产: " << trade.at("base")->get_string() 
                          << " | 价格: " << trade.at("price")->get_string() << std::endl;
            }
        }
    }
}

class connection_listener {
    sio::client &handler;
public:
    connection_listener(sio::client& h) : handler(h) { }
    
    void on_connected() {
        std::lock_guard<std::mutex> lock(_lock);
        connect_finish = true;
        _cond.notify_all();
        
        // 订阅BTC的trades事件
        handler.socket()->emit("subscribe", "trades", "BTC");
        std::cout << "已订阅BTC交易频道，等待数据..." << std::endl;
    }
    
    void on_close(client::close_reason const& reason) {
        std::lock_guard<std::mutex> lock(_lock);
        connect_finish = false;
        std::cout << "连接关闭，原因码: " << static_cast<int>(reason) << std::endl;
    }
    
    void on_fail() {
        std::lock_guard<std::mutex> lock(_lock);
        connect_finish = false;
        std::cout << "连接失败，请检查网络或配置" << std::endl;
    }
};

int main() {
    sio::client h;
    connection_listener l(h);
    h.set_listener(&l);
    
    // 设置连接选项，匹配coincap的Socket.IO v2版本
    sio::client::connection_option opts;
    opts.set_socket_io_version(2);
    opts.set_skip_check(true);
    
    h.connect("wss://ws.coincap.io", opts);
    
    // 等待连接完成
    std::unique_lock<std::mutex> lock(_lock);
    while(!connect_finish) {
        _cond.wait(lock);
    }
    
    // 绑定trades事件监听
    h.socket()->on("trades", &OnTradesEvent);
    
    // 保持程序运行，输入任意字符退出
    std::string input;
    std::cout << "输入任意字符退出程序..." << std::endl;
    std::cin >> input;
    
    h.close();
    return 0;
}

额外注意事项 #

• 确认你的socket.io-client-cpp版本支持v2协议，建议使用最新稳定版；
• 检查防火墙/代理是否拦截了WebSocket的消息传输（连接成功不代表消息能正常收发）；
• 如果还是收不到消息，可以开启socket.io-client-cpp的日志功能，查看底层的通信细节，排查协议交互问题。

内容的提问来源于stack exchange，提问作者user4150916