今天徒儿让我帮忙实现一个类似kangle这样的进程监控器，中间用到了php-fpm的status监听页，linux的进程查询指令。

在阅读本文章之前，请先确保你会开启php-fpm的status监听功能，如若不会请参考这篇文章：[《LNMP下php-fpm开启status监听页的正确步骤》](https://blog.junphp.com/details/310.jsp "《LNMP下php-fpm开启status监听页的正确步骤》")

进程基本的信息都可以通过php-fpm的status页获取到，但是进程对应来源的终端IP却没法获取到，在linux中，如果要通过PID直接查询终端地址，只能安装`lsof`命令，又或者是使用`root`权限执行`netstat -np`命令，因为PHP文件本身就是在php-fpm进程之一，所以就算用`exec`函数执行`netstat -np`，也只能获取到对应的父进程终端信息，而无法获取到子进程终端信息。

经过半天的思考，最终想到了一个折中的方法，就是用`netstat -np`命令先查出父进程，然后再通过`ps -eo user,pid,ppid,c,stime,time,size,rss,nice,stat,cmd`命令查出所有进程列表，该列表里子进程会有对应父进程的ID，然后两者之间在匹配，最终成功获取到了子进程所对应的终端地址。

最终实现效果如下图：
![](https://blog.junphp.com/public/upload/20190425134703_137.png)

具体的class封装如下：
```php
<?php
// +----------------------------------------------------------------------
// | 抓取PHP-FPM status
// +----------------------------------------------------------------------
// | Copyright (c) 2018 https://blog.junphp.com All rights reserved.
// +----------------------------------------------------------------------
// | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )
// +----------------------------------------------------------------------
// | Author: 小黄牛 <1731223728@qq.com>
// +----------------------------------------------------------------------
class python {
    /*
     * PHP-FPM的监控地址
    */
    private static $url = 'http://你们域名或IP/status?full';
    /*
     * 结果集
    */
    private static $list = [];
    /*
     * 请求所携带的域名，自动识别
    */
    private static $domain;
    /*
     * 进程对应的IP地址
    */
    private static $ip = [];
    
    /**
     * 微信接口数据传输的万能函数
     * @todo 无
     * @author 小黄牛
     * @version v1.0.1
     * @deprecated 暂不弃用
     * @global 无
     * @param string $url 请求地址
     * @param mixed $dea 请求头，默认为空
     * @return mixed 请求返回内容
    */
	private static function https_curl($url, $head = null){
		$curl = curl_init();

curl_setopt($curl, CURLOPT_URL, $url);
		curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
		curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false);

if (!empty($head)){
            curl_setopt($curl, CURLOPT_HTTPHEADER, $head);
		}

curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
		$response = curl_exec($curl);
		curl_close($curl);
		return $response;
    }

/**
     * 开始抓取
     * @todo 无
     * @author 小黄牛
     * @version v1.0.1
     * @deprecated 暂不弃用
     * @global 无
     * @return void
    */
    public static function run() {
        self::OS();
        self::$domain = self::getUrl();
        
        $res = self::https_curl(self::$url);
        $array = explode('************************', $res);

foreach ($array as $k=>$v) {
            // 处理内容
            self::main($v);
        }
        
        return self::$list;
    }

/**
     * 杀死子进程
     * @todo 无
     * @author 小黄牛
     * @version v1.0.1
     * @deprecated 暂不弃用
     * @global 无
     * @param string $pid 子进程ID
     * @return string
    */
    public static function kill($pid) {
        if (function_exists('exec') == false) return false;
        
        exec('kill -9 '.$pid, $retval, $status);
        if ($status == 0) return true;
        
        return false;
    }

/**
     * 秒转天数
     * @todo 无
     * @author 小黄牛
     * @version v1.1.8 + 2019.04.01
     * @deprecated 暂不弃用
     * @global 无
     * @param int $time
     * @return void
    */
    public static function getDate($time) {
        $d = floor($time / (3600*24));
        $h = floor(($time % (3600*24)) / 3600);
        $m = floor((($time % (3600*24)) % 3600) / 60);
        if ($d>'0') {
            return $d.'天'.$h.'小时'.$m.'分';
        } else {
            if ($h!='0') {
                return $h.'小时'.$m.'分';
            } else {
                return $m.'分';
            }
        }
    }

/**
     * 处理内容
     * @todo 无
     * @author 小黄牛
     * @version v1.0.1
     * @deprecated 暂不弃用
     * @global 无
     * @param string $string
     * @return void
    */
    private static function main($string) {
        $array = explode("\n", $string);
        $list = [];
        foreach ($array as $k=>$v) {
            if (empty($v)) continue;
            
            if (stripos($v, 'start time:') !== false) {
                $v = ltrim($v, 'start time:');
                $v = explode(' ', $v);
                $v = $v[0];
                $v = explode(':', $v);
                $date = self::getTime($v);
                $list['start_time'] = $date;
            } else {
                $v = explode(':', $v);
                $key = str_replace(' ', '_', $v[0]);
                $content = str_replace(' ', '', $v[1]);
                switch ($content) {
                    case 'Running'; $content = '接收'; break;
                    case 'Idle'; $content = '空闲'; break;
                }
                if ($key == 'request_URI' && stripos($content, '//') === false) {
                    $content = self::$domain.$content;
                } else if ($key == 'last_request_memory') {
                    $content = self::formatsize($content);
                } else if ($key == 'pid') {
                    $list['ip'] = self::getIp($content);
                }
                
                $list[$key] = $content;
            }
        }
        self::$list[] = $list;
    }

/**
     * linux的日期转换
     * @todo 无
     * @author 小黄牛
     * @version v1.0.1
     * @deprecated 暂不弃用
     * @global 无
     * @param string $date
     * @return string
    */
    private static function getTime($date) {
        $arr = array_reverse(explode('/', $date[0]));

if ($arr[1] == 'Sept') {
            $arr[1] = '08';
        } else {
            $vif = [
                'Jan'=>'01',
                'Feb'=>'02',
                'Mar'=>'03',
                'Apr'=>'04',
                'May'=>'05',
                'Jun'=>'06',
                'Jul'=>'07',
                'Aug'=>'08',
                'Sep'=>'09',
                'Oct'=>'10',
                'Nov'=>'11',
                'Dec'=>'12',
            ];
            if (!isset($vif[$arr[1]])) die('没有收录到该日期关键词：'.$arr[1]);
            $arr[1] = $vif[$arr[1]];
        }

return $arr[0].'-'.$arr[1].'-'.$arr[2].' '.$date[1].':'.$date[2].':'.$date[3];
    }

/**
     * 判断是否Linux环境
     * @todo 无
     * @author 小黄牛
     * @version v1.0.1
     * @deprecated 暂不弃用
     * @global 无
     * @return bool
    */
    private static function OS(){
        if (DIRECTORY_SEPARATOR != '/') die('只能在linux环境下运行');
    }

/**
     * 判断是否SSL协议
     * @todo 无
     * @author 小黄牛
     * @version v1.0.1
     * @deprecated 暂不弃用
     * @global 无
     * @return string
    */
    private static function getUrl() {
        $url = $_SERVER['HTTP_HOST'];
        if (stripos($url, '//') !== false) return $url;

if (isset($_SERVER['HTTPS']) && ('1' == $_SERVER['HTTPS'] || 'on' == strtolower($_SERVER['HTTPS']))) {
            return 'https://'.$url;
        } elseif(isset($_SERVER['SERVER_PORT']) && ('443' == $_SERVER['SERVER_PORT'] )) {
            return 'https://'.$url;
        }
        return 'http://'.$url;
    }

/**
     * 内存单位转换
     * @todo 无
     * @author 小黄牛
     * @version v1.0.1
     * @deprecated 暂不弃用
     * @global 无
     * @param int $size 内存数
     * @return int
    */
    private static function formatsize($size) {
        $units = array(' B', ' KB', ' MB', ' GB', ' TB'); 
        for ($i = 0; $size >= 1024 && $i < 4; $i++) $size /= 1024; 
        return round($size, 2).$units[$i]; 
    }

/**
     * 获取来源IP
     * @todo 无
     * @author 小黄牛
     * @version v1.0.1
     * @deprecated 暂不弃用
     * @global 无
     * @param string $pid 子进程ID
     * @return string
    */
    private static function getIp($pid) {
        if (function_exists('exec') == false) return false;
        
        if (count(self::$ip) <= 0) {
            exec('netstat -np', $retval, $status);
            if ($status == 0) {
                $list = [];
                foreach ($retval as $k=>$v) {
                    $v = preg_replace ( "/\s(?=\s)/","\\1", $v);
                    $arr = explode(' ', $v);
                    // 这里只保留了TCP的进程信息，其他进程信息也需要的话，自行扩展
                    $in_array = [
                        'tcp', 'tcp6', 'upd', 'upd6'
                    ];

if (in_array($arr[0], $in_array)) {
                        // 里面是为了拿到进程号
                        $array = explode('/', $arr[6]);
                        if (count($array) > 1) {
                            $list[$array[0]] = $arr[4];
                        }
                    }
                }
            }

$list2 = [];
            # 同为php-fpm是没权限的，所以需要查询父进程
            exec('ps -eo user,pid,ppid,c,stime,time,size,rss,nice,stat,cmd', $retval2, $status2);
            if ($status2 == 0) {
                foreach ($retval2 as $k => $v) {
                    $v = preg_replace ( "/\s(?=\s)/","\\1", $v);
                    $arr = explode(' ', $v);
                    if (stripos($v, 'netstat -nao') !== false) {
                        $pid = $arr[2];
                        $ppid = $arr[1];
                        if (!empty($list[$ppid])) {
                            $list2[$pid] = $list[$ppid];
                        }
                    }
                }
            }

self::$ip = $list2;
        }

return self::$ip[$pid];
    }
}
```

demo代码如下：
```php
<?php
require_once 'python.php';

$list = python::run();
if (!empty($_POST['pid'])) {
    $status = python::kill($_POST['pid']);

if ($status) {
        echo 1;exit;
    }
    echo 2;exit;
}

$head = array_shift($list);
?>

<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Strict//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd">
<html xmlns="http://www.w3.org/1999/xhtml">
<head>
    <title>PHP-FPM 监控页</title>
    <style>
    body,html{margin:0;padding:0;background: #f1f2f7; font-family: "微软雅黑";font-size: 16px;}
    .card-header {padding: .75rem 1.25rem;margin-bottom: 0;background-color: #fff;border-bottom: 1px solid rgba(0,0,0,.125);width:100%;}
    .card-title {margin-bottom: .75rem;}
    .table {width: 100%;margin-bottom: 1rem;background-color: transparent;}
    .table td {color: #343a40;font-size: 14px;font-weight: 600;vertical-align: middle;}
    .table th, .table td {border: none;border-bottom: 1px solid #e8e9ef;color: #868e96;font-size: 12px;font-weight: normal;padding: .75em 1.25em;}
    .header{width: 400px;text-align: left;}
    .header th{background: #fff;border-color: #fff;width: 170px;}
    .content td, .content th{text-align: left;}
    .content td{background:#fff}
    .badge-complete {background: #00c292;}
    .badge {display: inline-block;padding: 10PX;font-size:13px; line-height: 1;text-align: center;white-space: nowrap;vertical-align: baseline;border-radius: .25rem;text-decoration: none;}
    </style>
    <script src="http://www.jq22.com/jquery/jquery-1.10.2.js"></script>

</head>
<body>

<div>
    <div class="card-header">
        <strong class="card-title">PHP-FPM 说明</strong>
    </div>
    <table class="table header">
        <tr><th>进程池名称：</th><td><?php echo $head['pool'];?></td></tr>
        <tr><th>进程管理方式：</th><td><?php echo $head['process_manager'];?></td></tr>
        <tr><th>启动日期：</th><td><?php echo $head['start_time'];?></td></tr>
        <tr><th>运行时长：</th><td><?php echo python::getDate($head['start_since']);?></td></tr>
        <tr><th>当前进程池接受的请求数：</th><td><?php echo $head['accepted_conn'];?></td></tr>
        <tr><th>请求等待队列：</th><td><?php echo $head['listen_queue'];?></td></tr>
        <tr><th>等待队列峰值：</th><td><?php echo $head['max_listen_queue'];?></td></tr>
        <tr><th>socket等待队列长度：</th><td><?php echo $head['listen_queue_len'];?></td></tr>
        <tr><th>空闲进程数量：</th><td><?php echo $head['idle_processes'];?></td></tr>
        <tr><th>活跃进程数量：</th><td><?php echo $head['active_processes'];?></td></tr>
        <tr><th>总进程数量：</th><td><?php echo $head['total_processes'];?></td></tr>
        <tr><th>最大的活跃进程数量：</th><td><?php echo $head['max_active_processes'];?></td></tr>
        <tr><th>达到进程最大数量限制的次数：</th><td><?php echo $head['max_children_reached'];?></td></tr>
        <tr><th>缓慢请求的数量：</th><td><?php echo $head['slow_requests'];?></td></tr>
    </table>
</div>

<div>
    <div class="card-header">
        <strong class="card-title">进程列表</strong>
    </div>
    <table class="table content">
        <tr>
            <th>进程ID</th>
            <th>状态</th>
            <th>进程启动日期</th>
            <th>进程运行时长</th>
            <th>请求方法</th>
            <th>请求地址</th>
            <th>来源IP</th>
            <th>用户</th>
            <th>PHP脚本</th>
            <th> 最后一个请求CPU使用率(单核)</th>
            <th>上一个请求使用的内存</th>
            <th>操作</th>
        </tr>
        <?php foreach ($list as $k=>$v) { ?>
        <tr id="del-<?php echo $v['pid'];?>">
            <td><?php echo $v['pid'];?></td>
            <td><?php echo $v['state'];?></td>
            <td><?php echo $v['start_time'];?></td>
            <td><?php echo python::getDate($v['start_since']);?></td>
            <td><?php echo $v['request_method'];?></td>
            <td><?php echo $v['request_URI'];?></td>
            <td><?php echo $v['ip'];?></td>
            <td><?php echo $v['user'];?></td>
            <td><?php echo $v['script'];?></td>
            <td><?php echo $v['last_request_cpu'];?>%</td>
            <td><?php echo $v['last_request_memory'];?></td>
            <td>
                <a href='javascript:del("<?php echo $v['pid'];?>");' class="badge badge-complete" style="color:#fff">杀死进程</a>
            </td>
        </tr>
        <?php } ?>
    </table>
</div>

注意：如果不开放`exec`函数，则无法获取到子进程所对应的终端IP，但不影响该class正常的使用。

源码下载地址：[PHP-FPM进程监控器.zip](https://blog.junphp.com/github/PHP-FPM进程监控器.zip "PHP-FPM进程监控器.zip")

已有0条评论

添加新评论☺

如果认为本文对您有所帮助请赞助本站

支付宝扫一扫赞助

已有0条评论

添加新评论☺