Что будет, если не закрыть ресурс в приложении

Проблемы при незакрытии ресурсов

Это одна из самых частых причин production проблем. Незакрытые ресурсы ведут к утечкам памяти, файловым дескрипторам и блокировкам БД. Подробно разберу все последствия и решения.

Какие ресурсы нужно закрывать

1. Database Connections

// НЕПРАВИЛЬНО — связь не закрывается
Connection conn = DriverManager.getConnection(url, user, pass);
Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery("SELECT * FROM users");
// rs, stmt, conn остаются открыты!

Последствия:

• Connection pool исчерпывается
• Новые запросы ждут свободного соединения
• При недостатке connections приложение зависает

# В логах будут ошибки типа:
# java.sql.SQLException: Cannot get a connection, pool timeout
# org.postgresql.util.PSQLException: Connection limit exceeded

2. File I/O

// НЕПРАВИЛЬНО
FileInputStream fis = new FileInputStream("file.txt");
BufferedReader reader = new BufferedReader(new InputStreamReader(fis));
String line = reader.readLine();
// fis и reader открыты!

Последствия:

• Превышен лимит на открытые файлы (обычно 1024 на Linux)
• Приложение не может открыть новые файлы
• java.io.IOException: Too many open files

3. HTTP Connections

// НЕПРАВИЛЬНО
HttpURLConnection conn = (HttpURLConnection) 
    new URL("http://api.example.com/data").openConnection();
InputStream is = conn.getInputStream();
String data = new String(is.readAllBytes());
// conn не закрывается!

Последствия:

• Сокеты не закрываются
• TIME_WAIT состояние в ОС
• Лимит на открытые сокеты исчерпывается

4. Thread resources

// НЕПРАВИЛЬНО
ExecutorService executor = Executors.newFixedThreadPool(10);
for (int i = 0; i < 1000; i++) {
    executor.submit(() -> {
        // какая-то работа
    });
}
// executor.shutdown() не вызывается!

Последствия:

• Потоки не завершаются при shutdown приложения
• Graceful shutdown невозможен
• Задачи могут остаться выполненными

Реальные проблемы: утечки ресурсов

Сценарий 1: Database connection leak

@Service
public class UserService {
    @Autowired
    private DataSource dataSource;
    
    public List<User> getAllUsers() {
        try {
            Connection conn = dataSource.getConnection();
            Statement stmt = conn.createStatement();
            ResultSet rs = stmt.executeQuery("SELECT * FROM users");
            
            List<User> users = new ArrayList<>();
            while (rs.next()) {
                users.add(new User(rs.getString("name")));
            }
            
            // ЗАБЫЛИ ЗАКРЫТЬ!
            return users;
            // conn, stmt, rs остаются открыты
        } catch (SQLException e) {
            throw new RuntimeException(e);
        }
    }
}

При 100 вызовах в секунду:

Лосе 1: 10 открытых connections
Лосе 2: 20 открытых connections
Лосе 3: 30 открытых connections
...
Лосе 10: Connection pool исчерпан — приложение зависает

Сценарий 2: File descriptor leak

public void processLogs() {
    File logDir = new File("/var/logs");
    File[] files = logDir.listFiles();
    
    for (File file : files) {
        FileInputStream fis = new FileInputStream(file);
        BufferedReader reader = new BufferedReader(
            new InputStreamReader(fis)
        );
        
        String line;
        while ((line = reader.readLine()) != null) {
            processLine(line);
        }
        // Забыли закрыть!
    }
}

// Результат после обработки 1000 файлов:
// java.io.IOException: Too many open files

Правильные подходы

1. Try-with-resources (рекомендуемо, Java 7+)

// ПРАВИЛЬНО — автоматическое закрытие
List<User> users = new ArrayList<>();

try (Connection conn = dataSource.getConnection();
     Statement stmt = conn.createStatement();
     ResultSet rs = stmt.executeQuery("SELECT * FROM users")) {
    
    while (rs.next()) {
        users.add(new User(rs.getString("name")));
    }
    // Все ресурсы закроются автоматически
} catch (SQLException e) {
    throw new RuntimeException(e);
}

return users;

Так работает:

1. Создаются ресурсы (слева направо)
2. Выполняется код в блоке
3. Закрываются ресурсы (справа налево) — ВСЕГДА!
4. Даже если исключение

2. Файловый ввод-вывод

// ПРАВИЛЬНО
public String readFile(String path) throws IOException {
    try (FileInputStream fis = new FileInputStream(path);
         BufferedReader reader = new BufferedReader(
             new InputStreamReader(fis))) {
        
        StringBuilder content = new StringBuilder();
        String line;
        while ((line = reader.readLine()) != null) {
            content.append(line).append("\n");
        }
        return content.toString();
    }
    // fis и reader закроются автоматически
}

3. HTTP запросы

// Старый способ (Java 8)
public String fetchData(String url) throws IOException {
    HttpURLConnection conn = null;
    try {
        conn = (HttpURLConnection) new URL(url).openConnection();
        try (InputStream is = conn.getInputStream()) {
            return new String(is.readAllBytes());
        }
    } finally {
        if (conn != null) {
            conn.disconnect();
        }
    }
}

// Новый способ (Java 11+) — лучше
public String fetchData(String url) throws IOException, InterruptedException {
    try (HttpClient client = HttpClient.newHttpClient()) {
        HttpRequest request = HttpRequest.newBuilder()
            .uri(URI.create(url))
            .GET()
            .build();
        
        HttpResponse<String> response = client.send(
            request,
            HttpResponse.BodyHandlers.ofString()
        );
        return response.body();
        // Все ресурсы управляются автоматически
    }
}

4. ExecutorService

// НЕПРАВИЛЬНО
ExecutorService executor = Executors.newFixedThreadPool(10);
for (Task task : tasks) {
    executor.submit(task);
}
// executor.shutdown() забыли!

// ПРАВИЛЬНО
try (ExecutorService executor = Executors.newFixedThreadPool(10)) {
    for (Task task : tasks) {
        executor.submit(task);
    }
    executor.awaitTermination(1, TimeUnit.MINUTES);
} catch (InterruptedException e) {
    Thread.currentThread().interrupt();
}
// executor будет закрыт автоматически

5. Stream API

// ПРАВИЛЬНО — streams имплементируют AutoCloseable
try (Stream<String> lines = Files.lines(Paths.get("file.txt"))) {
    lines
        .filter(line -> !line.isEmpty())
        .map(String::toUpperCase)
        .forEach(System.out::println);
}
// Stream и файл закроются автоматически

Кастомные ресурсы

Если создаёте свой ресурс, реализуйте AutoCloseable:

public class DatabaseConnection implements AutoCloseable {
    private Connection connection;
    
    public DatabaseConnection(String url, String user, String pass) 
            throws SQLException {
        this.connection = DriverManager.getConnection(url, user, pass);
    }
    
    @Override
    public void close() throws Exception {
        if (connection != null) {
            connection.close();
        }
    }
    
    public void execute(String sql) throws SQLException {
        // ...
    }
}

// Использование
try (DatabaseConnection db = new DatabaseConnection(
    "jdbc:postgresql://localhost/mydb", 
    "user", 
    "password")) {
    db.execute("INSERT INTO users VALUES (...);");
}
// Соединение закроется автоматически

Мониторинг утечек

В development:

# Проверка открытых файлов процесса
lsof -p <PID>  # macOS/Linux
Get-Process java | select Handles  # Windows

# Через JMX
jcmd <PID> Thread.print | grep -i "open files"

В production:

// Мониторим connection pool
HikariDataSource dataSource = new HikariDataSource(config);
scheduledExecutor.scheduleAtFixedRate(() -> {
    System.out.println("Active: " + dataSource.getHikariPoolMXBean().getActiveConnections());
    System.out.println("Idle: " + dataSource.getHikariPoolMXBean().getIdleConnections());
}, 0, 1, TimeUnit.MINUTES);

Best Practices

1. Всегда используй try-with-resources для управления ресурсами
2. Закрывай файлы сразу после использования
3. Мониторь connection pool в production
4. Используй graceful shutdown для корректного завершения
5. Тестируй утечки через профайлинг
6. Документируй требования по управлению ресурсами
7. Используй инструменты типа Spotbugs для обнаружения проблем

Итог

Незакрытые ресурсы ведут к:

• Out of Memory (heap leak)
• Too many open files
• Connection pool exhaustion
• Graceful shutdown невозможен
• Приложение зависает и отказывает в обслуживании

Орешение: try-with-resources statement — это простой и эффективный способ избежать этих проблем.