From 47873f48d17bb8f7602fda73d29b19adcf43fdd0 Mon Sep 17 00:00:00 2001 From: mrDarker <mr.darker@163.com> Date: 星期四, 14 八月 2025 15:50:27 +0800 Subject: [PATCH] 1. 修复执行界面没有显示侧面检数据的问题 --- EdgeInspector_App/WebSocket/WebSocketClient.h | 52 ++++++++++++++++++++++++++-------------------------- 1 files changed, 26 insertions(+), 26 deletions(-) diff --git a/EdgeInspector_App/WebSocket/WebSocketClient.h b/EdgeInspector_App/WebSocket/WebSocketClient.h index e1f3789..ea850b0 100644 --- a/EdgeInspector_App/WebSocket/WebSocketClient.h +++ b/EdgeInspector_App/WebSocket/WebSocketClient.h @@ -1,4 +1,4 @@ -#ifndef WEBSOCKETCLIENT_H +锘�#ifndef WEBSOCKETCLIENT_H #define WEBSOCKETCLIENT_H //#include <websocketpp/config/asio_no_tls_client.hpp> @@ -27,62 +27,62 @@ // WebSocketClient(); // ~WebSocketClient(); // -// // 连接到指定的URI +// // 杩炴帴鍒版寚瀹氱殑URI // void connect(const std::string& uri); // -// // 增加客户端的状态标识 +// // 澧炲姞瀹㈡埛绔殑鐘舵�佹爣璇� // bool is_busy() const; // void set_busy(bool busy); // -// // 发送文本消息 +// // 鍙戦�佹枃鏈秷鎭� // void send(const std::string& message); // -// // 发送二进制数据 +// // 鍙戦�佷簩杩涘埗鏁版嵁 // void send_binary(const std::vector<char>& binary_data); // -// // 通过队列发送文本消息 +// // 閫氳繃闃熷垪鍙戦�佹枃鏈秷鎭� // void enqueue_message(const std::string& message); // -// // 通过队列发送二进制数据 +// // 閫氳繃闃熷垪鍙戦�佷簩杩涘埗鏁版嵁 // void enqueue_binary(const std::vector<char>& binary_data); // -// // 处理下一个消息 +// // 澶勭悊涓嬩竴涓秷鎭� // void process_next_message(); // void process_next_binary(); // -// // 发送文本消息并等待回复 +// // 鍙戦�佹枃鏈秷鎭苟绛夊緟鍥炲 // bool send_and_wait(const std::string& message, int timeout_ms); // -// // 发送二进制数据并等待回复 +// // 鍙戦�佷簩杩涘埗鏁版嵁骞剁瓑寰呭洖澶� // bool send_binary_and_wait(const std::vector<char>& binary_data, int timeout_ms); // -// // 关闭连接 +// // 鍏抽棴杩炴帴 // void close(); // -// // 设置各种回调函数 +// // 璁剧疆鍚勭鍥炶皟鍑芥暟 // void set_open_handler(OpenHandler handler); // void set_message_handler(MessageHandler handler); // void set_close_handler(CloseHandler handler); // void set_fail_handler(FailHandler handler); // void set_pong_handler(PongHandler handler); // -// // 设置心跳间隔（单位：秒） +// // 璁剧疆蹇冭烦闂撮殧锛堝崟浣嶏細绉掞級 // void set_heartbeat_interval(int interval); // -// // 获取当前连接的URL +// // 鑾峰彇褰撳墠杩炴帴鐨刄RL // std::string get_current_url(); // -// // 检查当前连接是否仍然有效 +// // 妫�鏌ュ綋鍓嶈繛鎺ユ槸鍚︿粛鐒舵湁鏁� // bool is_connected() const; // //private: -// // WebSocket 运行函数 +// // WebSocket 杩愯鍑芥暟 // void run(); // -// // 心跳检查函数 +// // 蹇冭烦妫�鏌ュ嚱鏁� // void heartbeat(); // -// // 回调函数触发器 +// // 鍥炶皟鍑芥暟瑙﹀彂鍣� // void on_open(websocketpp::connection_hdl hdl); // void on_message(connection_hdl hdl, message_ptr msg); // void on_close(websocketpp::connection_hdl hdl); @@ -90,13 +90,13 @@ // void on_pong(websocketpp::connection_hdl hdl, const std::string& payload); // //private: -// // WebSocket客户端实例 +// // WebSocket瀹㈡埛绔疄渚� // client m_client; // -// // WebSocket 连接句柄 +// // WebSocket 杩炴帴鍙ユ焺 // connection_hdl m_hdl; // -// // 线程相关 +// // 绾跨▼鐩稿叧 // std::thread m_thread; // std::thread m_heartbeat_thread; // std::atomic<bool> m_connected; @@ -104,21 +104,21 @@ // int m_heartbeat_interval; // bool m_message_received; // -// // 发送队列 +// // 鍙戦�侀槦鍒� // std::queue<std::string> m_message_queue; // std::queue<std::vector<char>> m_binary_queue; // -// // 标识客户端是否忙碌 +// // 鏍囪瘑瀹㈡埛绔槸鍚﹀繖纰� // std::atomic<bool> m_busy; // -// // 线程同步相关 +// // 绾跨▼鍚屾鐩稿叧 // bool m_close_done; // std::condition_variable m_cv; // -// // 互斥锁，用于保护共享资源 +// // 浜掓枼閿侊紝鐢ㄤ簬淇濇姢鍏变韩璧勬簮 // std::mutex m_mutex; // -// // 回调函数 +// // 鍥炶皟鍑芥暟 // OpenHandler m_open_handler; // MessageHandler m_message_handler; // CloseHandler m_close_handler; -- Gitblit v1.9.3