added test server and client
This commit is contained in:
		
							parent
							
								
									ea3879fbde
								
							
						
					
					
						commit
						549e74daff
					
				| 
						 | 
					@ -0,0 +1,51 @@
 | 
				
			||||||
 | 
					import socket
 | 
				
			||||||
 | 
					import random
 | 
				
			||||||
 | 
					import string
 | 
				
			||||||
 | 
					import time
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					def generate_random_data(size):
 | 
				
			||||||
 | 
					    return ''.join(random.choices(string.ascii_letters + string.digits, k=size)).encode('utf-8')
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					def start_client():
 | 
				
			||||||
 | 
					    # Definiere Host und Port
 | 
				
			||||||
 | 
					    host = '127.0.0.1'
 | 
				
			||||||
 | 
					    port = 12345
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    while True:
 | 
				
			||||||
 | 
					        # Erstelle einen Socket
 | 
				
			||||||
 | 
					        client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					        try:
 | 
				
			||||||
 | 
					            # Verbinde zum Server
 | 
				
			||||||
 | 
					            client_socket.connect((host, port))
 | 
				
			||||||
 | 
					            print(f"Connected to {host}:{port}")
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					            # Generiere eine zufällige Bytefolge
 | 
				
			||||||
 | 
					            data_to_send = generate_random_data(50)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					            # Sende die Daten an den Server
 | 
				
			||||||
 | 
					            client_socket.sendall(data_to_send)
 | 
				
			||||||
 | 
					            print(f"Sent data: {data_to_send.decode('utf-8')}")
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					            # Empfange die Antwort
 | 
				
			||||||
 | 
					            received_data = client_socket.recv(1024)
 | 
				
			||||||
 | 
					            print(f"Received data: {received_data.decode('utf-8')}")
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					            # Überprüfe, ob die Antwort die gesendeten Daten sind
 | 
				
			||||||
 | 
					            if received_data == data_to_send:
 | 
				
			||||||
 | 
					                print("Server response matches the sent data.")
 | 
				
			||||||
 | 
					            else:
 | 
				
			||||||
 | 
					                print("Server response does not match the sent data.")
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					        except Exception as e:
 | 
				
			||||||
 | 
					            print(f"Error: {e}")
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					        finally:
 | 
				
			||||||
 | 
					            # Schließe die Verbindung zum Server
 | 
				
			||||||
 | 
					            client_socket.close()
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					        # Warte für eine kurze Zeit, bevor die nächste Anfrage gesendet wird
 | 
				
			||||||
 | 
					        time.sleep(2)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					if __name__ == "__main__":
 | 
				
			||||||
 | 
					    start_client()
 | 
				
			||||||
| 
						 | 
					@ -0,0 +1,35 @@
 | 
				
			||||||
 | 
					import socket
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					def start_server():
 | 
				
			||||||
 | 
					    # Definiere Host und Port
 | 
				
			||||||
 | 
					    host = '127.0.0.1'
 | 
				
			||||||
 | 
					    port = 12345
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    # Erstelle einen Socket
 | 
				
			||||||
 | 
					    server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    # Binde den Socket an Host und Port
 | 
				
			||||||
 | 
					    server_socket.bind((host, port))
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    # Warte auf Verbindungen
 | 
				
			||||||
 | 
					    server_socket.listen()
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    print(f"Server listening on {host}:{port}...")
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    while True:
 | 
				
			||||||
 | 
					        # Warte auf eine Verbindung
 | 
				
			||||||
 | 
					        client_socket, client_address = server_socket.accept()
 | 
				
			||||||
 | 
					        print(f"Connection from {client_address}")
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					        # Empfange und sende Daten zurück
 | 
				
			||||||
 | 
					        data = client_socket.recv(1024)
 | 
				
			||||||
 | 
					        print(f"Received data: {data.decode('utf-8')}")
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					        # Sende die erhaltenen Daten zurück
 | 
				
			||||||
 | 
					        client_socket.sendall(data)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					        # Schließe die Verbindung zum Client
 | 
				
			||||||
 | 
					        client_socket.close()
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					if __name__ == "__main__":
 | 
				
			||||||
 | 
					    start_server()
 | 
				
			||||||
		Loading…
	
		Reference in New Issue