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

<?phpfor($i=0;$i<100;$i++){  $msg = "zhezhao[".$i."]";  $redis = new Redis();  $redis->connect("127.0.0.1");  $redis->publish("test",$msg);  $redis->close();}

<?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);}

<?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();}

<?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);}