1

我正在将 gevent-socketio v0.13.8 用于基于 django 的 Web 应用程序上的聊天应用程序。我的数据库是 MySql 并且有一个 max_user_connection = 1500 值。我的套接字服务器是用 python 守护进程守护的。我在没有猴子补丁的情况下使用套接字服务器，它运行良好，除了在 greenlet 上出现错误时，所有系统都因 SystemExit 而失败，并且无法再建立连接。解决方案是重新启动所有服务器。

但是我不想每次都重新启动服务器。最后我想出了猴子修补的想法。我不知道它是否与我的问题有关，但我希望我的套接字服务器能够运行，即使未处理的异常导致 Greenlet 上的 SystemExit 也是如此。

然后我在我的服务器启动函数中使用了 gevent.monkey.patch_all() 。这是我现在的主要问题： 3-4 次连接后，MySql 导致以下错误：

User xxx already has more than 'max_user_connections' active connections

max_user_connection 变量在 mysql 服务器中设置为 1500。我认为有些东西在greenlets中创建了与数据库的新连接。

顺便说一句，我使用时不会出现 max_user_connection 错误：

monkey.patch_all(socket=True, dns=True, time=True, select=True, thread=True, os=True, ssl=True, httplib=True, aggressive=True)

代替：

monkey.patch_all()

有没有办法使用猴子补丁而不会出现此错误？如果我忘记提供有关问题定义的任何信息，请告诉我，我会立即更新

这是我的守护服务器代码：

class App():

    def __init__(self):
        self.stdin_path = 'xxx.txt'
        self.stdout_path = 'xxx.txt'
        self.stderr_path = 'xxx.txt'
        self.pidfile_path =  'xxx.pid'
        self.pidfile_timeout = 5

    def run(self):
        from socketio.server import SocketIOServer
        from gevent import monkey
        monkey.patch_all()
        while True:
            try:
                bind = ("xx.xx.xx.xx", xxxx)
                handler = get_handler()
                server = SocketIOServer(bind, handler, resource="socket.io",policy_server=False)
                server.serve_forever()
            except:
                server.kill()
app = App()
logger = logging.getLogger("DaemonLog")
logger.setLevel(logging.INFO)
formatter = logging.Formatter("%(asctime)s - %(name)s - %(levelname)s - %(message)s")
handler = logging.FileHandler("xxx.log")
handler.setFormatter(formatter)
logger.addHandler(handler)

daemon_runner = runner.DaemonRunner(app)
daemon_runner.daemon_context.files_preserve=[handler.stream]
daemon_runner.do_action()
4

1 回答 1

1

我在以下位置找到了解决问题的方法：https ://github.com/abourget/gevent-socketio/issues/174

它实际上与greenlets的非封闭数据库连接有关。在我的命名空间类中添加类似的 exception_handler_decorator 后，我没有看到 max_user_connection 错误

from django.db import close_old_connections  # Django 1.6
class MyNamespace(BaseNamespace):
    ...
    def exception_handler_decorator(self, fun):
        def wrap(*args, **kwargs):
            try:
                return fun(*args, **kwargs)
            finally:
                close_old_connections()
        return wrap
    ...
于 2014-09-14T11:10:45.117 回答