swoole教程第二节:基础的通信实现-server篇-1

时间 2019-11-06

标签 swoole 教程第二基础通信实现 server 繁體版

原文原文链接

限于本人的技术水准不高，文章中若是有问题的地方但愿各位老爷们可以告诉我。
今天说swoole的通信。
这个swoole的官网首页已经有了例子，TCP Server和TCP Client
官网demo
实际上是四个步骤官网详细介绍php

构建Server对象html
设置运行时参数node
注册事件回调函数mysql
启动服务器react

其中设置运行参数看这里全部的设置参数
为了方便你们看，我本身作了整理，看看就好web

<?php
//文件名 setConfig.php
//来源http://wiki.swoole.com/wiki/page/274.html
//如下内容有不对的请告诉我，万分感谢
$setConfig = array();

// reactor线程数，reactor_num => 2，经过此参数来调节主进程内事件处理线程的数量，以充分利用多核。默认会启用CPU核数相同的数量。
// reactor_num通常设置为CPU核数的1-4倍，在swoole中reactor_num最大不得超过CPU核数*4。
// swoole的reactor线程是能够利用多核，如：机器有128核，那么swoole会启动128线程。每一个线程能都会维持一个EventLoop。线程之间是无锁的，
// 指令能够被128核CPU并行执行。考虑到操做系统调度存在必定程度的误差，能够设置为CPU核数*2，以便最大化利用CPU的每个核。
$setConfig['reactor_num']=2;




// 设置启动的worker进程数。
// 业务代码是全异步非阻塞的，这里设置为CPU的1-4倍最合理
// 业务代码为同步阻塞，须要根据请求响应时间和系统负载来调整
// 好比1个请求耗时100ms，要提供1000QPS的处理能力，那必须配置100个进程或更多。
// 但开的进程越多，占用的内存就会大大增长，并且进程间切换的开销就会愈来愈大。因此这里适立即可。不要配置过大。
// 每一个进程占用40M内存，那100个进程就须要占用4G内存
$setConfig['worker_num']=4;





// 设置worker进程的最大任务数。一个worker进程在处理完超过此数值的任务后将自动退出。这个参数是为了防止PHP进程内存溢出。
// 若是不但愿进程自动退出能够设置为0
// 当worker进程内发生致命错误或者人工执行exit时，进程会自动退出。主进程会从新启动一个新的worker进程来处理任务
$setConfig['max_request']=2000;





// 服务器程序，最大容许的链接数，如max_conn => 10000, 此参数用来设置Server最大容许维持多少个tcp链接。超过此数量后，新进入的链接将被拒绝。
// max_connection最大不得超过操做系统ulimit -n的值，不然会报一条警告信息，并重置为ulimit -n的值
// max_connection默认值为ulimit -n的值
// WARN    swServer_start_check: serv->max_conn is exceed the maximum value[100000].
// 此参数不要调整的过大，根据机器内存的实际状况来设置。Swoole会根据此数值一次性分配一块大内存来保存Connection信息
$setConfig['max_conn']=10000;











// 配置task进程的数量，配置此参数后将会启用task功能。因此swoole_server务必要注册onTask/onFinish2个事件回调函数。若是没有注册，服务器程序将没法启动。
// task进程是同步阻塞的，配置方式与worker同步模式一致。
// task进程内不能使用swoole_server->task方法
// task进程内不能使用mysql-async/redis-async/swoole_event等异步IO函数
$setConfig['task_worker_num']=2;








// 设置task进程与worker进程之间通讯的方式。
// 1, 使用unix socket通讯
// 2, 使用消息队列通讯
// 3, 使用消息队列通讯，并设置为争抢模式
// 设置为3后，task/taskwait将没法指定目标进程ID
$setConfig['task_ipc_mode']=3;




// 设置task进程的最大任务数。一个task进程在处理完超过此数值的任务后将自动退出。
// 这个参数是为了防止PHP进程内存溢出。若是不但愿进程自动退出能够设置为0。
// task_max_request默认为5000，受swoole_config.h的SW_MAX_REQUEST宏控制
// 1.7.17以上版本默认值调整为0，不会主动退出进程
$setConfig['task_max_request']=5000;








// 设置task的数据临时目录，在swoole_server中，若是投递的数据超过8192字节，
// 将启用临时文件来保存数据。这里的task_tmpdir就是用来设置临时文件保存的位置。
// 须要swoole-1.7.7+
$setConfig['task_tmpdir']="/tmp/tasl_tmpdir/";//路径我是随便写的







// 数据包分发策略。能够选择3种类型，默认为2
// 1，轮循模式，收到会轮循分配给每个worker进程
// 2，固定模式，根据链接的文件描述符分配worker。这样能够保证同一个链接发来的数据只会被同一个worker处理
// 3，抢占模式，主进程会根据Worker的忙闲状态选择投递，只会投递给处于闲置状态的Worker
// 4，IP分配，根据TCP/UDP链接的来源IP进行取模hash，分配给一个固定的worker进程。
// 能够保证同一个来源IP的链接数据总会被分配到同一个worker进程
// 5，UID分配，须要用户代码中调用$serv->bind() 将一个链接绑定1个uid。而后swoole根据UID的值分配到不一样的worker进程
// dispatch_mode 4,5两种模式，在 1.7.8以上版本可用
// dispatch_mode=1/3时，底层会屏蔽onConnect/onClose事件，缘由是这2种模式下没法保证onConnect/onClose/onReceive的顺序
// 非请求响应式的服务器程序，请不要使用模式1或3
// SWOOLE_BASE模式
// dispatch_mode 配置在BASE模式是无效的，由于BASE不存在投递任务。
// 当reactor收到客户端发来的数据后会当即回调onReceive，不须要投递Worker进程。
$setConfig['dispatch_mode']=2;










// 设置消息队列的KEY，仅在ipc_mode = 2或task_ipc_mode = 2时使用。
// 设置的Key仅做为队列的基数。此参数的默认值为ftok($php_script_file, 1)。实际使用的消息队列KEY为：
// recv数据消息队列KEY为 message_queue_key
// send数据消息队列KEY为 message_queue_key + 1
// task数据消息队列KEY为 message_queue_key + 2
// recv/send数据队列在server结束后，会自动销毁。
// task队列在server结束后不会销毁，从新启动程序后，task进程仍然会接着处理队列中的任务。
// 1.7.8之前的版本，KEY会+serv->master_pid。增长pid是为了防止服务器程序重启，致使复用上一次的消息队列数据，读取到错误的数据
$setConfig['message_queue_key']=2;








// 守护进程化。设置daemonize => 1时，程序将转入后台做为守护进程运行。长时间运行的服务器端程序必须启用此项。
// 若是不启用守护进程，当ssh终端退出后，程序将被终止运行。
// 启用守护进程后，标准输入和输出会被重定向到 log_file
// 若是未设置log_file，将重定向到 /dev/null，全部打印屏幕的信息都会被丢弃
$setConfig['daemonize']=1;





// Listen队列长度，如backlog => 128，此参数将决定最多同时有多少个等待accept的链接。
// 与php-fpm/apache等软件不一样，swoole并不依赖backlog来解决链接排队的问题。因此不须要设置太大的backlog参数。
$setConfig['backlog']= 128;




// log_file => '/data/log/swoole.log', 指定swoole错误日志文件。
// 在swoole运行期发生的异常信息会记录到这个文件中。默认会打印到屏幕。
// 注意log_file不会自动切分文件，因此须要按期清理此文件。
// 观察log_file的输出，能够获得服务器的各种异常信息和警告。
// log_file中的日志仅仅是作运行时错误记录，没有长久存储的必要。
// 开启守护进程模式后(daemonize => true)，标准输出将会被重定向到log_file。
// 在PHP代码中echo/var_dump/print等打印到屏幕的内容会写入到log_file文件
$setConfig['log_file']='/data/log/swoole.log';




// 启用心跳检测，此选项表示每隔多久轮循一次，单位为秒。
// 如 heartbeat_check_interval => 60，表示每60秒，遍历全部链接，若是该链接在60秒内，没有向服务器发送任何数据，此链接将被强制关闭。
// swoole_server并不会主动向客户端发送心跳包，而是被动等待客户端发送心跳。
// 服务器端的heartbeat_check仅仅是检测链接上一次发送数据的时间，若是超过限制，将切断链接。
// heartbeat_check仅支持TCP链接
$setConfig['heartbeat_check_interval']=60;


// 与heartbeat_check_interval配合使用。表示链接最大容许空闲的时间。如
// array(
// 'heartbeat_idle_time' => 600,
// 'heartbeat_check_interval' => 60,
// );
// 表示每60秒遍历一次，一个链接若是600秒内未向服务器发送任何数据，此链接将被强制关闭。
$setConfig['heartbeat_idle_time']=600;





// 打开EOF检测，此选项将检测客户端链接发来的数据，当数据包结尾是指定的字符串时才会投递给Worker进程。
// 不然会一直拼接数据包，直到超过缓存区或者超时才会停止。当出错时swoole底层会认为是恶意链接，丢弃数据并强制关闭链接。
// array(
// 'open_eof_check' => true, //打开EOF检测
// 'package_eof' => "\r\n", //设置EOF
// )
// 常见的Memcache/SMTP/POP等协议都是以\r\n结束的，就可使用此配置。
//开启后能够保证Worker进程一次性老是收到一个或者多个完整的数据包。

// EOF检测不会从数据中间查找eof字符串，因此Worker进程可能会同时收到多个数据包，
// 须要在应用层代码中自行explode("\r\n", $data) 来拆分数据包
// 1.7.15版本增长了open_eof_split，支持从数据中查找EOF，并切分数据
$setConfig['open_eof_check']=1;



// package_eof
// 与open_eof_check配合使用，设置EOF字符串。
// package_eof最大只容许传入8个字节的字符串
$setConfig['package_eof']="\r\n";






// open_eof_split
// 启用EOF自动分包。当设置open_eof_check后，底层检测数据是否以特定的字符串结尾来进行数据缓冲。
// 但默认只截取收到数据的末尾部分作对比。这时候可能会产生多条数据合并在一个包内。

// 启用open_eof_split参数后，底层会从数据包中间查找EOF，并拆分数据包。
// onReceive每次仅收到一个以EOF字串结尾的数据包。
// open_eof_split在1.7.15以上版本可用
$setConfig['open_eof_split']=1;



// 打开包长检测特性。包长检测提供了固定包头+包体这种格式协议的解析。
// 启用后，能够保证Worker进程onReceive每次都会收到一个完整的数据包。
$setConfig['open_length_check']=1;





// s ：有符号、主机字节序、2字节短整型
// S：无符号、主机字节序、2字节短整型
// n：无符号、网络字节序、2字节短整型
// N：无符号、网络字节序、4字节整型
// l：有符号、主机字节序、2字节短整型（小写L）
// L：无符号、主机字节序、2字节短整型（大写L）

$setConfig['package_length_type']='s';




// 设置最大数据包尺寸，开启open_length_check/open_eof_check/open_http_protocol等协议解析后。
// swoole底层会进行数据包拼接。这时在数据包未收取完整时，全部数据都是保存在内存中的。

// 因此须要设定package_max_length，一个数据包最大容许占用的内存尺寸。
// 若是同时有1万个TCP链接在发送数据，每一个数据包2M，那么最极限的状况下，就会占用20G的内存空间。

// open_length_check，当发现包长度超过package_max_length，将直接丢弃此数据，并关闭链接，不会占用任何内存。
// open_eof_check，由于没法事先得知数据包长度，因此收到的数据仍是会保存到内存中，持续增加。
// 当发现内存占用已超过package_max_length时，将直接丢弃此数据，并关闭链接
// open_http_protocol，GET请求最大容许8K，并且没法修改配置。
// POST请求会检测Content-Length，若是Content-Length超过package_max_length，将直接丢弃此数据，发送http 400错误，并关闭链接
// 此参数不宜设置过大，不然会占用很大的内存
$setConfig['package_max_length']=2;




// 启用CPU亲和性设置。在多核的硬件平台中，启用此特性会将swoole的reactor线程/worker进程绑定到固定的一个核上。
//能够避免进程/线程的运行时在多个核之间互相切换，提升CPU Cache的命中率。
// 使用taskset命令查看进程的CPU亲和设置：
// taskset -p 进程ID
// pid 24666's current affinity mask: f
// pid 24901's current affinity mask: 8
// mask是一个掩码数字，按bit计算每bit对应一个CPU核，若是某一位为0表示绑定此核，进程会被调度到此CPU上，为0表示进程不会被调度到此CPU。
// 示例中pid为24666的进程mask = f 表示未绑定到CPU，操做系统会将此进程调度到任意一个CPU核上。
// pid为24901的进程mask = 8，8转为二进制是 1000，表示此进程绑定在第4个CPU核上。
// 仅推荐在全异步非阻塞的Server程序中启用
$setConfig['open_cpu_affinity']=1;




// IO密集型程序中，全部网络中断都是用CPU0来处理，若是网络IO很重，CPU0负载太高会致使网络中断没法及时处理，那网络收发包的能力就会降低。
// 若是不设置此选项，swoole将会使用所有CPU核，底层根据reactor_id或worker_id与CPU核数取模来设置CPU绑定。
// 若是内核与网卡有多队列特性，网络中断会分布到多核，能够缓解网络中断的压力
// 此选项必须与open_cpu_affinity同时设置才会生效
// array('cpu_affinity_ignore' => array(0, 1))
// 接受一个数组做为参数，array(0, 1) 表示不使用CPU0,CPU1，专门空出来处理网络中断。
$setConfig['cpu_affinity_ignore']=array(0, 1);





// open_tcp_nodelay
// 启用open_tcp_nodelay，开启后TCP链接发送数据时会关闭Nagle合并算法，
// 当即发往客户端链接。在某些场景下，如http服务器，能够提高响应速度
$setConfig['open_tcp_nodelay']=1;





//启用tcp_defer_accept特性，能够设置为一个数值，表示当一个TCP链接有数据发送时才触发accept。
$setConfig['tcp_defer_accept']=5;




// 设置SSL隧道加密，设置值为一个文件名字符串，制定cert证书和key的路径。
$setConfig['ssl_cert_file']='/config/ssl.crt';
$setConfig['ssl_key_file']='/config//ssl.key';




// 设置worker/task子进程的所属用户。服务器若是须要监听1024如下的端口，
// 必须有root权限。但程序运行在root用户下，代码中一旦有漏洞，攻击者就能够以root的方式执行远程指令，风险很大。
// 配置了user项以后，可让主进程运行在root权限下，子进程运行在普通用户权限下。
// 此配置在swoole-1.7.9以上版本可用
// 仅在使用root用户启动时有效
$setConfig['user']='apache';
// 设置worker/task子进程的进程用户组。与user配置相同，此配置是修改进程所属用户组，提高服务器程序的安全性。
$setConfig['group']='www-data';
// 重定向Worker进程的文件系统根目录。此设置可使进程对文件系统的读写与实际的操做系统文件系统隔离。提高安全性
$setConfig['chroot']='/data/server/';







// 调整管道通讯的内存缓存区长度。swoole的reactor线程与worker进程之间使用unix socket进行通讯，
// 在收发大量数据的场景下，须要启用内存缓存队列。此函数能够修改内存缓存的长度。
// 此参数在1.7.17以上版本默认为32M，1.7.17如下版本默认为8M
$setConfig['pipe_buffer_size']=2;







// 此配置影响swoole 2个方面
// 数据发送缓存区
// 调整链接发送缓存区的大小。TCP通讯有拥塞控制机制，服务器向客户端发送大量数据时，并不能当即发出。这时发送的数据会存放在服务器端的内存缓存区内。此参数能够调整内存缓存区的大小。
// 若是发送数据过多，客户端阻塞，数据占满缓存区后Server会报以下错误信息：
// swFactoryProcess_finish: send failed, session#1 output buffer has been overflowed.
// swoole_server->send大小
// 调用 swoole_server->send， swoole_http_server->end/write，swoole_websocket_server->push 时，最大发送的数据不得超过 buffer_output_size 配置。
// buffer_output_size默认为2M，缓存区塞满后send将会失败
// 注意此函数不该当调整过大，避免拥塞的数据过多，致使吃光机器内存
// 开启大量worker进程时，将会占用worker_num * buffer_output_size 字节的内存
$setConfig['buffer_output_size']=2;//




// enable_unsafe_event
// swoole在配置dispatch_mode=1或3后，由于系统没法保证onConnect/onReceive/onClose的顺序，默认关闭了onConnect/onClose事件。

// 若是应用程序须要onConnect/onClose事件，而且能接受顺序问题可能带来的安全风险，
//能够经过设置 enable_unsafe_event = true，启用onConnect/onClose事件

// enable_unsafe_event配置在1.7.18以上版本可用

$setConfig['enable_unsafe_event']=1;




// swoole在配置dispatch_mode=1或3后，系统没法保证onConnect/onReceive/onClose的顺序，所以可能会有一些请求数据在链接关闭后，才能到达Worker进程。
// discard_timeout_request配置默认为true，表示若是worker进程收到了已关闭链接的数据请求，将自动丢弃。
// discard_timeout_request若是设置为false，表示不管链接是否关闭Worker进程都会处理数据请求。
$setConfig['discard_timeout_request']=1;

配置项目以后该说回调函数了，我也作了一些整理redis

<?php
//文件名 OnEvent.php
/// 来源 http://wiki.swoole.com/wiki/page/41.html
//不是全部回调都要写，由于有些回调函数须要有相关的配置项目开启才能生效
//这个文件的目的是告诉有哪些回调函数，用途是什么，以及观察swoole的触发流程
$serv->on('Start', function (swoole_server $server){//仅容许echo、打印Log、修改进程名称。不得执行其余操做。
// 已建立了manager进程
// 已建立了worker子进程
// 已监听全部TCP/UDP端口
// 已监听了定时器
// 接下来要执行
// 主Reactor开始接收事件，客户端能够connect到Server
    echo PHP_EOL;
    echo " start";
    echo PHP_EOL;
    var_dump($server);
    echo PHP_EOL;
});




$serv->on('Shutdown', function (swoole_server $server){
// 在此以前Swoole Server已进行了以下操做
// 已关闭全部线程
// 已关闭全部worker进程
// 已close全部TCP/UDP监听端口
// 已关闭主Rector
// 强制kill进程不会回调onShutdown，如kill -9
// 须要使用kill -15来发送SIGTREM信号到主进程才能按照正常的流程终止
     echo PHP_EOL;
    echo " shutdown";
    var_dump($server);

    echo PHP_EOL;
});




$serv->on('WorkerStart', function (swoole_server $server,  $worker_id){// 不能写 int $worker_id
//此事件在worker进程/task进程启动时发生。这里建立的对象能够在进程生命周期内使用
    echo PHP_EOL;
    echo " WorkerStart";
    echo PHP_EOL;
    var_dump($worker_id);
    echo PHP_EOL;
});




$serv->on('WorkerStop', function (swoole_server $server, int $worker_id){
//此事件在worker进程终止时发生。在此函数中能够回收worker进程申请的各种资源
// $worker_id是一个从0-$worker_num之间的数字，表示这个worker进程的ID
// $worker_id和进程PID没有任何关系
    echo PHP_EOL;
    echo " WorkerStop";
    var_dump($worker_id);
    echo PHP_EOL;
});





//定时器触发
$serv->on('Timer', function (swoole_server $server, int $interval) {
// $interval是定时器时间间隔，根据$interval的值来区分是哪一个定时器触发的。这里的定时器是由$serv->addtimer来添加的，是固定间隔循环触发的。
// onTimer中执行时间过长，会致使下一次定时延缓触发。如设定1秒的定时器，1秒后会触发onTimer，onTimer函数用时1.5s，那么第二次触发onTimer的时间为第3秒。中间第2秒的定时器会被丢弃
// onTimer回调函数若是要执行一个耗时操做，最好是使用$serv->task投递到task进程池中执行
    echo PHP_EOL;
    echo " Timer";
    var_dump($interval);
    echo PHP_EOL;
});





$serv->on('connect',function (swoole_server $server,  $fd,  $from_id){
// $server是swoole_server对象
// $fd是链接的文件描述符，发送数据/关闭链接时须要此参数
// $from_id来自那个Reactor线程
// $server是swoole_server对象
// $fd是链接的文件描述符，发送数据/关闭链接时须要此参数
// $from_id来自那个Reactor线程
// onConnect/onClose这2个回调发生在worker进程内，而不是主进程。
// UDP协议下只有onReceive事件，没有onConnect/onClose事件
    echo PHP_EOL;
    echo " connect";
    echo PHP_EOL;
    var_dump($fd);
    echo PHP_EOL;
    var_dump($from_id);
    echo PHP_EOL;
});




//接收到数据时回调此函数，发生在worker进程中
$serv->on('Receive',function (swoole_server $server,  $fd,  $from_id,  $data){
// $server，swoole_server对象
// $fd，TCP客户端链接的文件描述符
// $from_id，TCP链接所在的Reactor线程ID
// $data，收到的数据内容，多是文本或者二进制内容
//详情  http://wiki.swoole.com/wiki/page/50.html
    echo PHP_EOL;
    echo " Receive";
    echo PHP_EOL;
    var_dump($fd);
    echo PHP_EOL;
    var_dump($from_id);
    echo PHP_EOL;
    var_dump($data);
    echo PHP_EOL;
});





//接收到UDP数据包时回调此函数，发生在worker进程中。
$serv->on('Packet',function (swoole_server $server, string $data, array $client_info){
// $server，swoole_server对象
// $data，收到的数据内容，多是文本或者二进制内容
// $client_info，客户端信息包括address/port/server_socket 3项数据
// 服务器同时监听TCP/UDP端口时，收到TCP协议的数据会回调onReceive，收到UDP数据包回调onPacket
    echo PHP_EOL;
    echo " Packet";
    echo PHP_EOL;
    var_dump($data);
    echo PHP_EOL;
    var_dump($client_info);
    echo PHP_EOL;
});



//TCP客户端链接关闭后，在worker进程中回调此函数
$serv->on('Close',function (swoole_server $server, int $fd, int $from_id){
// $server是swoole_server对象
// $fd是链接的文件描述符
// $from_id来自那个reactor线程
// 注意：这里回调onClose时表示客户端链接已经关闭，因此无需执行$server->close($fd)。代码中执行$serv->close($fd) 会抛出PHP错误告警。
    echo PHP_EOL;
    echo " Close";
    echo PHP_EOL;
    var_dump($fd);
    echo PHP_EOL;
    var_dump($from_id);
    echo PHP_EOL;
});



//在task_worker进程内被调用。worker进程可使用swoole_server_task函数向task_worker进程投递新的任务
$serv->on('Task',function (swoole_server $serv, int $task_id, int $from_id, string $data){
// $task_id是任务ID，由swoole扩展内自动生成，用于区分不一样的任务。
//$task_id和$from_id组合起来才是全局惟一的，不一样的worker进程投递的任务ID可能会有相同
// $from_id来自于哪一个worker进程
// $data 是任务的内容
// 返回执行结果到worker进程
// 1.7.2以上的版本，在onTask函数中 return字符串，表示将此内容返回给worker进程。
//worker进程中会触发onFinish函数，表示投递的task已完成。
    echo PHP_EOL;
    echo " Task";
    echo PHP_EOL;
    var_dump($task_id);
    echo PHP_EOL;
    var_dump($from_id);
    echo PHP_EOL;
    var_dump($data);
    echo PHP_EOL;
});





//当worker进程投递的任务在task_worker中完成时，task进程会经过swoole_server->finish()方法将任务处理的结果发送给worker进程。
$serv->on('Finish',function (swoole_server $serv, int $task_id, string $data){
// $task_id是任务的ID
// $data是任务处理的结果内容
// task进程的onTask事件中没有调用finish方法或者return结果。worker进程不会触发onFinish
    echo PHP_EOL;
    echo " Finish";
    echo PHP_EOL;
    var_dump($task_id);
    echo PHP_EOL;
    var_dump($data);
    echo PHP_EOL;
});



//当工做进程收到由sendMessage发送的管道消息时会触发onPipeMessage事件。worker/task进程均可能会触发onPipeMessage事件
$serv->on('PipeMessage',function (swoole_server $server, int $from_worker_id, string $message){
    echo PHP_EOL;
    echo " PipeMessage";
    echo PHP_EOL;
    var_dump($from_worker_id);
    echo PHP_EOL;
    var_dump($message);
    echo PHP_EOL;
});



//当worker/task_worker进程发生异常后会在Manager进程内回调此函数
$serv->on('WorkerError',function (swoole_server $serv, int $worker_id, int $worker_pid, int $exit_code){
// $worker_id是异常进程的编号
// $worker_pid是异常进程的ID
// $exit_code退出的状态码，范围是 1 ～255
// 此函数主要用于报警和监控，一旦发现Worker进程异常退出，
// 那么颇有多是遇到了致命错误或者进程CoreDump。经过记录日志或者发送报警的信息来提示开发者进行相应的处理。
    echo PHP_EOL;
    echo " WorkerError";
    echo PHP_EOL;
    var_dump($from_worker_id);
    echo PHP_EOL;
    var_dump($worker_pid);
    echo PHP_EOL;
    var_dump($exit_code);
    echo PHP_EOL;
});





//当管理进程启动时调用它，函数原型：
$serv->on('ManagerStart',function (swoole_server $serv){
// 在这个回调函数中能够修改管理进程的名称。
// 注意manager进程中不能添加定时器
// manager进程中能够调用task功能
    echo PHP_EOL;
    echo " ManagerStart";
    echo PHP_EOL;
});





//当管理进程结束时调用它，函数原型：
$serv->on('ManagerStop',function (swoole_server $serv){
    echo PHP_EOL;
    echo " ManagerStop";
    echo PHP_EOL;
});

呼，终于写完了，我整理这两个文件的目的是方便你们本身测试，官网有文档，我作的只是代码化。算法

当我把这些所有看一遍以后，我对swoole_server有了大致印象，好比worker，好比task等等。
来，上个图sql

图片看不到，看这里apache

http://wiki.swoole.com/wiki/page/2.html

下面开始我最喜欢的环节，跑程序

server.php

<?php
$host  = "127.0.0.1";
$port  = 9501;//$port监听的端口，如9501，监听小于1024端口须要root权限，若是此端口被占用server->start时会失败
$serv = new swoole_server( $host,  $port);
$serv->set(array(
     'worker_num' => 3,   //工做进程数量
 ));
include 'OnEvent.php';
$serv->start();

client.php

<?php
$client = new swoole_client(SWOOLE_SOCK_TCP, SWOOLE_SOCK_ASYNC);
//设置事件回调函数
$client->on("connect", function($cli) {
    $cli->send("hello world\n");
});
$client->on("receive", function($cli, $data){
    echo "Received: ".$data."\n";
});
$client->on("error", function($cli){
    echo "Connect failed\n";
});
$client->on("close", function($cli){
    echo "Connection close\n";
});
//发起网络链接
$client->connect('127.0.0.1', 9501, 0.5);

我在server.php里引入了OnEvent.php（我写上了全部的回调函数）
我想看看，server作了什么
来，开始

php server.php

运行结果

start
object(swoole_server)#1 (4) {
  ["connections"]=>
  object(swoole_connection_iterator)#2 (0) {
  }
  ["setting"]=>
  array(5) {
    ["worker_num"]=>
    int(3)
    ["task_worker_num"]=>
    int(0)
    ["pipe_buffer_size"]=>
    int(33554432)
    ["buffer_output_size"]=>
    int(2097152)
    ["max_connection"]=>
    int(65536)
  }
  ["master_pid"]=>
  int(7418)
  ["manager_pid"]=>
  int(7420)
}


 WorkerStart
int(0)


 WorkerStart
int(1)


 ManagerStart

 WorkerStart
int(2)

程序并无死，上面的是回调函数里面的输出
server先是执行start，而后按照设置的worker_num的数目建立worker触发WorkerStart的回调，同时建立Manager执行了ManagerStart
咱们再看看上面的两个图片，结合server的运行结果，想必会更多一些了解
我以为两个图画的很好，让我再看一遍。

好的，顺便的，看到了server的属性

object(swoole_server)#1 (4) {
  ["connections"]=>//看这里 http://wiki.swoole.com/wiki/page/427.html
  object(swoole_connection_iterator)#2 (0) {
  }
  ["setting"]=>//看这里  http://wiki.swoole.com/wiki/page/157.html
  array(5) {
    ["worker_num"]=>
    int(3)
    ["task_worker_num"]=>
    int(0)
    ["pipe_buffer_size"]=>
    int(33554432)
    ["buffer_output_size"]=>
    int(2097152)
    ["max_connection"]=>
    int(65536)
  }
  ["master_pid"]=>//看这里   http://wiki.swoole.com/wiki/page/154.html
  int(7418)
  ["manager_pid"]=>//看这里  http://wiki.swoole.com/wiki/page/155.html
  int(7420)
}

由于配置的没写task，而且当前没有客户端连上来，这里还有一些属性没有展现出来
你们详细的看这里属性列表

好的，让咱们运行客户端

php client.php

connect
int(1) //  这个是 fd

int(0)// 这个是 from_id


 Receive
int(1)//  这个是 fd

int(0)// 这个是 from_id

string(12) "hello world
"// 这个是 data

这里贴出来 server端多出来的内容

补充一下:对一个对象使用get_class_methods能够得到对象的全部方法，今天忘了怎么获取客户端ip地址了，用这个查了一下，是server的connection_info方法

好的，但愿你们用多测试测试，观察server的变化，体会swoole的server调用
结合运行结果来看流程图

今天暂时到这里，哪里我说的不对，请你们指正，我也是一个学习中的人