初始化提交，导入现有项目源码： - 包含 BVisionPro（视觉处理相关模块） - 包含 SDK/Controls（控件库、缓冲区等） - ...

mrDarker

2025-07-08 ed84512b71ff17024524376074fe3cdf5fca5b67

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
#ifndef WEBSOCKETCLIENT_H
#define WEBSOCKETCLIENT_H
 
#include <websocketpp/config/asio_no_tls_client.hpp>
#include <websocketpp/client.hpp>
#include <string>
#include <vector>
#include <iostream>
#include <thread>
#include <atomic>
#include <mutex>
#include <functional>
#include <chrono>
 
typedef websocketpp::client<websocketpp::config::asio_client> client;
 
class WebSocketClient {
public:
    using message_ptr = websocketpp::config::asio_client::message_type::ptr;
    using connection_hdl = websocketpp::connection_hdl;
    using OpenHandler = std::function<void()>;
    using MessageHandler = std::function<void(const std::string&)>;
    using CloseHandler = std::function<void()>;
    using FailHandler = std::function<void()>;
    using PongHandler = std::function<void(const std::string&)>;
 
    WebSocketClient();
    ~WebSocketClient();
 
    // Á¬½Óµ½Ö¸¶¨µÄ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
    std::string get_current_url();
 
    // ¼ì²éµ±Ç°Á¬½ÓÊÇ·ñÈÔÈ»ÓÐЧ
    bool is_connected() const;
 
private:
    // 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);
    void on_fail(websocketpp::connection_hdl hdl);
    void on_pong(websocketpp::connection_hdl hdl, const std::string& payload);
 
private:
    // WebSocket¿Í»§¶ËʵÀý
    client m_client;
 
    // WebSocket Á¬½Ó¾ä±ú
    connection_hdl m_hdl;
 
    // Ïß³ÌÏà¹Ø
    std::thread m_thread;
    std::thread m_heartbeat_thread;
    std::atomic<bool> m_connected;
    std::atomic<bool> m_reconnect;
    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;
    FailHandler m_fail_handler;
    PongHandler m_pong_handler;
};
 
#endif // WEBSOCKETCLIENT_H