发生主备数据库切换之后, 在disconnect()里会发生exception

发生主备数据库切换之后, 因为地址发生了变化, 所以在找start position的时候会用timestamp, 从拿到的binlog文件里根据timestamp找对应的position, 这时候会把connection的dumping标致设为true, 在后面reconnect(), disconnect()里面会因为现在是dumping状态, 所以在关掉channel之后会执行一次"KILL CONNECTION", 而这时候用的connection id是之前的已经关闭的, 所以会抛异常.

建议先执行"KILL CONNECTION"再close channel

public void disconnect() throws IOException { if (connected.compareAndSet(true, false)) { try { if (channel != null) { channel.close(); } logger.info("disConnect MysqlConnection to {}...", address); } catch (Exception e) { throw new IOException("disconnect " + this.address + " failure:" + ExceptionUtils.getStackTrace(e)); }

    // 执行一次quit
    if (dumping && connectionId >= 0) {
        MysqlConnector connector = null;
        try {
            connector = this.fork();
            connector.connect();
            MysqlUpdateExecutor executor = new MysqlUpdateExecutor(connector);
            executor.update("KILL CONNECTION " + connectionId);
        } catch (Exception e) {
            throw new IOException("KILL DUMP " + connectionId + " failure:" + ExceptionUtils.getStackTrace(e));
        } finally {
            if (connector != null) {
                connector.disconnect();
            }
        }

        dumping = false;
    }
} else {
    logger.info("the channel {} is not connected", this.address);
}

}

原提问者GitHub用户kinkeylau