赞助商
- 感谢JetBrains对本项目的支持！
需要确保运行环境达到了以下的要求：
- PHP >= 7.4
- Swoole PHP 扩展 >= 4.5.2
- Redis PHP 扩展 （如需使用 Redis 客户端）
- PDO PHP 扩展 （如需使用 MySQL 客户端）
composer create-project api-swoole/skeleton
支持 HTTP 服务、WebSocket 服务、tcp服务,项目根目录./apiswoole.php执行命令。
php apiswoole.php
在api-swoole框架中，业务主要代码在app目录中。里面各个命名空间对应一个子目录，项目的默认命名空间是App，创建项目后app目录中包含Common、Example、Ext三个子目录，Common目录存放函数的functions.php文件，Ext一般放置工具等。目录结构如下：
./
└── app
├── Example # 放置接口源代码，相当于控制器层
├── Common # 公共代码目录，
└── Ext# 放置工具等
当项目需要新增接口时，先在./app/Example目录中新建hello.php文件，并用编辑器编辑代码。
<?php
namespace App\Example;
use Sapi\Api;
class Hello extends Api
{
public function index()
{
return [
'code' => 200,
'data' => [
'name' => 'api-swoole',
'version' => DI()->config->get('conf.version'),
],
];
}
}
在route/http.php路由文件中定义项目路由，第一个参数为定义的浏览器访问地址，第二个参数@前半部分为文件的完整命名空间，@
后半部分为在类中调用的具体方法。
return [
\HttpRouter("/hello", "App\Example\Hello@index"),
];
在项目根目录下执行如下命令以非守护模式启动。
php apiswoole.php
默认情况下监听本地的HTTP和websocket的9501端口，在cmd中出现如下输出信息表示项目启动成功。
[Success] Swoole: 4.5.9, PHP: 7.4.13, Port: 9501
[Success] Swoole Http Server running：http://0.0.0.0:9501
[Success] Swoole websocket Server running：ws://0.0.0.0:9501
[Success] Swoole tcp Server running：0.0.0.0:9500
[Success] Swoole udp Server running：0.0.0.0:9502
在浏览器地址栏中输入定义的路由地址，地址组成http://ip网址:端口/定义的路由。
http://127.0.0.1:9501/hello
请求成功返回数据默认json方式返回，包含默认的code、msg、data字段，data中数据为方法中返回的数据。
{
"code": 200,
"msg": "success",
"data": {
"code": 200,
"data": {
"name": "api-swoole",
"version": "1.0.2"
}
},
"debug": []
}由于 Http\Server 对 HTTP 协议的支持并不完整，建议仅作为应用服务器，用于处理动态请求，并且在前端增加 Nginx
作为代理。（参考地址）
server {
listen 80;
server_name swoole.test;
location / {
proxy_set_header Host $http_host;
proxy_set_header X-Real-IP $remote_addr;
proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
proxy_pass http://127.0.0.1:9501;
}
}
可以通过读取 $request->header['x-real-ip'] 来获取客户端的真实 IP
默认config文件夹下包含conf.php、db.php、events.php三个文件，conf.php放置项目的配置信息，http、tcp、udp、websocket等配置。db.php负责配置MySQL、Redis连接，events.php负责定义定制特定事件注册监听，现支持workerStart、open、close、task、finish
事件注册 。可以通过DI()->config->get('conf.ws')或者\Sapi\Di::one()->config->get('conf.ws')方式读取配置信息。
./config/
├── conf.php #http、tcp、udp、websocket等配置
├── db.php #数据库配置
└── events.php #定制特定事件注册监听
<?php
return [
'version' => '1.0.2',
'debug' => true,//调试模式
'log' => [
'displayConsole' => true,//true控制台打印日志
'saveLog' => true,//保存日志
],
'udp' => [
'host' => '0.0.0.0',
'port' => 9502,
'sockType' => SWOOLE_SOCK_UDP,
'events' => [
['packet', \App\Example\UdpServe::class, 'onPacket'],
],
'settings' => [],
],
'tcp' => [
'host' => '0.0.0.0',
'port' => 9501,
'sockType' => SWOOLE_SOCK_TCP,
'events' => [
['Receive', \App\Example\TcpServe::class, 'onReceive'],
['connect', \App\Example\TcpServe::class, 'onConnect'],
['close', \App\Example\TcpServe::class, 'onClose'],
],
'settings' => [],
],
'ws' => [
'host' => '0.0.0.0',
'port' => 9500,
'events' => [
['open', \Sapi\Events::class, 'onOpen'],
['message', \Sapi\Events::class, 'onMessage'],
['close', \Sapi\Events::class, 'onClose'],
['request', \Sapi\Events::class, 'onRequest'],
['Task', \Sapi\Events::class, 'onTask'],
['Finish', \Sapi\Events::class, 'onFinish'],
['workerStart', \Sapi\Events::class, 'onWorkerStart'],
['start', \Sapi\Events::class, 'onStart'],
],
'settings' => [
'daemonize' => false,//设置 daemonize => true 时，程序将转入后台作为守护进程运行。长时间运行的服务器端程序必须启用此项。如果不启用守护进程，当 ssh 终端退出后，程序将被终止运行
// 'dispatch_mode' => 2,//数据包分发策略。【默认值：2】
'worker_num' => swoole_cpu_num(),
'log_file' => 'storage/swoole',
'log_rotation' => SWOOLE_LOG_ROTATION_DAILY,
'log_date_format' => '%Y-%m-%d %H:%M:%S',
'log_level' => SWOOLE_LOG_DEBUG,
'task_worker_num' => 10,
'enable_coroutine' => true,//是否启用异步风格服务器的协程支持
// 'buffer_output_size' => 32 * 1024 * 1024, //配置发送输出缓存区内存尺寸。【默认值：2M】
// 'document_root' => ROOT_PATH,
// 'enable_static_handler' => true,//开启静态文件请求处理功能
// 'static_handler_locations' => ['/chatroom', '/app/images'],//设置静态处理器的路径。类型为数组，默认不启用。
],
// SWOOLE_LOG_DEBUG 调试日志，仅作为内核开发调试使用
// SWOOLE_LOG_TRACE 跟踪日志，可用于跟踪系统问题，调试日志是经过精心设置的，会携带关键性信息
// SWOOLE_LOG_INFO 普通信息，仅作为信息展示
// SWOOLE_LOG_NOTICE 提示信息，系统可能存在某些行为，如重启、关闭
// SWOOLE_LOG_WARNING 警告信息，系统可能存在某些问题
// SWOOLE_LOG_ERROR 错误信息，系统发生了某些关键性的错误，需要即时解决
// SWOOLE_LOG_NONE 相当于关闭日志信息，日志信息不会抛出
],
'process' => [
[\App\Example\Process::class, 'addProcess']
],//添加用户自定义的工作进程
];
项目启动时在apiswoole.php已经默认注册服务。
$di = DI();
$di->config = new Config("./config");
例如配置信息为conf.php,结构为：
return [
'debug' => true,//调试模式
'tcp' => [
'host' => '0.0.0.0',
'port' => 9500,
'sockType' => SWOOLE_SOCK_TCP,
'events' => [
['receive', \App\Controller\TcpServe::class, 'onReceive'],
],
'settings' => [],
],
]
可以使用DI()->config->get('conf.tcp')读取配置文件
DI()->config->get('conf.tcp') #返回数组
返回数组数据结构：
{
"host": "0.0.0.0",
"port": 9500,
"sockType": 1,
"events": [
[
"receive",
"App\\Controller\\TcpServe",
"onReceive"
]
],
"settings": []
}根据PSR规范中详尽定义了日志接口，日志记录在./storage/log目录中，按照每日生成对应日期.log日志文件。目前支持以下几种日志记录：
- error： 系统异常类日记
- info： 业务纪录类日记
- debug： 开发调试类日记
- notice： 系统提示类日记
- waring： 系统致命类日记
日志系统使用：
DI()->logger->debug("日志测试debug"); #开发调试类日记
DI()->logger->info("日志测试info"); #业务纪录类日记
DI()->logger->notice("日志测试notice");#系统提示类日记
DI()->logger->waring("日志测试waring");#系统致命类日记
DI()->logger->error("日志测试error"); #系统异常类日记
./storage/log/20220906.log目录下对应日志：
[swoole] | [2022-09-06 01:32:05] | debug | 日志测试debug
[swoole] | [2022-09-06 01:32:05] | info | 日志测试info
[swoole] | [2022-09-06 01:32:05] | notice | 日志测试notice
[swoole] | [2022-09-06 01:32:05] | warning | 日志测试waring
[swoole] | [2022-09-06 01:32:05] | error | 日志测试error
(六).HTTP/websocket服务器(参考地址)
WebSocket\Server 继承自 Http\Server，所以 Http\Server 提供的所有 API
和配置项都可以使用。请参考 Http\Server 章节。
- 设置了 onRequest 回调，
WebSocket\Server也可以同时作为HTTP服务器 - 未设置 onRequest 回调，
WebSocket\Server收到HTTP请求后会返回HTTP 400错误页面
如若只想实现websocket服务器，则在./config/conf.php配置中删除['request', \Sapi\Events::class, 'onRequest']即可。
HTTP/websocket服务器配置选项在./config/conf.php
中。具体配置信息可以参考Swoole文档配置选项。
<?php
return [
'ws' => [
'host' => '0.0.0.0',//监听地址
'port' => 9501,//监听端口
'events' => [
['open', \Sapi\Events::class, 'onOpen'],
['message', \Sapi\Events::class, 'onMessage'],
['close', \Sapi\Events::class, 'onClose'],
['request', \Sapi\Events::class, 'onRequest'],//HTTP服务器回调
['Task', \Sapi\Events::class, 'onTask'],
['Finish', \Sapi\Events::class, 'onFinish'],
['workerStart', \Sapi\Events::class, 'onWorkerStart'],
['start', \Sapi\Events::class, 'onStart'],
],//回调函数
'settings' => [
'daemonize' => false,//设置 daemonize => true 时，程序将转入后台作为守护进程运行。长时间运行的服务器端程序必须启用此项。如果不启用守护进程，当 ssh 终端退出后，程序将被终止运行
'worker_num' => swoole_cpu_num(),
'log_file' => 'storage/swoole',
'log_rotation' => SWOOLE_LOG_ROTATION_DAILY,
'log_date_format' => '%Y-%m-%d %H:%M:%S',
'log_level' => SWOOLE_LOG_DEBUG,
'task_worker_num' => 10,
],
],
];
HTTP 服务器的路由构建文件位于./route/http.php中。声明具体的路由规则，第一个参数为定义的浏览器访问地址，第二个参数@
前半部分为文件的完整命名空间，@后半部分为在类中调用的具体方法。
return [
\HttpRouter("/", "App\Example\App@Index"),
\HttpRouter("/hello", "App\Example\Hello@index"),
\HttpRouter("声明浏览器地址", "命名空间+类@类中的方法"),
];
完整的URL地址组成http://ip网址:端口/定义的路由。
构建基本路由只需要一个 URI 与一个 闭包，提供了一个非常简单定义路由的方法：
return [
\HttpRouter("/", function (\Swoole\Http\Request $request, \Swoole\Http\Response $response) {
return [
"code" => 200,
"msg" => "hello World!",
'tm' => date('Y-m-d H:i:s'),
"data" => [
'name' => 'api-swoole',
'version' => DI()->config->get('conf.version'),
],
];
}),
];
对应的控制器方法默认有两个参数 $request 和 $reponse，关于 Request 和 Response 对象完整的介绍请查看 Swoole
文档：Http\Request 、 Http\Response
<?php
namespace App\Controller;
use Sapi\Api;
class Hello extends Api
{
public function index()
{
return [
'code' => 200,
'data' => 'hello world'
];
}
}
接口参数规则通过继承Api类实现，具体的定义规则通过rule()方法。
- 一维下标是接口类的方法名。
- 二维下标是接口参数名称。
- 三维下标
name对应客户端传入的值require表示值传入可选项,true必须传入，false非必须传入。type传入类型，支持int、string、float、bool、array、filesource参数传入位置，支持get、post、headermessage接口参数提示信息
<?php
namespace App\Example;
use Sapi\Api;
//字段验证
class App extends Api
{
public function rule()
{
return [
'Index' => [
'intValue' => ['name' => 'intValue', 'require' => true, 'type' => 'int', 'source' => 'post', 'message' => 'intValue必须携带'],
'stringValue' => ['name' => 'stringValue', 'require' => true, 'type' => 'string', 'source' => 'post', 'message' => 'stringValue必须携带'],
'floatValue' => ['name' => 'floatValue', 'require' => true, 'type' => 'float', 'source' => 'post', 'message' => 'floatValue是必须的'],
'boolValue' => ['name' => 'boolValue', 'require' => true, 'type' => 'bool', 'source' => 'post', 'message' => 'boolValue是必须的'],
'arrayValue' => ['name' => 'arrayValue', 'require' => true, 'type' => 'array', 'source' => 'post', 'message' => 'arrayValue是必须的'],
'file' => ['name' => 'file', 'require' => false, 'type' => 'file', 'ext' => 'jpeg,png,txt', 'source' => 'post', 'message' => 'file文件是必须的'],
'x-token' => ['name' => 'x-token', 'require' => true, 'type' => 'string', 'source' => 'header', 'message' => '缺少请求头x-token'],
]
];
}
public function Index(\Swoole\Http\Request $request, \Swoole\Http\Response $response): array
{
return [
"code" => 200,
"msg" => "hello World!",
'tm' => date('Y-m-d H:i:s'),
"data" => [
'name' => 'api-swoole',
'version' => DI()->config->get('conf.version'),
'intValue' => $request->post['intValue'],
'stringValue' => $request->post['stringValue'],
'floatValue' => $request->post['floatValue'],
'boolValue' => $request->post['boolValue'],
'arrayValue' => $request->post['arrayValue'],
'x-token' => $request->header['x-token'],
'file' => saveFile($request, './tmp/')
],
];
}
}
websocket服务器的路由定义文件位于./route/websocket.php
中。声明具体的路由规则，第一个参数为定义的浏览器访问地址，第二个参数@前半部分为文件的完整命名空间，@后半部分为在类中调用的具体方法。
return [
WsRouter("/", "\App\Example\Websocket@index"),
WsRouter("/login", "\App\Example\Websocket@login"),
];
完整的URL地址组成 ws://ip网址:端口。
对应的控制器方法默认有两个参数 $server 和 $msg，关于 $server对象完整的介绍请查看 Swoole
文档：WebSocket\Server。 $msg
是客户端发送的数据信息。
客户端发送的数据信息，默认需以json格式传送，必须包含id、path、data三个字段。
id字段消息体的唯一标识。path字段是./route/websocket.php路由声明的访问地址。data字段是项目的具体消息参数，控制方法默认的$msg。
{
"id": "918wsEMQDrj0RXxm",
"path": "/",
"data": {
"username": "api-swoole"
}
}控制器代码部分示例：
<?php
namespace App\Example;
use Sapi\Api;
class WebsocketHello extends Api
{
public function hello(\Swoole\WebSocket\Server $server, array $msg): array
{
return [
'err' => 200,
'data' => [
'name' => 'api-swoole',
'version' => DI()->config->get('conf.version'),
]
];
}
}
接口参数规则通过继承Api类实现，具体的定义规则通过rule()方法。
- 一维下标是接口类的方法名。
- 二维下标是接口参数名称。
- 三维下标
name对应客户端传入的值require表示值传入可选项,true必须传入，false非必须传入。type传入类型，支持int、string、float、bool、arraymessage接口参数提示信息
<?php
namespace App\Example;
class Websocket extends WsBase
{
public function rule()
{
return [
'Index' => [
'intValue' => ['name' => 'intValue', 'require' => true, 'type' => 'int', 'message' => 'intValue必须携带'],
'stringValue' => ['name' => 'stringValue', 'require' => true, 'type' => 'string', 'message' => 'stringValue必须携带'],
'floatValue' => ['name' => 'floatValue', 'require' => true, 'type' => 'float', 'message' => 'floatValue是必须的'],
'boolValue' => ['name' => 'boolValue', 'require' => true, 'type' => 'bool', 'message' => 'boolValue是必须的'],
'arrayValue' => ['name' => 'arrayValue', 'require' => true, 'type' => 'array', 'message' => 'arrayValue是必须的'],
'x-token' => ['name' => 'x-token', 'require' => true, 'type' => 'string', 'message' => '缺少请求头x-token'],
]
];
}
public function Index(\Swoole\WebSocket\Server $server, array $msg): array
{
return [
'err' => 200,
'data' => [
'intValue' => $msg['intValue'],
'stringValue' => $msg['stringValue'],
'floatValue' => $msg['floatValue'],
'boolValue' => $msg['boolValue'],
'arrayValue' => $msg['arrayValue'],
'x-token' => $msg['x-token'],
]
];
}
}
Api类内置了钩子函数userCheck,HTTP控制器均可继承Api类重载。例如可完成用户身份验证。
首先定义声明HttpBase.php文件。
<?php
namespace App\Example;
use Sapi\Api;
class HttpBase extends Api
{
//用户权限验证
public function userCheck(\Swoole\Http\Request $request): string
{
if ($request->header["x-token"] != "123123") {
return "token过期";
}
return "";
}
}
然后继承HttpBase.php实现类重载，。
<?php
namespace App\Example;
class Auth extends HttpBase
{
public function rule()
{
return [
'login' => [
'username' => ['name' => 'username', 'require' => true, 'type' => 'string', 'source' => 'post', 'message' => '必须携带username'],
]
];
}
public function login(\Swoole\Http\Request $request, \Swoole\Http\Response $response): array
{
return [
"code" => 200,
"msg" => "login",
"data" => [
'username' => $request->post['username']
]
];
}
}
Api类内置了钩子函数userWsCheck,websocket控制器均可继承Api类重载。例如可完成用户身份验证。
首先定义声明WsBase.php文件。
<?php
namespace App\Example;
use Sapi\Api;
class WsBase extends Api
{
public function userWsCheck(\Swoole\WebSocket\Frame $frame): string
{
$res = json_decode($frame->data, true);
if (!isset($res['data']["x-token"]) || $res['data']["x-token"] != "123123") {
return "token expired";
}
return "";
}
}
然后继承WsBase.php实现类重载，。
<?php
namespace App\Example;
class Websocket extends WsBase
{
public function rule()
{
return [
'Index' => [
'intValue' => ['name' => 'intValue', 'require' => true, 'type' => 'int', 'message' => 'intValue必须携带'],
'stringValue' => ['name' => 'stringValue', 'require' => true, 'type' => 'string', 'message' => 'stringValue必须携带'],
'floatValue' => ['name' => 'floatValue', 'require' => true, 'type' => 'float', 'message' => 'floatValue是必须的'],
'boolValue' => ['name' => 'boolValue', 'require' => true, 'type' => 'bool', 'message' => 'boolValue是必须的'],
'arrayValue' => ['name' => 'arrayValue', 'require' => true, 'type' => 'array', 'message' => 'arrayValue是必须的'],
'x-token' => ['name' => 'x-token', 'require' => true, 'type' => 'string', 'message' => '缺少请求头x-token'],
]
];
}
public function Index(\Swoole\WebSocket\Server $server, array $msg): array
{
return [
'err' => 200,
'data' => [
'intValue' => $msg['intValue'],
'stringValue' => $msg['stringValue'],
'floatValue' => $msg['floatValue'],
'boolValue' => $msg['boolValue'],
'arrayValue' => $msg['arrayValue'],
'x-token' => $msg['x-token'],
]
];
}
}
Server 可以监听多个端口，每个端口都可以设置不同的协议处理方式，例如 80 端口处理 HTTP 协议，9500 端口处理 TCP 协议,9502
端口处理 UDP 协议。SSL/TLS
传输加密也可以只对特定的端口启用。参考Swoole官方文档(多端口监听)
TCP服务器配置选项在./config/conf.php中增加tcp
字段。具体配置信息可以参考Swoole文档TCP配置。
'tcp' => [
'host' => '0.0.0.0',
'port' => 9500,
'sockType' => SWOOLE_SOCK_TCP,
'events' => [
['receive', \App\Controller\TcpServe::class, 'onReceive'],//TCP服务器回调
],
'settings' => [],
],
UDP服务器配置选项在./config/conf.php中增加udp
字段。具体配置信息可以参考Swoole文档UDP配置。
'udp' => [
'host' => '0.0.0.0',
'port' => 9502,
'sockType' => SWOOLE_SOCK_UDP,
'events' => [
['packet', \App\Controller\UdpServe::class, 'onPacket'],//UDP服务器回调
],
'settings' => [],
],
Swoole 开发组采用 Hook 原生 PHP 函数的方式实现协程客户端，通过一行代码就可以让原来的同步 IO 的代码变成可以协程调度的异步
IO，即一键协程化。Swoole 提供的 Swoole\Server 类簇
都是自动做好的，不需要手动做，参考 enable_coroutine
。具体内容可参考Swoole官网一键协程化
框架数据库引入simple-swoole第三方拓展包具体详情可参考simple-swoole/db
Redis服务器配置选项在./config/db.php中。
<?php
return [
'redis' => [
'host' => '192.168.0.105',//Redis服务器地址
'port' => 6379,//指定 Redis 监听端口
'auth' => '',//登录密码
'db_index' => 2,//指定数据库
'time_out' => 1,//
'size' => 64,//连接池数量
],
];
项目中使用Redis
<?php
namespace App\Controller;
use App\Ext\Redis;
class RedisDemo
{
public function setData(\Swoole\Http\Request $request, \Swoole\Http\Response $response)
{
$redis = new \Simps\DB\BaseRedis();
$res = $redis->set('我是key', '我是value');
return [
"code" => 200,
"msg" => "hello World!",
"data" => [
'res' => $res,
'key' => $request->get['key'],
'val' => $request->get['val'],
],
];
}
}
MySQL服务器配置选项在./config/db.php中。
<?php
return [
'mysql' => [
'host' => '',//连接地址
'port' => ,//连接端口
'database' => '',//数据库名称
'username' => 'root',//用户
'password' => '',//密码
'charset' => 'utf8',//字符集
'unixSocket' => null,//
'options' => [
PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
],
'size' => 64 // 连接池数量
],
];
./app/Ext/Pool.php配置连接池：
<?php
namespace App\Ext;
use Sapi\Singleton;
use Simps\DB\PDO;
use Simps\DB\Redis;
class Pool
{
use Singleton;
public function startPool(...$args)
{
$mysql_config = DI()->config->get('db.mysql');
if (!empty($mysql_config)) {
PDO::getInstance($mysql_config);
}
$redis_config = DI()->config->get('db.redis');
if (!empty($redis_config)) {
Redis::getInstance($redis_config);
}
}
}
simple-swoole集成了轻量级的 PHP 数据库框架 Medoo
，使用时需要继承 Simps\DB\BaseModel，所以使用方法和 Medoo
基本一致，具体请查看 Medoo 的文档
唯一不同的是事务相关操作，在 Medoo 中是使用 action( $callback ) 方法，而在本框架中也可以使用 action( $callback )
方法，另外也支持以下方法
beginTransaction(); // 开启事务
commit(); // 提交事务
rollBack(); // 回滚事务
事务示例
$this->beginTransaction();
$this->insert("user", [
"name" => "luffy",
"gender" => "1"
]);
$this->delete("user", [
"id" => 2
]);
if ($this->has("user", ["id" => 23]))
{
$this->rollBack();
} else {
$this->commit();
}
项目中使用，数据库表结构：
CREATE TABLE `user_info` (
`uid` int(11) NOT NULL AUTO_INCREMENT,
`nick` varchar(15) DEFAULT NULL,
PRIMARY KEY (`uid`)
) ENGINE=InnoDB AUTO_INCREMENT=1000001 DEFAULT CHARSET=utf8;
<?php
namespace App\Controller;
class MysqlDemo
{
public function getOne(\Swoole\Http\Request $request, \Swoole\Http\Response $response)
{
$uid = $request->post['uid'];
$database = new \Simps\DB\BaseModel();
$res = $database->select("user_info", [
"uid",
"nick",
], [
"uid" => $uid
]);
return [
"code" => 200,
"msg" => "MysqlDemo getOne",
"data" => [
'res' => $res,
'uid' => $uid,
],
];
}
public function save(\Swoole\Http\Request $request, \Swoole\Http\Response $response)
{
$username = $request->post['username'];
$database = new \Simps\DB\BaseModel();
$last_user_id = $database->insert("user_info", [
"uid" => time(),
"nick" => $username,
]);
return [
"code" => 200,
"msg" => "MysqlDemo save",
"data" => [
'last_user_id' => $last_user_id,
'username' => $username,
],
];
}
public function del(\Swoole\Http\Request $request, \Swoole\Http\Response $response)
{
$uid = $request->post['uid'];
$database = new \Simps\DB\BaseModel();
$res = $database->delete("user_info", [
"uid" => $uid
]);
return [
"code" => 200,
"msg" => "MysqlDemo del",
"data" => [
'res' => $res,
'uid' => $uid,
],
];
}
public function update(\Swoole\Http\Request $request, \Swoole\Http\Response $response)
{
$uid = $request->post['uid'];
$username = $request->post['username'];
$database = new \Simps\DB\BaseModel();
$res = $database->update("user_info", [
"nick" => $username
], [
"uid" => $uid
]);
return [
"code" => 200,
"msg" => "MysqlDemo update",
"data" => [
'res' => $res,
'uid' => $uid,
'username' => $username,
],
];
}
}
添加一个用户自定义的工作进程。此函数通常用于创建一个特殊的工作进程，用于监控、上报或者其他特殊的任务。具体内容可参考Swoole官网 addProcess
注意事项：
- 创建的子进程可以调用
$server对象提供的各个方法，如getClientList/getClientInfo/stats - 在
Worker/Task进程中可以调用$process提供的方法与子进程进行通信 - 在用户自定义进程中可以调用
$server->sendMessage与Worker/Task进程通信 - 用户进程内不能使用
Server->task/taskwait接口 - 用户进程内可以使用
Server->send/close等接口 - 用户进程内应当进行
while(true)(如下边的示例) 或 EventLoop 循环 (例如创建个定时器) ，否则用户进程会不停地退出重启
使用示例
添加一个用户自定义的工作进程，在./config/conf.php中增加process配置，如下：
'process' => [
[\App\Controller\Process::class, 'addProcess']
],
控制器示例：
<?php
namespace App\Controller;
class Process
{
//添加用户自定义的工作进程
public function addProcess($server)
{
return new \Swoole\Process(function ($process) use ($server) {
while (true) {
\Co::sleep(1);
echo "Hello, api-swoole!\r\n";
}
}, false, 2, 1);
}
}
框架已默认埋点workerStart、open、close、task、finish
五个订制事件注册。可根据具体的业务特征在对应的事件回调增加处理业务代码。./confg/events.php，每个事件允许有多个回调
<?php
return [
'workerStart' => [
[\App\Ext\Pool::class, 'startPool'],//启动连接池
// [\App\Controller\EventsDemo::class, 'workerStart'],
],
'open' => [
[\App\Controller\EventsDemo::class, 'open'],
],
'close' => [
[\App\Controller\EventsDemo::class, 'close'],
],
'task' => [
[\App\Controller\EventsDemo::class, 'task'],
],
'finish' => [
[\App\Controller\EventsDemo::class, 'finish'],
],
];