2. 程式人生 > >Swoole 整合成一個小框架

Swoole 整合成一個小框架

阿新 • • 發佈：2019-05-15

目錄

  • 概述
  • 效果
  • 程式碼
  • 小結

概述

這是關於 Swoole 學習的第六篇文章：Swoole 整合成一個小框架。

  • 第五篇：Swoole 多協議 多埠 的應用
  • 第四篇：Swoole HTTP 的應用
  • 第三篇：Swoole WebSocket 的應用
  • 第二篇：Swoole Task 的應用
  • 第一篇：Swoole Timer 的應用

寫了關於 Swoole 入門的 5 篇文章後，增加了不少的關注者，也得到了一些大佬的鼓勵，也有很多關注者都加了微信好友，交流之後發現一些朋友比我優秀還比我努力，也得到了一些大佬的建議。

發現持續寫文章真的不是件容易的事，擔心別人認為沒價值，擔心想法太幼稚或有漏洞被別人笑話，擔心肚子裡墨水太少，寫不出來... 知道自己思路還不夠清晰，邏輯還不夠嚴謹，告訴自己沒關係，一些都會好起來的，逆境才能成長嘛，敢寫就是好的開始，以此來激勵自己持續的學習和思考。

跑題了，說回正題。

這篇文章其實是讀者的小小要求，事情是這樣的：

讀者：“亮哥，看了你的文章很有收穫，將文章 Demo 放在本地直接就能運行了，太感謝了”

本人：“哈哈。。。有收穫就好，感謝支援 ~ ”

讀者：“我有一個小小的要求，現在每個檔案都是獨立的，我想部署到生產環境，想操作上更便捷，有日誌...”

本人：“你說的不是框架嗎？現在有很多現成的，看 Swoole 官網推薦的 Swoft、EasySwoole、MixPHP 等。詳細的參考這個地址：https://wiki.swoole.com/wiki/page/p-open_source.html”

讀者：“看了，發現檔案太多了，看不懂，你能幫忙講解下嗎？”

本人：“What？我也是入門呀，要不我搞個簡單的輪子吧”

......

於是就有了這篇文章，正好也是對前面 5 篇文章的複習吧。

效果


命令如下：

  • php index.php 可以檢視到上圖
  • php index.php start 開啟服務（Debug模式）
  • php index.php start -d 開啟服務（Daemon模式）
  • php index.php status 檢視服務狀態
  • php index.php reload 服務熱載入
  • php index.php stop 關閉服務

index.php 這是檔名稱，大家叫什麼都可以。

目錄結構如下：

├─ controller
│     ├── ...
├─ client
│  ├─ websocket
│     ├── ...
│  ├─ tcp
│     ├── ...
├─ server
│  ├─ config
│     ├── config.php
│  ├─ core
│     ├── Common.php
│     ├── Core.php
│     ├── HandlerException.php
│  ├─ log  -- 需要 讀/寫 許可權
│     ├── ...
├─ index.php

目前就這幾個檔案，後期研究新的知識點會直接整合到這裡面。

說說實現了什麼：

1、啟動了 WebSocket、HTTP、TCP、UDP 等服務。

2、WebSocket 例子，在 client/websocket 資料夾，實現了視訊彈幕。

3、HTTP 例子，在瀏覽器直接訪問：http://ip:port，邏輯程式碼在 controller 資料夾。

4、TCP 例子，在 client/tcp 資料夾。

5、UDP 例子，直接執行 netcat -u ip port 即可。

6、相關配置，在 server/config 資料夾。

程式碼

放不全，就放一個主要的檔案吧（Core.php）。

<?php

if (!defined('SERVER_PATH')) exit("No Access");

class Core
{
    private static $serv;

    public function __construct() {
        set_error_handler(['HandlerException', 'appError']);
        register_shutdown_function(['HandlerException', 'fatalError']);
    }

    public static function run() {
        static::checkCli();
        static::checkExtension();
        static::showUsageUI();
        static::parseCommand();
    }

    protected static function checkCli() {
        if (php_sapi_name() !== 'cli') {
            exit(output('服務只能執行在 cli sapi 模式下'));
        }
    }

    protected static function checkExtension() {
        if (!extension_loaded('swoole')) {
            exit(output('請安裝 swoole 擴充套件'));
        }
    }

    protected static function showUsageUI() {
        global $argc;
        if ($argc <= 1 || $argc >3) {
            echo PHP_EOL;
            echo "----------------------------------------".PHP_EOL;
            echo "|               Swoole                 |".PHP_EOL;
            echo "|--------------------------------------|".PHP_EOL;
            echo '|    USAGE: php index.php commond      |'.PHP_EOL;
            echo '|--------------------------------------|'.PHP_EOL;
            echo '|    1. start    以debug模式開啟服務   |'.PHP_EOL;
            echo '|    2. start -d 以daemon模式開啟服務  |'.PHP_EOL;
            echo '|    3. status   檢視服務狀態          |'.PHP_EOL;
            echo '|    4. reload   熱載入                |'.PHP_EOL;
            echo '|    5. stop     關閉服務              |'.PHP_EOL;
            echo "----------------------------------------".PHP_EOL;
            echo PHP_EOL;
            exit;
        }
    }

    protected static function parseCommand() {
        global $argv;
        $command = $argv[1];
        $option  = isset( $argv[2] ) ? $argv[2] : '' ;
        switch ($command) {
            case 'start':
                if ($option === '-d') { //以daemon形式啟動
                    get_config(['set@daemonize' => true]);
                }
                self::workerStart();
                break;
            case 'status':
                self::workerStatus();
                break;
            case 'reload':
                self::workerReload();
                break;
            case 'stop':
                self::workerStop();
                break;
            default:
                echo "Bad Command.".PHP_EOL;
        }
    }

    protected static function workerStart() {
        $config = get_config();

        self::$serv = new swoole_websocket_server($config['ip'], $config['websocket_port']);
        self::$serv->set($config['set']);
        self::$serv->on('Start', function ($serv) use ($config) {
            $start = new OnStart();
            $start::run($serv, $config);
        });

        self::$serv->on('ManagerStart', function ($serv) use ($config) {
            $manager_start = new OnManagerStart();
            $manager_start::run($serv, $config);
        });

        self::$serv->on('WorkerStart', function ($serv, $worker_id) use ($config) {
            $worker_start = new OnWorkerStart();
            $worker_start::run($serv, $worker_id, $config);
        });

        //TCP
        $tcp = self::$serv->listen($config['ip'], $config['tcp_port'], SWOOLE_SOCK_TCP);
        $tcp->set($config['tcp_set']);
        $tcp->on('Receive', function ($serv, $fd, $reactor_id, $data) {
            $receive = new OnReceive();
            $receive::run($serv, $fd, $reactor_id, $data);
        });

        //UDP
        $udp = self::$serv->listen($config['ip'], $config['udp_port'], SWOOLE_SOCK_UDP);
        $udp->set($config['udp_set']);
        $udp->on('Packet', function ($serv, $data, $client_info) {
            $packet = new OnPacket();
            $packet::run($serv, $data, $client_info);
        });

        self::$serv->on('Task', function ($serv, $task_id, $src_worker_id, $data) use ($config) {
            $task = new OnTask();
            $dataArr = json_decode($data, true);
            switch ($dataArr['server']) {
                case "tcp":
                    $task::tcp_task_run($serv, $task_id, $src_worker_id, $data);
                    break;
                case "ws":
                    $task::ws_task_run($serv, $task_id, $src_worker_id, $data);
                    break;
            }
        });

        self::$serv->on('Open', function ($serv, $request) {
            echo output("onOpen: handshake success with fd={$request->fd}");
        });

        self::$serv->on('Message', function ($serv, $frame) {
            $message = new OnMessage();
            $message::run($serv, $frame);
        });

        self::$serv->on('Request', function ($request, $response) {
            $req = new OnRequest();
            $req::run($request, $response);
        });

        self::$serv->on('Finish', function ($serv, $task_id, $data) {
            $finish = new OnFinish();
            $finish::run($serv, $task_id, $data);
        });

        self::$serv->on('Close', function ($serv, $fd, $reactor_id){
            try {
                echo output('客戶端關閉');
            } catch(Exception $e) {
            }
        });

        self::$serv->on('Shutdown', function ($serv) {
           echo output("服務關閉");
        });

        self::showProcessUI();

        self::$serv->start();
    }

    protected static function workerStatus() {
        $config = get_config();

        if (!file_exists($config['master_pid_file']) ||
            !file_exists($config['manager_pid_file']) ||
            !file_exists($config['worker_pid_file']) ) {
            echo output("暫無啟動的服務");
            return false;
        }

        self::showProcessUI($config);

        $masterPidString = trim(@file_get_contents($config['master_pid_file']));
        $masterPidArr    = explode( '-', $masterPidString);

        echo str_pad("Master", 18, ' ', STR_PAD_BOTH ).
            str_pad($config['master_process_name'], 26, ' ', STR_PAD_BOTH ).
            str_pad($masterPidArr[0], 16, ' ', STR_PAD_BOTH ).
            str_pad($masterPidArr[1], 16, ' ', STR_PAD_BOTH ).
            str_pad($masterPidArr[2], 16, ' ', STR_PAD_BOTH ).PHP_EOL;

        $managerPidString = trim(@file_get_contents($config['manager_pid_file']));
        $managerPidArr    = explode( '-', $managerPidString);

        echo str_pad("Manager", 20, ' ', STR_PAD_BOTH ).
            str_pad($config['manager_process_name'], 24, ' ', STR_PAD_BOTH ).
            str_pad($managerPidArr[0], 16, ' ', STR_PAD_BOTH ).
            str_pad($managerPidArr[1], 16, ' ', STR_PAD_BOTH ).
            str_pad($managerPidArr[2], 16, ' ', STR_PAD_BOTH ).PHP_EOL;


        $workerPidString = rtrim(@file_get_contents($config['worker_pid_file']), '|' );
        $workerPidArr    = explode( '|', $workerPidString );
        if (isset($workerPidArr) && !empty($workerPidArr)) {
            foreach ($workerPidArr as $key => $val) {
                $v = explode( '-', $val);
                echo str_pad("Worker", 18, ' ', STR_PAD_BOTH ).
                     str_pad($config['worker_process_name'], 26, ' ', STR_PAD_BOTH ).
                     str_pad($v[0], 16, ' ', STR_PAD_BOTH ).
                     str_pad($v[1], 16, ' ', STR_PAD_BOTH ).
                     str_pad($v[2], 16, ' ', STR_PAD_BOTH ).PHP_EOL;
            }
        }

        $taskPidString = rtrim(@file_get_contents($config['task_pid_file']), '|' );
        $taskPidArr  = explode( '|', $taskPidString );
        if (isset($taskPidArr) && !empty($taskPidArr)) {
            foreach ($taskPidArr as $key => $val) {
                $v = explode( '-', $val);
                echo str_pad("Task", 18, ' ', STR_PAD_BOTH ).
                     str_pad($config['task_process_name'], 24, ' ', STR_PAD_BOTH ).
                     str_pad($v[0], 20, ' ', STR_PAD_BOTH ).
                     str_pad($v[1], 12, ' ', STR_PAD_BOTH ).
                     str_pad($v[2], 20, ' ', STR_PAD_BOTH ).PHP_EOL;
            }
        }
    }

    protected static function workerReload() {
        $config = get_config();

        if (!file_exists($config['master_pid_file'])) {
            echo output("暫無啟動的服務");
            return false;
        }

        $masterPidString = trim(file_get_contents($config['master_pid_file']));
        $masterPidArr    = explode( '-', $masterPidString);

        if (!swoole_process::kill($masterPidArr[0], 0)) {
            echo output("PID:{$masterPidArr[0]} 不存在");
            return false;
        }

        swoole_process::kill($masterPidArr[0], SIGUSR1);

        @unlink($config['worker_pid_file']);
        @unlink($config['task_pid_file']);

        echo output("熱載入成功");
        return true;
    }

    protected static function workerStop() {
        $config = get_config();

        if (!file_exists($config['master_pid_file'])) {
            echo output("暫無啟動的服務");
            return false;
        }

        $masterPidString = trim(file_get_contents($config['master_pid_file']));
        $masterPidArr    = explode( '-', $masterPidString);

        if (!swoole_process::kill($masterPidArr[0], 0)) {
            echo output("PID:{$masterPidArr[0]} 不存在");
            return false;
        }

        swoole_process::kill($masterPidArr[0]);

        $time = time();
        while (true) {
            usleep(2000);
            if (!swoole_process::kill($masterPidArr[0], 0)) {
                unlink($config['master_pid_file']);
                unlink($config['manager_pid_file']);
                unlink($config['worker_pid_file']);
                unlink($config['task_pid_file']);
                echo output("服務關閉成功");
                break;
            } else {
                if (time() - $time > 5) {
                    echo output("服務關閉失敗，請重試");
                    break;
                }
            }
        }
        return true;
    }

    protected static function showProcessUI() {
        $config = get_config();
        if ($config['set']['daemonize'] == true) {
            return false;
        }
        echo str_pad("-", 90, '-', STR_PAD_BOTH) . PHP_EOL;
        echo "|" . str_pad("啟動/關閉", 92, ' ', STR_PAD_BOTH) . "|" . PHP_EOL;
        echo str_pad("-", 90, '-', STR_PAD_BOTH) . PHP_EOL;

        echo str_pad("Start success.", 50, ' ', STR_PAD_BOTH) .
            str_pad("php index.php stop", 50, ' ', STR_PAD_BOTH) . PHP_EOL;

        echo str_pad("-", 90, '-', STR_PAD_BOTH) . PHP_EOL;
        echo "|" . str_pad("版本資訊", 92, ' ', STR_PAD_BOTH) . "|" . PHP_EOL;
        echo str_pad("-", 90, '-', STR_PAD_BOTH) . PHP_EOL;

        echo str_pad("Swoole Version:" . SWOOLE_VERSION, 50, ' ', STR_PAD_BOTH) .
            str_pad("PHP Version:" . PHP_VERSION, 50, ' ', STR_PAD_BOTH) . PHP_EOL;

        echo str_pad("-", 90, '-', STR_PAD_BOTH) . PHP_EOL;
        echo "|" . str_pad("IP 資訊", 90, ' ', STR_PAD_BOTH) . "|" . PHP_EOL;
        echo str_pad("-", 90, '-', STR_PAD_BOTH) . PHP_EOL;

        echo str_pad("IP:" . $config['ip'], 50, ' ', STR_PAD_BOTH) .
            str_pad("PORT:" . $config['websocket_port'], 50, ' ', STR_PAD_BOTH) . PHP_EOL;

        echo str_pad("-", 90, '-', STR_PAD_BOTH) . PHP_EOL;
        echo "|" . str_pad("程序資訊", 92, ' ', STR_PAD_BOTH) . "|" . PHP_EOL;
        echo str_pad("-", 90, '-', STR_PAD_BOTH) . PHP_EOL;

        echo str_pad("Swoole程序", 20, ' ', STR_PAD_BOTH) .
            str_pad('程序別名', 30, ' ', STR_PAD_BOTH) .
            str_pad('程序ID', 18, ' ', STR_PAD_BOTH) .
            str_pad('父程序ID', 18, ' ', STR_PAD_BOTH) .
            str_pad('使用者', 18, ' ', STR_PAD_BOTH) . PHP_EOL;
    }

    protected static function signalHandler() {
        //TODO 未完成
        //swoole_process::signal(SIGINT, function ($signal) {
        //    echo $signal;
        //    return;
        //});
    }
}

小結

耗費了 3 個晚上的時間，終於完成了一個初版，比較初級，希望可以給入門的同學一個參考吧。

當然我自己也會繼續完善它，後期的一些新知識點會整合到這裡面，做成自己迭代的小專案。

初版比較糙，不喜勿噴。

後期會新增：

  • RPC
  • Coroutine - MySQL
  • Coroutine - Redis
  • Process
  • ...

需要原始碼的，加我微信吧。（選單-> 加我微信-> 掃我）

本文歡迎轉發，轉發請註明作者和出處，謝

相關推薦

Swoole 整合成一個小框架

目錄 概述 效果 程式碼 小結 概述 這是關於 Swoole 學習的第六篇文章：Swoole 整合成一個小框架。 第五篇：Swoole 多協議 多埠 的應用 第四篇：Swool

SSH框架整合的一個小案例

<!-- 啟動伺服器，自動載入配置檔案，將自動建立表 --> <!-- 引入外部的屬性檔案 --> <context:property-placeholder location="classpath:jdbc.properties"/> <!-- 配置c3p0連線池

利用jdbc簡單封裝一個小框架（類似DBUtils）

add string url lar conn () 列名 lang con 利用jdbc寫的一個類似DBUtils的框架 package com.jdbc.orm.dbutils; import java.io.IOException; import java.io.

多個頁面跳轉到一個頁面，每次跳轉顯示不一樣的內容，相同功能形式不同的jsp頁面整合成一個 根據傳遞的引數值來決定跳轉的jsp頁面該顯示什麼樣的內容，避免new多個jsp頁面，節省資源

在jsp開發過程中，會遇到這樣的情況； 一個頁面跳轉到另一個頁面，需要兩個jsp頁面； 如果有5、6種不同的一個頁面跳轉到另一個不同的jsp頁面的時候，基本的功能都差不多，類似的情況，如果建立很多的jsp，會導致資源浪費，還有就是建立多個jsp頁面到後來自己都有點暈； 那麼只需要在傳遞的

springboot2.1.0整合elasticsearch一個小

<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-elasticsearch</

Java POI元件實現多個Excel檔案整合成一個多Sheet的Excel檔案

程式碼: package com.weichai; import java.io.File; import java.io.FileInputStream; import java.io.FileOutputStream; import java.io.InputStre

兩個相同欄位list整合成一個list

        List<Object> list_a = ajblService.selectGrpm(paraMap);          List<Object> list_b = ajblService.exceptGrpm(paraMap

將兩個有序的單向連結串列整合成一個有序單向連結串列

題目：將兩個有序的單向連結串列整合成一個新的有序單向連結串列。 以小到大有序基準的單向連結串列，演算法原理： 1、取連結串列A，連結串列B 各自頭節點進行比較，確定新連結串列的頭節點。 2、若取的是連結串列A的節點，取出連結串列A該節點的下一節點與B連結串

spring-boot 和 redis 整合的一個小例子

轉自：http://blog.csdn.net/a67474506/article/details/52595053 在網上看到好多的spring-boot和redis整合的，弄到本地一直報Error resolving template "get", template m

從零開始學習 asp.net core 2.1 web api 後端api基礎框架(六)-把獲取資料的程式碼整理成一個服務

建立一個Services目錄, 然後建立一個 ProductService.cs類 我們把獲取資料的程式碼整理成一個ProductService, 然後保證程式執行的時候, 操作的是同一批資料: namespace CoreBackend.Api.Services { public

UI框架 可以直接當一個小外掛的使用

1.資料夾規範： 2.做UI的時候：2D模式，正交攝像機  3. 選擇這個 數值改成0.5適應寬高 4.。一個空的image來當爹，其他的物體是他兒子，這樣兒子依附於他在右下角 就不會改變形狀了 5.方便ui管理，點選什麼，就出現什麼，用列舉列舉和結構體都是值型別： 通過文字載入，通

JAVA小白啟蒙篇：第一個SSM框架搭建示例（附原始碼下載）

  HelloWorld工程原始碼下載 http://download.csdn.net/detail/baidu_31657889/9682606 有償連結(0.1rmb)：https://www.fageka.com/Home/Index/sell?id=ctLT7f4

戰勝主導設計：一個整合性的分析框架

一、引言 技術變遷與產業結構的關係一直以來都是創新理論、產業組織理論及公司理論等理論所重點關注的問題。這一問題之所以重要，是因為技術的進步時常導致已有的產業結構的劇烈變動，舊的大企業可能在新的技術浪潮中被淘汰，而新的名不見經傳的小企業則在競爭中脫穎而出，成為新

ssi(spring struts ibatis)框架下 搭建一個新包寫一個小的系統理解

ssi(spring struts ibatis)框架下 搭建一個新包寫一個小的系統理解 不同公司有不同的結構,再此就本公司的結構簡要介紹一下: servers專案下放的是tomcat伺服器啟動的配置檔案 context.xml 中可以找到資料庫 資訊 url

整理js開發中的實用小工具（一）：做一個整合儲存的小工具

在開發工作中，常遇到程式碼重複開發的問題，比如一個分頁，左滑動等常見功能，而我們的解決辦法可能是這次寫一點，下次 copy 一點，如果不能解決問題，再改寫一點。若是沒有把可複用的程式碼抽離出來，做成一個通用的、可配置的小工具，私以為對技能的提升無益，所以在此立下個 flag，以後工作中遇到頻繁開發的功能

自己整合的Android mvp+singlenet小框架

最近看到了一篇關於阿里何洪輝的singlenet框架，然後自己結合了mvp框架自己架構了一個簡單的程式框架，接下去我將以登入模組來說明一下我的這個小框架 首先是singlenet的框架，這個框架的知識是照搬書上的 //首先是request的抽象類，根據http協議的格式設定response

cordova 一個將web應用程式封裝成app的框架

我接下來主要將如何搭建。 1.首先你需要下載幾樣東西 1.jdk. 2.android_SDK. 2.安裝這兩個，並配置環境變數 這裡jdk的環境變數配置我就不細說了。 android_SDK的環境變數配置 C:\Development\android-sdk\platf

jquery，當把滑鼠 移到某上時，把滑鼠形狀 換成自己的一個小圖片。

滑鼠樣式這個東西挺繞的。我總結下我的經驗。 首先不需要用jquery定義滑鼠，css裡面就有。 語法 cursor:url(你自己的路徑),auto; url裡面是你自己的路徑，auto實際上是後面需要跟的標準樣式。 瀏覽器會先載入你設定路徑的樣式，如果沒有則載入auto這

基於Eclipse搭建SSH框架：第四篇 使用SSH開發一個小程式

本文將介紹如何使用SSH框架開發一個簡單的使用者註冊程式。 注:由於在開發本註冊程式的時候，報出了 java.lang.ClassNotFoundException: org.hibernate.service.jta.platform.spi.JtaPlatform等錯誤

讓微信小程式在瀏覽器和自己的App中執行--自己寫的一個開源框架FreeMina（開發中。。）

FreeMina： An open mina compatible framework for running in browser or webview. 一個相容微信小程式Mina框架的開源框架 從小程式的設計來看，微信正走向封閉生態。我們開發的微信