max_user_connections after gevent.monkey.patch_all()

Question

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

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

然后我在服务器启动函数中使用了geevent .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()

Answer 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
    ...