5

大家好，我有一个基本的 Storm 应用程序设置，它接收推文流并将它们存储在 MySQL 数据库中。该应用程序在前约 23 小时左右运行良好，然后开始出现以下错误：

SQL Exception
SQL State: 08003

在它这样做几次之后，它就死了。我正在使用标准 JBDC 连接器从 Java 连接到数据库。存储和建立数据库连接的函数代码如下：

private String _db="";
private Connection conn = null;
private PreparedStatement pst = null;

public ArchiveBolt(String db){
    _db = db;
}

private void setupConnection() {
    //Connect to the database
    try {
        Class.forName("com.mysql.jdbc.Driver");
        conn = DriverManager.getConnection("jdbc:mysql://localhost:8889/twitter_recording", "root", "root");
    } catch (Exception e){
        e.printStackTrace();
    }
}

public void execute(Tuple tuple, BasicOutputCollector collector) {

    Status s = (Status) tuple.getValue(0);

    //setup the connection on the first run through or if the connection got closed down
    try {
        setupConnection();
    } catch (Exception e) {
        // TODO: handle exception
        System.out.println(e.toString());
    }


    try {

        pst = conn.prepareStatement("INSERT INTO " + _db + " (tweet)" +
                                    "VALUES (?);");

        pst.setString(1, s.toString());

        //execute the SQL
        pst.executeUpdate();

    } catch (SQLException ex) {
        // handle any errors
        System.out.println("SQLException: " + ex.getMessage());
        System.out.println("SQLState: " + ex.getSQLState());
        System.out.println("VendorError: " + ex.getErrorCode());

        if(ex.getSQLState().equals("08003")){
            setupConnection();
        }

    } finally {
        try {
            conn.close();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}

在很明显它由于 08003 错误而崩溃后，我决定如果它抛出该错误，它应该重试连接设置，但这也无济于事。谁能指出我解决这个问题的正确方向？

4

1 回答 1

3

在很明显它由于 08003 错误而崩溃后，我决定如果它抛出该错误，它应该重试连接设置，但这也无济于事。谁能指出我解决这个问题的正确方向？

这里基本上有两个问题需要解决：

  • 为什么连接首先会丢失？
  • 为什么您重新连接的尝试没有成功？

对于第一个问题，您应该查看 MySQL 日志，看看那里是否有任何迹象。此外，在（重复的）“状态 080003”异常之前立即检查 SQL 异常。后者只是告诉您连接之前已断开。

我的猜测是问题是以下之一：

  • MySQL 服务器由于不活动而导致连接超时。如果这是问题，您可以在 MySQL 配置中更改连接超时。

  • 您的应用程序可能会慢慢泄漏 JDBC 连接。

对于第二个问题，一般做法是正确的，但你的代码与描述不符。实际上，每次调用您的方法时，它似乎总是试图建立一个新的数据库连接。execute这使得异常处理程序中的重新连接调用毫无意义。（OTOH，代码显示有人一直在“敲打它”试图让它工作......这很可能是问题的一部分。）

我会检查它是否在需要时setupConnection被调用，并查找可能引发的任何异常。此外，您应该确保您明确地死连接对象......并重新考虑/重新编码您的连接管理，使其不会泄漏。close()

作为记录，有一个名为“autoReconnect”的连接 URL 参数在遥远的过去用于“处理”丢失的连接。不幸的是，最初的实现是不安全的，所以他们有效地禁用了它；有关详细信息，请参阅此问题：为什么 autoReconnect=true 似乎不起作用？

于 2012-11-15T00:12:28.257 回答