Python学习笔记（六）多进程实现并发服务器

# coding: utf-8
import socket
import sys
import errno
import threading
from time import ctime

class ClientThread(threading.Thread):
def __init__(self, client_socket, client_address):
threading.Thread.__init__(self)
self.client_socket = client_socket
self.client_address = client_address

def run(self):
self.handle_connection()

def handle_connection(self):
while True:
data = self.client_socket.recv(1024)
if not data:
print 'disconnect', self.client_address
self.client_socket.close()
break;
else:
self.client_socket.send('[%s] %s' % (ctime(), data)) #回显消息

if __name__ == '__main__':
server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
listen_address = ('localhost', 9981)
server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
server_socket.bind(listen_address)
server_socket.listen(10)

while True:
try:
(client_socket, client_address) = server_socket.accept()
except IOError, e:
if e.errno == errno.EINTR:
continue #继续等待
else:
raise #将异常向外throw
print 'Got connection from ', client_address
t = ClientThread(client_socket, client_address)
t.start()