Swoole HTTP 的應用

来源:https://www.cnblogs.com/it-3327/archive/2019/11/07/11815835.html
-Advertisement-
Play Games

我們都知道 HTTP 是一種協議,允許 WEB 伺服器和瀏覽器通過互聯網進行發送和接受數據。想對 HTTP 進行詳細的瞭解,可以找下其他文章,這篇文章不多做介紹。我們在網上能看到的界面,圖片,動畫,音頻,視頻 等,都有依賴這個協議的。在做 WEB 系統的時候,都使用過 IIS、Apache、Ngin ...


我們都知道 HTTP 是一種協議,允許 WEB 伺服器和瀏覽器通過互聯網進行發送和接受數據。

想對 HTTP 進行詳細的瞭解,可以找下其他文章,這篇文章不多做介紹。

我們在網上能看到的界面,圖片,動畫,音頻,視頻 等,都有依賴這個協議的。

在做 WEB 系統的時候,都使用過 IIS、Apache、Nginx 吧,我們利用 Swoole 也可以 簡單的實現一個 WEB 伺服器。

主要使用了 HTTP 的兩大對象:Request 請求對象、Response 響應對象。

Request,包括 GET、POST、COOKIE、Header等。

Response,包括 狀態、響應體、跳轉、發送文件等。

不多說,先分享兩個程式:

    一、實現一個基礎的 Demo:“你好,Swoole.”

    二、實現一個簡單的 路由控制

本地版本:

    PHP 7.2.6

    Swoole 4.3.1

代碼

一、Demo:“你好,Swoole.”

示例效果:



備註:IP 地址是我的虛擬機。

示例代碼:

 

   <?php    
    class Server    
    {    
        private $serv;    
        public function __construct() {    
            $this->serv = new swoole_http_server("0.0.0.0", 9502);    
            $this->serv->set([    
                'worker_num'      => 2, //開啟2個worker進程    
                'max_request'     => 4, //每個worker進程 max_request設置為4次    
                'daemonize'       => false, //守護進程(true/false)    
            ]);    
            $this->serv->on('Start', [$this, 'onStart']);    
            $this->serv->on('WorkerStart', [$this, 'onWorkStart']);    
            $this->serv->on('ManagerStart', [$this, 'onManagerStart']);    
            $this->serv->on("Request", [$this, 'onRequest']);    
            $this->serv->start();    
        }    
        public function onStart($serv) {    
            echo "#### onStart ####".PHP_EOL;    
            echo "SWOOLE ".SWOOLE_VERSION . " 服務已啟動".PHP_EOL;    
            echo "master_pid: {$serv->master_pid}".PHP_EOL;    
            echo "manager_pid: {$serv->manager_pid}".PHP_EOL;    
            echo "########".PHP_EOL.PHP_EOL;    
        }    
        public function onManagerStart($serv) {    
            echo "#### onManagerStart ####".PHP_EOL.PHP_EOL;    
        }    
        public function onWorkStart($serv, $worker_id) {    
            echo "#### onWorkStart ####".PHP_EOL.PHP_EOL;    
        }    
        public function onRequest($request, $response) {    
            $response->header("Content-Type", "text/html; charset=utf-8");    
            $html = "<h1>你好 Swoole.</h1>";    
            $response->end($html);    
        }    
    }    
    $server = new Server();

 

這裡我還準備了一分學習圖和資料,如下:

鏈接:https://pan.baidu.com/s/1v5gm7n0L7TGyejCmQrMh2g 提取碼:x2p5

免費分享,但是X度限制嚴重,如若鏈接失效點擊鏈接或搜索加群 群號518475424



二、路由控制

示例效果:



目錄結構:

    ├─ swoole_http  -- 代碼根目錄    
    │  ├─ server.php    
    │  ├─ controller    
    │     ├── Index.php    
    │     ├── Login.php

示例代碼:

server.php

    <?php    
    class Server    
    {    
        private $serv;    
        public function __construct() {    
            $this->serv = new swoole_http_server("0.0.0.0", 9501);    
            $this->serv->set([    
                'worker_num'      => 2, //開啟2個worker進程    
                'max_request'     => 4, //每個worker進程 max_request設置為4次    
                'document_root'   => '',    
                'enable_static_handler' => true,    
                'daemonize'       => false, //守護進程(true/false)    
            ]);    
            $this->serv->on('Start', [$this, 'onStart']);    
            $this->serv->on('WorkerStart', [$this, 'onWorkStart']);    
            $this->serv->on('ManagerStart', [$this, 'onManagerStart']);    
            $this->serv->on("Request", [$this, 'onRequest']);    
            $this->serv->start();    
        }    
        public function onStart($serv) {    
            echo "#### onStart ####".PHP_EOL;    
            swoole_set_process_name('swoole_process_server_master');    
            echo "SWOOLE ".SWOOLE_VERSION . " 服務已啟動".PHP_EOL;    
            echo "master_pid: {$serv->master_pid}".PHP_EOL;    
            echo "manager_pid: {$serv->manager_pid}".PHP_EOL;    
            echo "########".PHP_EOL.PHP_EOL;    
        }    
        public function onManagerStart($serv) {    
            echo "#### onManagerStart ####".PHP_EOL.PHP_EOL;    
            swoole_set_process_name('swoole_process_server_manager');    
        }    
        public function onWorkStart($serv, $worker_id) {    
            echo "#### onWorkStart ####".PHP_EOL.PHP_EOL;    
            swoole_set_process_name('swoole_process_server_worker');    
            spl_autoload_register(function ($className) {    
                $classPath = __DIR__ . "/controller/" . $className . ".php";    
                if (is_file($classPath)) {    
                    require "{$classPath}";    
                    return;    
                }    
            });    
        }    
        public function onRequest($request, $response) {    
            $response->header("Server", "SwooleServer");    
            $response->header("Content-Type", "text/html; charset=utf-8");    
            $server = $request->server;    
            $path_info    = $server['path_info'];    
            $request_uri  = $server['request_uri'];    
            if ($path_info == '/favicon.ico' || $request_uri == '/favicon.ico') {    
                return $response->end();    
            }    
            $controller = 'Index';    
            $method     = 'home';    
            if ($path_info != '/') {    
                $path_info = explode('/',$path_info);    
                if (!is_array($path_info)) {    
                    $response->status(404);    
                    $response->end('URL不存在');    
                }    
                if ($path_info[1] == 'favicon.ico') {    
                    return;    
                }    
                $count_path_info = count($path_info);    
                if ($count_path_info > 4) {    
                    $response->status(404);    
                    $response->end('URL不存在');    
                }    
                $controller = (isset($path_info[1]) && !empty($path_info[1])) ? $path_info[1] : $controller;    
                $method = (isset($path_info[2]) && !empty($path_info[2])) ? $path_info[2] : $method;    
            }    
            $result = "class 不存在";    
            if (class_exists($controller)) {    
                $class = new $controller();    
                $result = "method 不存在";    
                if (method_exists($controller, $method)) {    
                    $result = $class->$method($request);    
                }    
            }    
            $response->end($result);    
        }    
    }    
    $server = new Server();

Index.php

    <?php    
    class Index    
    {    
        public function home($request)    
        {    
            $get = isset($request->get) ? $request->get : [];    
            //@TODO 業務代碼    
            $result = "<h1>你好,Swoole。</h1>";    
            $result.= "GET參數:".json_encode($get);    
            return $result;    
        }    
    }

Login.php

    <?php    
    class Login    
    {    
        public function index($request)    
        {    
            $post = isset($request->post) ? $request->post : [];    
            //@TODO 業務代碼    
            return "<h1>登錄成功。</h1>";    
        }    
    }

 


小結

一、Swoole 可以替代 Nginx 嗎?

暫時不能,隨著 Swoole 越來越強大,以後說不准。

官方建議 Swoole 與 Nginx 結合使用。

    Http\Server 對 Http 協議的支持並不完整,建議僅作為應用伺服器。並且在前端增加Nginx作為代理。

根據自己的 Nginx 配置文件,可以自行調整。

比如:可以新增一個配置文件

enable-swoole-php.conf

    location ~ [^/]\.php(/|$)    
    {    
        proxy_http_version 1.1;    
        proxy_set_header Connection "keep-alive";    
        proxy_set_header X-Real-IP $remote_addr;    
        proxy_pass http://127.0.0.1:9501;    
    }

 


我們都習慣於將虛擬功能變數名稱的配置文件放在 vhost 文件夾中。

比如,虛擬功能變數名稱的配置文件為:local.swoole.com.conf,可以選擇載入 enable-php.conf ,也可以選擇載入 enable-swoole-php.conf。

配置文件供參考:

 

   server    
        {    
            listen 80;    
            #listen [::]:80;    
            server_name local.swoole.com ;    
            index index.html index.htm index.php default.html default.htm default.php;    
            root  /home/wwwroot/project/swoole;    
            #include rewrite/none.conf;    
            #error_page   404   /404.html;    
            #include enable-php.conf;    
            include enable-swoole-php.conf;    
            location ~ .*\.(gif|jpg|jpeg|png|bmp|swf)$    
            {    
                expires      30d;    
            }    
            location ~ .*\.(js|css)?$    
            {    
                expires      12h;    
            }    
            location ~ /.well-known {    
                allow all;    
            }    
            location ~ /\.    
            {    
                deny all;    
            }    
            access_log  /home/wwwlogs/local.swoole.com.log;    
        }

 



當前,我們直接編輯 server 段的代碼也是可以的。

二、修改了 controller 文件夾中的業務代碼,每次都是重啟服務才生效嗎?

不是,每次重啟服務可能會影響到正常用戶使用的,正常處理的請求會被強制關閉。

在本地運行 路由控制 的代碼時,試試這個命令:

ps aux | grep swoole_process_server_master | awk '{print $2}' | xargs kill -USR1

給 master 進程發送一個 USR1 的信號,當 Swoole Server 接到這個信號後,就會讓所有 worker 在處理完當前的請求後,進行重啟。

如果查看所有的進程,試試這個命令:

ps -ef | grep 'swoole_process_server' | grep -v 'grep'


擴展

    可以試著上傳文件,做一個小的FTP伺服器。

    可以學習 Swoole 開源框架:EasySwoole、Swoft、One。

    可以將 Swoole 整合到目前正在使用的PHP框架中。


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • Python繪圖庫Turtle Turtle介紹 Turtle是Python內嵌的繪製線、圓以及其他形狀(包括文本)的圖形模塊。 一個Turtle實際上是一個對象,在導入Turtle模塊時,就創建了對象,然後,可以調用Turtle對象的各種方法完成不同的操作。 當創建一個Turtle對象時,它的位置 ...
  • 寫在前面的話 適用讀者:有一定經驗的,本文不適合初學者,因為可能不能理解我在說什麼 文章思路:不會一開始就像別的博客文章那樣,Bean 的生命周期,源碼解讀(給你貼一大堆的源碼)。個人覺得應該由問題驅動,為什麼為出現 BeanFactory ,為什麼會有生命周期。 正文 一開始我們使用 bean 都 ...
  • 1、Eureka服務端集群開發 1、先創建一個父工程 若是不是普通demo,還有別的配置時,需要註意若是服務開不起來可能就是父類依賴中可能會需要<dependencyManagement>這個標簽。 2、再創建兩個子工程 1、導入依賴 <dependency> <groupId>org.spring ...
  • 1 簡介 我們知道 只是一個介面,它有多種實現,Java中最常用的是 了。而本文想講述的是另一個實現: 。它是枚舉類型的 ,要求它的Key值都必須是枚舉型的。 2 創建你的EnumMap 既然是關於枚舉類型的Map,我們先創建一個枚舉,以便後續使用: 2.1 創建EnumMap的三種方法 JDK提供 ...
  • 1. lamda匿名函數 為瞭解決⼀些簡單的需求⽽設計的⼀句話函數 # 計算n的n次⽅ def func(n): return n**n print(func(10)) f = lambda n: n**n print(f(10)) lambda表⽰的是匿名函數,不需要⽤def來聲明,⼀句話就可以聲 ...
  • 調優基本概念 在調整JVM性能時,通常有三個組件需要考慮: 堆大小調整 垃圾收集器調整 JIT編譯器 大多數調優選項都與調整堆大小和選擇合適的垃圾收集器有關,JIT編譯器對性能也有很大影響,但很少需要對其進行調優,尤其是針對較新版本的JVM。 通常,在進行Java程式調優的時候,會重點關註兩個主要指 ...
  • 這篇文章主要分享 Timer 毫秒精度的定時器。本地版本:PHP 7.2.6、Swoole 4.3.1。Timer主要有三個方法:swoole_timer_tick 間隔的時鐘控制器swoole_timer_after 指定的時間後執行swoole_timer_clear 刪除定時器示例代碼:運行結 ...
  • 包裝 1.二次加工標準類型(包裝) class List(list): def append(self, a_objcet): if type(a_objcet) is str: super().append(a_objcet) else: print('請傳入字元轉類型') l1 = List(' ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...