MySQL：半同步（三）从库端初始化和回调函数

semisync_slave_plugin.cc

semisync.cc

继承自ReplSemiSyncBase

执行语句

INSTALL PLUGIN rpl_semi_sync_slave SONAME 'semisync_slave.so'

相关调用过程

调用者：IO线程

回调时机

具体过程

这个回调函数比较简单，只是设置了从库是否使用为半同步方式，但是随后还会修改，参考repl_semi_slave_request_dump回调函数。

调用者：IO线程

回调时机

具体过程

这个回调函数也很简单只是将 rpl_semi_sync_slave_status状态设置为OFF

调用者：IO线程

回调方式：

具体过程

我们可以看到这里在和主库进行交互，实际探测主库是否安装了半同步插件，没有的话rpl_semi_sync_slave_status也会在io线程启动时刻设置为OFF。

调用者：IO线程

回调方式

具体过程

可以看到这个回调函数主要通过读取event，然后通过kPacketFlagSync去判断是否本event需要进行ack反馈。注意是否需要反馈是放在semi_sync_need_reply里面的，但是这是全局变量（多源复制如何处理？多源复制不支持半同步）

调用者：IO线程

注意本函数内部会做replay的判断，根据前面的semi_sync_need_reply进行判断如果不是事务的最后一个event则不需要反馈ack

回调方式

具体过程：

可以看到这个回调函数，实际的构建了需要反馈的信息给主库的Ack_recevier线程。

mysql返回修改后的列_PDO Mysql驱动返回结果的列类型问题

PDO的Mysql驱动返回的结果中，所有的字段都是字符串，

使用statement->getColumnMeta得到的列元信息，其中的pdo_type也表明是字符串。

php可以自动处理类型转换，比如整型和字符串，但是对于其他环境，比如传给其他平台(如flash)，就要在其中一端进行类型转换，或者在协议中处理。另外，要基于查询结果的元信息构建自动化的数据处理，比如ORM，也就不方便了。

原因是，mysql驱动使用mysql_fetch_row函数取得结果集，它是个字符串数组，即所有列都是字符串方式的存储，并且没根据DB存储的类型进行转换，相应地，列的元数据也就都是字符串类型了；

另外，pdo本身的数据类型也有限，跟DB、DB客户端库函数的数据类型有差异，比如pdo没有浮点数类型。

根据pdo接口规范，只要修改mysql驱动中的两个回调函数就可以了：

通常情况下在PHP中MySQL查询是串行的，如果能实现MySQL查询的异步化，就能实现多条SQL语句同时执行，这样就能大大地缩短MySQL查询的耗时，提高数据库查询的效率。目前MySQL的异步查询只在MySQLi扩展提供，查询方法分别是：

1、使用MYSQLI_ASYNC模式执行mysqli::query

2、获取异步查询结果：mysqli::reap_async_query

使用mysql异步查询，需要使用mysqlnd作为PHP的MySQL数据库驱动。

使用MySQL异步查询，因为需要给所有查询都创建一个新的连接，而MySQL服务端会为每个连接创建一个单独的线程进行处理，如果创建的线程过多，则会造成线程切换引起系统负载过高。Swoole中的异步MySQL其原理是通过MYSQLI_ASYNC模式查询，然后获取mysql连接的socket，加入到epoll事件循环中，当数据库返回结果时会回调指定函数，这个过程是完全异步非阻塞的。

---