初識 swoole【下】

yeooo 發布于2019-07-01 11:06 / 1998人閱讀

摘要：前言接初識上，這篇主要是異步問題有收獲的話請加顆小星星，沒有收獲的話可以反對沒有幫助舉報三連代碼倉庫初識下異步任務設置異步任務的工作進程數量連接連接歡迎大山驢回調投遞異步任務觸發異步任務服務端回復說處理異步任務新的異步任務

前言：接初識swoole【上】，這篇主要是異步問題

有收獲的話請加顆小星星，沒有收獲的話可以反對 沒有幫助 舉報三連

代碼倉庫

初識swoole【下】

6、異步任務

set(["task_worker_num" => 4]);
// connect 連接
$server->on("connect", function (swoole_server $server, $fd) {
    dump("{$fd}連接");
    $server->send($fd, "歡迎{$fd}大山驢
");
});
// receive 回調
$server->on("receive", function (swoole_server $server, $fd, $from_id, $data) {
    //投遞異步任務
    $task_id = $server->task($data);
    dump("觸發異步任務ID={$task_id}");
    $server->send($fd, "服務端回復:{$data}
");
    foreach ($server->connections as $connection) {
        if ($connection != $fd){
            $server->send($connection, "{$fd}說{$data}");
        }
    }
});
// task 處理異步任務
$server->on("task", function (swoole_server $server, $task_id, $from_id, $data){
    dump("新的異步任務[ID={$task_id}]");
    //返回任務執行的結果
    $server->finish("{$data}完成了");
});
// finish 處理異步任務的結果
$server->on("finish", function (swoole_server $server, $task_id, $data){
    dump("異步任務[{$task_id}]已經完成[{$data}]");
});
// close
$server->on("close", function (swoole_server $server, $fd) {
    dump("{$fd}關閉");
    foreach ($server->connections as $connection) {
        if ($connection != $fd){
            $server->send($connection, "{$fd}斷開連接");
        }
    }
});
// start
$server->start();

php async.php

telnet 127.0.0.1 9505

7、同步TCP客戶端

connect(HOST, 9501, 0.5)){
    dump("連接失敗");
}
// send
if (! $client->send("你個山驢逼
")) {
    dump("發送失敗");
}
// receive
if (! $data = $client->recv()) {
    dump("接收失敗");
}
dump($data);
// close
$client->close();

php tcp_server.php

php tcp_sync_client.php

8、異步TCP客戶端

on("connect", function (SwooleClient $cli){
    $cli->send("你個山驢逼
");
});
// receive
$client->on("receive", function (SwooleClient $cli, $data){
    dump("接收：{$data}");
});
// error
$client->on("error", function (SwooleClient $cli){
    dump("連接失敗");
});
// close
$client->on("close", function (SwooleClient $cli){
    dump("連接關閉");
});
$client->connect(HOST, 9501, 0.5);

php tcp_server.php

php tcp_async_client.php

9、異步客戶端

mysql

// 異步mysql客戶端
$db = new SwooleMysql();
$config = [
    "host" => "127.0.0.1",
    "user" => "root",
    "password" => "root",
    "database" => "mac",
    "port" => "3307",
];

$db->connect($config, function (SwooleMysql $db, $rs) {
    $db->query("SELECT * FROM user", function (SwooleMysql $db, $rs) {
        dump($rs);
        $db->close();
    });
});

http

// 異步http客戶端
$cli = new SwooleHttpClient("127.0.0.1", 80);
$cli->setHeaders(array("User-Agent" => "swoole-http-client"));
$cli->setCookies(array("test" => "value"));

$cli->get("/login", function (SwooleHttpClient $cli) {
    dump($cli->statusCode);
    dump($cli->cookies);
    dump($cli->headers);
});

10、協程客戶端

// 協程mysql客戶端
$http = new swoole_http_server(HOST, 9506);
$http->on("request", function ($request, $response) {
    $db = new SwooleCoroutineMysql();
    $db->connect([
        "host" => "127.0.0.1",
        "user" => "root",
        "password" => "root",
        "database" => "mac",
        "port" => "3307",
    ]);
    $data = $db->query("select * from user");
    dump($data);
    $response->end(json_encode($data));
});
$http->start();

php coroutine_client.php

curl -XGET "127.0.0.1:9506"

GPU云服務器云服務器 docker初識初識關系數據庫 Swoole swoole+websocket

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

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

Swoole學習手記（一）初識Swoole

摘要：目錄初識創建服務器上創建服務器下異步任務持續更新中。。。參加工作有一段時間了，偶爾會聽到，對我這種小白粗略看下文檔都會覺得很牛逼。個人理解就是解決這樣應用場景的。目錄初識Swoole 創建服務器(上) 創建服務器(下) 異步任務task 持續更新中。。。參加工作有一段時間了，偶爾會聽到swoole，對我這種PHP小白粗略看下文檔都會覺得很牛逼。由于學習成本比較高，自身對網絡異...

yeyan1996 2019-06-28 18:47 評論0 收藏0
初識 swoole【上】

摘要：前言都是為了生存有收獲的話請加顆小星星，沒有收獲的話可以反對沒有幫助舉報三連代碼倉庫初始上一什么是面向生產環境的異步網絡通信引擎使開發人員可以編寫高性能的異步并發，服務。前言：都是為了生存有收獲的話請加顆小星星，沒有收獲的話可以反對沒有幫助舉報三連代碼倉庫初始swoole【上】一、什么是swoole Swoole：面向生產環境的 PHP 異步網絡通信引擎使 PHP...

scola666 2019-07-01 11:06 評論0 收藏0
swoole入門4-初識swoole

摘要：當某種網絡事件發生時，會回調用戶設置的指定回調函數。承擔了底層網絡事件的監聽及各種底層事件處理，當收到請求時，會觸發事件提醒，然后將控制權轉交預先注冊的事件回調函數，來進行后續的處理。請求到來時創建，請求結束后銷毀。運行流程圖 showImg(https://segmentfault.com/img/remote/1460000017207791);showImg(https://s...

forsigner 2019-07-01 11:00 評論0 收藏0
【宇潤日常瘋測-007】Swoole 協程與傳統 fpm 同步模式比較

摘要：初識協程執行結果協程與同步模式比較我們一直在說協程適合用于密集場景，在同樣的硬件配置環境下，它會比傳統的同步模式承載更多的訪問量。假設一次查詢為，在傳統同步模式下，當前進程在這的時間里，是不能做其它操作的。同步模式，耗費左右的是。如果說數組是 PHP 的精髓，數組玩得不6的，根本不能算是會用PHP。那協程對于 Swoole 也是同理，不理解協程去用 Swoole，那就是在瞎用。首先...

henry14 2019-07-01 12:39 評論0 收藏0
swoole學習手記（三）創建服務器(下)

摘要：目錄初識創建服務器上創建服務器下異步任務持續更新中。。。而它的最大特點就是，服務器可以主動向客戶端推送信息，客戶端也可以主動向服務器發送信息，是真正的雙向平等對話，屬于服務器推送技術的一種。目錄初識Swoole 創建服務器(上) 創建服務器(下) 異步任務task 持續更新中。。。 1.創建HttpServer服務器 HttpServer是基于swoole_server，所以s...

aikin 2019-06-28 18:47 評論0 收藏0