# 在php-fpm/apache中使用task功能 AsyncTask是swoole提供一套生產者消費者模型，可以方便地將一個慢速任務投遞到隊列，由進程池異步地執行。task功能目前只能在swoole_server中使用。1.9.0版本提供了RedisServer框架，可以基于RedisServer和Task實現一個Server程序，在php-fpm或apache中直接調用Redis擴展就可以使用swoole的task功能了。 創建RedisServer ---- ```php use Swoole\Redis\Server; $server = new Server("127.0.0.1", 9501, SWOOLE_BASE); $server->set(array( 'task_worker_num' => 32, 'worker_num' => 1, )); $server->setHandler('LPUSH', function ($fd, $data) use ($server) { $taskId = $server->task($data); if ($taskId === false) { return Server::format(Server::ERROR); } else { return Server::format(Server::INT, $taskId); } }); $server->on('Finish', function() { }); $server->on('Task', function ($serv, $taskId, $workerId, $data) { //處理任務 }); $server->start(); ``` - 如果是本機調用可以監聽UnixSocket，局域網內調用需要使用IP:PORT - Task中`$data`就是客戶端投遞的數據 - 其他語言也可以使用Redis客戶端投遞任務 - 可以根據Task任務執行的速度調節`task_worker_num`控制啟動的進程數量，這些進程是由swoole底層負責管理的，在發生致命錯誤或進程退出后底層會重新創建新的任務進程 投遞任務 --- ```php $redis = new Redis; $redis->connect('127.0.0.1', 9501); $taskId = $redis->lpush("myqueue", json_encode(array("hello", "swoole"))); ``` 注意這個RedisServer并不是一臺真正的Redis服務器，它只支持`LPUSH`一個指令。