- Notifications
You must be signed in to change notification settings - Fork 27
Expand file tree
/
Copy pathechoServer.py
More file actions
Latest commit
80 lines (65 loc) · 1.99 KB
/
Copy pathechoServer.py
File metadata and controls
80 lines (65 loc) · 1.99 KB
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
#!/usr/bin/env python
"""
An echo server that uses threads to handle multiple clients at a time.
Entering any line of input at the terminal will exit the server.
"""
importselect
importsocket
importsys
importthreading
classServer:
def__init__(self):
self.host=''
self.port=50000
self.backlog=5
self.size=1024
self.server=None
self.threads= []
defopen_socket(self):
try:
self.server=socket.socket(socket.AF_INET, socket.SOCK_STREAM)
self.server.bind((self.host,self.port))
self.server.listen(5)
exceptsocket.error, (value,message):
ifself.server:
self.server.close()
print"Could not open socket: "+message
sys.exit(1)
defrun(self):
self.open_socket()
input= [self.server,sys.stdin]
running=1
whilerunning:
inputready,outputready,exceptready=select.select(input,[],[])
forsininputready:
ifs==self.server:
# handle the server socket
c=Client(self.server.accept())
c.start()
self.threads.append(c)
elifs==sys.stdin:
# handle standard input
junk=sys.stdin.readline()
running=0
# close all threads
self.server.close()
forcinself.threads:
c.join()
classClient(threading.Thread):
def__init__(self,(client,address)):
threading.Thread.__init__(self)
self.client=client
self.address=address
self.size=1024
defrun(self):
running=1
whilerunning:
data=self.client.recv(self.size)
ifdata:
self.client.send(data)
else:
self.client.close()
running=0
if__name__=="__main__":
s=Server()
s.run()