swoole使用 經常使用案例

swoole使用

服務器及客戶端

4種服務器【tcp/udp/web/websocket】

TCP服務器

//建立Server對象，監聽 127.0.0.1:9501端口
$serv = new swoole_server("127.0.0.1", 9501);
//監聽鏈接進入事件
$serv->on('connect', function ($serv, $fd) {
    echo "Client: Connect.\n";
});
//監聽數據接收事件
$serv->on('receive', function ($serv, $fd, $from_id, $data) {
    $serv->send($fd, "Server: ".$data);
});
//監聽鏈接關閉事件
$serv->on('close', function ($serv, $fd) {
    echo "Client: Close.\n";
});
//啓動服務器
$serv->start();

UDP服務器

//建立Server對象，監聽 127.0.0.1:9502端口，類型爲SWOOLE_SOCK_UDP
$serv = new swoole_server("127.0.0.1", 9502, SWOOLE_PROCESS, SWOOLE_SOCK_UDP);
//監聽數據接收事件
$serv->on('Packet', function ($serv, $data, $clientInfo) {
    $serv->sendto($clientInfo['address'], $clientInfo['port'], "Server ".$data);
    var_dump($clientInfo);
});
//啓動服務器
$serv->start();

http服務器

$http = new swoole_http_server("0.0.0.0", 9501);
$http->on('request', function ($request, $response) {
    var_dump($request->get, $request->post);
    $response->header("Content-Type", "text/html; charset=utf-8");
    $response->end("<h1>Hello Swoole. #".rand(1000, 9999)."</h1>");
});
$http->start();

websocket服務器

服務器端： 
//建立websocket服務器對象，監聽0.0.0.0:9502端口 
$ws = new swoole_websocket_server(「0.0.0.0」, 9502);

//監聽WebSocket鏈接打開事件
$ws->on('open', function ($ws, $request) {
    var_dump($request->fd, $request->get, $request->server);
    $ws->push($request->fd, "hello, welcome\n");
});

//監聽WebSocket消息事件
$ws->on('message', function ($ws, $frame) {
    echo "Message: {$frame->data}\n";
    $ws->push($frame->fd, "server: {$frame->data}");
});

//監聽WebSocket鏈接關閉事件
$ws->on('close', function ($ws, $fd) {
    echo "client-{$fd} is closed\n";
});

$ws->start();

客戶端JS：

var wsServer = 'ws://192.168.50.151:9502';
var websocket = new WebSocket(wsServer);
websocket.onopen = function (evt) {
    console.log("Connected to WebSocket server.");
};

websocket.onclose = function (evt) {
    console.log("Disconnected");
};

websocket.onmessage = function (evt) {
    console.log('Retrieved data from server: ' + evt.data);
};

websocket.onerror = function (evt, e) {
    console.log('Error occured: ' + evt.data);
};

輔助

定時器

//每隔2000ms觸發一次
swoole_timer_tick(2000, function ($timer_id) {
    echo "tick-2000ms\n";
});

//3000ms後執行此函數
swoole_timer_after(3000, function () {
    echo "after 3000ms.\n";
});

異步tcp服務器處理任務

$serv = new swoole_server("127.0.0.1", 9501);

//設置異步任務的工做進程數量
$serv->set(array('task_worker_num' => 4));

$serv->on('receive', function($serv, $fd, $from_id, $data) {
//投遞異步任務
    $task_id = $serv->task($data);
    echo "Dispath AsyncTask: id=$task_id\n";
});

//處理異步任務
$serv->on('task', function ($serv, $task_id, $from_id, $data) {
    echo "New AsyncTask[id=$task_id]".PHP_EOL;
    //返回任務執行的結果
    $serv->finish("$data -> OK");
});

//處理異步任務的結果
    $serv->on('finish', function ($serv, $task_id, $data) {
    echo "AsyncTask[$task_id] Finish: $data".PHP_EOL;
});

$serv->start();

tcp同步客戶端

$client = new swoole_client(SWOOLE_SOCK_TCP);

//鏈接到服務器
if (!$client->connect('127.0.0.1', 9501, 0.5))
{
die("connect failed.");
}
//向服務器發送數據
if (!$client->send("hello world"))
{
die("send failed.");
}
//從服務器接收數據
$data = $client->recv();
if (!$data)
{
die("recv failed.");
}
echo $data;
//關閉鏈接
$client->close();

tcp異步客戶端

$client = new swoole_client(SWOOLE_SOCK_TCP, SWOOLE_SOCK_ASYNC);

//註冊鏈接成功回調
$client->on("connect", function($cli) {
$cli->send("hello world\n");
});

//註冊數據接收回調
$client->on("receive", function($cli, $data){
echo "Received: ".$data."\n";
});

//註冊鏈接失敗回調
$client->on("error", function($cli){
echo "Connect failed\n";
});

//註冊鏈接關閉回調
$client->on("close", function($cli){
echo "Connection close\n";
});

//發起鏈接
$client->connect('127.0.0.1', 9501, 0.5);

自定義通信協議設計

進程/協程管理

進程

單獨進程

$process = new swoole_process('callback_function', true);
$pid = $process->start();
function callback_function(swoole_process $worker){
$worker->exec('/usr/bin/php', array(__DIR__.'/write_file.php'));
}// 啓用本地的命令，加上絕對路徑
swoole_process::wait();

【子進程】管道緩衝區讀寫及事件監聽？

$workers = [];
$worker_num = 3;//建立的進程數
for($i=0;$i<$worker_num; $i++){
$process = new swoole_process('process');// 建立子進程 啓動函數爲 process
$pid = $process->start();// 子進程啓動
$workers[$pid] = $process;// 存入字符數組
}
foreach($workers as $process){
//子進程會包含此事件,加入到子進程中 異步IO
swoole_event_add($process->pipe, function ($pipe) use($process){
$data = $process->read();
echo "RECV: " . $data.PHP_EOL;// 接收數據
});//函數調用的神奇狀況
}
function process(swoole_process $process){// 第一個處理
$process->write("processId:".$process->pid);// 子進程寫入信息到管道。
echo "echo:".$process->pid."\t".$process->callback .PHP_EOL;// 打印提示信息結果 及製表符
}
// 兩次等待子進程結束
for($i=0; $i<$worker_num; $i++){// 回收子進程 不然出現殭屍進程
$ret = swoole_process::wait();// 回收結束運行的子進程,若是子進程結束。相似於 join
$pid = $ret['pid'];
unset($workers[$pid]);
echo "子進程退出, PID=".$pid.PHP_EOL;
}

隊列讀寫

// 進程通訊
$workers = [];// 進程倉庫
$worker_num = 2;// 最大進程數
// 循環建立子進程
for($i = 0; $i < $worker_num; $i++){
$process = new swoole_process('callback_function', false, false);
$process->useQueue();// 開啓隊列使用，相似於全局隊列
$pid = $process->start();//開啓進程
$workers[$pid] = $process;// 存入句柄倉庫
}
// 子進程執行函數
function callback_function(swoole_process $worker){
sleep(2);//睡覺2秒
$recv = $worker->pop();// 獲取隊列數據
echo "從主進程獲取數據: $recv\n";
$worker->exit(0);// 當前子進程結束
}
// 主進程內，新增隊列數據
foreach($workers as $pid => $process){
$process->push("Hello 子進程[$pid]\n");
}
// 兩次等待子進程結束
for($i = 0; $i < $worker_num; $i++){
// 回收子進程 不然出現殭屍進程
$ret = swoole_process::wait();// 回收結束運行的子進程,若是子進程結束。相似於 join
$pid = $ret['pid'];
unset($workers[$pid]);
echo "子進程退出, PID=".$pid.PHP_EOL;
}

循環觸發進程

// 循環定時執行
// 定時器觸發函數
swoole_process::signal(SIGALRM, function () {
static $i = 0;
echo "#{$i}\t alarm\n";
$i++;
if ($i > 20) {
swoole_process::alarm(-1);// 清除定時器
}
});

//100ms
swoole_process::alarm(100 * 1000);// 定時器，相似於定時觸發，相似js 裏面的setinterval()

協程

2.0開始執行，暫不深刻了解

內存讀寫

內存鎖—互斥鎖

$lock = new swoole_lock(SWOOLE_MUTEX);
echo "[主進程]建立鎖\n";
$lock->lock();
if (pcntl_fork() > 0){// 這個是主進程
sleep(1);
$lock->unlock();
}else{// 這個是子進程
echo "[子進程]等待鎖\n";
$lock->lock();
echo "[子進程]獲取鎖\n";
$lock->unlock();
exit("[子進程]退出\n");
}
echo "[主進程]釋放鎖\n";
unset($lock);
sleep(1);
echo "[主進程]退出\n";

異步IO

DNS輪詢

swoole_async_dns_lookup("www.baidu.com", function($host, $ip){
echo "{$host} : {$ip}\n";
});

異步讀取

swoole_async_readfile(__DIR__."/server.php", function($filename, $content) {
echo "$filename: $content";
});

異步寫入

$file_content = 'jingshan';
swoole_async_writefile('test.log', $file_content, function($filename) {
echo "wirte ok.\n";
}, $flags = 0);

異步事件

$fp = stream_socket_client("tcp://www.qq.com:80", $errno, $errstr, 30);
fwrite($fp,"GET / HTTP/1.1\r\nHost: www.qq.com\r\n\r\n");
swoole_event_add($fp, function($fp) {
$resp = fread($fp, 8192);
//socket處理完成後，從epoll事件中移除socket
//var_dump($resp);
swoole_event_del($fp);
fclose($fp);
});
echo "Finish\n";  //swoole_event_add不會阻塞進程，這行代碼會順序執行

異步mysql

// mysql異步客戶端
$db = new swoole_mysql;
$server = array(
'host' => '192.168.50.145',
'user' => 'root',
'password' => 'flzx_3QC',
'database' => 'mysql',
'chatset' => 'utf8', //指定字符集
);

$db->connect($server, function ($db, $r) {
if ($r === false){
var_dump($db->connect_errno, $db->connect_error);
die;
}
$sql = 'show tables';
$db->query($sql, function(swoole_mysql $db, $r) {
global $s;
if ($r === false){
var_dump($db->error, $db->errno);
}
elseif ($r === true ){
var_dump($db->affected_rows, $db->insert_id);
}
var_dump($r);
$db->close();
});
});