Socket_Fork

 1 #!/usr/bin/env python 
 2 #coding=utf-8 
 3 
 4 #完整的多进程服务器模型 
 5 import os,sys
 6 from socket import socket,AF_INET,SOCK_STREAM,SOL_SOCKET,SO_REUSEADDR 
 7 def reaping():
 8     while 1:
 9         try:
10             deadprocess = os.waitpid(-1,WNOHANG)
11             if not deadprocess[0]:break 
12         except:
13             print "\033[31;1mNo Zombie Process!!!\033[0m"
14             break 
15         ‘‘‘没有遇到except，有僵尸进程！！‘‘‘
16         print "\033[32;1mZombie Process: %s is reaped!!!\033[0m"
17 
18 
19 
20 def socket_server(host,port):
21     s = socket(AF_INET,SOCK_STREAM)
22     s.setsockopt(SOL_SOCKET,SO_REUSEADDR,1)
23     s.bind((host,port))
24     s.listen(5)
25     return s 
26 
27 
28 def client_handler(c_socket):
29     while True:
30         data = c_socket.recv(1024)
31         print "Recv From:%s, data:[%s]" %(c_socket.getpeername()[0],data.strip())
32         ACK = "Server ACK,data:[%s],data_length:[%s]\n" %(data.strip(),len(data))
33         c_socket.send(ACK)
34         if not data or data.strip()=="quit":
35             break 
36         
37     c_socket.close()
38     os._exit(0) 
39 
40 
41 #Main
42 Host = "0.0.0.0"
43 Port = 12345
44 server = socket_server(Host,Port)
45 
46 print "\033[31;1mServer is waiting for the connection from client...\033[0m"
47 while True:
48     try:
49         sock,addr = server.accept() 
50     except KeyboardInterrupt: 
51         print "Server Ending ...."
52         sys.exit()
53     except:
54         print "Error occured"
55         sys.exit() 
56 #Before generate new process, scanning zombie process
57     reaping()
58     pid = os.fork()
59     if pid:
60         """parent process,must close the client socket""" 
61         sock.close()
62         continue  
63     else:
64         """child process,must close the server socket"""
65         server.close()
66         print "\033[32;1mClient:[%s:%s] is connected!!\033[0m" %(addr[0],addr[1])
67         client_handler(sock)