使用SocketServer编写一个套接字程序

使用SocketServer编写一个套接字程序

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

本文永久更新链接地址：