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);
        //配置靜態(tài)文件根目錄，可選
        $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();
    }
    /**
     * 監(jiān)聽ws連接事件
     * @param $ws
     * @param $request
     */
    public function onOpen($ws, $request) {
        print_r($request->fd);
    }
    /**
     * 監(jiān)聽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();

????ws_client.html

  
  


singwa-swoole-ws測試
  

????1. 通過WebSocket靜態(tài)文件目錄測試

????

????2. 通過HTTP服務(wù)測試

????

????使用場景

執(zhí)行耗時的操作（發(fā)送郵件 廣播等）

????注意：

投遞異步任務(wù)之后程序會繼續(xù)往下執(zhí)行，不會等待任務(wù)執(zhí)行完后再繼續(xù)向下執(zhí)行

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的事件回調(diào)函數(shù)
        $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();
    }
    /**
     * 監(jiān)聽ws連接事件
     * @param $ws
     * @param $request
     */
    public function onOpen($ws, $request) {
        var_dump($request->fd);
    }
    /**
     * 監(jiān)聽ws消息事件
     * @param $ws
     * @param $frame
     */
    public function onMessage($ws, $frame) {
        echo "ser-push-message:{$frame->data}
";
        // todo 10s
        $data = [
            "task" => 1,
            "fd" => $frame->fd,
        ];
        //投遞異步任務(wù)
        //注意：程序會繼續(xù)往下執(zhí)行，不會等待任務(wù)執(zhí)行完后再繼續(xù)向下執(zhí)行
        $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();

????關(guān)注的是消息通知機制；

同步：調(diào)用發(fā)出之后不會立即返回，但一旦返回，則返回最終結(jié)果；
異步：調(diào)用發(fā)出之后，被調(diào)用方立即返回消息，但返回的并非最終結(jié)果。被調(diào)用者通過狀態(tài)、通知機制等來通知調(diào)用者，或通過回調(diào)函數(shù)來處理結(jié)果；

????關(guān)注的是調(diào)用者等待被調(diào)用者返回調(diào)用結(jié)果時的狀態(tài)。

阻塞：調(diào)用結(jié)果返回之前，調(diào)用者會被掛起，調(diào)用者只有在得到返回結(jié)果之后才能繼續(xù)。 
非阻塞：調(diào)用者在結(jié)果返回之前，不會被掛起；

blocking IO：阻塞式IO 
nonblocking IO：非阻塞IO
multiplexing IO：多路復(fù)用IO 
signal driven IO：事件驅(qū)動式IO 
asynchronous IO：異步IO 

????真正執(zhí)行IO過程的階段是內(nèi)核內(nèi)存數(shù)據(jù)拷貝到進程內(nèi)存中

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

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

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

????Swoole官網(wǎng)文檔：異步文件系統(tǒng)IO

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

    echo "content:".$fileContent.PHP_EOL;
});
//命名空間風(fēng)格
$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;

$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));
});

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 執(zhí)行邏輯
     * @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返回的是 查詢的結(jié)果內(nèi)容
                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;

????

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

redis服務(wù)

hiredis庫

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

????編譯安裝hiredis

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

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

$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入門到實戰(zhàn)打造高性能賽事直播平臺