mysql - 使用多处理在同一个 mysqldb 连接中查询， block ？

Question

中止 MySQLdb。

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

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

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

import timeimport multiprocessingimport MySQLdbdb = MySQLdb.connect("127.0.0.1","root","123123","rui" )def func(*args):    while 1:        cursor = db.cursor()        cursor.execute("select sleep(10)")        data = cursor.fetchall()        print len(data)        cursor.close()        print time.time()        time.sleep(0.1)if __name__ == "__main__":    task = []    for i in range(20):        p = multiprocessing.Process(target = func, args = (i,))        p.start()        task.append(p)    for i in task:        i.join()

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

11464325514.8211464325524.8311464325534.8311464325544.8311464325554.8311464325564.8311464325574.8311464325584.8311464325594.8311464325604.8311464325614.8311464325624.83

tcpdump 日志:

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

13:07:04.827304 IP localhost.44281 > localhost.mysql: Flags [.], ack 525510411, win 513, options [nop,nop,TS val 2590846552 ecr 2590846552], length 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.X13:07:04.928106 IP localhost.44281 > localhost.mysql: Flags [P.], seq 0:21, ack 1, win 513, options [nop,nop,TS val 2590846653 ecr 2590846552], length 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.....select.    0x0040:  736c 6565 7028 3130 29                   sleep(10)13:07:14.827526 IP localhost.44281 > localhost.mysql: Flags [.], ack 65, win 513, options [nop,nop,TS val 2590856553 ecr 2590856552], length 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                                .mUh13:07:14.927960 IP localhost.44281 > localhost.mysql: Flags [P.], seq 21:42, ack 65, win 513, options [nop,nop,TS val 2590856653 ecr 2590856552], length 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.....select.    0x0040:  736c 6565 7028 3130 29                   sleep(10)

```

```

结束。

Answer 1

它在偶然情况下起作用。

MySQL 是请求-响应协议(protocol)。

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

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

尝试从一个进程发送“SELECT 1+2”并从另一个进程发送“SELECT 1+3”。 “1+2”可能偶然是4，“SELECT 1+3”可能偶然是3。<​​/p>