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(); |