在多线程环境中使用Mysql++的问题

Issues using Mysql++ in a multithreaded environment

本文关键字:Mysql++ 问题 多线程 环境      更新时间:2023-10-16

希望有人能帮我,因为我遇到了一些"奇怪"的分割错误。我目前正在开发一个C++守护进程,它定期处理来自输入源的传入数据,然后将其发送回另一个系统。

守护进程目前运行两个线程——一个线程(主线程)从消息队列中读取传入数据并将处理后的数据插入MySQL数据库,另一个线程从特定表中读取并将处理过的数据推送到不同的系统。

我假设这个错误在某种程度上与MySQL和线程有关,因为我在运行一个线程时没有问题(只是数据处理,或者只是推送处理后的数据)。

SIGSEGV错误都与mysql++相关(连接到DB后调用的第一个mysql++方法),例如:

(gdb) backtrace
#0  clear (this=0xabd4e8) at /usr/include/c++/4.7/bits/basic_string.h:801
#1  ping (this=0xabcf40) at ./lib/dbdriver.h:465
#2  mysqlpp::Connection::ping (this=<optimized out>) at ./lib/connection.cpp:243

崩溃也总是由辅助线程触发,当两个线程都连接到MySQL数据库时(当主线程运行人工while(true)循环时运行良好)

连接代码:

mysqlConnection = new mysqlpp::Connection(false);
mysqlConnection->set_option(new mysqlpp::ReconnectOption(true)); // Reconnect if session times out
if(!mysqlConnection->connect("fakeDbName", "fakeHostName",
"fakeUserName", "fakePassword))
{
printf("Failed to connect..n");
}
if(!mysqlConnection->thread_aware())
{
printf("Mysql++ not compiled with threading supportn");
}
else
{
printf("Mysql++ compiled with threading supportn");
}

我遵循了Mysql++的指导原则,使用"--enable thread check"进行配置/编译,并使用"libmysqlclient_r"进行链接。连接后,我得到了一个"Mysql++编译并支持线程"的printf。我还为两个线程创建了一个单独的连接对象。

有什么想法吗?

您可以在数据库访问周围放置一个信号灯,以排除mysql库中的一些线程安全问题。但我很好奇你为什么需要单独的线程。。。发送线程的动作似乎直接绑定到接收线程。为什么你不能在同一条线上同时做这两件事?