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

Question

中止 MySQLdb。

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

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

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

import time
import multiprocessing
import MySQLdb

db = 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()

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

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], 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.X
13: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                                .mUh
13: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>