Echoserver in Python

puQy · puQy · commit ddc6b7f5c64c · 2016-05-19T18:00:56.000+02:00
diff --git a/echo_server.py b/echo_server.py
@@ -0,0 +1,36 @@
+#!/usr/bin/env python
+
+import socket
+
+#create stream socket, AF_inet adress family internet
+tcpsocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 
+
+tcpsocket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) 
+#set options sol_socket ist das socket layer und benutzt protocal unabhaengige  options
+#wenn bspw eine option benutzt wird beschreibt sol_socket das diese in dem socket selbst gesucht werden soll
+#http://pubs.opengroup.org/onlinepubs/7908799/xns/getsockopt.html
+
+tcpsocket.bind(('localhost', 8000,)) #bindet den socket an eine ip und einen Port, (HOST,PORT) -tuple
+
+tcpsocket.listen(10) #besagt wieviele anfragen der socket bearbeiten kann
+
+print "Waiting for a client request..."
+
+(client, (ip,port)) = tcpsocket.accept() #erstellt neuen sock welcher vom client benutzt wird gibt ein tuple (conn, address) zurueck
+
+print "Received connection from: ", ip, port
+print "Starting ECHO Server"
+
+data = 'dummy'
+
+while len(data):
+	data = client.recv(2048)
+	print "Client sent: " + data
+	client.send(data)
+
+print "Closing connection...."
+client.close()
+
+print "Shuting down server ..."
+
+tcpsocket.close()
diff --git a/multi_process_echo_server.py b/multi_process_echo_server.py
@@ -0,0 +1,38 @@
+#!/usr/bin/env python
+
+import socket
+import multiprocessing
+import signal
+import sys
+
+def worker(client):
+	data = 'dummy'
+	while len(data):
+		data = client.recv(2048)
+		print "Client sent: " + data
+		client.send(data)
+	
+	print "Connection closed.."
+	client.close()
+	
+def ctrlcHandler(signum, frame):
+	print "Shutting down server...:"
+	tcp_socket.close()
+	sys.exit(0)
+
+signal.signal(signal.SIGINT, ctrlcHandler)
+
+tcpsocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+tcpsocket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
+tcpsocket.bind(('localhost', 8000,))
+tcpsocket.listen(10)
+
+while True:
+	print "Waiting for client request...."
+	(conn,address) = tcpsocket.accept()
+	
+	print "MultiProcessEchoServer receive connection from: ", address
+	print "Starting Echoing: ", address
+	p = multiprocessing.Process(target=worker, args=(conn,))
+	p.start()
+
diff --git a/multi_threaded_echo_server.py b/multi_threaded_echo_server.py
@@ -0,0 +1,42 @@
+#!/usr/bin/env python
+
+import socket
+import threading
+import sys
+import signal
+
+class WorkerThread(threading.Thread):
+	def __init__(self, client):
+		threading.Thread.__init__(self)
+		self.client = client
+
+	def run(self):
+		data = 'dummy'
+		while len(data):
+			data = self.client.recv(2048)
+			print "Client sent: ", data
+			self.client.send(data)
+
+		print "Closing connection..."
+
+def ctrlHandler(signum, frame):
+	print "Shutting down server ...."
+	tcpsocket.close()
+	sys.exit(0)
+
+signal.signal(signal.SIGINT, ctrlHandler)
+tcpsocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+tcpsocket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
+tcpsocket.bind(('localhost', 8000,))
+tcpsocket.listen(10)
+
+while True:
+	print "Waiting for a client...."
+	(client,(ip,port)) = tcpsocket.accept()
+
+	print "Received connection from client: ", ip, port
+	print "Starting conversation...", client
+	
+	worker = WorkerThread(client)
+	worker.setDaemon(True)
+	worker.start()
