栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Python

python socketserver handle方法传递参数样例

Python 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

python socketserver handle方法传递参数样例

目录

实现思路

最终实现的完整的代码(demo)


实现思路

从官方文档及其他地方并未找到合适的handle传参的方法,因此考虑重写部分类或类方法。

如果使用TCPServer启动的服务实例,则我们在注册server实例的时候就应该将参数传递过去,因此我们考虑重写下TCPServer的__init__方法:

以增加一个info参数为例

# 重写TCPServer构造函数
class MyTCPServer(TCPServer):
    def __init__(self, server_address, RequestHandlerClass, bind_and_activate=True, info=None):
        self.info = info  # 增加的参数
        TCPServer.__init__(self, server_address, RequestHandlerClass, bind_and_activate=bind_and_activate)

如果说仅仅是串行单Client端的情况下,我们用重写好的M有TCPServer去启动实例就满足需求了,但是大多数情况下,我们需要用到异步处理,多Client端的情况,也就是需要用ThreadingTCPServer去启动一个实例。

因此如果我们要异步,ThreadingTCPServer也需要重写一下。

先查看下原来的ThreadingTCPServer是怎么写的:

官方的写法:

class ThreadingTCPServer(ThreadingMixIn, TCPServer): pass

很显然,ThreadingTCPServer并没有其他的操作,因此我们只需要将TCPServer换成我们已经重写好的MyTCPServer即可达到效果。

重写ThreadingTCPServer:

# 如果使用异步的形式则需要再重写ThreadingTCPServer
class MyThreadingTCPServer(ThreadingMixIn, MyTCPServer): pass

最终实现的完整的代码(demo)
from socketserver import TCPServer, ThreadingMixIn, baseRequestHandler


# 重写TCPServer构造函数
class MyTCPServer(TCPServer):
    def __init__(self, server_address, RequestHandlerClass, bind_and_activate=True, info=None):
        self.info = info  # 增加的参数
        TCPServer.__init__(self, server_address, RequestHandlerClass, bind_and_activate=bind_and_activate)


# 如果使用异步的形式则需要再重写ThreadingTCPServer
class MyThreadingTCPServer(ThreadingMixIn, MyTCPServer): pass


class Handler(baseRequestHandler):
    def handle(self):
        print("打印传入的参数:", self.server.info)  # server是MyTcpServer的一个对象,构造时使用了你重写的构造函数
        self.data = self.request.recv(1024).strip()
        print(self.data)


if __name__ == "__main__":
    ADDR = ("127.0.0.1", 8089)
    server = MyThreadingTCPServer(ADDR, Handler, info="hahaha我是传入的参数")  # 异步,多Client
    # server = MyTCPServer(ADDR, Handler, info="test")  # 单Client
    server.serve_forever()

需要注意的是,使用自己传入的参数,需要用self.server.xxx,因为server是TcpServer的对象

打印出来的我们自定义的info参数的值(效果):

同步发在了python socketserver handle方法传递参数样例 | Guf's Blog实现思路从官方文档及其他地方并未找到合适的handle传参的方法,因此考虑重写部分类或类方法。 如果使用TCPServer启动的服务实例,则我们在注册server实例的时候就应该将参数传递过去,因此我们考虑重写下TCPServer的__init__方法: 以增加一个info参数为例 12345# 重写TCPServer构造函数class MyTCPServer(TCPServer):https://blog.gcoperation.top/posts/7261e347/

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/498760.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号