~~~
class server {
public function __construct() {
//HTTP_SERVER_URL:監聽的http請求地址，如何是監聽內部http請求，最好寫成內網地址，HTTP_SERVER_PORT：監聽端
$serv = new Swoole\Http\Server(HTTP_SERVER_URL, HTTP_SERVER_PORT);
$serv->set(array(
'worker_num' => 1,
'task_worker_num' =>2 ,
'daemonize' => true,//守護進程，如果服務需要長時間開啟，設為true
'heartbeat_check_interval' => 30,//心跳檢測時間
'heartbeat_idle_time' => 65,//超過該時間回調close斷開TCP
'log_file' => '/data/dt/swoole/error/nydp.log'
));
$serv->on('request', array($this, 'request')); //接收http請求
$serv->on('task', array($this, 'task')); //開啟一個task進程，必須調用finish進程
$serv->on('finish', array($this, 'finish'));
$serv->on('workerStart', array($this, 'worker_start')); //開啟一個work進程
$this->_serv = $serv;
$this->_tcp = $serv->addListener(TCP_SERVER_URL, TCP_SERVER_PORT, SWOOLE_SOCK_TCP);//監聽接受客戶端數據的服務器端口
$this->_tcp->set(array(
'worker_num' => 2,
'task_worker_num' => 10,
'daemonize' => false,
'heartbeat_check_interval' => 60,
'heartbeat_idle_time' => 125,
'log_file' => '/data/dt/swoole/error/nydp.log'
));
$this->_tcp->on('connect', array($this, 'connect'));
$this->_tcp->on('receive', array($this, 'receive'));
$this->_tcp->on('close', array($this, 'close'));
$serv->start();
}
public function connect($serv, $fd) {
echo "you success connect client {$fd}\n";
}
public function worker_start($serv, $work_id) {
//在Worker進程開啟時綁定定時器
//只有當worker_id為0時才添加定時器,避免重復添加
if ($work_id == 0) {
swoole_timer_tick(30000, array($this, 'timer_send_msg'), $serv); //30秒發送一次數據到設備
}
}
public function receive($serv, $fd, $from_id, $data) {
//接收到客戶端傳來的數據調用該方法
}
public function request($request, $response) {
//監聽所有的http請求
$response->cookie("User", "Swoole");
$response->header("X-Server", "Swoole");
$response->end("<h1>Hello Swoole!</h1>");
$data['fd'] = isset($request->post['fd']) ? $request->post['fd'] : '';//獲取post數據
｝
public function task($serv, $task_id, $from_id, $data){
//task 任務
}
public function finish($serv, $task_id, $data) {
//任務完成執行的函數
}
public function close($serv, $fd) {
//進程關閉執行的函數
}
}
$server = new server ();
