$ip = 'text://127.0.0.1:' . Cfg::tp_gateway_port;
$task_connection = new AsyncTcpConnection( $ip );
// 任务及参数数据
$task_data = array(
'function' => $funcName ,
'args' => $args ,
);
// 发送数据
$task_connection->send( json_encode( $task_data ) );
// 异步获得结果
$task_connection->onMessage = function( $task_connection , $task_result ) use ( $funcName , $connection ) {
};
// 执行异步链接
$task_connection->connect();
现在这样到events中处理是随机发送到一个进程的,如何指定发送到某个进程?
假如进程id为1中启动了一个定时器,需要这样去停止这个定时器,结果随机发送到了events的id为2的进程中,就没法停止。有什么好的解决办法吗?
路由试试