testing

Author: j2doll

custom_websocket_client.cpp

@@ -70,4 +70,8 @@ void custom_websocket_client::send_message(const std::string& text) {
     } else {
         std::cerr << "[경고] Cannot send. Connection is not open." << std::endl;
     }
-}
+}
+
+bool custom_websocket_client::isReady() const {
+    return _web_socket.getReadyState() == ix::ReadyState::Open;
+}   

custom_websocket_client.hpp

@@ -16,6 +16,9 @@ class custom_websocket_client {
     // 외부 쓰레드 안전 송신
     void send_message(const std::string& text);
 
+    // 연결 상태 확인
+    bool isReady() const;
+
 private:
     void setup_callback();
 

main.cpp

@@ -13,14 +13,23 @@ int main() {
     std::cout << "--- Enter message to send (type 'exit' to quit) ---" << std::endl;
 
     std::string user_input;
+    user_input = "hello world"; // 테스트용 초기 메시지
+
     while (true) {
-        if (!std::getline(std::cin, user_input)) break;
-        if (user_input == "exit") break;
+        // if (!std::getline(std::cin, user_input)) break;
+        // if (user_input == "exit") break;
 
         if (!user_input.empty()) {
-            // 쓰레드 세이프하게 메시지 송신. 외부 쓰레드에서 호출해도 됨.
-            client.send_message(user_input);
+            if (client.isReady()) {
+                std::cout << "[송신] " << user_input << std::endl;
+                client.send_message(user_input);
+                // 쓰레드 세이프하게 메시지 송신. 외부 쓰레드에서 호출해도 됨.
+            } else {
+                std::cerr << "[경고] Connection is not open. Message will be sent when connection is established." << std::endl;
+            } 
         }
+
+        std::this_thread::sleep_for(std::chrono::milliseconds(1000)); // CPU 과부하 방지 위해 잠시 대기
     }
 
     client.stop(); // 웹소켓 클라이언트 종료