python多线程socket编程之多客户端接入_Python

python多线程socket编程之多客户端接入

2020-12-07 00:41Lockeyi Python

这篇文章主要为大家详细介绍了python多线程socket编程之多客户端接入，具有一定的参考价值，感兴趣的小伙伴们可以参考一下

Python中实现socket通信的服务端比较复杂，而客户端非常简单，所以客户端基本上都是用sockct模块实现，而服务
端用有很多模块可以使用，如下：

python多线程socket编程之多客户端接入

1、客户端

									#!/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

									'''

									import socket,sys

									HOST = '192.168.1.6'

									PORT = 8998

									ADDR =(HOST,PORT)

									BUFSIZE = 1024

									sock = socket.socket()

									try:

									 sock.connect(ADDR)

									 print('have connected with server')

									 while True:

									  data = input('lockey# ')

									  if len(data)>0:

									  print('send:',data)

									  sock.sendall(data.encode('utf-8')) #不要用send()

									  recv_data = sock.recv(BUFSIZE)

									  print('receive:',recv_data.decode('utf-8'))

									  else:

									  sock.close()

									  break

									except Exception:

									 print('error')

									 sock.close()

									 sys.exit()

2、SocketServer模块

为了能够让多个客户端同时接入服务并进行通信，服务端将使用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)