MySQL中统计各个IP的连接数的方法总结

SELECT 
    SUBSTRING_INDEX(host, ':', 1) AS client_ip,
    COUNT(*) AS connection_count
FROM information_schema.processlist 
WHERE host != ''
GROUP BY client_ip
ORDER BY connection_count DESC;

-- 先创建临时表存储结果
CREATE TEMPORARY TABLE temp_processlist AS
SHOW PROCESSLIST;

-- 然后查询统计
SELECT 
    SUBSTRING_INDEX(host, ':', 1) AS client_ip,
    COUNT(*) AS connection_count
FROM temp_processlist
WHERE host != ''
GROUP BY client_ip
ORDER BY connection_count DESC;

SELECT 
    SUBSTRING_INDEX(host, ':', 1) AS client_ip,
    COUNT(*) AS total_connections,
    SUM(CASE WHEN command = 'Sleep' THEN 1 ELSE 0 END) AS sleep_connections,
    SUM(CASE WHEN command != 'Sleep' THEN 1 ELSE 0 END) AS active_connections,
    GROUP_CONCAT(DISTINCT user) AS connected_users
FROM information_schema.processlist 
WHERE host != ''
GROUP BY client_ip
ORDER BY total_connections DESC;

#!/bin/bash
# 保存为 monitor_connections.sh

mysql -u root -p -e "
SELECT 
    SUBSTRING_INDEX(host, ':', 1) AS '客户端IP',
    COUNT(*) AS '连接数',
    GROUP_CONCAT(DISTINCT USER) AS '用户列表'
FROM information_schema.processlist 
WHERE host != ''
GROUP BY SUBSTRING_INDEX(host, ':', 1)
ORDER BY COUNT(*) DESC;"

-- 创建统计记录表
CREATE TABLE IF NOT EXISTS connection_stats (
    id INT AUTO_INCREMENT PRIMARY KEY,
    stat_time DATETIME DEFAULT CURRENT_TIMESTAMP,
    client_ip VARCHAR(45),
    connection_count INT,
    unique_users INT
);

-- 插入统计数据的存储过程
DELIMITER //
CREATE PROCEDURE log_connection_stats()
BEGIN
    INSERT INTO connection_stats (client_ip, connection_count, unique_users)
    SELECT 
        SUBSTRING_INDEX(host, ':', 1) AS client_ip,
        COUNT(*) AS connection_count,
        COUNT(DISTINCT user) AS unique_users
    FROM information_schema.processlist 
    WHERE host != ''
    GROUP BY SUBSTRING_INDEX(host, ':', 1);
END //
DELIMITER ;

-- 执行统计
CALL log_connection_stats();

SELECT 
    ID as connection_id,
    USER as mysql_user,
    SUBSTRING_INDEX(host, ':', 1) AS client_ip,
    DB as database_name,
    COMMAND as command_type,
    TIME as time_seconds,
    STATE as connection_state,
    INFO as current_query
FROM information_schema.processlist 
WHERE host != ''
ORDER BY client_ip, TIME DESC;

SELECT 
    SUBSTRING_INDEX(host, ':', 1) AS client_ip,
    COUNT(*) AS connection_count
FROM information_schema.processlist 
WHERE host != ''
GROUP BY client_ip
HAVING connection_count > 10  -- 设置阈值
ORDER BY connection_count DESC;

-- 先生成kill语句预览
SELECT CONCAT('KILL ', ID, ';') AS kill_command
FROM information_schema.processlist 
WHERE SUBSTRING_INDEX(host, ':', 1) = '192.168.1.100';  -- 替换为目标IP

-- 确认无误后执行kill