使用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写的客户端源码相同。

在这里服务器端要进行多个通话,因此,只是将接收到的字符串大写后然后再进行返回,现在运行服务器端以及两个客户端的结果为:

服务器端:

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

客户端1:

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

客户端2:

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

于是这便实现了多线程的socket通话,其实在这个程序的关键源码为:

socketserver.ThreadingTCPServer((HOST,PORT),MyTCPHandle)

这一行实现了多线程通话,以及这一行:

server.serve_forever()              #循环停止,等待它。

这一行的源码效果为不会出现在一个客户端结束后,当前服务器端就会关闭或者报错,而是继续运行,与其他的客户端继续进行通话。

使用socketserver进行多线程通话,就是这样。

内容版权声明:除非注明,否则皆为本站原创文章。

转载注明出处:https://www.heiqu.com/80633005b015261da0ae41f7305fba23.html