使用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进行多线程通话,就是这样。