首页 > 代码库 > Python学习笔记（六）多进程实现并发服务器
Python学习笔记（六）多进程实现并发服务器
这个相对于多进程更加简单，每accept一个新的连接就创建一个新的线程。代码如下：
# coding: utf-8import socketimport sysimport errnoimport threadingfrom time import ctimeclass 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()
注意这里的thread不能进行join，否则会阻塞主线程，丧失并发能力。
另外，python中的线程不需要进行detach。
Python学习笔记（六）多进程实现并发服务器
声明：以上内容来自用户投稿及互联网公开渠道收集整理发布，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任，若内容有误或涉及侵权可进行投诉： 投诉/举报 工作人员会在5个工作日内联系你，一经查实，本站将立刻删除涉嫌侵权内容。