多线程socket模型

from socket import *

import time

import os

import sys

import threading

def client_deal(client,client_info):

    while True:

        msg = client.recv(1024)

        if msg == ‘‘:

            client.close()

            break

        print ‘recv=‘,msg,‘from:‘,cleint_info

        client.send(‘echo‘ + msg)

        if msg == ‘q‘:

            client.close()

            break

def thread_process(client,client_info):

        p_thread = threading.Thread(target=client_deal,args=(client,client_info))

        p_thread.setDaemon(True)

        p_thread.start()

        print "start one thread"

if __name__ == ‘__main__‘:

    tcp_server = socket(AF_INET,SOCK_STREAM)

    tcp_server.bind((‘localhost‘,5001))

    tcp_server.listen(5)

    while True:

        print ‘pid=‘,os.getpid(),"wait client"

        client,client_info = tcp_server.accept()

        print client_info

        client_process(client,client_info)

    tcp_server.close()