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

砸漏

发布于 2020-10-20 10:48:51

7060

发布于 2020-10-20 10:48:51

文章被收录于专栏：恩蓝脚本

本文实例讲述了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异步任务日志