ClientConnectionHandler.java

package io.github.winroot33;

import lombok.RequiredArgsConstructor;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.nio.charset.StandardCharsets;

/**
 * Класс для обработки соединений с клиентами, Runnable для передачи в пул потоков
 */
@RequiredArgsConstructor
public class ClientConnectionHandler implements Runnable {
    private final Socket clientSocket;

    @Override
    public void run() {
        handleConnection();
    }

    /**
     * Обработка нового соединения
     */
    private void handleConnection() {
        try (Socket socket = this.clientSocket;
             PrintWriter out = new PrintWriter(socket.getOutputStream(), true, StandardCharsets.UTF_8);
             BufferedReader in = new BufferedReader(
                     new InputStreamReader(socket.getInputStream(), StandardCharsets.UTF_8))) {

            processClientMessages(in, out);

        } catch (IOException e) {
            System.err.println("IO Error: " + e.getMessage());
        }
    }

    /**
     * Метод для отправки эхо сообщений пользователю
     *
     * @param in  входной поток данных
     * @param out выходной поток
     */
    private void processClientMessages(BufferedReader in, PrintWriter out) throws IOException {
        String inputLine;
        while ((inputLine = in.readLine()) != null) {
            out.println(inputLine);
            System.out.printf("Thread: %s\tMessage sent: %s\n", Thread.currentThread().getName(), inputLine);
        }
    }
}