first commit

socket_test.py

@@ -0,0 +1,133 @@
+# import socket
+# import time
+
+# def handle_client(client_socket, client_address):
+#     print(f"Connected by {client_address}")
+
+#     with client_socket:
+#         while True:
+#             try:
+#                 recv_data = client_socket.recv(1024).decode()
+
+#                 if not recv_data:
+#                     print(f"Connection closed by {client_address}")
+#                     break
+                
+#                 print(f"Received from {client_address}: {recv_data}")
+            
+#                 if recv_data == 'get <socket_num>':
+#                     send_data = '<socket_num><2>'
+#                     client_socket.send(send_data.encode())
+            
+#                 if recv_data == 'get <socket_str>':
+#                     send_data = '<socket_str><"b">'
+#                     client_socket.send(send_data.encode())
+            
+#                 if recv_data == 'get <socket_arr>':
+#                     send_data = '<socket_arr><[1,1,1,1,1,1]>'
+#                     client_socket.send(send_data.encode())
+            
+#                 if recv_data == 'get #real#6#':
+#                     send_data = '[2,2,2,2,2,2]'
+#                     client_socket.send(send_data.encode())
+            
+#                 if recv_data == 'palletType':
+#                     send_data = '<palletType><1>'
+#                     client_socket.send(send_data.encode())
+            
+#             except ConnectionResetError as e:
+#                 print(f"Connection closed by {client_address}")
+#                 break
+            
+# def start_server(host='0.0.0.0', port=12345):
+#     server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+#     server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
+#     server_socket.bind((host, port))
+#     server_socket.listen()
+#     server_socket.settimeout(1) 
+#     print(f"Server listening on {host}:{port}")
+
+#     try:
+#         while True:
+#             try:
+#                 client_socket, client_address = server_socket.accept()
+#                 handle_client(client_socket, client_address)
+                
+#             except socket.timeout:
+#                 continue 
+#     except KeyboardInterrupt:
+#         print("Server shutting down...")
+#     finally:
+#         server_socket.close()
+
+# if __name__ == "__main__":
+#     start_server()
+import socket
+import time
+
+def handle_client(client_socket, client_address):
+    print(f"Connected by {client_address}")
+
+    with client_socket:
+        while True:
+            try:
+                recv_data = client_socket.recv(1024).decode()
+
+                if not recv_data:
+                    print(f"Connection closed by {client_address}")
+                    return False  # 클라이언트 종료 신호 반환
+                
+                print(f"Received from {client_address}: {recv_data}")
+            
+                if recv_data == 'get <socket_num>':
+                    send_data = '<socket_num><2>'
+                    client_socket.send(send_data.encode())
+            
+                if recv_data == 'get <socket_str>':
+                    send_data = '<socket_str><"b">'
+                    client_socket.send(send_data.encode())
+            
+                if recv_data == 'get <socket_arr>':
+                    send_data = '<socket_arr><[1,1,1,1,1,1]>'
+                    client_socket.send(send_data.encode())
+            
+                if recv_data == 'get #real#6#':
+                    send_data = '[2,2,2,2,2,2]'
+                    client_socket.send(send_data.encode())
+            
+                if recv_data == 'palletType':
+                    send_data = '<palletType><1>'
+                    client_socket.send(send_data.encode())
+            
+            except ConnectionResetError:
+                print(f"Connection closed by {client_address}")
+                return False  # 클라이언트 종료 신호 반환
+    return True  # 클라이언트 정상 처리 완료 신호 반환
+
+
+def start_server(host='0.0.0.0', port=12345):
+    server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+    server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
+    server_socket.bind((host, port))
+    server_socket.listen()
+    server_socket.settimeout(1) 
+    print(f"Server listening on {host}:{port}")
+
+    try:
+        while True:
+            try:
+                client_socket, client_address = server_socket.accept()
+                connection_active = handle_client(client_socket, client_address)
+                if not connection_active:
+                    print("Client disconnected. Shutting down server...")
+                    break  # 루프 종료
+            except socket.timeout:
+                continue 
+    except KeyboardInterrupt:
+        print("Server shutting down...")
+    finally:
+        server_socket.close()
+        print("Server socket closed.")
+
+if __name__ == "__main__":
+    start_server()