快速搭建 WebSocket 服务（C++）

WebSocket 是一种在单个 TCP 连接上实现全双工通信的协议。C++ 中可以通过库如 Boost.Beast 或 WebSocket++ 快速实现服务端。

安装 Boost.Beast（需依赖 Boost.Asio）

sudo apt-get install libboost-all-dev

基础服务端代码示例：

#include <boost/beast/core.hpp>
#include <boost/beast/websocket.hpp>
#include <boost/asio/ip/tcp.hpp>
#include <cstdlib>

namespace beast = boost::beast;
namespace websocket = beast::websocket;
namespace net = boost::asio;
using tcp = net::ip::tcp;

void run_server(unsigned short port) {
    net::io_context ioc;
    tcp::acceptor acceptor(ioc, {tcp::v4(), port});
    
    for(;;) {
        tcp::socket socket(ioc);
        acceptor.accept(socket);
        
        std::make_shared<websocket::stream<tcp::socket>>(std::move(socket))->async_accept(
            [](beast::error_code ec) {
                if(ec) std::cerr << "Error: " << ec.message() << "\n";
            }
        );
    }
}

常见问题与解决方案

跨线程数据竞争问题 WebSocket 操作涉及异步回调，需确保共享数据的线程安全。推荐使用 strand 或互斥锁：

net::strand<net::io_context::executor_type> strand_ = net::make_strand(ioc);

连接意外断开处理 需实现心跳机制和错误回调：

ws.set_option(websocket::stream_base::timeout::suggested(
    beast::role_type::server
));
ws.async_read(buffer, [&](auto ec, size_t){
    if(ec == websocket::error::closed) 
        cleanup_connection();
});

性能优化策略

启用压缩扩展 通过 permessage_deflate 选项减少带宽消耗：

websocket::permessage_deflate pmd;
pmd.client_enable = true;
ws.set_option(pmd);

批量消息处理 使用 async_write_some 替代单条发送，结合缓冲区管理：

std::vector<std::string> message_queue;
void process_messages() {
    if(!message_queue.empty()) {
        ws.async_write_some(
            net::buffer(message_queue.front()),
            [this](auto ec, size_t){ message_queue.pop_front(); }
        );
    }
}

调试与测试建议

Wireshark 抓包验证 使用过滤器 websocket && tcp.port == 你的端口号 检查协议交互

压力测试工具 推荐使用 Autobahn|Testsuite 进行合规性测试：

wstest -m fuzzingclient -s config.json

内存泄漏检测 Valgrind 工具检查异步操作中的资源释放：

valgrind --leak-check=full ./your_server