事件
优质
小牛编辑
136浏览
2023-12-01
imi 框架事件
IMI.INITED
框架初始化事件
事件参数：
无
IMI.APP.INIT
项目初始化事件
事件参数：
无
IMI.LOAD_RUNTIME_INFO
加载 runtime 事件，在此事件中，绝对可以使用 App::getRuntimeInfo() 获取到数据。
IMI.MAIN_SERVER.WORKER.START.APP
在项目中监听 WorkerStart 事件
事件参数：
class WorkerStartEventParam extends EventParam
{
/**
* 服务器对象
* @var \Imi\Server\Base
*/
public $server;
/**
* Worker进程ID
* @var int
*/
public $workerID;
}
IMI.SERVER.CREATE.BEFORE
创建服务器对象前置操作，主服务器+子服务器，每个创建前都会触发！
事件参数：
无
IMI.SERVER.CREATE.AFTER
创建服务器对象前置后作，主服务器+子服务器，每个创建后都会触发！
事件参数：
无
IMI.SERVERS.CREATE.BEFORE
创建服务器对象前置后作，只会触发一次！
事件参数：
无
IMI.SERVERS.CREATE.AFTER
创建服务器对象前置后作，只会触发一次！
事件参数：
无
IMI.INIT.WORKER.BEFORE
Worker 进程初始化后置
事件参数：
无
IMI.INIT.WORKER.AFTER
Worker 进程初始化后置
事件参数：
无
IMI.PROCESS.BEGIN
自定义进程开始事件
事件参数：
string $name, \Swoole\Process $process
IMI.PROCESS.END
自定义进程结束事件
事件参数：
string $name, \Swoole\Process $process
IMI.PROCESS_POOL.PROCESS.BEGIN
自定义进程池中的进程开始事件
事件参数：
string $name, \Swoole\Process\Pool $pool, int $workerId, int $workerNum, array $args, int $ipcType, string $msgQueueKey
IMI.PROCESS_POOL.PROCESS.END
自定义进程池中的进程结束事件
事件参数：
string $name, \Swoole\Process\Pool $pool, int $workerId, int $workerNum, array $args, int $ipcType, string $msgQueueKey
IMI.SERVER.GROUP.JOIN
服务器逻辑分组加入事件
事件参数：
\Imi\Server\Base $server, string $groupName, int $fd
IMI.SERVER.GROUP.LEAVE
服务器逻辑分组离开事件
事件参数：
\Imi\Server\Base $server, string $groupName, int $fd
IMI.REQUEST_CONTENT.CREATE
请求上下文创建事件
事件参数：无
IMI.REQUEST_CONTENT.DESTROY
请求上下文销毁事件
事件参数：无
Swoole Server 全局事件
IMI.MAIN_SERVER.START
OnStart
事件参数：
class StartEventParam extends EventParam
{
/**
* 服务器对象
* @var \Imi\Server\Base
*/
public $server;
}
IMI.MAIN_SERVER.SHUTDOWN
OnShutdown
事件参数：
class ShutdownEventParam extends EventParam
{
/**
* 服务器对象
* @var \Imi\Server\Base
*/
public $server;
}
IMI.MAIN_SERVER.WORKER.START
OnWorkerStart
事件参数：
class WorkerStartEventParam extends EventParam
{
/**
* 服务器对象
* @var \Imi\Server\Base
*/
public $server;
/**
* Worker进程ID
* @var int
*/
public $workerID;
}
IMI.MAIN_SERVER.WORKER.STOP
OnWorkerStop
事件参数：
class WorkerStopEventParam extends EventParam
{
/**
* 服务器对象
* @var \Imi\Server\Base
*/
public $server;
/**
* Worker进程ID
* @var int
*/
public $workerID;
}
IMI.MAIN_SERVER.MANAGER.START
OnManagerStart
事件参数：
class ManagerStartEventParam extends EventParam
{
/**
* 服务器对象
* @var \Imi\Server\Base
*/
public $server;
}
IMI.MAIN_SERVER.MANAGER.STOP
OnManagerStop
事件参数：
class ManagerStopEventParam extends EventParam
{
/**
* 服务器对象
* @var \Imi\Server\Base
*/
public $server;
}
IMI.MAIN_SERVER.TASK
OnTask
事件参数：
class TaskEventParam extends EventParam
{
/**
* 服务器对象
* @var \Imi\Server\Base
*/
public $server;
/**
* 任务ID
* @var int
*/
public $taskID;
/**
* worker进程ID
* @var int
*/
public $workerID;
/**
* 任务数据
* @var mixed
*/
public $data;
}
IMI.MAIN_SERVER.FINISH
OnFinish
事件参数：
class FinishEventParam extends EventParam
{
/**
* 服务器对象
* @var \Imi\Server\Base
*/
public $server;
/**
* 任务ID
* @var int
*/
public $taskID;
/**
* 任务数据
* @var mixed
*/
public $data;
}
IMI.MAIN_SERVER.PIPE_MESSAGE
OnPipeMessage
事件参数：
class PipeMessageEventParam extends EventParam
{
/**
* 服务器对象
* @var \Imi\Server\Base
*/
public $server;
/**
* Worker进程ID
* @var int
*/
public $workerID;
/**
* 消息内容，可以是任意PHP类型
* @var mixed
*/
public $message;
}
IMI.MAIN_SERVER.WORKER_ERROR
OnWorkerError
事件参数：
class WorkerErrorEventParam extends EventParam
{
/**
* 服务器对象
* @var \Imi\Server\Base
*/
public $server;
/**
* Worker进程ID
* @var int
*/
public $workerID;
/**
* Worker进程PID
*
* @var int
*/
public $workerPid;
/**
* 退出的状态码，范围是 1 ～255
*
* @var int
*/
public $exitCode;
/**
* 进程退出的信号
*
* @var int
*/
public $signal;
}
Swoole Server 对象事件
对象事件是由多个服务器对象发出的，监听多个端口即认定为多个服务器。
Http Server
request
事件参数：
class RequestEventParam extends EventParam
{
/**
* swoole 请求对象
* @var \Imi\Server\Http\Message\Request
*/
public $request;
/**
* swoole 响应对象
* @var \Imi\Server\Http\Message\Response
*/
public $response;
}
close
事件参数：
class CloseEventParam extends EventParam
{
/**
* 服务器对象
* @var \Imi\Server\Base
*/
public $server;
/**
* 客户端连接的标识符
* @var int
*/
public $fd;
/**
* 来自那个reactor线程
*
* @var int
*/
public $reactorID;
}
WebSocket Server
handShake
握手事件
事件参数：
class HandShakeEventParam extends EventParam
{
/**
* swoole 请求对象
* @var \Imi\Server\Http\Message\Request
*/
public $request;
/**
* swoole 响应对象
* @var \Imi\Server\Http\Message\Response
*/
public $response;
}
open
握手完成后打开连接事件
事件参数：
class OpenEventParam extends EventParam
{
/**
* 服务器对象
*
* @var \Imi\Server\Base
*/
public $server;
/**
* 客户端连接的标识符.
*
* @var \Imi\Server\Http\Message\Request
*/
public $request;
}
message
事件参数：
class MessageEventParam extends EventParam
{
/**
* 服务器对象
* @var \Imi\Server\Base
*/
public $server;
/**
* swoole 数据帧对象
* @var \swoole_websocket_frame
*/
public $frame;
}
close
事件参数：
class CloseEventParam extends EventParam
{
/**
* 服务器对象
* @var \Imi\Server\Base
*/
public $server;
/**
* 客户端连接的标识符
* @var int
*/
public $fd;
/**
* 来自那个reactor线程
*
* @var int
*/
public $reactorID;
}
TCP Server
connect
事件参数：
class ConnectEventParam extends EventParam
{
/**
* 服务器对象
* @var \Imi\Server\Base
*/
public $server;
/**
* 客户端连接的标识符
* @var int
*/
public $fd;
/**
* Reactor线程ID
* @var int
*/
public $reactorID;
}
receive
事件参数：
class ReceiveEventParam extends EventParam
{
/**
* 服务器对象
* @var \Imi\Server\Base
*/
public $server;
/**
* 客户端连接的标识符
* @var int
*/
public $fd;
/**
* Reactor线程ID
* @var int
*/
public $reactorID;
/**
* 接收到的数据
*
* @var string
*/
public $data;
}
close
事件参数：
class CloseEventParam extends EventParam
{
/**
* 服务器对象
* @var \Imi\Server\Base
*/
public $server;
/**
* 客户端连接的标识符
* @var int
*/
public $fd;
/**
* 来自那个reactor线程
*
* @var int
*/
public $reactorID;
}
BufferFull
事件参数：
class BufferEventParam extends EventParam
{
/**
* 服务器对象
* @var \Imi\Server\Base
*/
public $server;
/**
* 客户端连接的标识符
* @var int
*/
public $fd;
}
BufferEmpty
事件参数：
class BufferEventParam extends EventParam
{
/**
* 服务器对象
* @var \Imi\Server\Base
*/
public $server;
/**
* 客户端连接的标识符
* @var int
*/
public $fd;
}
UDP Server
packet
class PacketEventParam extends EventParam
{
/**
* 服务器对象
* @var \Imi\Server\Base
*/
public $server;
/**
* 数据
* @var string
*/
public $data;
/**
* 客户端信息
*
* @var array
*/
public $clientInfo;
}