PHP swoole和redis异步任务实现方法分析
2019-08-12 09:29
1356 查看
本文实例讲述了PHP swoole和redis异步任务实现方法。分享给大家供大家参考,具体如下:
redis异步任务
interface.php
<?php for($i=0;$i<100;$i++){ $msg = "zhezhao[".$i."]"; $redis = new Redis(); $redis->connect("127.0.0.1"); $redis->publish("test",$msg); $redis->close(); }
handler.php
<?php $redis = new Redis(); $redis->connect("127.0.0.1"); $redis->subscribe(array("test"), 'handleFun'); function handleFun($redis, $chan, $data) { write($data); } function write($data){ $path = "/tmp/mailList-redis.log"; $str = "[".date("Y-m-d H:i:s")."]".$data; $str .= PHP_EOL; file_put_contents($path,$str,FILE_APPEND); }
swoole异步任务
interface.php
<?php for($i=0;$i<100;$i++){ $msg = "zhezhao[".$i."]"; $client = new swoole_client(SWOOLE_SOCK_TCP); $client->connect('127.0.0.1', 9501, 0.5); $client->send($msg); $client->close(); }
handler.php
<?php $serv = new swoole_server("127.0.0.1", 9501); $serv->set(array('task_worker_num' => 4)); $serv->on('receive', function($serv, $fd, $from_id, $data) { $task_id = $serv->task($data); }); $serv->on('task', function ($serv, $task_id, $from_id, $data) { handle($data); $serv->finish($data); }); $serv->start(); function handle($data){ sleep(2); mailLog("Send Mail successfully to $data"); } function mailLog($str){ $path = "/tmp/mailList.log"; $str = "[".date("Y-m-d H:i:s")."]".$str; $str .= PHP_EOL; file_put_contents($path,$str,FILE_APPEND); }
比较
redis异步任务日志
swoole异步任务日志
通过对比任务日志我们可以看到,由于swoole开了4个进程执行异步任务,所以处理异步任务的效率大概是redis的四倍,如果swoole只开一个进程的话,效率和redis几乎没有什么差别。
更多关于PHP相关内容感兴趣的读者可查看本站专题:《PHP进程与线程操作技巧总结》、《PHP网络编程技巧总结》、《PHP基本语法入门教程》、《PHP数组(Array)操作技巧大全》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》
希望本文所述对大家PHP程序设计有所帮助。
您可能感兴趣的文章:
相关文章推荐
- PHP使用swoole来实现实时异步任务队列
- PHP扩展Swoole实现实时异步任务队列示例
- PHP使用swoole来实现实时异步任务队列
- PHP使用swoole来实现实时异步任务队列
- php基于协程实现异步的方法分析
- PHP操作swoole来实现实时异步任务队列
- PHP使用swoole来实现实时异步任务队列
- php定时计划任务的实现方法详解
- PHP实现计划任务的几种方法
- PHP使用redis实现统计缓存mysql压力的方法
- PHP实现异步调用方法研究
- 使用php方法curl抓取AJAX异步内容思路分析及代码分享
- 一个基于redis和disque实现的轻量级异步任务执行器
- php中foreach结合curl实现多线程的方法分析
- php定时计划任务的实现方法详解
- 实现PHP多线程异步请求的3种方法
- 支持windows与linux的php计划任务的实现方法
- Redis3.0集群crc16算法php实现方法(php取得redis3.0集群中redis数据所在的redis分区插槽,并根据分区插槽取得分区所在redis服务器地址)
- php实现异步数据调用的方法
- 用php实现异步执行任务的队列(二)