PHP swoole和redis异步任务实现方法分析

内容导读

收集整理的这篇技术教程文章主要介绍了PHP swoole和redis异步任务实现方法分析，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1836字，纯文字阅读大概需要3分钟。

内容图文

本文实例讲述了PHP swoole和redis异步任务实现方法。分享给大家供大家参考，具体如下：

redis异步任务

interface.php

<?phpfor($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

<?phpfor($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和redis异步任务实现方法分析全部内容，希望文章能够帮你解决PHP swoole和redis异步任务实现方法分析所遇到的程序开发问题。 如果觉得技术教程内容还不错，欢迎将网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。