使用SocketServer写一个套接字程序来实现多线程,即服务器端可与多个客户端进行通话,首先服务器端程序为:
#!/usr/bin/python
#coding:utf-8
import socketserver
class MyTCPHandle(socketserver.BaseRequestHandler):
? ? def handle(self):
? ? ? ? print("recived address:"+format(self.client_address[0]))
? ? ? ? while True:
? ? ? ? ? ? self.data=self.request.recv(1024*4).strip()
? ? ? ? ? ? print(self.data)
? ? ? ? ? ? self.request.sendall(self.data.upper())
? ? ? ?
if __name__=="__main__":
? ? HOST,PORT="localhost",9999
server=socketserver.ThreadingTCPServer((HOST,PORT),MyTCPHandle)
server.serve_forever()? ? ? ? ? ? ? #循环停止,等待它。
客户端源程序为:
#!/usr/bin/python
#coding:utf-8
import socket
HOST,PORT="localhost",9999
data=""
sock=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
try:
? ? sock.connect((HOST,PORT))
? ? while True:
? ? ? ? data=input("please input a string:")
? ? ? ? sock.sendall(data.encode('utf-8','strict'))
? ? ? ? received=sock.recv(1024*4)
? ? ? ? print(str(received))
except Exception:
? ? raise
finally:
? ? sock.close()
其实只有服务器端的源码不同,客户端与之前的用socket写的客户端源码相同。
在这里服务器端要进行多个通话,因此,只是将接收到的字符串大写后然后再进行返回,现在运行服务器端以及两个客户端的结果为:
服务器端:

客户端1:

客户端2:

于是这便实现了多线程的socket通话,其实在这个程序的关键源码为:
socketserver.ThreadingTCPServer((HOST,PORT),MyTCPHandle)
这一行实现了多线程通话,以及这一行:
server.serve_forever()? ? ? ? ? ? ? #循环停止,等待它。
这一行的源码效果为不会出现在一个客户端结束后,当前服务器端就会关闭或者报错,而是继续运行,与其他的客户端继续进行通话。
使用socketserver进行多线程通话,就是这样。