有没有办法让 BaseRequestHandler 类成为有状态的？

Posted 2023-02-16

【中文标题】有没有办法让 BaseRequestHandler 类成为有状态的？

【英文标题】：Is there a way for BaseRequestHandler classes to be stateful?

【发布时间】：2012-01-22 20:46:51

【问题描述】：

小问题 使用下面的示例，是否有一种 Pythonic 方式可以与 BaseRequestHandler 类共享my_object 的实际实例？

背景 根据定义，BaseRequestHandler 类为每个请求创建一个新实例。因此，我正在努力尝试找到一个解决方案，了解如何将数据从handle() 函数返回到ProtocolInterface 实例。请注意，如果我需要在handle() 中执行某些操作而不是打印到标准输出，这可能是错误的方法。

在这个时间点，我不相信全局变量会起作用，因为my_object被传入并且预计会经常更改（这就是为什么handle()需要查看它。查看示例客户端（发送虚假数据）见我的other SO question。我认为我面临的最大问题是套接字服务器在后台线程中运行。

我想做的示例

class ProtocolHandler(SocketServer.BaseRequestHandler):
    def handle(self):
        while(1):
            self.data = self.request.recv(1024)
            if self.data == '':
                break
            self.request.send("Success") 
            self.my_object.success = True#  <--- How can I share my_object's instance?

class ProtocolInterface():
    def __init__(self, obj, host='127.0.0.1', port=8000, single_connection=False):
        self.my_object = obj # <--- This ideally is the same instance seen in ProtocolHandler
        self.host = host
        self.port = port

        # Create the socket server to process in coming traffic
        if(single_connection):
            self.server = SocketServer.TCPServer((self.host, self.port), ProtocolHandler)
        else:
            self.server = SocketServer.ThreadingTCPServer((self.host, self.port), ProtocolHandler)

    def start(self):
        print "Server Starting on HOST: " + self.host
        server_thread = threading.Thread(target=self.server.serve_forever)
        server_thread.daemon = True
        server_thread.start()

【问题讨论】：

handle() 中的while 循环中的代码似乎缩进不正确？

@Francis Avila。我猜它是为你设置换行的方式。减去 self.my_object 它是一个工作示例。

【参考方案1】：

您可以通过服务器实例传递对象：

self.server = SocketServer.TCPServer((self.host, self.port), ProtocolHandler)
self.server.my_object = self.my_object

documentation 表示您可以通过self.server 访问handle() 中的服务器实例。

【讨论】：

希望我能看到这一点。像冠军一样工作。谢谢！

如果没有线程同步，这有什么用？多个线程正在写入同一个变量。服务器对象应该如何使用或理解它？

@FrancisAvila：您向基本客户端公开的对象必须是线程安全的/实现锁定。诚然，我上面的示例代码仅使用 bool 就写得不好。带有 set/clear 方法的 threading.Event 会是一个更好的例子。