首页问答社区数据库正文

MySQL连接被阻塞的问题分析与解决方案(从错误到修复)

2025-04-02 20:18:58 200

1. 引言

在java应用开发中，数据库连接是必不可少的一环。然而，在使用mysql时，我们可能会遇到类似以下的错误：

host '124.221.131.191' is blocked because of many connection errors; unblock with 'mysqladmin flush-hosts'

这个错误表明，mysql服务器由于检测到过多的连接失败，自动阻止了来自该主机的连接请求。本文将深入分析该问题的原因，并提供完整的解决方案，包括如何在代码层面优化数据库连接管理。

2. 问题背景与错误分析

2.1 错误日志分析

从错误日志可以看出，druid连接池在尝试建立mysql连接时失败，关键错误信息如下：

java.sql.sqlexception: null, message from server: 
"host '124.221.131.191' is blocked because of many connection errors; 
unblock with 'mysqladmin flush-hosts'"

2.2 为什么会发生这个错误？

mysql有一个安全机制，当某个客户端（ip）在短时间内多次连接失败（默认max_connect_errors=100），mysql会认为该主机可能存在恶意攻击或配置错误，从而自动阻止其连接。

常见触发原因：

数据库账号密码错误
网络不稳定导致连接超时
数据库连接池配置不合理（如初始连接数过大，但数据库无法承载）
数据库服务器资源不足（cpu、内存、连接数满）

3. 解决方案

3.1 临时解决方案：解除mysql的ip封锁

在mysql服务器上执行以下命令：

flush hosts;

或者使用mysqladmin命令：

mysqladmin flush-hosts -u root -p

3.2 长期解决方案：优化连接池配置

(1) 调整mysql的max_connect_errors

-- 查看当前值
show variables like 'max_connect_errors';

-- 修改（需重启mysql或动态调整）
set global max_connect_errors = 1000;

(2) 优化druid连接池配置

在application.yml或application.properties中调整druid参数：

spring:
  datasource:
    url: jdbc:mysql://124.221.131.191:3306/kwan?usessl=false&useunicode=true&characterencoding=utf-8&servertimezone=asia/shanghai
    username: your_username
    password: your_password
    driver-class-name: com.mysql.cj.jdbc.driver
    type: com.alibaba.druid.pool.druiddatasource
    druid:
      initial-size: 5       # 初始连接数
      min-idle: 5           # 最小空闲连接
      max-active: 20        # 最大活跃连接
      max-wait: 60000       # 获取连接超时时间（毫秒）
      validation-query: select 1  # 连接检测sql
      test-while-idle: true # 空闲时检测连接
      test-on-borrow: false  # 获取连接时不检测（影响性能）
      test-on-return: false  # 归还连接时不检测
      time-between-eviction-runs-millis: 60000 # 检测间隔
      min-evictable-idle-time-millis: 300000    # 最小空闲时间

(3) 使用try-with-resources确保连接正确关闭

import java.sql.connection;
import java.sql.preparedstatement;
import java.sql.resultset;
import java.sql.sqlexception;
import javax.sql.datasource;

public class userdao {
    private final datasource datasource;

    public userdao(datasource datasource) {
        this.datasource = datasource;
    }

    public string getusernamebyid(int id) {
        string sql = "select username from users where id = ?";
        try (connection conn = datasource.getconnection();
             preparedstatement stmt = conn.preparestatement(sql)) {
            stmt.setint(1, id);
            try (resultset rs = stmt.executequery()) {
                if (rs.next()) {
                    return rs.getstring("username");
                }
            }
        } catch (sqlexception e) {
            throw new runtimeexception("failed to query user", e);
        }
        return null;
    }
}

4. 深入分析：如何避免连接失败？

4.1 监控数据库连接状态

使用druid自带的监控：

@bean
public servletregistrationbeandruidstatviewservlet() {
    servletregistrationbeanregistrationbean = 
        new servletregistrationbean<>(new statviewservlet(), "/druid/*");
    registrationbean.addinitparameter("loginusername", "admin");
    registrationbean.addinitparameter("loginpassword", "admin");
    return registrationbean;
}

访问http://localhost:8080/druid可查看连接池状态。

4.2 使用重试机制

public connection getconnectionwithretry(datasource datasource, int maxretries) {
    int retrycount = 0;
    while (retrycount < maxretries) {
        try {
            return datasource.getconnection();
        } catch (sqlexception e) {
            retrycount++;
            if (retrycount >= maxretries) {
                throw new runtimeexception("failed to get connection after " + maxretries + " retries", e);
            }
            try {
                thread.sleep(1000); // 1秒后重试
            } catch (interruptedexception ie) {
                thread.currentthread().interrupt();
                throw new runtimeexception("interrupted while waiting for retry", ie);
            }
        }
    }
    throw new illegalstateexception("should not reach here");
}

4.3 优化mysql服务器配置

[mysqld]
max_connections = 200          # 最大连接数
wait_timeout = 28800          # 非交互式连接超时时间（秒）
interactive_timeout = 28800   # 交互式连接超时时间
max_connect_errors = 1000     # 调高连接错误阈值