\GatewayWorkerBusinessWorker

runAll()

runAll() : void

Run all worker instances.

getAllWorkers()

getAllWorkers() : array

Get all worker instances.

Returns

getEventLoop()

getEventLoop() : \Workerman\Events\EventInterface

Get global event-loop instance.

Returns

signalHandler()

signalHandler(integer  $signal) 

Signal handler.

Parameters

resetStd()

resetStd() 

Redirect standard input and output.

Throws

\Exception

getStartFilesForWindows()

getStartFilesForWindows() : array

Get start files for windows.

Returns

forkOneWorkerForWindows()

forkOneWorkerForWindows(string  $start_file) 

Fork one worker process.

Parameters

checkWorkerStatusForWindows()

checkWorkerStatusForWindows() : void

check worker status for windows.

setUserAndGroup()

setUserAndGroup() : void

Set unix user and group for current process.

stopAll()

stopAll() : void

Stop.

checkIfChildRunning()

checkIfChildRunning() 

check if child processes is really running

getStatus()

getStatus() : \Workerman\number

Get process status.

Returns

getGracefulStop()

getGracefulStop() : boolean

If stop gracefully.

Returns

checkErrors()

checkErrors() : void

Check errors when current process exited.

log()

log(string  $msg) : void

Log.

Parameters

safeEcho()

safeEcho(  $msg, boolean  $decorated = false) : boolean

Safe Echo.

Parameters

Returns

__construct()

__construct(string  $socket_name = '', array  $context_option = array()) 

构造函数

Parameters

listen()

listen() 

Listen.

Throws

\Exception

unlisten()

unlisten() : void

Unlisten.

pauseAccept()

pauseAccept() : void

Pause accept new connections.

resumeAccept()

resumeAccept() : void

Resume accept new connections.

getSocketName()

getSocketName() : string

Get socket name.

Returns

run()

run() : void

Run worker instance.

stop()

stop() : void

Stop current worker instance.

acceptConnection()

acceptConnection(resource  $socket) : void

Accept a connection.

Parameters

acceptUdpConnection()

acceptUdpConnection(resource  $socket) : boolean

For udp package.

Parameters

Returns

connectToRegister()

connectToRegister() : void

连接服务注册中心

onRegisterConnectionMessage()

onRegisterConnectionMessage(  $register_connection,   $data) : void

当注册中心发来消息时

Parameters

onGatewayMessage()

onGatewayMessage(\Workerman\Connection\TcpConnection  $connection, mixed  $data) 

当 gateway 转发来数据时

Parameters

onGatewayClose()

onGatewayClose(\Workerman\Connection\TcpConnection  $connection) : void

当与 Gateway 的连接断开时触发

Parameters

tryToConnectGateway()

tryToConnectGateway(string  $addr) 

尝试连接 Gateway 内部通讯地址

Parameters

checkGatewayConnections()

checkGatewayConnections(array  $addresses_list) 

检查 gateway 的通信端口是否都已经连 如果有未连接的端口，则尝试连接

Parameters

onConnectGateway()

onConnectGateway(\Workerman\Connection\TcpConnection  $connection) : void

当连接上 gateway 的通讯端口时触发 将连接 connection 对象保存起来

Parameters

onGatewayError()

onGatewayError(\Workerman\Connection\TcpConnection  $connection, integer  $error_no, string  $error_msg) 

当与 gateway 的连接出现错误时触发

Parameters

getAllGatewayAddresses()

getAllGatewayAddresses() : array

获取所有 Gateway 内部通讯地址

Returns

timeoutHandler()

timeoutHandler(integer  $signal) 

业务超时回调

Parameters

Throws

\Exception

checkSapiEnv()

checkSapiEnv() : void

Check sapi.

init()

init() : void

Init.

initWorkers()

initWorkers() : void

Init All worker instances.

initId()

initId() 

Init idMap.

return void

getCurrentUser()

getCurrentUser() : string

Get unix user of current porcess.

Returns

displayUI()

displayUI() : void

Display staring UI.

parseCommand()

parseCommand() : void

Parse command.

formatStatusData()

formatStatusData() : string

Format status data.

Returns

installSignal()

installSignal() : void

Install signal handler.

reinstallSignal()

reinstallSignal() : void

Reinstall signal handler.

daemonize()

daemonize() 

Run as deamon mode.

Throws

\Exception

saveMasterPid()

saveMasterPid() 

Save pid.

Throws

\Exception

getEventLoopName()

getEventLoopName() : string

Get event loop name.

Returns

getAllWorkerPids()

getAllWorkerPids() : array

Get all pids of worker processes.

Returns

forkWorkers()

forkWorkers() : void

Fork some worker processes.

forkWorkersForLinux()

forkWorkersForLinux() : void

Fork some worker processes.

forkWorkersForWindows()

forkWorkersForWindows() : void

Fork some worker processes.

forkOneWorkerForLinux()

forkOneWorkerForLinux(\Workerman\Worker  $worker) 

Fork one worker process.

Parameters

Throws

\Exception

getId()

getId(integer  $worker_id, integer  $pid) : integer

Get worker id.

Parameters

Returns

setProcessTitle()

setProcessTitle(string  $title) : void

Set process name.

Parameters

monitorWorkers()

monitorWorkers() : void

Monitor all child processes.

monitorWorkersForLinux()

monitorWorkersForLinux() : void

Monitor all child processes.

monitorWorkersForWindows()

monitorWorkersForWindows() : void

Monitor all child processes.

exitAndClearAll()

exitAndClearAll() : void

Exit current process.

reload()

reload() : void

Execute reload.

writeStatisticsToStatusFile()

writeStatisticsToStatusFile() : void

Write statistics data to disk.

writeConnectionsStatisticsToStatusFile()

writeConnectionsStatisticsToStatusFile() : void

Write statistics data to disk.

getErrorType()

getErrorType(integer  $type) : string

Get error message by error code.

Parameters

Returns

onWorkerStart()

onWorkerStart() : void

当进程启动时一些初始化工作

onWorkerReload()

onWorkerReload(\Workerman\Worker  $worker) 

onWorkerReload 回调

Parameters

onWorkerStop()

onWorkerStop() : void

当进程关闭时一些清理工作

outputStream()

outputStream(null  $stream = null) : boolean|resource

Parameters

Returns