PHP 抓取监控报警

wen PHP项目 2026-08-10 146

本文目录导读：

PHP 抓取监控报警

基础系统监控类
Web服务监控类
数据库监控类
应用日志监控
报警通知渠道
主监控程序
使用示例
配置文件

我来为您提供一个完整的PHP监控报警系统示例,包含多种监控场景：

基础系统监控类

<?php
/**
 * 系统资源监控类
 */
class SystemMonitor {
    private $thresholds;
    private $alertChannel;
    public function __construct($thresholds = [], $alertChannel = null) {
        $this->thresholds = array_merge([
            'cpu_usage' => 80,        // CPU使用率阈值
            'memory_usage' => 80,     // 内存使用率阈值
            'disk_usage' => 85,       // 磁盘使用率阈值
            'load_average' => 10      // 负载均衡阈值
        ], $thresholds);
        $this->alertChannel = $alertChannel ?? new AlertChannel();
    }
    /**
     * 检查CPU使用率
     */
    public function checkCpuUsage() {
        $cpuUsage = $this->getCpuUsage();
        $threshold = $this->thresholds['cpu_usage'];
        if ($cpuUsage > $threshold) {
            $this->alertChannel->send("CPU使用率过高: {$cpuUsage}%", 'critical');
        }
        return [
            'metric' => 'cpu',
            'value' => $cpuUsage,
            'threshold' => $threshold,
            'status' => $cpuUsage > $threshold ? 'ALERT' : 'OK'
        ];
    }
    /**
     * 获取CPU使用率
     */
    private function getCpuUsage() {
        $load = sys_getloadavg();
        if (function_exists('proc_open')) {
            $cmd = "top -b -n1 | grep 'Cpu(s)' | awk '{print $2}'";
            $result = exec($cmd);
            return floatval($result);
        }
        return $load[0] * 100;
    }
    /**
     * 检查内存使用率
     */
    public function checkMemoryUsage() {
        $memInfo = file('/proc/meminfo');
        $totalMem = 0;
        $freeMem = 0;
        foreach ($memInfo as $line) {
            if (strpos($line, 'MemTotal:') === 0) {
                $parts = explode(':', $line);
                $totalMem = (int)trim(str_replace('kB', '', $parts[1]));
            } elseif (strpos($line, 'MemAvailable:') === 0) {
                $parts = explode(':', $line);
                $freeMem = (int)trim(str_replace('kB', '', $parts[1]));
            }
        }
        if ($totalMem > 0) {
            $usagePercent = (($totalMem - $freeMem) / $totalMem) * 100;
            $threshold = $this->thresholds['memory_usage'];
            if ($usagePercent > $threshold) {
                $this->alertChannel->send("内存使用率过高: " . round($usagePercent, 2) . "%", 'warning');
            }
            return [
                'metric' => 'memory',
                'value' => round($usagePercent, 2),
                'threshold' => $threshold,
                'status' => $usagePercent > $threshold ? 'ALERT' : 'OK'
            ];
        }
        return null;
    }
    /**
     * 检查磁盘使用率
     */
    public function checkDiskUsage() {
        $diskPath = '/';
        $diskFree = disk_free_space($diskPath);
        $diskTotal = disk_total_space($diskPath);
        if ($diskTotal > 0) {
            $usagePercent = (($diskTotal - $diskFree) / $diskTotal) * 100;
            $threshold = $this->thresholds['disk_usage'];
            if ($usagePercent > $threshold) {
                $this->alertChannel->send("磁盘空间不足: " . round($usagePercent, 2) . "%", 'critical');
            }
            return [
                'metric' => 'disk',
                'value' => round($usagePercent, 2),
                'threshold' => $threshold,
                'status' => $usagePercent > $threshold ? 'ALERT' : 'OK'
            ];
        }
        return null;
    }
    /**
     * 检查负载均衡
     */
    public function checkLoadAverage() {
        $load = sys_getloadavg();
        if ($load[0] > $this->thresholds['load_average']) {
            $this->alertChannel->send("系统负载过高: {$load[0]}", 'warning');
        }
        return [
            'metric' => 'load_average',
            'value' => $load[0],
            'threshold' => $this->thresholds['load_average'],
            'status' => $load[0] > $this->thresholds['load_average'] ? 'ALERT' : 'OK'
        ];
    }
}

Web服务监控类

<?php
/**
 * Web服务监控类
 */
class WebMonitor {
    private $sites = [];
    private $alertChannel;
    public function __construct($sites = [], $alertChannel = null) {
        $this->sites = $sites;
        $this->alertChannel = $alertChannel ?? new AlertChannel();
    }
    /**
     * 检查网站可用性
     */
    public function checkWebsite($url) {
        $startTime = microtime(true);
        $ch = curl_init($url);
        curl_setopt_array($ch, [
            CURLOPT_RETURNTRANSFER => true,
            CURLOPT_HEADER => true,
            CURLOPT_NOBODY => true,
            CURLOPT_TIMEOUT => 10,
            CURLOPT_CONNECTTIMEOUT => 5
        ]);
        $response = curl_exec($ch);
        $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
        $responseTime = microtime(true) - $startTime;
        curl_close($ch);
        // 检查HTTP状态码
        if ($httpCode >= 400) {
            $this->alertChannel->send("网站 {$url} 返回错误状态码: {$httpCode}", 'critical');
        }
        // 检查响应时间
        if ($responseTime > 3.0) {
            $this->alertChannel->send("网站 {$url} 响应过慢: " . round($responseTime, 2) . "s", 'warning');
        }
        return [
            'url' => $url,
            'http_code' => $httpCode,
            'response_time' => round($responseTime, 2),
            'status' => $httpCode >= 400 ? 'ALERT' : ($responseTime > 3.0 ? 'WARNING' : 'OK')
        ];
    }
    /**
     * 监控API接口
     */
    public function checkApi($url, $method = 'GET', $data = null) {
        $ch = curl_init($url);
        $headers = [
            'Content-Type: application/json',
            'Accept: application/json'
        ];
        $options = [
            CURLOPT_RETURNTRANSFER => true,
            CURLOPT_HTTPHEADER => $headers,
            CURLOPT_TIMEOUT => 10,
            CURLOPT_CUSTOMREQUEST => $method
        ];
        if ($data && in_array($method, ['POST', 'PUT', 'PATCH'])) {
            $options[CURLOPT_POSTFIELDS] = json_encode($data);
        }
        curl_setopt_array($ch, $options);
        $response = curl_exec($ch);
        $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
        curl_close($ch);
        // 解析JSON响应
        $responseData = json_decode($response, true);
        // 检查是否包含错误信息
        if (isset($responseData['error']) || isset($responseData['code']) && $responseData['code'] > 0) {
            $this->alertChannel->send("API {$url} 返回错误: " . json_encode($responseData), 'critical');
        }
        return [
            'url' => $url,
            'http_code' => $httpCode,
            'response' => $responseData,
            'status' => $httpCode >= 400 ? 'ALERT' : 'OK'
        ];
    }
    /**
     * 监控网页内容变化
     */
    public function checkContent($url, $expectedContent) {
        $content = file_get_contents($url);
        if (strpos($content, $expectedContent) === false) {
            $this->alertChannel->send("网站 {$url} 内容异常，未找到预期内容", 'warning');
            return ['status' => 'ALERT', 'message' => 'Content mismatch'];
        }
        return ['status' => 'OK', 'message' => 'Content OK'];
    }
}

数据库监控类

<?php
/**
 * 数据库监控类
 */
class DatabaseMonitor {
    private $pdo;
    private $alertChannel;
    public function __construct($config, $alertChannel = null) {
        try {
            $dsn = "mysql:host={$config['host']};dbname={$config['dbname']};charset=utf8mb4";
            $this->pdo = new PDO($dsn, $config['user'], $config['password'], [
                PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
                PDO::ATTR_TIMEOUT => 3
            ]);
            $this->alertChannel = $alertChannel ?? new AlertChannel();
        } catch (Exception $e) {
            $this->alertChannel->send("数据库连接失败: " . $e->getMessage(), 'critical');
        }
    }
    /**
     * 检查数据库连接
     */
    public function checkConnection() {
        try {
            $this->pdo->query('SELECT 1');
            return ['status' => 'OK', 'message' => 'Connection successful'];
        } catch (Exception $e) {
            $this->alertChannel->send("数据库连接失败: " . $e->getMessage(), 'critical');
            return ['status' => 'ALERT', 'error' => $e->getMessage()];
        }
    }
    /**
     * 检查表空间使用率
     */
    public function checkTableSpace($tableName) {
        $sql = "SELECT DATA_LENGTH + INDEX_LENGTH as table_size 
                FROM information_schema.TABLES 
                WHERE TABLE_SCHEMA = DATABASE() 
                AND TABLE_NAME = :table";
        $stmt = $this->pdo->prepare($sql);
        $stmt->execute(['table' => $tableName]);
        $size = $stmt->fetchColumn();
        return [
            'table' => $tableName,
            'size_mb' => round($size / 1024 / 1024, 2),
            'status' => 'OK'
        ];
    }
    /**
     * 检查慢查询
     */
    public function checkSlowQueries($threshold = 2.0) {
        $sql = "SHOW FULL PROCESSLIST";
        $queries = $this->pdo->query($sql)->fetchAll();
        $slowQueries = array_filter($queries, function($query) use ($threshold) {
            return $query['Time'] > $threshold && !empty($query['Info']);
        });
        if (count($slowQueries) > 0) {
            foreach ($slowQueries as $query) {
                $this->alertChannel->send(
                    "慢查询检测到: SQL='{$query['Info']}' 耗时={$query['Time']}s",
                    'warning'
                );
            }
        }
        return [
            'total_queries' => count($queries),
            'slow_queries' => count($slowQueries),
            'status' => count($slowQueries) > 0 ? 'ALERT' : 'OK'
        ];
    }
    /**
     * 监控连接池使用率
     */
    public function checkConnections() {
        $maxConnections = 100;
        $sql = "SHOW STATUS WHERE Variable_name = 'Threads_connected'";
        $current = $this->pdo->query($sql)->fetchColumn();
        $usagePercent = ($current / $maxConnections) * 100;
        if ($usagePercent > 80) {
            $this->alertChannel->send("数据库连接数过高: {$current}/{$maxConnections}", 'warning');
        }
        return [
            'current_connections' => $current,
            'max_connections' => $maxConnections,
            'usage_percent' => round($usagePercent, 2),
            'status' => $usagePercent > 80 ? 'ALERT' : 'OK'
        ];
    }
}

应用日志监控

<?php
/**
 * 日志监控类
 */
class LogMonitor {
    private $logFile;
    private $alertChannel;
    private $tailCount = 100;
    public function __construct($logFile = '/var/log/php_errors.log', $alertChannel = null) {
        $this->logFile = $logFile;
        $this->alertChannel = $alertChannel ?? new AlertChannel();
    }
    /**
     * 监控错误日志
     */
    public function checkErrorLog($keywords = ['ERROR', 'FATAL', 'CRITICAL']) {
        if (!file_exists($this->logFile)) {
            return ['status' => 'OK', 'message' => 'Log file not found'];
        }
        $lines = $this->tailFile($this->tailCount);
        $matches = [];
        foreach ($lines as $line) {
            foreach ($keywords as $keyword) {
                if (stripos($line, $keyword) !== false) {
                    $matches[] = $line;
                    break;
                }
            }
        }
        if (count($matches) > 0) {
            $this->alertChannel->send(
                "日志中发现错误: " . count($matches) . "条\n" . implode("\n", array_slice($matches, 0, 5)),
                'critical'
            );
        }
        return [
            'total_lines' => count($lines),
            'error_lines' => count($matches),
            'status' => count($matches) > 0 ? 'ALERT' : 'OK'
        ];
    }
    /**
     * 读取文件末尾内容
     */
    private function tailFile($lines) {
        $file = new SplFileObject($this->logFile);
        $file->seek(PHP_INT_MAX);
        $totalLines = $file->key();
        $startLine = max(0, $totalLines - $lines);
        $file->seek($startLine);
        $result = [];
        while (!$file->eof()) {
            $result[] = $file->fgets();
        }
        return $result;
    }
}

报警通知渠道

<?php
/**
 * 报警通知渠道
 */
class AlertChannel {
    private $webhook;
    private $emailConfig;
    public function __construct() {
        // 可以配置多个通知渠道
        $this->webhook = 'https://example.com/webhook'; // Slack/DingTalk/企业微信
        $this->emailConfig = [
            'host' => 'smtp.example.com',
            'port' => 465,
            'username' => 'alert@example.com',
            'password' => 'your_password',
            'to' => 'admin@example.com'
        ];
    }
    /**
     * 发送报警通知
     */
    public function send($message, $level = 'warning') {
        // 1. 发送到Webhook
        $this->sendToWebhook($message, $level);
        // 2. 发送邮件
        $this->sendEmail($message, $level);
        // 3. 发送短信（可选）
        // $this->sendSMS($message, $level);
        // 4. 记录到数据库
        $this->logToDatabase($message, $level);
    }
    /**
     * 发送Webhook通知
     */
    private function sendToWebhook($message, $level) {
        $data = [
            'message' => $message,
            'level' => $level,
            'timestamp' => date('Y-m-d H:i:s'),
            'host' => gethostname()
        ];
        $ch = curl_init($this->webhook);
        curl_setopt_array($ch, [
            CURLOPT_RETURNTRANSFER => true,
            CURLOPT_POST => true,
            CURLOPT_POSTFIELDS => json_encode($data),
            CURLOPT_HTTPHEADER => ['Content-Type: application/json']
        ]);
        curl_exec($ch);
        curl_close($ch);
    }
    /**
     * 发送邮件通知
     */
    private function sendEmail($message, $level) {
        // 使用PHP内置mail函数或其他邮件库
        // 这里使用简单的示例
        $subject = "[服务器报警] {$level} - " . date('Y-m-d H:i');
        // mail($this->emailConfig['to'], $subject, $message);
    }
    /**
     * 记录到数据库
     */
    private function logToDatabase($message, $level) {
        // 使用PDO连接数据库并记录报警信息
        // 这里简化处理
        $logEntry = [
            'timestamp' => date('Y-m-d H:i:s'),
            'level' => $level,
            'message' => $message,
            'host' => gethostname()
        ];
        // 可以写入数据库或文件
        $logFile = '/var/log/monitor_alerts.log';
        file_put_contents($logFile, json_encode($logEntry) . "\n", FILE_APPEND);
    }
}

主监控程序

<?php
/**
 * 主监控调度器
 */
class MonitorScheduler {
    private $monitors = [];
    private $alerts = [];
    private $runInterval = 60; // 运行间隔（秒）
    public function __construct() {
        $this->initializeMonitors();
    }
    /**
     * 初始化所有监控任务
     */
    private function initializeMonitors() {
        // 系统监控
        $this->monitors['system'] = new SystemMonitor([
            'cpu_usage' => 80,
            'memory_usage' => 80,
            'disk_usage' => 85
        ]);
        // Web监控
        $this->monitors['web'] = new WebMonitor([
            ['url' => 'https://example.com', 'name' => '主站'],
            ['url' => 'https://api.example.com', 'name' => 'API服务']
        ]);
        // 数据库监控
        $this->monitors['database'] = new DatabaseMonitor([
            'host' => 'localhost',
            'dbname' => 'monitor_db',
            'user' => 'monitor',
            'password' => 'monitor_password'
        ]);
        // 日志监控
        $this->monitors['logs'] = new LogMonitor('/var/log/app.log');
    }
    /**
     * 运行监控任务
     */
    public function run() {
        while (true) {
            echo "\n=========== 开始监控 " . date('Y-m-d H:i:s') . " ===========\n";
            // 执行所有监控
            $results = [];
            $results['system_cpu'] = $this->monitors['system']->checkCpuUsage();
            $results['system_memory'] = $this->monitors['system']->checkMemoryUsage();
            $results['system_disk'] = $this->monitors['system']->checkDiskUsage();
            $results['system_load'] = $this->monitors['system']->checkLoadAverage();
            // 打印结果
            $this->printResults($results);
            // 等待下一次运行
            echo "\n等待 {$this->runInterval} 秒后继续监控...\n";
            sleep($this->runInterval);
        }
    }
    /**
     * 打印监控结果
     */
    private function printResults($results) {
        foreach ($results as $name => $result) {
            if ($result && isset($result['status'])) {
                $status = $result['status'];
                $color = $status === 'OK' ? "\033[32m" : ($status === 'ALERT' ? "\033[31m" : "\033[33m");
                $reset = "\033[0m";
                echo "{$color}[{$status}]{$reset} {$name}: ";
                if (isset($result['value'])) {
                    echo "value = " . $result['value'];
                }
                echo "\n";
            }
        }
    }
    /**
     * 单次运行（用于cron定时任务）
     */
    public function runOnce() {
        $this->initializeMonitors();
        // 执行所有监控
        $this->monitors['system']->checkCpuUsage();
        $this->monitors['system']->checkMemoryUsage();
        $this->monitors['system']->checkDiskUsage();
        $this->monitors['system']->checkLoadAverage();
        // Web监控
        foreach ($this->monitors['web']->getSites() as $site) {
            $this->monitors['web']->checkWebsite($site['url']);
        }
        // 数据库监控
        $this->monitors['database']->checkConnection();
        $this->monitors['database']->checkSlowQueries(2);
        // 日志监控
        $this->monitors['logs']->checkErrorLog();
    }
}

使用示例

<?php
// 启动监控程序
require_once 'monitor.php';
// 创建调度器并启动
$scheduler = new MonitorScheduler();
// 方式1：连续运行（适合开发和测试）
// $scheduler->run();
// 方式2：单次运行（配合cron定时任务）
// 在crontab中添加：*/5 * * * * php /path/to/monitor.php
$scheduler->runOnce();

配置文件

<?php
// config.php
return [
    'system' => [
        'cpu_threshold' => 80,
        'memory_threshold' => 80,
        'disk_threshold' => 85
    ],
    'websites' => [
        ['url' => 'https://example.com', 'name' => '主页'],
        ['url' => 'https://api.example.com', 'name' => 'API']
    ],
    'database' => [
        'host' => 'localhost',
        'dbname' => 'monitor',
        'user' => 'monitor_user',
        'password' => 'monitor_password'
    ],
    'alert' => [
        'webhook' => 'https://hooks.slack.com/services/xxx',
        'email' => 'admin@example.com',
        'levels' => ['warning', 'critical']
    ]
];

这个监控系统包含：