刘刚刚的个人博客

python标准库-socketserver的使用

创建时间:2020-09-05 16:46:49
更新时间:2020-09-07 10:20:03

python内置的socket单独是使用时不直接支持并发的,socketserver将socket模块和select模块进行了封装,可以使服务端更方便的处理socket请求。

socketserver是python标准库的模块之一,使用方法:

  • 创建一个请求处理类,继承BaseRequestHandlerclass类并且重写父类的handle()方法,该方法将处理传入的请求。
  • 实例化一个上面类型中的一个类(如TCPServer)传递服务器的地址和你创建的请求处理类 给这个TCPServer。
  • 调用serve_forever()方法来处理请求。

服务端代码:

import socketserver

# 需要定义一个类,并继承tcp相关的类socketserver.BaseRequestHandler
class MyRequestHandle(socketserver.BaseRequestHandler):
    
    # 实现handle方法,处理收到的数据
    def handle(self):
        # 链接的对象为:self.request
        # 客户端的地址为:self.client_address)
        while True:
            try:
                msg = self.request.recv(1024)
                if len(msg) == 0: break
                # 发送消息
                self.request.send(msg.upper())
            except Exception:
                break
        # 如果断开则关闭连接
        self.request.close()


# 服务端应该做两件事
# 循环地从半连接池中取出链接请求与其建立双向链接,拿到链接对象
s=socketserver.ThreadingTCPServer(('127.0.0.1',8888),MyRequestHandle)
# 处理多个请求
# 如果只想处理一个请求,可以使用ser.handle_request()  
s.serve_forever()

UDP服务端代码:

import socketserver

class MyRequestHanlde(socketserver.BaseRequestHandler):
    def handle(self):
        client_data=self.request[0]
        server=self.request[1]
        client_address=self.client_address
        server.sendto(client_data.upper(),client_address)

s=socketserver.ThreadingUDPServer(("127.0.0.1",8888),MyRequestHanlde)
s.serve_forever()
我的名片

昵称:shuta

职业:后台开发(python、php)

邮箱:648949076@qq.com

站点信息

建站时间: 2020/2/19
网站程序: ANTD PRO VUE + TP6.0
晋ICP备18007778号