swoole_server->addProcess
���һ���û��Զ���Ĺ������̡�
bool swoole_server->addProcess(swoole_process $process);
- $processΪswoole_process����ע�ⲻ��Ҫִ��start����swoole_server��ʱ���Զ��������̣���ִ��ָ�����ӽ��̺���
- �������ӽ��̿��Ե���$server�����ṩ�ĸ�����������connection_list/connection_info/stats
- ��worker/task�����п��Ե���$process�ṩ�ķ������ӽ��̽���ͨ��
- ���û��Զ�������п��Ե���$server->sendMessage��worker/task����ͨ��
�˺���ͨ�����ڴ���һ������Ĺ������̣����ڼ�ء��ϱ������������������
�ӽ��̻��йܵ�Manager���̣����������������manager���̻����´���һ��
�ӽ����ڲ���ʹ��swoole_server->task/taskwait�ӿ�
�˺�����swoole-1.7.9���ϰ汾����
ʾ������
$server = new swoole_server('127.0.0.1', 9501);
$process = new swoole_process(function($process) use ($server) {
while (true) {
$msg = $process->read();
foreach($server->connections as $conn) {
$server->send($conn, $msg);
}
}
});
$server->addProcess($process);
$server->on('receive', function ($serv, $fd, $from_id, $data) use ($process) {
//Ⱥ���յ�����Ϣ
$process->write($data);
});
$server->start();