1. 首页
  2. 未分类
  3. 正文

Swoole 整合成一个小框架

2019年5月12日 202点热度 0人点赞 0条评论

第 82 篇文章

这是关于 Swoole 学习的第六篇文章：Swoole 整合成一个小框架。

概述

写了关于 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 这是文件名称，大家叫什么都可以。

目录结构如下：

  1. ├─ controller
  2. │     ├── ...
  3. ├─ client
  4. │  ├─ websocket
  5. │     ├── ...
  6. │  ├─ tcp
  7. │     ├── ...
  8. ├─ server
  9. │  ├─ config
  10. │     ├── config.php
  11. │  ├─ core
  12. │     ├── Common.php
  13. │     ├── Core.php
  14. │     ├── HandlerException.php
  15. │  ├─ log  -- 需要 读/写 权限
  16. │     ├── ...
  17. ├─ 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）。

  1. <?php

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

  5. class Core
  6. {
  7.     private static $serv;

  9.     public function __construct() {
  10.         set_error_handler(['HandlerException', 'appError']);
  11.         register_shutdown_function(['HandlerException', 'fatalError']);
  12.     }

  14.     public static function run() {
  15.         static::checkCli();
  16.         static::checkExtension();
  17.         static::showUsageUI();
  18.         static::parseCommand();
  19.     }

  21.     protected static function checkCli() {
  22.         if (php_sapi_name() !== 'cli') {
  23.             exit(output('服务只能运行在 cli sapi 模式下'));
  24.         }
  25.     }

  27.     protected static function checkExtension() {
  28.         if (!extension_loaded('swoole')) {
  29.             exit(output('请安装 swoole 扩展'));
  30.         }
  31.     }

  33.     protected static function showUsageUI() {
  34.         global $argc;
  35.         if ($argc <= 1 || $argc >3) {
  36.             echo PHP_EOL;
  37.             echo "----------------------------------------".PHP_EOL;
  38.             echo "|               Swoole                 |".PHP_EOL;
  39.             echo "|--------------------------------------|".PHP_EOL;
  40.             echo '|    USAGE: php index.php commond      |'.PHP_EOL;
  41.             echo '|--------------------------------------|'.PHP_EOL;
  42.             echo '|    1. start    以debug模式开启服务   |'.PHP_EOL;
  43.             echo '|    2. start -d 以daemon模式开启服务  |'.PHP_EOL;
  44.             echo '|    3. status   查看服务状态          |'.PHP_EOL;
  45.             echo '|    4. reload   热加载                |'.PHP_EOL;
  46.             echo '|    5. stop     关闭服务              |'.PHP_EOL;
  47.             echo "----------------------------------------".PHP_EOL;
  48.             echo PHP_EOL;
  49.             exit;
  50.         }
  51.     }

  53.     protected static function parseCommand() {
  54.         global $argv;
  55.         $command = $argv[1];
  56.         $option  = isset( $argv[2] ) ? $argv[2] : '' ;
  57.         switch ($command) {
  58.             case 'start':
  59.                 if ($option === '-d') { //以daemon形式启动
  60.                     get_config(['set@daemonize' => true]);
  61.                 }
  62.                 self::workerStart();
  63.                 break;
  64.             case 'status':
  65.                 self::workerStatus();
  66.                 break;
  67.             case 'reload':
  68.                 self::workerReload();
  69.                 break;
  70.             case 'stop':
  71.                 self::workerStop();
  72.                 break;
  73.             default:
  74.                 echo "Bad Command.".PHP_EOL;
  75.         }
  76.     }

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

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

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

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

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

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

  114.         self::$serv->on('Task', function ($serv, $task_id, $src_worker_id, $data) use ($config) {
  115.             $task = new OnTask();
  116.             $dataArr = json_decode($data, true);
  117.             switch ($dataArr['server']) {
  118.                 case "tcp":
  119.                     $task::tcp_task_run($serv, $task_id, $src_worker_id, $data);
  120.                     break;
  121.                 case "ws":
  122.                     $task::ws_task_run($serv, $task_id, $src_worker_id, $data);
  123.                     break;
  124.             }
  125.         });

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

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

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

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

  146.         self::$serv->on('Close', function ($serv, $fd, $reactor_id){
  147.             try {
  148.                 echo output('客户端关闭');
  149.             } catch(Exception $e) {
  150.             }
  151.         });

  153.         self::$serv->on('Shutdown', function ($serv) {
  154.            echo output("服务关闭");
  155.         });

  157.         self::showProcessUI();

  159.         self::$serv->start();
  160.     }

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

  165.         if (!file_exists($config['master_pid_file']) ||
  166.             !file_exists($config['manager_pid_file']) ||
  167.             !file_exists($config['worker_pid_file']) ) {
  168.             echo output("暂无启动的服务");
  169.             return false;
  170.         }

  172.         self::showProcessUI($config);

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

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

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

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


  193.         $workerPidString = rtrim(@file_get_contents($config['worker_pid_file']), '|' );
  194.         $workerPidArr    = explode( '|', $workerPidString );
  195.         if (isset($workerPidArr) && !empty($workerPidArr)) {
  196.             foreach ($workerPidArr as $key => $val) {
  197.                 $v = explode( '-', $val);
  198.                 echo str_pad("Worker", 18, ' ', STR_PAD_BOTH ).
  199.                      str_pad($config['worker_process_name'], 26, ' ', STR_PAD_BOTH ).
  200.                      str_pad($v[0], 16, ' ', STR_PAD_BOTH ).
  201.                      str_pad($v[1], 16, ' ', STR_PAD_BOTH ).
  202.                      str_pad($v[2], 16, ' ', STR_PAD_BOTH ).PHP_EOL;
  203.             }
  204.         }

  206.         $taskPidString = rtrim(@file_get_contents($config['task_pid_file']), '|' );
  207.         $taskPidArr  = explode( '|', $taskPidString );
  208.         if (isset($taskPidArr) && !empty($taskPidArr)) {
  209.             foreach ($taskPidArr as $key => $val) {
  210.                 $v = explode( '-', $val);
  211.                 echo str_pad("Task", 18, ' ', STR_PAD_BOTH ).
  212.                      str_pad($config['task_process_name'], 24, ' ', STR_PAD_BOTH ).
  213.                      str_pad($v[0], 20, ' ', STR_PAD_BOTH ).
  214.                      str_pad($v[1], 12, ' ', STR_PAD_BOTH ).
  215.                      str_pad($v[2], 20, ' ', STR_PAD_BOTH ).PHP_EOL;
  216.             }
  217.         }
  218.     }

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

  223.         if (!file_exists($config['master_pid_file'])) {
  224.             echo output("暂无启动的服务");
  225.             return false;
  226.         }

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

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

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

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

  241.         echo output("热加载成功");
  242.         return true;
  243.     }

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

  248.         if (!file_exists($config['master_pid_file'])) {
  249.             echo output("暂无启动的服务");
  250.             return false;
  251.         }

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

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

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

  263.         $time = time();
  264.         while (true) {
  265.             usleep(2000);
  266.             if (!swoole_process::kill($masterPidArr[0], 0)) {
  267.                 unlink($config['master_pid_file']);
  268.                 unlink($config['manager_pid_file']);
  269.                 unlink($config['worker_pid_file']);
  270.                 unlink($config['task_pid_file']);
  271.                 echo output("服务关闭成功");
  272.                 break;
  273.             } else {
  274.                 if (time() - $time > 5) {
  275.                     echo output("服务关闭失败，请重试");
  276.                     break;
  277.                 }
  278.             }
  279.         }
  280.         return true;
  281.     }

  283.     protected static function showProcessUI() {
  284.         $config = get_config();
  285.         if ($config['set']['daemonize'] == true) {
  286.             return false;
  287.         }
  288.         echo str_pad("-", 90, '-', STR_PAD_BOTH) . PHP_EOL;
  289.         echo "|" . str_pad("启动/关闭", 92, ' ', STR_PAD_BOTH) . "|" . PHP_EOL;
  290.         echo str_pad("-", 90, '-', STR_PAD_BOTH) . PHP_EOL;

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

  295.         echo str_pad("-", 90, '-', STR_PAD_BOTH) . PHP_EOL;
  296.         echo "|" . str_pad("版本信息", 92, ' ', STR_PAD_BOTH) . "|" . PHP_EOL;
  297.         echo str_pad("-", 90, '-', STR_PAD_BOTH) . PHP_EOL;

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

  302.         echo str_pad("-", 90, '-', STR_PAD_BOTH) . PHP_EOL;
  303.         echo "|" . str_pad("IP 信息", 90, ' ', STR_PAD_BOTH) . "|" . PHP_EOL;
  304.         echo str_pad("-", 90, '-', STR_PAD_BOTH) . PHP_EOL;

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

  309.         echo str_pad("-", 90, '-', STR_PAD_BOTH) . PHP_EOL;
  310.         echo "|" . str_pad("进程信息", 92, ' ', STR_PAD_BOTH) . "|" . PHP_EOL;
  311.         echo str_pad("-", 90, '-', STR_PAD_BOTH) . PHP_EOL;

  313.         echo str_pad("Swoole进程", 20, ' ', STR_PAD_BOTH) .
  314.             str_pad('进程别名', 30, ' ', STR_PAD_BOTH) .
  315.             str_pad('进程ID', 18, ' ', STR_PAD_BOTH) .
  316.             str_pad('父进程ID', 18, ' ', STR_PAD_BOTH) .
  317.             str_pad('用户', 18, ' ', STR_PAD_BOTH) . PHP_EOL;
  318.     }

  320.     protected static function signalHandler() {
  321.         //TODO 未完成
  322.         //swoole_process::signal(SIGINT, function ($signal) {
  323.         //    echo $signal;
  324.         //    return;
  325.         //});
  326.     }
  327. }

小结

耗费了 3 个晚上的时间，终于完成了一个初版，比较初级，希望可以给入门的同学一个参考吧。

当然我自己也会继续完善它，后期的一些新知识点会集成到这里面，做成自己迭代的小项目。

初版比较糙，不喜勿喷。

后期会新增：

  • RPC

  • Coroutine - MySQL

  • Coroutine - Redis

  • Process

  • ...

需要源码的，加我微信。（菜单-> 加我微信-> 扫我）

推荐阅读

本文欢迎转发，转发请注明作者和出处，谢谢！图片

34480Swoole 整合成一个小框架
标签： 暂无
最后更新：2019年5月12日

这个人很懒，什么都没留下

文章评论

Bootstrap 5入门指南 IDEA2022.3最新版永久激活教程（亲测有效） 转需！几百款中文永久版软件及安装方法（含百度云、天翼云下载） 50 万用户无人付费，Kite 停止开发！ 50w人白嫖！历经 8 年研发的 Python 代码补全神器 Kite 停止开发 有效的phpstorm正式版激活码，配合插件可永久破解！ 软件安装目录大全 Pycharm 2022 Pycharm激活码-PyCharm 2022.2.1中文版激活教程 （更新）Python编辑开发PyCharm pro 2022.2.4 for Mac 中文破解版下载（附激活码） Go语言爱好者周刊：第 170 期 — Gopher 图片集 GoLand 迎来五周年，同时发布 2022.3：有彩蛋 GoLand迎来五周年，2022.3发布 互联网摸鱼日报（2022-12-03） 《怪物猎人：崛起》即将登陆Xbox及PS平台
Linux 启动性能分析 | Linux 中国 用Python搞定豆瓣上征婚交友的小姐姐们~ Excel表格中筛选数据，你的方法太笨了！ 2022 Kotlin 中文开发者大会倒计时，迎接周末两天专属 Kotlin 的技术盛宴！ 新能源车涨价潮里，没有赢家 告诉你IOS到底比Android好在哪？ 基于Prometheus的分布式监控平台落地与实践 Excel表格“假”合并，有多牛？ Linux中的软件安装进度条怎么搞? 煎鱼 Go Gin 系列十：定制 GORM Callbacks ECharts：基于HTML5 Canvas的JavaScript图表库 Linux基础入门5：Linux权限管理 硬件资讯|苹果M2 MacBook Air拆解，确认 256GB机型只有一个NAND芯片 Wave Simulation: Part 1 资讯 | 新款MacBook Air引入多彩配色，自研M2芯片加持
标签聚合
二手车 前端 机器学习 caddy https idea 2022 激活 科技 农业 编程语言排行 芯片 游戏 表情包 世界杯 m3u8 开发 python tiktok goland 2022 xbox 软件 web3 网盘 linux
other

COPYRIGHT © 2022 编程网. ALL RIGHTS RESERVED.

Theme Kratos Made By Seaton Jiang