PHP使用SWOOLE扩展实现定时同步 MySQL 数据

发布时间：2020-12-12 22:05:30 所属栏目：PHP教程来源：网络整理

导读：南宁公司和几个分公司之间都使用了呼叫系统，然后现在需要做一个呼叫通话数据分析，由于分公司的呼叫服务器是在内网，通过技术手段映射出来，分公司到南宁之间的网络不稳定，所以需要把分公司的通话数据同步到南宁。本身最简单的方法就是直接配置MySQL的主

南宁公司和几个分公司之间都使用了呼叫系统，然后现在需要做一个呼叫通话数据分析，由于分公司的呼叫服务器是在内网，通过技术手段映射出来，分公司到南宁之间的网络不稳定，所以需要把分公司的通话数据同步到南宁。

本身最简单的方法就是直接配置MySQL的主从同步就可以同步数据到南宁来了。但是销售呼叫系统那边的公司不给MySQL权限我们。所以这个方法只能放弃了。

于是我们干脆的想，使用PHP来实现定时一个简易的PHP定时同步工具，然后PHP进程常驻后台运行，所以首先就先到了一个PHP组件：SWOOLE，经过讨论，分公司的每天半天生成的数据量最大在5000条左右，所以这个方案是可行，就这样干。

我们使用PHP SWOOLE 做一个异步的定时任务系统。

本身MySQL数据库的主从同步是通过解析Master库中的binary-log来进行同步数据到从库的。然而我们使用PHP来同步数据的时候，那么只能从master库分批查询数据，然后插入到南宁的slave库来了。

这里我们使用的框架是 ThinkPHP 3.2 .

首先安装PHP扩展： SWOOLE,因为没有使用到特别的功能，所以这里我们使用pecl来快速安装:

安装完成后在 php.ini 里面加入 extension="swoole.so" 安装完成后，我们使用 phpinfo() 来检查是否成功了.

安装成功了，我们就来写业务.

服务端

1、首先启动一个后台的服务端,监听端口9501

set([ 'worker_num' => 1,//一般设置为服务器CPU数的1-4倍 'task_worker_num' => 8,//task进程的数量 'daemonize' => 1,//以守护进程执行 'max_request' => 10000,//最大请求数量 "task_ipc_mode " => 2 //使用消息队列通信，并设置为争抢模式 ]); $serv->on('Receive',[$this,'onReceive']);//接收任务，并投递 $serv->on('Task','onTask']);//可以在这个方法里面处理任务 $serv->on('Finish','onFinish']);//任务完成时候调用 $serv->start(); }

2、接收和投递任务

task($area); } }

3、任务执行，数据从master库查询和写入到slave数据库

//master 库为分公司的数据库，slave库为数据同步到南宁后的从库
Code......

//使用$sql获取从库中最大的自增: SELECT MAX(id) AS maxid FROM ss_cdr_cdr_info limit 1
$slaveMaxIncrementId = ...;

//使用$sql获取主库中最大的自增: SELECT MAX(id) AS maxid FROM ss_cdr_cdr_info limit 1
$masterMaxIncrementId = ...;

//如果相等的就不同步了
if($slaveMaxIncrementId >= $masterMaxIncrementId){
return false;
}

//根据条数计算页数
$dataNumber = ceil($masterMaxIncrementId - $slaveMaxIncrementId);
$eachNumber = ceil($dataNumber / $rows);
$left = 0;

//根据页数来进行分批循环进行写入，要记得及时清理内存
for ($i = 0; $i < $eachNumber; $i++) {
$left = $i == 0 ? $slaveMaxIncrementId : $left + $rows;
$right = $left + $rows;
//生成分批查询条件
//$where = "id > $left AND <= $right";
$masterData = ...;//从主库查询数据
$slaveLastInsertId = ...;//插入到从库
unset($masterData,$slaveLastInsertId);
}

echo "New AsyncTask[id=$task_id]".PHP_EOL;
$serv->finish("$area -> OK");
}

4、任务完成时候调用

客户端推送任务

到此基本完成，剩下来我们来写客户端任务推送

connect('127.0.0.1',9501,1)) { throw new Exception('链接SWOOLE服务错误'); } $areas = json_encode(['liuzhou','yulin','beihai','guilin']); //开始遍历检查 $client->send($areas); echo "任务发送成功".PHP_EOL; }

至此基本完成了，剩下的我们来写一个shell脚本定时执行：/home/wwwroot/sync_db/crontab/send.sh

定时推送异步的数据同步任务

/usr/bin/php /home/wwwroot/sync_db/server.php home/index/index

使用crontab定时任务，我们把脚本加入定时任务

Tips: 最好推荐在里面加入写日志操作，这样好知道是任务推送、执行是否成功。

至此基本完成，程序有待优化~~~，各位看客有更好的方法欢迎提出。

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!