这篇文章主要介绍了PHP扩展Swoole实现实时异步任务队列,结合实例形式分析了PHP扩展Swoole实现实时异步任务队列相关客户端与服务器端操作技巧,需要的朋友可以参考下。

本文实例讲述了PHP扩展Swoole实现实时异步任务队列。分享给大家供大家参考，具体如下：

假如要发100封邮件，for循环100遍，用户直接揭竿而起，什么破网站！

但实际上，我们很可能有超过1万的邮件。怎么处理这个延迟的问题？

答案就是用异步。把“发邮件”这个操作封装，然后后台异步地执行1万遍。这样的话，用户提交网页后，他所等待的时间只是“把发邮件任务请求推送进队列里”的时间。而我们的后台服务将在用户看不见的地方跑。

在实现“异步队列”这点上，有人采用MySQL表或者redis来存放待发送的邮件，然后，每分钟定时读取待发送列表，然后处理。这便是定时异步任务队列。但当前提交的任务要一分钟后才能执行，在某些实时性要求应用场景里还是不快。有些场景要求，只有一提交任务，便马上执行，但用户不需要等待返回结果。

本文将探讨用php扩展swoole实现实时异步任务队列的方案。

服务端

在打算放置脚本的目录（你也可以自行新建）新建Server.php，代码如下：

1. <?php 
2. class Server 
3. { 
4.   private $serv; 
5.   public function __construct() 
6.   { 
7.     $this->serv = new swoole_server("0.0.0.0", 9501); 
8.     $this->serv->set(array( 
9.       'worker_num' => 1, //一般设置为服务器CPU数的1-4倍 
10.       'daemonize' => 1, //以守护进程执行 
11.       'max_request' => 10000, 
12.       'dispatch_mode' => 2, 
13.       'task_worker_num' => 8, //task进程的数量 
14.       "task_ipc_mode " => 3, //使用消息队列通信，并设置为争抢模式 
15.       //"log_file" => "log/taskqueueu.log" ,//日志 
16.     )); 
17.     $this->serv->on('Receive', array($this, 'onReceive')); 
18.     // bind callback 
19.     $this->serv->on('Task', array($this, 'onTask')); 
20.     $this->serv->on('Finish', array($this, 'onFinish')); 
21.     $this->serv->start(); 
22.   } 
23.   public function onReceive(swoole_server $serv, $fd, $from_id, $data) 
24.   { 
25.     //echo "Get Message From Client {$fd}:{$data}\n"; 
26.     // send a task to task worker. 
27.     $serv->task($data); 
28.   } 
29.   public function onTask($serv, $task_id, $from_id, $data) 
30.   { 
31.     $array = json_decode($data, true); 
32.     if ($array['url']) { 
33.       return $this->httpGet($array['url'], $array['param']); 
34.     } 
35.   } 
36.   public function onFinish($serv, $task_id, $data) 
37.   { 
38.     //echo "Task {$task_id} finish\n"; 
39.     //echo "Result: {$data}\n"; 
40.   } 
41.   protected function httpGet($url, $data) 
42.   { 
43.     if ($data) { 
44.       $url .= '?' . http_build_query($data); 
45.     } 
46.     $curlObj = curl_init(); //初始化curl， 
47.     curl_setopt($curlObj, CURLOPT_URL, $url); //设置网址 
48.     curl_setopt($curlObj, CURLOPT_RETURNTRANSFER, 1); //将curl_exec的结果返回 
49.     curl_setopt($curlObj, CURLOPT_SSL_VERIFYPEER, FALSE); 
50.     curl_setopt($curlObj, CURLOPT_SSL_VERIFYHOST, FALSE); 
51.     curl_setopt($curlObj, CURLOPT_HEADER, 0); //是否输出返回头信息 
52.     $response = curl_exec($curlObj); //执行 
53.     curl_close($curlObj); //关闭会话 
54.     return $response; 
55.   } 
56. } 
57. $server = new Server(); 

客户端

启动服务后，让我们看看如何调用服务。新建测试文件Client_test.php

1. <?php 
2. class Client 
3. { 
4.   private $client; 
5.   public function __construct() 
6.   { 
7.     $this->client = new swoole_client(SWOOLE_SOCK_TCP); 
8.   } 
9.   public function connect() 
10.   { 
11.     if (!$this->client->connect("127.0.0.1", 9501, 1)) { 
12.       throw new Exception(sprintf('Swoole Error: %s', $this->client->errCode)); 
13.     } 
14.   } 
15.   public function send($data) 
16.   { 
17.     if ($this->client->isConnected()) { 
18.       if (!is_string($data)) { 
19.         $data = json_encode($data); 
20.       } 
21.       return $this->client->send($data); 
22.     } else { 
23.       throw new Exception('Swoole Server does not connected.'); 
24.     } 
25.   } 
26.   public function close() 
27.   { 
28.     $this->client->close(); 
29.   } 
30. } 
31. $data = array( 
32.   "url" => "http://192.168.10.19/send_mail", 
33.   "param" => array( 
34.     "username" => 'test', 
35.     "password" => 'test' 
36.   ) 
37. ); 
38. $client = new Client(); 
39. $client->connect(); 
40. if ($client->send($data)) { 
41.   echo 'success'; 
42. } else { 
43.   echo 'fail'; 
44. } 
45. $client->close(); 

在上面代码中，url即为任务所在地址，param为所需传递参数。

保存好代码，在命令行或者浏览器中执行Client_test.php,便实现了异步任务队列。你所填写的URL，将会在每次异步任务被提交后，以HTTP GET的方式异步执行。

Tags: Swoole PHP异步任务

分享到：