Swoole入門到實戰（一）：PHP7&Swoole源碼安裝、玩轉網絡通信引擎、異步非堵塞I

weakish 發布于2019-06-28 18:48 / 904人閱讀

摘要：服務重點基本概述協議是基于的一種新的網絡協議。被調用者通過狀態通知機制等來通知調用者，或通過回調函數來處理結果阻塞和非阻塞關注的是調用者等待被調用者返回調用結果時的狀態。

一、PHP7源碼安裝和Swoole源碼編譯安裝 1.1 PHP7源碼安裝 1.1.1 獲取源碼與安裝

????獲取PHP7源碼：www.php.net

tar -xzvf ... # 解壓命令

./configure --prefix=/home/study/php # 安裝至某個路徑，提前安裝gcc等
make # 編譯
make install # 安裝

????源碼執行文件放在：bin目錄下

php -m  # 查看 PHP 安裝的擴展

1.1.2 簡化PHP執行命令

????alias 命令=命令的絕對路徑

vim /.bash_profile
alias php=/home/work/soft/php/bin/php # 添加
source /.bash_profile # 注意

????source FileName
????作用:在當前bash環境下讀取并執行FileName中的命令。????用于重新執行剛修改的初始化文檔，如 .bash_profile 和 .profile 等等
????注：該命令通常用命令“.”來替代
????如：source /etc/profile 與 . /etc/profile是等效的

php -i | grep php.ini # 查找PHP的配置文件

1.2 Swoole源碼編譯安裝

獲取swoole源碼：https://gitee.com/swoole/swoole.git

phpize是用來擴展php模塊的，通過phpize可以建立php的外掛模塊,解決沒有configure問題

/usr/local/php/bin/phpize # 在需要執行的目錄執行這行代碼即可
./configure --with-php-config=/usr/local/php/bin/php-config

 make
 make install

????最后可以在PHP的擴展目錄中看見swoole.so 擴展文件

????

1.3 雙劍合璧，PHP7支持swoole

????在php.ini文件中添加：extension=swoole.so
????查看是否添加成功：php -m

????在swoole/examples/server下執行php echo.php
????查看是否執行端口：9501

netstat -anp|grep 9501

二、玩轉網絡通信引擎(非常重要) 2.1 TCP服務&TCP客戶端 2.1.1 TCP服務

Swoole官網文檔：創建TCP服務器 | 創建UDP服務器

//創建Server對象，監聽 127.0.0.1:9501端口
$serv = new swoole_server("127.0.0.1", 9501);
//swoole_server->set函數用于設置swoole_server運行時的各項參數
$serv->set([
    "worker_num" => 6 , // worker進程數，cpu 1-4倍
    "max_request" => 10000,
]);
/**
 * 監聽連接進入事件
 * $fd 客戶端連接的唯一標示
 * $reactor_id 線程id
 */
$serv->on("connect", function ($serv, $fd, $reactor_id) {
    echo "Client: {$reactor_id} - {$fd}-Connect.
";
});
/**
 * 監聽數據接收事件
 * $reactor_id = $from_id
 */
$serv->on("receive", function ($serv, $fd, $reactor_id, $data) {
    $serv->send($fd, "Server: {$reactor_id} - {$fd}".$data);
});
//監聽連接關閉事件
$serv->on("close", function ($serv, $fd) {
    echo "Client: Close.
";
});
//啟動服務器
$serv->start();

????測試tcp服務器方法：

netstat -anp | grep 9501

通過telnet方式登錄遠程主機:telnet 127.0.0.1 9501

tcp客戶端腳本

????查看當前worker進程數：ps -aft | grep tcp_server.php

????

????Tips：為了保證程序執行的完整性，當修改tcp服務器腳本后最好設置平滑重啟worker進程
????平滑重啟worker進程

2.1.2 TCP客戶端 阿里云服務器巨坑----端口未對外打開！！！websocket連接不上服務器，提示Provisional headers are shown

????

connect("127.0.0.1", 9501)) {
    echo "連接失敗";
    exit;
}

// php cli常量
fwrite(STDOUT, "請輸入消息:");
$msg = trim(fgets(STDIN));

// 發送消息給 tcp server服務器
$client->send($msg);

// 接受來自server 的數據
$result = $client->recv();
echo $result;

2.2 HTTP服務（常用）

????

$http = new swoole_http_server("0.0.0.0", 8811);

//添加測試一：獲取參數并打印出來
//$http->on("request", function ($request, $response) {
//    $response->cookie("singwa","xsssss", time() + 1800);
//    $response->end("sss".json_encode($request->get));
//});
/**
 * https://wiki.swoole.com/wiki/page/783.html
 * 配置靜態文件根目錄，與enable_static_handler配合使用。
 * 設置document_root并設置enable_static_handler為true后，
 * 底層收到Http請求會先判斷document_root路徑下是否存在此文件，
 * 如果存在會直接發送文件內容給客戶端，不再觸發onRequest回調。
 */
$http->set(
    [
        "enable_static_handler" => true,
        "document_root" => "/home/work/hdtocs/swoole_mooc/data",
    ]
);
$http->on("request", function($request, $response) {
    //print_r($request->get);
    $content = [
        "date:" => date("Ymd H:i:s"),
        "get:" => $request->get,
        "post:" => $request->post,
        "header:" => $request->header,
    ];
    swoole_async_writefile(__DIR__."/access.log", json_encode($content).PHP_EOL, function($filename){
        // todo
    }, FILE_APPEND);
    $response->cookie("singwa", "xsssss", time() + 1800);
    $response->end("sss". json_encode($request->get));
});

$http->start();

2.3 WebSocket服務（重點） 2.3.1 基本概述

????WebSocket協議是基于TCP的一種新的網絡協議。它實現了瀏覽器與服務器全雙工（full-duplex）通信--允許服務器主動發送信息給客戶端

????為什么需要WebSocket

缺陷：HTTP的通信只能由客戶端發起

????WebSocket特點

建立在TCP協議之上

性能開銷小通信高效

客戶端可以與任意服務器通信

協議標識符ws wss

持久化網絡通信協議

2.3.2 案例實現 2.3.2.1 服務端實現

????1. 面向過程：procedure_ws_server.php

$server = new swoole_websocket_server("0.0.0.0", 9912);
//配置靜態文件根目錄，可選
$server->set(
    [
        "enable_static_handler" => true,
        "document_root" => "/home/wwwroot/www.lingyuan88.com/public/swoole/data",
    ]
);
//監聽websocket連接打開事件
$server->on("open", "onOpen");
function onOpen($server, $request) {
    print_r($request->fd);
}
// 監聽ws消息事件
$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, "singwa-push-secesss");
});
$server->on("close", function ($ser, $fd) {
    echo "client {$fd} closed
";
});

$server->start();

????2. WebSocket服務優化，基礎類庫面向對象：object_ws_server.php

class Ws {

    CONST HOST = "0.0.0.0";
    CONST PORT = 9912;
    public $ws = null;
    public function __construct() {
        $this->ws = new swoole_websocket_server(self::HOST, self::PORT);
        //配置靜態文件根目錄，可選
        $this->ws->set(
            [
                "enable_static_handler" => true,
                "document_root" => "/home/wwwroot/www.lingyuan88.com/public/swoole/data",
            ]
        );
        $this->ws->on("open", [$this, "onOpen"]);
        $this->ws->on("message", [$this, "onMessage"]);
        $this->ws->on("close", [$this, "onClose"]);

        $this->ws->start();
    }
    /**
     * 監聽ws連接事件
     * @param $ws
     * @param $request
     */
    public function onOpen($ws, $request) {
        print_r($request->fd);
    }
    /**
     * 監聽ws消息事件
     * @param $ws
     * @param $frame
     */
    public function onMessage($ws, $frame) {
        echo "ser-push-message:{$frame->data}
";
        $ws->push($frame->fd, "server-push:".date("Y-m-d H:i:s"));
    }
    /**
     * close
     * @param $ws
     * @param $fd
     */
    public function onClose($ws, $fd) {
        echo "clientid:{$fd}
";
    }
}
$obj = new Ws();

2.3.2.2 客戶端實現

????ws_client.html




  
  


singwa-swoole-ws測試

2.3.2.3 測試

????1. 通過WebSocket靜態文件目錄測試

????

????2. 通過HTTP服務測試

????

2.4 異步Task任務使用（重點）

????使用場景

執行耗時的操作（發送郵件廣播等）

????注意：

投遞異步任務之后程序會繼續往下執行，不會等待任務執行完后再繼續向下執行

class Ws {
    CONST HOST = "0.0.0.0";
    CONST PORT = 9912;
    public $ws = null;
    public function __construct() {
        $this->ws = new swoole_websocket_server(self::HOST, self::PORT);
        $this->ws->set(
            [
                "worker_num" => 2,
                "task_worker_num" => 2,
            ]
        );
        //注冊Server的事件回調函數
        $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);
    }
    /**
     * 監聽ws消息事件
     * @param $ws
     * @param $frame
     */
    public function onMessage($ws, $frame) {
        echo "ser-push-message:{$frame->data}
";
        // todo 10s
        $data = [
            "task" => 1,
            "fd" => $frame->fd,
        ];
        //投遞異步任務
        //注意：程序會繼續往下執行，不會等待任務執行完后再繼續向下執行
        $ws->task($data);
        //客戶端會馬上收到以下信息
        $ws->push($frame->fd, "server-push:".date("Y-m-d H:i:s"));
    }
    /**
     * @param $serv
     * @param $taskId
     * @param $workerId
     * @param $data
     * @return string
     */
    public function onTask($serv, $taskId, $workerId, $data) {
        print_r($data);
        // 耗時場景 10s
        sleep(10);
        return "on task finish"; // 告訴worker，并返回給onFinish的$data
    }
    /**
     * @param $serv
     * @param $taskId
     * @param $data
     */
    public function onFinish($serv, $taskId, $data) {
        echo "taskId:{$taskId}
";
        echo "finish-data-sucess:{$data}
";
    }
    /**
     * close
     * @param $ws
     * @param $fd
     */
    public function onClose($ws, $fd) {
        echo "clientid:{$fd}
";
    }
}
$obj = new Ws();

三、異步非堵塞IO場景 3.1 異步、阻塞和IO模型（務必理解） 3.1.1 同步和異步

????關注的是消息通知機制；

同步：調用發出之后不會立即返回，但一旦返回，則返回最終結果；

異步：調用發出之后，被調用方立即返回消息，但返回的并非最終結果。被調用者通過狀態、通知機制等來通知調用者，或通過回調函數來處理結果；

3.1.2 阻塞(block)和非阻塞(nonblock)

????關注的是調用者等待被調用者返回調用結果時的狀態。

阻塞：調用結果返回之前，調用者會被掛起，調用者只有在得到返回結果之后才能繼續。

非阻塞：調用者在結果返回之前，不會被掛起；

3.1.3 IO模型

blocking IO：阻塞式IO 
nonblocking IO：非阻塞IO
multiplexing IO：多路復用IO 
signal driven IO：事件驅動式IO 
asynchronous IO：異步IO

????真正執行IO過程的階段是內核內存數據拷貝到進程內存中

3.2 Swoole異步毫秒定時器

????異步高精度定時器，粒度為毫秒級

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

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

3.3 異步文件系統IO

????Swoole官網文檔：異步文件系統IO

3.3.1 異步讀

/**
 * 讀取文件
 * __DIR__
 * 文件不存在會返回false
 * 成功打開文件立即返回true
 * 數據讀取完畢后會回調指定的callback函數。
 */
//函數風格
$result = swoole_async_readfile(__DIR__."/1.txt", function($filename, $fileContent) {
    echo "filename:".$filename.PHP_EOL;  // 
 

    echo "content:".$fileContent.PHP_EOL;
});
//命名空間風格
$result = SwooleAsync::readfile(__DIR__."/1.txt", function($filename, $fileContent) {
    echo "filename:".$filename.PHP_EOL;  // 
 

    echo "content:".$fileContent.PHP_EOL;
});
var_dump($result);
echo "start".PHP_EOL;

3.3.2 異步寫（如日志）

$http->on("request", function($request, $response) {
    $content = [
        "date:" => date("Ymd H:i:s"),
        "get:" => $request->get,
        "post:" => $request->post,
        "header:" => $request->header,
    ];
    swoole_async_writefile(__DIR__."/access.log", json_encode($content).PHP_EOL, function($filename){
        // todo
    }, FILE_APPEND);
    $response->end("response：". json_encode($request->get));
});

3.4 異步MySQL詳解

class AsyncMySql {
    /**
     * @var string
     */
    public $dbSource = "";
    /**
     * mysql的配置
     * @var array
     */
    public $dbConfig = [];
    public function __construct() {
        //new swoole_mysql;
        $this->dbSource = new SwooleMysql;

        $this->dbConfig = [
            "host" => "127.0.0.1",
            "port" => 3306,
            "user" => "root",
            "password" => "test",
            "database" => "test",
            "charset" => "utf8",
        ];
    }
    public function update() {}
    public function add() {}
    /**
     * mysql 執行邏輯
     * @param $id
     * @param $username
     * @return bool
     */
    public function execute($id, $username) {
        $this->dbSource->connect($this->dbConfig, function($db, $result) use($id, $username)  {
            echo "mysql-connect".PHP_EOL;
            if($result === false) {
                var_dump($db->connect_error);
                // todo
            }
            $sql = "select * from cmf_user where id=1";
            //$sql = "update test set `username` = "".$username."" where id=".$id;
            // insert into
            // query (add select update delete)
            $db->query($sql, function($db, $result){
                // select => result返回的是 查詢的結果內容
                if($result === false) {
                    // todo
                    var_dump($db->error);
                }elseif($result === true) {// add update delete
                    // todo
                    var_dump($db->affected_rows);
                }else {
                    print_r($result);
                }
                $db->close();
            });

        });
        return true;
    }
}
$obj = new AsyncMySql();
$flag = $obj->execute(1, "singwa-111112");
var_dump($flag).PHP_EOL;
echo "start".PHP_EOL;

????

3.5 異步Redis 3.5.1 環境準備

????swoole使用redis的前置條件

redis服務

hiredis庫

編譯swoole需要加入 -enable-async-redis

????編譯安裝hiredis

使用Redis客戶端，需要安裝hiredis庫,下載hiredis源碼后，執行

make -j
sudo make install
sudo ldconfig

????hiredis下載地址

????啟用異步Redis客戶端

編譯swoole時，在configure指令中加入--enable-async-redis

[root@izwz93ee3z8wdxsujiec2oz swoole]# ./configure --with-php-config=/usr/local/php/bin/php-config --enable-async-redis
make clean
make -j
sudo make install

????查看PHP的swoole擴展：php -m
????查看hiredis是否編譯安裝成功：php --ri swoole

3.5.2 代碼測試

$redisClient = new swoole_redis;// SwooleRedis
$redisClient->connect("127.0.0.1", 6379, function(swoole_redis $redisClient, $result) {
    echo "connect".PHP_EOL;
    var_dump($result);

    // 同步 redis (new Redis())->set("key",2);
    /*$redisClient->set("singwa_1", time(), function(swoole_redis $redisClient, $result) {
        var_dump($result);
    });*/

    /*$redisClient->get("singwa_1", function(swoole_redis $redisClient, $result) {
        var_dump($result);
        $redisClient->close();
    });*/
    $redisClient->keys("*gw*", function(swoole_redis $redisClient, $result) {
        var_dump($result);
        $redisClient->close();
    });

});
echo "start".PHP_EOL;

下一篇：Swoole入門到實戰（二）：進程，內存和協程、Swoole完美支持ThinkPHP5、分發Task異步任務機制實現

參考教程：韓天峰力薦 Swoole入門到實戰打造高性能賽事直播平臺

GPU云服務器云服務器異步非堵塞io Swoole swoole+websocket php_swoole

文章版權歸作者所有，未經允許請勿轉載,若此文章存在違規行為，您可以聯系管理員刪除。

轉載請注明本文地址：http://specialneedsforspecialkids.com/yun/28681.html

Swoole 初探：環境搭建與入門案例

摘要：對于這一問題企業一般多會采用其他技術，比如使用或者其他語言。但是有了之后，由于底層全是用語言實現，其出色的性能深受追捧。由于以前適用場景的局限性比較大，所以會有說重新定義了的說法。到這里的環境已經搭建完成了。 Swoole 是一個 php 的擴展，它的核心目標就是解決 php 在實現一些高訪問 server 服務中可能遇到的一系列問題，這些問題用原生的 php 往往并不能很方便高效的解...

toddmark 2019-07-01 10:48 評論0 收藏0
Swoole筆記（一）

摘要：修復添加超過萬個以上定時器時發生崩潰的問題增加模塊，下高性能序列化庫修復監聽端口設置無效的問題等。線程來處理網絡事件輪詢，讀取數據。當的三次握手成功了以后，由這個線程將連接成功的消息告訴進程，再由進程轉交給進程。此時進程觸發事件。本文示例代碼詳見：https://github.com/52fhy/swoo...。簡介 Swoole是一個PHP擴展，提供了PHP語言的異步多線程服務器...

SHERlocked93 2019-06-27 16:41 評論0 收藏0
2017年PHP程序員未來路在何方

摘要：目前來看等語言還難以企及和。作為一個資深的開發者，在技術上給各位程序十點未來的建議，希望對大家有所幫助。開發者應當學習掌握規范，在開發程序時應當盡量遵循規范。程序員除了寫后臺程序之外，還有很大一部分工作在展現層，和瀏覽器前端打交道。 PHP 從誕生到現在已經有20多年歷史，從Web時代興起到移動互聯網退潮，互聯網領域各種編程語言和技術層出不窮， Node.js 、 GO 、 Pytho...

william 2019-06-27 15:55 評論0 收藏0
PHP小知識點

摘要：那些瑣碎的知識點作者記錄的的很奇特很難記的知識點。易錯知識點整理注意和的區別中和都是輸出的作用，但是兩者之間還是有細微的差別。今天手頭不忙，總結一下，分享過程中掌握的知識點。深入理解 PHP 之：Nginx 與 FPM 的工作機制這篇文章從 Nginx 與 FPM 的工作機制出發，探討配置背后的原理，讓我們真正理解 Nginx 與 PHP 是如何協同工作的。 PHP 那些瑣碎的知識...

hover_lew 2019-06-28 14:35 評論0 收藏0