swoole 安裝與簡單應用

方法一:PECL安裝

安裝依賴包

apt-get install libpcre3 libpcre3-dev

安裝swoole

pecl install swoole

修改PHP配置 php.ini  加載 swoole

驗證安裝與加載:

php -m | grep swoole

 

方法二:源碼編譯安裝

1.下載swoole

下載源碼包,解壓,並切換到解壓目錄

wget -c https://github.com/swoole/swoole-src/archive/v2.0.6.tar.gz

解壓:tar -zxvf v2.0.6.tar.gz

cd swoole-src-2.0.6/

2.編譯安裝

使用phpize來生成php編譯配置

.configure來做編譯配置檢測

make進行編譯 make install 進行安裝

執行命令:

phpize

./configure

make 

make install

正常情況下會出現

Installing shared extensions :             /usr/lib64/php/modules

表示 在上述目錄 /usr/lib64/php/modules  中生成了 swoole.so 文件

 

3.修改配置文件,加載模塊

要在PHP配置文件 php.ini 添加swoole模塊. 注意,PHP7模塊配置文件是單獨分開的,只需在 /etc/php.d/  目錄中添加模塊配置文件 swoole.ini 即可

進入到 /etc/php.d/  執行命令

vim swoole.ini    

在swoole.ini 中輸入

;Enable swoole extension module 

extension=swoole.so

保存.

 

4.重啟服務,模塊是否已加載

service  apache2 restart

 php -m | grep swoole

三  .簡單示例

1.TCP服務器

創建swoole_test.php 文件,內容如下:  示例代碼

 

切換到所創建swoole_test.php 所在目錄,執行命令

php  swoole_test.php  (本人電腦多版本PHP 故指明版本 php7.0)

監聽9898 端口的程序已啟動執行

新打開一個終端窗口,使用telnet 連接服務端監聽的端口,輸入文字,觀察.可以發現  連接時  監聽連接的回調函數正常輸出了 如圖:

示例只是簡單的模擬個回復 ,客戶端發什么,服務端就回什么

 

退出Telnet 連接 觀察 服務器顯示什么

Ctrl + ] 

quit

服務器 顯示 Client:Close

 

上述telnet 連接測試 可用swoole_client 同理測試

注:swoole_client 是針對TCP服務器的客戶端,即:swoole_server

創建swoole_client.php,內容如下:

 

function client($argv)
{
    $client= new swoole_client(SWOOLE_SOCK_TCP);
    //連接到服務器
    if (!$client->connect($argv[1],$argv[2],'0.5')) {
        die("connect failed.");
    }

    //向服務器發送數據
    if (!$client->send('data: '.$argv[3])) {
        die("send failed.");
    }
    echo "success send data: ".$argv[3]."\n";
    $client->close();
}
client($argv);

打開終端執行:
php7.0  swoole_client.php   127.0.0.1  9898   hello

數據 'hello' 發送成功. 
PHP 中可用 exec()函數執行:exec('php7.0 swoole_client.php 127.0.0.1 9898 hello'),可打印日志,跟蹤過程.


2. webSocket服務器程序.

內置的webSocket服務器支持，通過幾行PHP代碼就可以寫出一個異步非阻塞多進程的webSocket服務 如下例:

①.html:

<table>
    <tr>
        <td><input type="text" id="text"></td>
    </tr>
    <tr>
        <td><input type="button" value="點擊" onclick="ab()"></td>
    </tr>
</table>
<div id="div" style="width:200px; height:200px;" }>

</div>

②.客戶端js:

目前瀏覽器安基本都內置了js語言的webSocket客戶端,微信小程序開發框架也內置了webSocket客戶端,除此之外異步的php程序中可以使用swoole\http\client作為websocket客戶端,注意的是:非webSocket客戶端不能與webSocket服務器通訊.

//引入jQuery
<script>
    var wsServer = 'ws://127.0.0.1:9999';//這里的IP應該更改
    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) {
        $('#div').append(evt.data+"<br>");
        // document.getElementById('div').style.background = evt.data;
        console.log('Retrieved data from server: ' + evt.data);
    };

    websocket.onerror = function (evt, e) {
        console.log('Error occured: ' + evt.data);
    };
    function ab(){
        var zhi=document.getElementById('text').value;
        websocket.send(zhi);
    }
</script>

webSocket服務器: webSocket_server.php

//創建websocket服務器對象，監聽0.0.0.0:9502端口
$ws = new swoole_websocket_server("0.0.0.0", 9999);

//監聽WebSocket連接打開事件
$ws->on('open', function ($ws, $request) {
    var_dump($request->fd, $request->get, $request->server);
    //獲取所有連接人存為數組

    $GLOBALS['fd'][] = $request->fd;
    //$ws->push($request->fd, "hello, welcome\n");
});

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

//循環所有連接人發送內容

    foreach($GLOBALS['fd'] as $key => $val){
        $ws->push($val,$frame->data);
    }
    //$ws->push($frame->fd, "{$frame->data}");
});

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

$ws->start();

運行    終端運行   php  webSocket_server.php

瀏覽器打開html頁面:輸入文字,得到回復

 

這里只做了簡單的示例測試,具體應用參考官方文檔 :https://wiki.swoole.com/

 實際項目應用示例demo