- 事件
- imi 框架事件
- IMI.INITED
- IMI.APP.INIT
- IMI.LOAD_RUNTIME_INFO
- IMI.MAIN_SERVER.WORKER.START.APP
- IMI.SERVER.CREATE.BEFORE
- IMI.SERVER.CREATE.AFTER
- IMI.SERVERS.CREATE.BEFORE
- IMI.SERVERS.CREATE.AFTER
- IMI.INIT.WORKER.BEFORE
- IMI.INIT.WORKER.AFTER
- IMI.PROCESS.BEGIN
- IMI.PROCESS.END
- IMI.PROCESS_POOL.PROCESS.BEGIN
- IMI.PROCESS_POOL.PROCESS.END
- IMI.SERVER.GROUP.JOIN
- IMI.SERVER.GROUP.LEAVE
- IMI.REQUEST_CONTENT.CREATE
- IMI.REQUEST_CONTENT.DESTROY
- Swoole Server 全局事件
- Swoole Server 对象事件
- imi 框架事件
事件
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;
}
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;
}