使用多处理在同一个mysqldb连接中查询，块？答案

【问题标题】：use multiprocessing to query in same mysqldb connect , block?使用多处理在同一个mysqldb连接中查询，块？
【发布时间】：2016-09-25 07:30:32
【问题描述】：

中止 MySQLdb。

我知道很多进程不使用相同的连接，因为这将是一个问题。

但是，运行下面的代码，mysql请求是阻塞的，然后多个进程同时开始查询sql，sql是“select sleep(10)”，它们是一一对应的。

在 MySQLdb/mysql.c 中没有找到 code abort lock/mutux，为什么没有问题？我认为通常相同的连接 fd 会有问题。但是通过我的测试，只阻塞io，没有出现问题。锁在哪里？

进口时间导入多处理导入 MySQL 数据库 db = MySQLdb.connect("127.0.0.1","root","123123","rui" ) 定义函数（* args）：而1：游标 = db.cursor() cursor.execute("选择睡眠(10)") 数据 = cursor.fetchall() 打印长度（数据）光标.close() 打印时间.time() 时间.睡眠（0.1）如果 __name__ == "__main__": 任务 = [] 对于范围内的我（20）： p = multiprocessing.Process(target = func, args = (i,)) p.start() task.append(p) 对于我的任务：我加入（）

结果日志，我们发现每个请求间隔是十秒。

1 1464325514.82 1 1464325524.83 1 1464325534.83 1 1464325544.83 1 1464325554.83 1 1464325564.83 1 1464325574.83 1 1464325584.83 1 1464325594.83 1 1464325604.83 1 1464325614.83 1 1464325624.83

tcpdump 日志：

我们发现每个请求间隔是十秒两次。

13:07:04.827304 IP localhost.44281 > localhost.mysql: Flags [.], ack 525510411, win 513, options [nop,nop,TS val 2590846552 ecr 2590846552], 长度 0 0x0000: 4508 0034 23ad 4000 4006 190d 7f00 0001 E..4#.@.@....... 0x0010: 7f00 0001 acf9 0cea fc09 7cf9 1f52 a70b ....|..R.. 0x0020: 8010 0201 ebe9 0000 0101 080a 9a6d 2e58 ....m.X 0x0030: 9a6d 2e58 .m.X 13:07:04.928106 IP localhost.44281 > localhost.mysql: 标志 [P.], seq 0:21, ack 1, win 513, options [nop,nop,TS val 2590846653 ecr 2590846552], 长度 21 0x0000: 4508 0049 23ae 4000 4006 18f7 7f00 0001 E..I#.@.@....... 0x0010: 7f00 0001 acf9 0cea fc09 7cf9 1f52 a70b ....|..R.. 0x0020: 8018 0201 fe3d 0000 0101 080a 9a6d 2ebd .....=.......m.. 0x0030: 9a6d 2e58 1100 0000 0373 656c 6563 7420 .m.X .....选择。 0x0040: 736c 6565 7028 3130 29 睡眠(10) 13:07:14.827526 IP localhost.44281 > localhost.mysql: 标志 [.], ack 65, win 513, 选项 [nop,nop,TS val 2590856553 ecr 2590856552], 长度 0 0x0000: 4508 0034 23af 4000 4006 190b 7f00 0001 E..4#.@.@....... 0x0010: 7f00 0001 acf9 0cea fc09 7d0e 1f52 a74b ....}..R.K 0x0020: 8010 0201 9d73 0000 0101 080a 9a6d 5569 .....s.......mUi 0x0030: 9a6d 5568 .mUh 13:07:14.927960 IP localhost.44281 > localhost.mysql: 标志 [P.], seq 21:42, ack 65, win 513, options [nop,nop,TS val 2590856653 ecr 2590856552], 长度 21 0x0000: 4508 0049 23b0 4000 4006 18f5 7f00 0001 E..I#.@.@....... 0x0010: 7f00 0001 acf9 0cea fc09 7d0e 1f52 a74b ....}..R.K 0x0020: 8018 0201 fe3d 0000 0101 080a 9a6d 55cd .....=.......mU。 0x0030: 9a6d 5568 1100 0000 0373 656c 6563 7420 .mUh .....选择。 0x0040: 736c 6565 7028 3130 29 睡眠(10)

```

结束。

【问题讨论】：

我不明白你的问题。

标签： mysql linux mysql-python pymysql

【解决方案1】：

它是应急的。

MySQL 是请求-响应协议。

当两个进程发送查询时，除非查询很大，否则不会混合。 MySQL 服务器 (1) 接收一个查询，(2) 发送 (1) 的响应，(3) 接收下一个查询，(4) 发送 (3) 的响应。

当第一个响应从 MySQL 服务器发送时，两个进程之一接收它。由于响应足够小，它被原子接收。另一个进程收到下一个响应。

尝试从一个进程发送“SELECT 1+2”，从另一个进程发送“SELECT 1+3”。 “1+2”可能是4，“SELECT 1+3”可能是3。

【讨论】：