Swoole筆記（三）

wua_wua2012 發(fā)布于2019-06-27 16:40 / 2894人閱讀

摘要：服務(wù)器里直接運行啟動即可。包含了客戶端發(fā)來的數(shù)據(jù)幀信息使用獲取獲取數(shù)據(jù)內(nèi)容使用向客戶端發(fā)送消息。長度最大不得超過。使用，通過幾行代碼即可寫出一個異步非阻塞多進程的服務(wù)器里使用運行。

WebSocket

使用Swoole可以很簡單的搭建異步非阻塞多進程的WebSocket服務(wù)器。

WebSocket服務(wù)器

set(array(
    "daemonize" => false,
    "worker_num" => 2,
));

$server->on("Start", function (swoole_websocket_server $server) {
    echo "Server Start... 
";
    swoole_set_process_name("swoole_websocket_server");
});

$server->on("ManagerStart", function (swoole_websocket_server $server) {
    echo "ManagerStart
";
});

$server->on("WorkerStart", function (swoole_websocket_server $server, $worker_id) {
    echo "WorkerStart 
";
    if ($server->worker_id == 0){
        swoole_timer_tick(10000,function($id) use ($server) {
            echo "test timer
";
        });
    }
});

$server->on("Open", function (swoole_websocket_server $server, $request) {
    echo "server: handshake success with fd{$request->fd}
";
});

$server->on("Message", function (swoole_websocket_server $server, $frame) {
    echo "receive from {$frame->fd}:{$frame->data},opcode:{$frame->opcode},fin:{$frame->finish}
";
    $server->push($frame->fd, "this is server");
});

$server->on("Close", function ($ser, $fd) {
    echo "client {$fd} closed
";
});

$server->start();

shell里直接運行php swoole_ws_server.php啟動即可。如果設(shè)置了后臺運行，可以使用下列命令強殺進程：

kill -9 $(ps aux|grep swoole|grep -v grep|awk "{print $2}")

或者重新啟動worker進程：

kill -10 $(ps aux|grep swoole_websocket_server|grep -v grep|awk "{print $2}")

輸出：

[2017-06-01 22:06:21 $2479.0]    NOTICE    Server is reloading now.
WorkerStart 
WorkerStart

注意：

onMessage回調(diào)函數(shù)為必選，當(dāng)服務(wù)器收到來自客戶端的數(shù)據(jù)幀時會回調(diào)此函數(shù)。

/**
* @param $server
* @param $frame 包含了客戶端發(fā)來的數(shù)據(jù)幀信息；使用$frame->fd獲取fd；$frame->data獲取數(shù)據(jù)內(nèi)容
*/
function onMessage(swoole_server $server, swoole_websocket_frame $frame)

使用$server->push()向客戶端發(fā)送消息。長度最大不得超過2M。發(fā)送成功返回true，發(fā)送失敗返回false。

function swoole_websocket_server->push(int $fd, string $data, int $opcode = 1, bool $finish = true);

WebSocket客戶端

最簡單的是使用JS編寫：

socket = new WebSocket("ws://192.168.1.107:9501/"); 
socket.onopen = function(evt) { 
    // 發(fā)送一個初始化消息
    socket.send("I am the client and I"m listening!"); 
}; 

// 監(jiān)聽消息
socket.onmessage = function(event) { 
    console.log("Client received a message", event); 
}; 

// 監(jiān)聽Socket的關(guān)閉
socket.onclose = function(event) { 
    console.log("Client notified socket has closed",event); 
}; 

socket.onerror = function(evt) { 
    console.log("Client onerror",event); 
};

Swoole里沒有直接提供swoole_websocket客戶端，不過通過引入WebSocketClient.php文件可以實現(xiàn)：

connect())
{
    echo "connect failed 
";
    return false;
}

$send_data = "I am client.
";
if (!$client->send($send_data))
{
    echo $send_data. " send failed 
";
    return false;
}

echo "send succ 
";
return true;

上面代碼實現(xiàn)的是一個同步的swoole_websocket客戶端。發(fā)送完消息會自動關(guān)閉，可以用來與php-fpm應(yīng)用協(xié)作：將耗時任務(wù)使用客戶端發(fā)送到swoole_websocket_server。

如何創(chuàng)建一個聊天室

實際項目里，我們可以將用戶uid和fd進行雙向綁定（暫不考慮多臺服務(wù)器分布式部署情況），例如使用Redis保存：在onMessage進行用戶信息驗證后:

$this->redis->set($fd, $uid);
$this->redis->set($uid, $fd);

后續(xù)需要指定給某人發(fā)消息，只需要根據(jù)uid/fd發(fā)送即可。在onClose事件里進行解綁操作。群發(fā)的話只需要遍歷一遍$server->connections即可。

示例（該項目只實現(xiàn)群發(fā)）：
moell-peng/webim: PHP + Swoole 實現(xiàn)的簡單聊天室
https://github.com/moell-peng...

HttpServer

swoole內(nèi)置Http服務(wù)器的支持。swoole版的http server相對于php-fpm，最大優(yōu)勢在于高性能：代碼一次載入內(nèi)存，后續(xù)無需再解釋執(zhí)行。缺點是調(diào)試沒有nginx+php-fpm方便。

使用swoole，通過幾行代碼即可寫出一個異步非阻塞多進程的Http服務(wù)器：

on("Start", function() {
    echo "Start";
});

$serv->on("Request", function($request, $response) {
    var_dump($request->get);
    var_dump($request->post);
    var_dump($request->cookie);
    var_dump($request->files);
    var_dump($request->header);
    var_dump($request->server);

    $response->cookie("User", "Swoole");
    $response->header("X-Server", "Swoole");
    $response->end("Hello Swoole!");
});

$serv->start();

shell里使用php swoole_http_server.php運行server。瀏覽器打開http://192.168.1.107:9502/即可看到輸出。

歡迎關(guān)注公眾號及時獲取最新文章推送！