1.修改ws.php
```
<?php
class Ws {
CONST HOST = "0.0.0.0";
CONST PORT = 9501;
public $ws = null;
public function __construct() {
$this->ws = new swoole_websocket_server("0.0.0.0", 9501);
$this->ws->set([
'worker'=>2,
'task_worker_num'=>2,
//'enable_static_handler'=>true,
//'document_root'=>'/web/tool/demo/html',
]);
$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();
}
/**
* 监听ws连接事件
* @param $ws
* @param $request
*/
public function onOpen($ws, $request) {
var_dump($request->fd);
if($request->fd == 1) {
// 每2秒执行
swoole_timer_tick(2000, function($timer_id){
echo "2s: timerId:{$timer_id}\n";
});
}
}
/**
* 监听ws消息事件
* @param $ws
* @param $frame
*/
public function onMessage($ws, $frame) {
echo "ser-push-message:{$frame->data}\n";
$data = [
'task'=>1,
'fd'=>$frame->fd,
];
//$ws->task($data);
swoole_timer_after(5000, function() use($ws, $frame) {
echo "5s-after\n";
$ws->push($frame->fd, "server-time-after:");
});
$ws->push($frame->fd,"server-push:".date('Y-m-d H:i:s'));
}
public function onTask($serv,$taskId,$workerId,$data)
{
print_r($data);
sleep(10);
return "task finish";
}
public function onFinish($serv,$taskId,$data)
{
echo "taskId:{$taskId}\n";
echo "finish data success:{$data}\n";
}
/**
* close
* @param $ws
* @param $fd
*/
public function onClose($ws, $fd) {
echo "clientid:{$fd}关闭\n";
}
}
$obj = new Ws();
```
2.启动http_server.php与ws.php
