第Swoole實現(xiàn)異步投遞task任務(wù)案例詳解本文實例講述了Swoole實現(xiàn)異步投遞task任務(wù)案例。分享給大家供大家參考，具體如下：

【使用場景】

Swolle的task模塊可以用來做一些異步的慢速任務(wù)、耗時場景。如webim中發(fā)廣播，發(fā)送郵件等，把這些任務(wù)丟給task進(jìn)程之后，worker進(jìn)程可以繼續(xù)處理新的數(shù)據(jù)請求，任務(wù)完成后會異步通知worker進(jìn)程告訴它此任務(wù)已經(jīng)完成。此外利用task還可以實現(xiàn)PHP的數(shù)據(jù)庫連接池，異步隊列等。

【使用須知】

必須設(shè)置Task進(jìn)程數(shù)：task_worker_num

投遞一個異步任務(wù)到task_worker池中：Server-task

必須注冊onTask、onFinish2個事件回調(diào)函數(shù)。

【示例】

以創(chuàng)建一個WebSocket服務(wù)異步投遞任務(wù)為例：

ws_server.php：

classWs{

public$ws=null;

publicfunction__construct(){

$this-ws=newswoole_websocket_server("",9501);

$this-ws-set([

'worker_num'=2,//worker進(jìn)程數(shù)

'task_worker_num'=2,//task進(jìn)程數(shù)

$this-ws-on("open",[$this,'onOpen']);

$this-ws-on("message",[$this,'onMessage']);

$this-ws-on("task",[$this,'onTask']);

$this-ws-on("finish",[$this,'onFinish']);

$this-ws-on("close",[$this,'onClose']);

$this-ws-start();

//建立連接回調(diào)

publicfunctiononOpen($ws,$request){

echo"{$request-fd}建立了連接";

//接受消息回調(diào)

publicfunctiononMessage($ws,$frame){

//worker進(jìn)程異步投遞任務(wù)到task_worker進(jìn)程中

$data=[

'fd'=$frame-fd,

$ws-task($data);

//服務(wù)器返回

echo"服務(wù)器發(fā)送消息:666";

//完成異步任務(wù)回調(diào)

publicfunctiononTask($serv,$task_id,$worker_id,$data){

var_dump($data);

//模擬慢速任務(wù)

sleep(5);

//返回字符串給worker進(jìn)程——觸發(fā)onFinish

return"success";

//完成任務(wù)投遞回調(diào)

publicfunctiononFinish($serv,$task_id,$data){

//task_worker進(jìn)程將任務(wù)處理結(jié)果發(fā)送給worker進(jìn)程

echo"完成任務(wù){(diào)$task_id}投遞處理結(jié)果：{$data}";

//關(guān)閉連接回調(diào)

publicfunctiononClose($ws,$fd){

echo"{$fd}關(guān)閉了連接";

$obj=newWs();

前端頁面js監(jiān)聽：

!DOCTYPEhtmlPUBLIC"-//W3C//DTDXHTML1.0Transitional//EN""/TR/xhtml1/DTD/xhtml1-transitional.dtd"

htmlxmlns="/1999/xhtml"

head

titleWebSocket/title

/head

body

/body

scripttype="text/javascript"

varwebsocket=newWebSocket('ws://:9501');

websocket.onopen=function(evt){onOpen(evt)};

websocket.onclose=function(evt){onClose(evt)};

websocket.onmessage=function(evt){onMessage(evt)};

websocket.onerror=function(evt){onError(evt)};

functiononOpen(evt){

console.log("ConnectedtoWebSocketserver.");

//*發(fā)送消息到websocket服務(wù)器

websocket.send('666');

functiononClose(evt){

console.log("Disconnected");

functiononMessage(evt){

console.log('Retrieveddatafromserver:'+evt.data);

functiononError(evt){

console.log('Erroroccured:'+evt.data);

/script

/html

開啟WebSocket服務(wù)：

phpws_server.php

前后刷新了兩次頁面，WebSocket服務(wù)器監(jiān)聽結(jié)果：

（服務(wù)器會先返回消息給客戶端，然后再執(zhí)行投遞任務(wù)）

更多關(guān)于PHP相關(guān)內(nèi)容感興趣的讀者可查看本站專題：《PHP擴(kuò)展開發(fā)教程》、《ph