cat /proc/stat

cpu  123456 789 101112 131415 161718 192021 222324 0 0
cpu0 65432 394 50556 65707 80859 96010 111161 0 0
...

#!/bin/bash

# cpu_monitor.sh - 基礎(chǔ)版 CPU 使用率監(jiān)控腳本
# 作者：SystemAdmin
# 日期：2025

INTERVAL=5

get_cpu_usage() {
    # 讀取 /proc/stat 第一行
    read cpu user nice system idle iowait irq softirq steal guest < /proc/stat
    
    # 計算總時間和空閑時間
    total=$((user + nice + system + idle + iowait + irq + softirq + steal))
    idle_time=$idle

    sleep $INTERVAL

    # 再次讀取
    read cpu user2 nice2 system2 idle2 iowait2 irq2 softirq2 steal2 guest2 < /proc/stat
    total2=$((user2 + nice2 + system2 + idle2 + iowait2 + irq2 + softirq2 + steal2))
    idle_time2=$idle2

    # 計算差值
    total_diff=$((total2 - total))
    idle_diff=$((idle_time2 - idle_time))

    # 避免除零
    if [ $total_diff -eq 0 ]; then
        echo "0.0"
        return
    fi

    # 計算使用率: (總時間 - 空閑時間) / 總時間 * 100
    usage=$(awk "BEGIN {printf \"%.2f\", (1 - $idle_diff / $total_diff) * 100}")
    echo "$usage"
}

echo "開始監(jiān)控 CPU 使用率... (按 Ctrl+C 退出)"
while true; do
    usage=$(get_cpu_usage)
    timestamp=$(date '+%Y-%m-%d %H:%M:%S')
    echo "[$timestamp] CPU 使用率: ${usage}%"
done

chmod +x cpu_monitor.sh
./cpu_monitor.sh

#!/bin/bash
# advanced_cpu_monitor.sh - 增強(qiáng)版 CPU 監(jiān)控腳本
# 支持日志、告警、參數(shù)配置
LOG_FILE="cpu_monitor.log"
MAX_LOG_SIZE=10485760  # 10MB
ALERT_THRESHOLD=${1:-80}   # 默認(rèn)閾值 80%
INTERVAL=${2:-5}           # 默認(rèn)間隔 5 秒
rotate_log() {
    if [ -f "$LOG_FILE" ] && [ $(stat -c%s "$LOG_FILE") -gt $MAX_LOG_SIZE ]; then
        mv "$LOG_FILE" "${LOG_FILE}.old"
        echo "[$(date)] 日志文件已輪轉(zhuǎn)" >> "${LOG_FILE}.old"
    fi
}
alert_if_high() {
    local usage=$1
    if (( $(echo "$usage > $ALERT_THRESHOLD" | bc -l) )); then
        echo "??  [$(date)] 警告：CPU 使用率過高！當(dāng)前：${usage}%，閾值：${ALERT_THRESHOLD}%" >&2
    fi
}
get_cpu_usage() {
    read cpu user nice system idle iowait irq softirq steal guest < /proc/stat
    total=$((user + nice + system + idle + iowait + irq + softirq + steal))
    idle_time=$idle
    sleep $INTERVAL
    read cpu user2 nice2 system2 idle2 iowait2 irq2 softirq2 steal2 guest2 < /proc/stat
    total2=$((user2 + nice2 + system2 + idle2 + iowait2 + irq2 + softirq2 + steal2))
    idle_time2=$idle2
    total_diff=$((total2 - total))
    idle_diff=$((idle_time2 - idle_time))
    if [ $total_diff -eq 0 ]; then
        echo "0.0"
        return
    fi
    usage=$(awk "BEGIN {printf \"%.2f\", (1 - $idle_diff / $total_diff) * 100}")
    echo "$usage"
}
echo "?? 啟動增強(qiáng)版 CPU 監(jiān)控..."
echo "?? 閾值：${ALERT_THRESHOLD}%，間隔：${INTERVAL}秒"
while true; do
    rotate_log
    usage=$(get_cpu_usage)
    timestamp=$(date '+%Y-%m-%d %H:%M:%S')
    alert_if_high "$usage"
    log_entry="[$timestamp] CPU: ${usage}%"
    echo "$log_entry" | tee -a "$LOG_FILE"
    # 可選：寫入單獨的 CSV 文件用于后續(xù)分析
    echo "$timestamp,$usage" >> cpu_history.csv
done

./advanced_cpu_monitor.sh 85 10  # 設(shè)置閾值85%，間隔10秒

<dependency>
    <groupId>com.github.oshi</groupId>
    <artifactId>oshi-core</artifactId>
    <version>6.4.8</version>
</dependency>
<dependency>
    <groupId>ch.qos.logback</groupId>
    <artifactId>logback-classic</artifactId>
    <version>1.4.14</version>
</dependency>

import oshi.SystemInfo;
import oshi.hardware.CentralProcessor;
import oshi.hardware.HardwareAbstractionLayer;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
public class CPUMonitor {
    private static final Logger logger = LoggerFactory.getLogger(CPUMonitor.class);
    private static final DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
    private final CentralProcessor processor;
    private final int intervalSeconds;
    private final double alertThreshold;
    private ScheduledExecutorService scheduler;
    public CPUMonitor(int intervalSeconds, double alertThreshold) {
        this.intervalSeconds = intervalSeconds;
        this.alertThreshold = alertThreshold;
        SystemInfo si = new SystemInfo();
        HardwareAbstractionLayer hal = si.getHardware();
        this.processor = hal.getProcessor();
    }
    public void start() {
        scheduler = Executors.newSingleThreadScheduledExecutor();
        scheduler.scheduleAtFixedRate(this::collectAndLog, 0, intervalSeconds, TimeUnit.SECONDS);
        logger.info("? CPU 監(jiān)控器已啟動，間隔：{}秒，告警閾值：{}%", intervalSeconds, alertThreshold);
    }
    public void stop() {
        if (scheduler != null && !scheduler.isShutdown()) {
            scheduler.shutdown();
            logger.info("??  CPU 監(jiān)控器已停止");
        }
    }
    private void collectAndLog() {
        double[] load = processor.getProcessorCpuLoadBetweenTicks();
        double usage = load[0] * 100; // 獲取整體 CPU 使用率
        String timestamp = LocalDateTime.now().format(formatter);
        String logMessage = String.format("[%s] CPU 使用率: %.2f%%", timestamp, usage);
        if (usage > alertThreshold) {
            logger.warn("?? 高負(fù)載警告！{}", logMessage);
            triggerAlert(usage);
        } else {
            logger.info(logMessage);
        }
    }
    private void triggerAlert(double usage) {
        // 此處可擴(kuò)展：發(fā)送郵件、調(diào)用 webhook、寫入數(shù)據(jù)庫等
        System.err.println("?? 觸發(fā)告警邏輯：CPU 使用率 " + String.format("%.2f", usage) + "% 超過閾值 " + alertThreshold + "%");
    }
    public static void main(String[] args) {
        int interval = args.length > 0 ? Integer.parseInt(args[0]) : 5;
        double threshold = args.length > 1 ? Double.parseDouble(args[1]) : 80.0;
        CPUMonitor monitor = new CPUMonitor(interval, threshold);
        Runtime.getRuntime().addShutdownHook(new Thread(monitor::stop));
        monitor.start();
        // 保持主線程運行
        try {
            Thread.currentThread().join();
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            logger.error("主線程被中斷", e);
        }
    }
}

<configuration>
    <appender name="FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
        <file>logs/cpu_monitor.log</file>
        <rollingPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
            <fileNamePattern>logs/cpu_monitor.%d{yyyy-MM-dd}.%i.log</fileNamePattern>
            <maxFileSize>10MB</maxFileSize>
            <maxHistory>30</maxHistory>
            <totalSizeCap>1GB</totalSizeCap>
        </rollingPolicy>
        <encoder>
            <pattern>%d{HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
        </encoder>
    </appender>
    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
        <encoder>
            <pattern>%d{HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
        </encoder>
    </appender>
    <root level="INFO">
        <appender-ref ref="FILE"/>
        <appender-ref ref="STDOUT"/>
    </root>
</configuration>

mvn compile
mvn exec:java -Dexec.mainClass="CPUMonitor" -Dexec.args="5 85"

<dependency>
    <groupId>com.influxdb</groupId>
    <artifactId>influxdb-client-java</artifactId>
    <version>7.0.0</version>
</dependency>

private InfluxDBClient influxDBClient;
private String bucket = "system_metrics";
private String org = "myorg";
public CPUMonitor(int intervalSeconds, double alertThreshold) {
    // ... 原有代碼
    initInfluxDB();
}
private void initInfluxDB() {
    influxDBClient = InfluxDBClientFactory.create(
        "http://localhost:8086",
        "your-token".toCharArray(),
        org,
        bucket
    );
}
private void writeMetric(double usage) {
    Point point = Point.measurement("cpu_usage")
        .addTag("host", "server-01")
        .addField("value", usage)
        .time(Instant.now(), WritePrecision.NS);
    influxDBClient.getWriteApiBlocking().writePoint(point);
    logger.debug("?? 數(shù)據(jù)已寫入 InfluxDB: {}%", usage);
}

public class BaselineAlertManager {
    private Map<String, List<Double>> historyData = new ConcurrentHashMap<>();
    public boolean shouldAlert(String timeKey, double currentValue) {
        List<Double> pastValues = historyData.getOrDefault(timeKey, new ArrayList<>());
        if (pastValues.size() < 5) {
            pastValues.add(currentValue);
            historyData.put(timeKey, pastValues);
            return false; // 數(shù)據(jù)不足，暫不告警
        }
        double mean = pastValues.stream().mapToDouble(v -> v).average().orElse(0.0);
        double stdDev = calculateStandardDeviation(pastValues, mean);
        double baseline = mean + 2 * stdDev;
        if (currentValue > baseline) {
            logger.warn("?? 動態(tài)基線告警：當(dāng)前 {}%，基線 {}%", currentValue, baseline);
            return true;
        }
        // 更新歷史數(shù)據(jù)（滑動窗口）
        if (pastValues.size() >= 30) {
            pastValues.remove(0);
        }
        pastValues.add(currentValue);
        return false;
    }
    private double calculateStandardDeviation(List<Double> values, double mean) {
        double sum = values.stream()
            .mapToDouble(v -> Math.pow(v - mean, 2))
            .sum();
        return Math.sqrt(sum / values.size());
    }
}

public class WeComNotifier {
    private static final String WEBHOOK_URL = "https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key=YOUR_KEY";
    public static void sendAlert(String message) {
        String jsonPayload = String.format("""
            {
              "msgtype": "text",
              "text": {
                "content": "%s",
                "mentioned_list": ["@all"]
              }
            }
            """, message);
        try {
            HttpClient client = HttpClient.newHttpClient();
            HttpRequest request = HttpRequest.newBuilder()
                .uri(URI.create(WEBHOOK_URL))
                .header("Content-Type", "application/json")
                .POST(HttpRequest.BodyPublishers.ofString(jsonPayload))
                .build();
            HttpResponse<String> response = client.send(request, HttpResponse.BodyHandlers.ofString());
            if (response.statusCode() == 200) {
                logger.info("? 企業(yè)微信消息發(fā)送成功");
            } else {
                logger.error("? 發(fā)送失敗: {}", response.body());
            }
        } catch (Exception e) {
            logger.error("發(fā)送企業(yè)微信消息異常", e);
        }
    }
}

#!/bin/bash
get_per_core_usage() {
    cores=()
    while IFS= read -r line; do
        if [[ $line =~ ^cpu[0-9]+ ]]; then
            cores+=("$line")
        fi
    done < /proc/stat
    for core_line in "${cores[@]}"; do
        read -r core_name user nice system idle iowait irq softirq steal <<< "$core_line"
        total=$((user + nice + system + idle + iowait + irq + softirq + steal))
        idle_time=$idle
        # 存儲初始值（略）...
        # 之后計算每個核心的使用率（邏輯同整體 CPU）
        # ...
    done
}

import oshi.software.os.OSProcess;
// ...
for (OSProcess p : si.getOperatingSystem().getProcesses(5, ProcessSort.CPU_DESC)) {
    if (p.getName().contains("java")) {
        double cpuUsage = p.getProcessCpuLoadCumulative() * 100;
        logger.info("Java 進(jìn)程 [{}] CPU 占用: {:.2f}%", p.getProcessID(), cpuUsage);
    }
}

# 查看實時 CPU 使用率
top -bn1 | grep "Cpu(s)"

# 查看每個核心使用率
mpstat -P ALL 1

# 查看進(jìn)程 CPU 占用 TOP 10
ps aux --sort=-%cpu | head -11

# 查看系統(tǒng)平均負(fù)載
uptime

# 查看 CPU 詳細(xì)信息
lscpu