class msgServer

{

private $serv;

function __construct()

{

$this->serv = new Swoole\Server("127.0.0.1", 9501);//創建一個服務

$this->serv->set(array('task_worker_num' => 4)); //配置task進程的數量

$this->serv->on('receive', array($this, 'onReceive'));//有數據進來的時候執行

$this->serv->on('task', array($this, 'onTask'));//有任務的時候執行

$this->serv->on('finish', array($this, 'onFinish'));//任務結束時執行

$this->serv->start();

}

public function onReceive($serv, $fd, $from_id, $data)

{

$data = json_decode($data, true);

$task_id = $serv->task($data);//這里發起了任務，于是上面的on('task', array($this, 'onTask'))就會執行

}

public function onTask($serv, $task_id, $from_id, $data)

{

$data['send_res'] = $this->sendMsg($data); //發送短信

//1.7.3之前，是$serv->finish("result");

return "result.";//這里告訴任務結束，于是上面的on('finish', array($this, 'onFinish'))就會執行

}

public function onFinish($serv, $task_id, $data)

{

$this->addSendLog($data); //添加短信發送記錄

}

}