swoole异步mysql有什么用_php如何使用SwooleTaskWorker实现异步操作Mysql(代码)
本篇文章给大家带来的内容是关于php如何使用SwooleTaskWorker实现异步操作Mysql(代码),有一定的参考价值,有需要的朋友可以参考一下,希望对你有所帮助。
在一般的 Server 程序中都会有一些耗时的任务,比如:发送邮件、聊天服务器发送广播等。如果我们采用同步阻塞的防水去执行这些任务,那么这肯定会非常的慢。
Swoole 的 TaskWorker 进程池可以用来执行一些异步的任务,而且不会影响接下来的任务,很适合处理以上场景。
那么什么是异步任务呢?
可以从下面的图示中来简单了解一下。(来源于网络,侵删)
我们上一个 Swoole 的文章介绍了如何创建一个简单的服务器,并且知道了几个核心的回调函数的使用方法。
要实现上述的异步处理,只需要增加两个事件回调即可:onTask 和 onFinish, 这两个回调函数分别用于执行 Task 任务和处理 Task 任务的返回结果。另外还需要在 set 方法中设置 task 进程数量。
使用示例:class Server
{
private $serv;
public function __construct() {
$this->serv = new swoole_server("0.0.0.0", 9501);
$this->serv->set(array(
'worker_num' => 4,
'daemonize' => false,
'task_worker_num' => 8
));
$this->serv->on('Start', array($this, 'onStart'));
$this->serv->on('Connect', array($this, 'onConnect'));
$this->serv->on('Receive', array($this, 'onReceive'));
$this->serv->on('Close', array($this, 'onClose'));
$this->serv->on('Task', array($this, 'onTask'));
$this->serv->on('Finish', array($this, 'onFinish'));
$this->serv->start();
}
public function onReceive( swoole_server $serv, $fd, $from_id, $data ) {
echo "Get Message From Client {$fd}:{$data}\n";
// 发送任务到Task进程
$param = array(
'fd' => $fd
);
$serv->task( json_encode( $param ) );
echo "继续处理之后的逻辑\n";
}
public function onTask($serv, $task_id, $from_id, $data) {
echo "This Task {$task_id} from Worker {$from_id}\n";
echo "Data: {$data}\n";
for($i = 0 ; $i < 5 ; $i ++ ) {
sleep(1);
echo "Task {$task_id} Handle {$i} times...\n";
}
$fd = json_decode( $data , true )['fd'];
$serv->send( $fd , "Data in Task {$task_id}");
return "Task {$task_id}'s result";
}
public function onFinish($serv,$task_id, $data) {
echo "Task {$task_id} finish\n";
echo "Result: {$data}\n";
}
public function onStart( $serv ) {
echo "Server Start\n";
}
public function onConnect( $serv, $fd, $from_id ) {
echo "Client {$fd} connect\n";
}
public function onClose( $serv, $fd, $from_id ) {
echo "Client {$fd} close connection\n";
}
}
$server = new Server();
通过上述示例可以看到,发起一个异步任务只需要调用 swoole_server 的 task 方法就可以。发送之后会触发 onTask 回调,可以通过 $task_id 和 $from_id 处理不同进程的不同任务。最后可以通过 return 一个字符串来将执行结果返回给 Worker 进程,Worker 进程通过 onFinish 回调来处理结果。
那么基于上述代码就可以实现异步操作 mysql。异步操作 mysql 较适合以下场景:并发的读写操作
没有时序上的严格关系
不影响主线程逻辑
好处:提高并发
降低 IO 消耗
数据库的压力主要在于 mysql 维持的连接数,如果存在 1000 个并发,那么 mysql 就需要建立对应数量的连接。而采用长连接的方式,mysql 的连接一直维持在进程中,减少了创建连接的损耗。可以通过 swoole 开启多个 task 进程,每一个进程内维持一个mysql 长连接,那么这样子也可以引申出来 mysql 连接池技术。还需要注意的是,mysql 服务器如果检测到长时间没有没有查询,则会断开连接回收资源,所以要有断线重连的机制。
以下是一个简单的异步操作 mysql 的示例:
还是以上的代码,我们只需要修改 onReceive、onTask、onFinish 三个函数。class Server
{
private $serv;
public function __construct() {
$this->serv = new swoole_server("0.0.0.0", 9501);
$this->serv->set(array(
'worker_num' => 4,
'daemonize' => false,
'task_worker_num' => 8 // task进程数量 即为维持的MySQL连接的数量
));
$this->serv->on('Start', array($this, 'onStart'));
$this->serv->on('Connect', array($this, 'onConnect'));
$this->serv->on('Receive', array($this, 'onReceive'));
$this->serv->on('Close', array($this, 'onClose'));
$this->serv->on('Task', array($this, 'onTask'));
$this->serv->on('Finish', array($this, 'onFinish'));
$this->serv->start();
}
public function onReceive( swoole_server $serv, $fd, $from_id, $data ) {
echo "收到数据". $data . PHP_EOL;
// 发送任务到Task进程
$param = array(
'sql' => $data, // 接收客户端发送的 sql
'fd' => $fd
);
$serv->task( json_encode( $param ) ); // 向 task 投递任务
echo "继续处理之后的逻辑\n";
}
public function onTask($serv, $task_id, $from_id, $data) {
echo "This Task {$task_id} from Worker {$from_id}\n";
echo "recv SQL: {$data['sql']}\n";
static $link = null;
$sql = $data['sql'];
$fd = $data['fd'];
HELL:
if ($link == null) {
$link = @mysqli_connect("127.0.0.1", "root", "root", "test");
}
$result = $link->query($sql);
if (!$result) { //如果查询失败
if(in_array(mysqli_errno($link), [2013, 2006])){
//错误码为2013,或者2006,则重连数据库,重新执行sql
$link = null;
goto HELL;
}
}
if(preg_match("/^select/i", $sql)){//如果是select操作,就返回关联数组
$data = array();
while ($fetchResult = mysqli_fetch_assoc($result) ){
$data['data'][] = $fetchResult;
}
}else{//否则直接返回结果
$data['data'] = $result;
}
$data['status'] = "OK";
$data['fd'] = $fd;
$serv->finish(json_encode($data));
}
public function onFinish($serv, $task_id, $data) {
echo "Task {$task_id} finish\n";
$result = json_decode($result, true);
if ($result['status'] == 'OK') {
$this->serv->send($result['fd'], json_encode($result['data']) . "\n");
} else {
$this->serv->send($result['fd'], $result);
}
}
public function onStart( $serv ) {
echo "Server Start\n";
}
public function onConnect( $serv, $fd, $from_id ) {
echo "Client {$fd} connect\n";
}
public function onClose( $serv, $fd, $from_id ) {
echo "Client {$fd} close connection\n";
}
}
$server = new Server();
以上代码在 onReceive 时直接接收一条 sql,之后直接发送到 Task 任务中。这个时候下一步的流程紧接着输出,这里也就体现出了异步。然后 onTask 和 onFinish 分别用来向数据库发送 sql,处理 task 执行结果。
swoole异步mysql有什么用_php如何使用SwooleTaskWorker实现异步操作Mysql(代码)相关推荐
- php调mysql接口头文件_php基础系列:PHP连接MySQL数据库用到的三种API
参考自php手册.本文没有太大意义,仅为方便自己上网查阅. 1.PHP的MySQL扩展 2.PHP的mysqli扩展 3.PHP数据对象(PDO) MySQL扩展函数 这是设计开发允许PHP应用与My ...
- mysql数据迁移 脚本_PHP将数据从Oracle向Mysql数据迁移实例
为什么要迁移? 首先从运营成本考虑,用Mysql可以节约不少的费用.另一方面,Mysql的稳定性及功能不断地提高与增强,基本上可以满足客户的需求,如支持多 节点部署,数据分区等.还有就是Mysql使用 ...
- php 读取mysql 二维数组_PHP操作 二维数组模拟mysql函数
PHP操作 二维数组模拟mysql函数 public function monimysqltest(){ $testarray=array( array('ss'=>'1','dd'=>' ...
- mysql not like 没用_PHP - 使用NOT LIKE时,mysql查询不起作用
我有一个正在构建的查询字符串,当我使用LIKE时它工作正常,但它不适用于NOT LIKE $sWhere = ""; if ( $_GET['sSearch'] != " ...
- 前端调用mysql异步_PHP 使用 Swoole – TaskWorker 实现异步操作 Mysql
在一般的 Server 程序中都会有一些耗时的任务,比如:发送邮件.聊天服务器发送广播等.如果我们采用同步阻塞的防水去执行这些任务,那么这肯定会非常的慢. Swoole 的 TaskWorker 进程 ...
- swoole实现Timer定时器、心跳检测及Task进阶实例:mysql连接池
2019独角兽企业重金招聘Python工程师标准>>> Table of Contents 1.Timer定时器 2.心跳检测 3.Task进阶:MySQL连接池 环境说明: 系统: ...
- apache php mysql配置详解,详细介绍:Apache+PHP+MySQL配置攻略_php基础
一.系统要求: 本系统在REDHAT7.2版本测试通过 二.服务器端软件要求: 1:到APACHE的网络站下载APACHE WEB SERVER http://www.apache.org/ 2. 到 ...
- php用到的mysql语句_PHP中常用到的一些MySQL语句_php
在php开发中,经常会使用到mysql语句,下面就为您列举了一些经常使用的MySQL语句,希望对您平时的学习和开发工作能起到些许的作用. MySQL语句显示数据库或表: show databases; ...
- php使用异步redis,PHP Swoole异步Redis客户端实现方法示例
本文实例讲述了PHP Swoole异步Redis客户端实现方法.分享给大家供大家参考,具体如下: 使用版本:1.8.0及以上 使用条件: 1.开启async-redis php --ri swoole ...
最新文章
- .gitignore文件如何编写?
- 使用希捷DiscWizard格式化3TB硬盘并分区
- 非空约束对数据更新的影响
- 删除表格数据后自动刷新_表格中一键即可删除重复数据,你居然还用逐条排查?...
- CodeForces - 1366D Two Divisors(数论)
- 3.6.1.非阻塞IO
- 【CTSC2017】【BZOJ4903】吉夫特 卢卡斯定理 DP
- table表格边框样式_如何在CAD创建、导入表格?原来CAD的表格功能这么强大
- msscript 64位找不到的替代方法
- 2011-5-学习总结
- 基于邮件推拉技术的数据库远程数据同步解决方案
- 风格迁移篇----艺术风格转换的内容与风格解构
- 计算机技术毕业生个人简历,计算机技术毕业生个人简历模板
- 一维数组的定义以及使用
- 编一程序,将两个字符串连接起来,不要用strcat函数。
- mysql安装 防火墙,mysql8 参考手册--安装或卸载MySQL企业防火墙
- idea如何创建XML文件
- slickedit调试linux内核,SlickEdit介绍
- 从金蝶k3到金税盘_金蝶K3操作流程图详解
- 变分自编码器(VAE,Variational Auto-Encoder)
热门文章
- 在Objective-C中,如何测试对象类型?
- rosweb,roslib:bug汇总。报Warning: Invalid argument “/map“ passed to canTransform
- Android:解决Failed to load D:\Android-Studio\sdk\build-tools\xx.xx.xx\lib\dx.jar
- peterson算法p0流程图_Dekker算法与Peterson算法
- adam优化_认识 AdaMod: 一个新的有记忆的深度学习优化器
- CSS3盒子模型(CSS3)
- 单行溢出文字省略号显示(HTML、CSS)
- 微信小程序API之showActionSheet(操作菜单)
- js过滤时间方法,几分钟前,1小时前
- 电脑管家pc版离线包_王国统治电脑版下载_王国统治游戏pc版下载[策略经营]