diff --git a/src/core/client.cc b/src/core/client.cc index 85853634..6cc0a41a 100644 --- a/src/core/client.cc +++ b/src/core/client.cc @@ -164,12 +164,12 @@ void Client::handleWebSocketMessage() { } // 连接断开,可能是地址冲突,触发正常退出进程的流程 if (message.type == WebSocketMessageType::Close) { - spdlog::info("websocket communication disconnected"); + spdlog::info("client websocket close: {}", message.buffer); break; } // 通信出现错误,触发正常退出进程的流程 if (message.type == WebSocketMessageType::Error) { - spdlog::critical("websocket communication exception"); + spdlog::critical("client websocket error: {}", message.buffer); break; } } diff --git a/src/core/server.cc b/src/core/server.cc index 0f9b2619..11114c3e 100644 --- a/src/core/server.cc +++ b/src/core/server.cc @@ -134,7 +134,7 @@ void Server::handleWebSocketMessage() { continue; } if (message.type == WebSocketMessageType::Error) { - spdlog::critical("websocket communication exception"); + spdlog::critical("server websocket error: {}", message.buffer); break; } } diff --git a/src/websocket/client.cc b/src/websocket/client.cc index 5939bdc4..e98a0360 100644 --- a/src/websocket/client.cc +++ b/src/websocket/client.cc @@ -27,6 +27,7 @@ class WebSocketClientImpl { this->ixWs->setPingInterval(30); this->ixWs->disablePerMessageDeflate(); this->ixWs->setOnMessageCallback(std::bind(&WebSocketClientImpl::handleMessage, this, std::placeholders::_1)); + this->ixWs->disableAutomaticReconnection(); this->ixWs->setAutoThreadName(false); this->ixWs->start();