python多线程socket编程中将多客户端接入的方法(2)-木庄网络博客

为了能够让多个客户端同时接入服务并进行通信，服务端将使用SocketServer模块来实现，这样的话用户不用在子线程结束后，利用父进程对它进行处理，也不用关心socket的关闭，一切都由SocketServer来完成。

#!/usr/bin/env python
#coding:utf-8
'''
file:client.py
date:9/9/17 3:43 PM
author:lockey
email:lockey@123.com
desc:socket编程服务器端，python3.6.2
'''
from socketserver import BaseRequestHandler,ThreadingTCPServer
import threading
 
BUF_SIZE=1024
 
class Handler(BaseRequestHandler):
 def handle(self):
  address,pid = self.client_address
  print('%s connected!'%address)
  while True:
   data = self.request.recv(BUF_SIZE)
   if len(data)>0:
    print('receive=',data.decode('utf-8'))
    cur_thread = threading.current_thread()
    #response = '{}:{}'.format(cur_thread.ident,data)
    self.request.sendall('response'.encode('utf-8'))
    print('send:','response')
   else:
    print('close')
    break
 
if __name__ == '__main__':
 HOST = '192.168.1.6'
 PORT = 8998
 ADDR = (HOST,PORT)
 server = ThreadingTCPServer(ADDR,Handler) #参数为监听地址和已建立连接的处理类
 print('listening')
 server.serve_forever() #监听，建立好TCP连接后，为该连接创建新的socket和线程，并由处理类中的handle方法处理
 print(server)