基于上一篇文章swoole+tp5异步多线程，发现很多问题，所以深入理解一下swoole的进程模型
想探讨一下swoole，swoole在大流量生产环境下需要哪些特别注意的地方， 求指导，联系我就可以
运行环境linux 服务开启命令 php think Tcp
namespace app\swoole\command;
use app\common\cache\Redis;
use think\console\Command;
use think\console\Input;
use think\console\Output;
use think\Db;
use think\Log;
class Tcp extends Command{
TP5命令行使用方法，手册可以查到，原理是加载文件并执行文件
protected function configure(){
$this->setName('Tcp')->setDescription('OK ');
}
public function execute(Input $input, Output $output){
参数配置
$serv = new \swoole_server("0.0.0.0", 9501);
$serv->set([
'reactor_num' => 1,//同服务器核心数
'worker_num' => 2,//同服务器核心数或1--4倍服务器核心数
'task_worker_num' => 4,//当task繁忙导致server没有响应请求时，可以适当增加num，具体根据官方文档和试运行情况修改
'backlog' => 128,
'daemonize' => 0,//加入此参数后，执行php server.php将转入后台作为守护进程运行
'max_conn' => 10000,//此参数用来设置Server最大允许维持多少个tcp连接。超过此数量后，新进入的连接将被拒绝。
'max_request' => 2000,//此参数表示worker进程在处理完n次请求后结束运行。manager会重新创建一个worker进程。此选项用来防止worker进程内存溢出。
// 'log_file' => '/data/log/Swoole.log',//指定swoole错误日志文件。在swoole运行期发生的异常信息会记录到这个文件中。默>认会打印到屏幕。
'heartbeat_check_interval' => 30,//每隔多少秒检测一次，单位秒，Swoole会轮询所有TCP连接，将超过心跳时间的连接关闭掉
'heartbeat_idle_time' => 60,//TCP连接的最大闲置时间，单位s , 如果某fd最后一次发包距离现在的时间超过 heartbeat_idle_time必须大于或等于heartbeat_check_interval
'task_max_request' => 100,//设置task进程的最大任务数。一个task进程在处理完超过此数值的任务后将自动退出。这个参数是为了防止PHP进程内存溢出。如果不希望进程自动退出可以设置为0。
'open_cpu_affinity' => 1,//启用CPU亲和性设置。在多核的硬件平台中，启用此特性会将swoole的reactor线程/worker进程绑定到固定的一个核上。可以避免进程/线程的运行时在多个核之间互相切换，提高CPU Cache的命中率。
]);
常用方法的回调函数
$serv->on('start', function ($serv){
$this->timter();
echo "第一步master进程被拉起\n";
});
注意：如果manager进程和worker进程存在多个，请不要在manager和worker进程中开启全局任务
$serv->on('ManagerStart', function ($serv){
echo "第二步指定数目的调度reactor进程被拉起\n";
});
$serv->on('WorkerStart', function ($serv){
echo "第三步指定数目的worker进程被拉起\n";
});
$serv->on('WorkerStop', function (){
echo "第四步指定数目的worker进程被kill\n";
});
$serv->on('ManagerStop', function (){
echo "第五步指定数目的reactor进程被kill\n";
});
$serv->on('shutdown', function (){
echo "第六步master进程被kill\n";
});
$serv->on('receive', function($serv, $fd, $from_id, $data) {
if(intval($data) == '9501'){
$serv->reload();//触发worker进程的stop方法
// $serv->shutdown();//触发所有进程的stop及shutdown方法
return;
}
//投递异步任务
$task_id = $serv->task($data);
echo "任务".$task_id."开始\n";
});
//模拟处理异步任务
$serv->on('task', function ($serv, $task_id, $from_id, $data) {
$begin = intval($data);
$insertAll = [];
for ($i = $begin; $i < $begin+20000; $i++){
$insert = array();
$insert['value'] = $i.mt_rand($i, $i+1000);
$insert['addtime'] = time();
$insert['from_id'] = $from_id;
$insert['task_id'] = $task_id;
$insertAll[] = $insert;
// Db::table('test')->insert($insert);
}
Db::table('test')->insertAll($insertAll);
//返回任务执行的结果
unset($insertAll);
$serv->finish("ID".$task_id);
});
//处理异步任务的结果
$serv->on('finish', function ($serv, $task_id, $data) {
echo "任务".$data."结束\n";
});
$serv->start();
}
定时器调用方法
private function timter(){
\swoole_timer_tick(3000, function () {
//30S一次
echo 1;
$this->checkPort();
});
}
监听系统服务php-fpm/nginx/swoole
private function checkPort(){
$res = exec('netstat -apn | grep 9501');
if(!$res){
Log::write(time().'|9501|swooleStop');
$this->sendEmail();
}
$res = exec('netstat -apn | grep 9000');
if(!$res){
Log::write(time().'|9000|fpmStop');
$this->sendEmail();
}
$res = exec('netstat -apn | grep 80');
if(!$res){
Log::write(time().'|80|nginxStop');
$this->sendEmail();
}
}
邮件提醒
private function sendEmail(){
$email='xbc@gmail.com';
$subject='线上提醒';
$content='服务器出现问题请及时处理';
send_email($email,$subject,$content);
}
}
