mysql 重新连接 c++

Question

现在我有一个 C++ 客户端应用程序，它使用 mysql.h 连接到 MYSQL 数据库，并且必须执行一些逻辑，以防断开连接。我想知道这是否是在客户端断开连接的情况下重新连接 MYSQL 数据库的最佳方法。

bool MYSQL::Reconnect(const char *host, const char *user, const char *passwd, const char *db)
{
bool out = false;

pid_t command_pid = fork();
if (command_pid == 0)
{
    while(1)
    {
        sleep(1);
        if (mysql_real_connect(&m_mysql, host, user, passwd, db, 0, NULL, 0) == NULL )
        {
            fprintf(stderr, "Failed to connect to database: Error: %s\n",
            mysql_error(&m_mysql));
        }
        else
        {
            m_connected = true;
            out = true;
            break;
        }
    }
    exit(0);
}

if (command_pid < 0)
    fprintf(stderr, "Could not fork process[reconnect]: %s\n", mysql_error(&m_mysql));

return out;
}

现在我获取所有参数并执行分叉。子进程每秒尝试使用 sleep() 语句重新连接。这是一个好方法吗？谢谢

Answer 1

抱歉，您的代码没有按照您的想法执行，Kaiser Wilhelm。

从本质上讲，您试图将叉子视为线程，但事实并非如此。

当您分叉一个子进程时，父进程将被完全克隆，包括文件和套接字描述符，这就是您的程序连接到 MySQL 数据库服务器的方式。也就是说，当您分叉时，父级和子级最终都会获得与数据库服务器的相同连接的自己的副本。我假设父级仅在发现连接断开时调用此 Reconnect() 方法，并停止使用现已失效的 MySQL 连接对象 m_mysql 的副本。如果是这样，当您开始重新连接操作时，父连接的副本与客户端的连接副本一样无用。

问题是，反之亦然：一旦子进程成功重新连接到数据库服务器，父进程的连接对象仍然失效。孩子所做的任何事情都不会传播回父母。分叉后，两个进程完全独立，除非它们可能尝试访问它们最初共享的某些 I/O 资源。例如，如果您在连接建立时调用此 Reconnect() 并继续使用父级中的连接，则子级尝试在同一连接上与数据库服务器通信将会混淆 mysqld 或 libmysqlclient，可能会导致数据损坏或崩溃。

如上所述，解决此问题的一种方法是使用线程而不是分叉。但是，请注意使用线程的许多问题使用 MySQL C API。

如果有选择，我宁愿使用异步 I/O 在应用程序的主线程中进行后台连接尝试，但 MySQL C API 不允许这样做。

看来您在尝试重新连接数据库服务器时试图避免阻塞主应用程序线程。您可能可以通过设置来同步执行此操作连接超时为1秒，当MySQL服务器与客户端位于同一台机器或同一局域网上时，这很好。如果您可以容忍主线程因连接尝试失败而阻塞长达一秒钟（最坏的情况发生在服务器位于单独的计算机上并且物理上断开连接或设有防火墙时），那么这可能是比线程更干净的解决方案。如果服务器计算机仍在运行且端口未受防火墙保护，例如在重新启动且 TCP/IP 堆栈[仍然]运行时，连接尝试可能会更快失败。

Answer 2

据我所知，这并没有达到您的预期。

逻辑问题

重新连接根本不“在断开连接的情况下执行某些逻辑”。

它会一遍又一遍地尝试连接，直到成功为止，然后停止。就是这样。连接状态不再被检查。如果连接断开，此代码对此一无所知。

技术问题

还要密切关注 Warren 提出的技术问题。

Answer 3

当然，完全没问题。您可能想考虑用类似的东西替换 while ( 1 ) 循环，

  while ( NULL == mysql_real_connect( ... )) {
    sleep( 1 );
    ... 
  }

这是一种通过实践学习的习惯用法，但据我所知，您的代码工作得很好。不要忘记在 while 循环内放置一个计数器。