import java.net.*;

public class ReachableExample {
    public static void main(String[] args) {
        try {
            // 구글 서버 주소
            InetAddress google = InetAddress.getByName("www.google.com");

            System.out.println("호스트 이름: " + google.getHostName());
            System.out.println("호스트 주소: " + google.getHostAddress());

            // 5초 동안 응답 여부 확인
            if (google.isReachable(5000)) {
                System.out.println("구글 서버에 연결 가능합니다!");
            } else {
                System.out.println("구글 서버에 연결할 수 없습니다.");
            }

            // 로컬호스트 테스트
            InetAddress local = InetAddress.getLocalHost();
            if (local.isReachable(2000)) {
                System.out.println("로컬호스트 연결 가능!");
            }

        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

public class SimpleEchoServer {
	private final static int PORT = 7777;

	public static void main(String[] args) {

		// 호스트 지정이 없으면 서버가 모든 네트워크의 인터페이스에서 접속을 받을 수 있음
		try (var serverSocket = new ServerSocket(PORT)) {
			System.out.println(PORT + " 포트가 열렸습니다.");

			while (true) {
				/*
				accept() 로 클라이언트가 들어오길 기다림
				클라이언트가 접속을 했다면 client 소켓이 리턴됨

				클라이언트의 소켓을 통해서 in, out 의 연결 통로가 필요(양방향)
				항상 입출력은 하나의 통로에서 동작할 수 없다.
				 */
				try (Socket socket = serverSocket.accept();
				     BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
				     PrintWriter out = new PrintWriter(new BufferedOutputStream(socket.getOutputStream()), true)) {

					System.out.println("클라이언트 " + socket.getRemoteSocketAddress() + " 님 접속 완료");

					String line;

					while ((line = in.readLine()) != null) {
						System.out.println("클라이언트로부터 받은 메시지: " + line);

						out.println("Echo " + line);

						if ("bye".equalsIgnoreCase(line))
							break;
					}
				}
			}
		} catch (IOException e) {
			System.err.println("서버 시작 실패했습니다.");
		}
	}
}

socket.getRemoteSocketAddress()

public class SimpleEchoClient {
	private static final String HOST = "localhost";
	private static final int PORT = 7777;

	public static void main(String[] args) {

		// 호스트 지정이 있기에 서버가 특정 IP 주소에만 바인딩 됨
		try (var socket = new Socket(HOST, PORT);
		     var in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
		     var out = new PrintWriter(new BufferedOutputStream(socket.getOutputStream()), true);
		     var keyboard = new Scanner(System.in)) {

			System.out.println("접속 완료");
			System.out.println("bye 를 입력하시면 종료됩니다.");

			while (true) {
				// 클라이언트의 입력을 전송
				System.out.print("서버에 전달할 메시지를 입력하세요: ");
				var line = keyboard.nextLine();
				out.println(line);

				// 서버가 응답한 내용을 읽어옴
				var response = in.readLine();

                // [안정성] 서버가 연결을 먼저 끊었을 경우를 확인합니다.
                if (response == null) {
                    System.out.println("서버와의 연결이 끊어졌습니다.");
                    break;
                }

                System.out.println(response);

				if ("bye".equalsIgnoreCase(line))
					break;
			}
		} catch (IOException e) {
			throw new RuntimeException(e);
		}
	}
}

static class ClientHandler implements Runnable {
    private final Socket socket;

    ClientHandler(Socket socket) {
        this.socket = socket;
    }

    @Override
    public void run() {
        try (BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
        ) {
            SocketAddress clientAddress = socket.getRemoteSocketAddress();
            System.out.println(clientAddress + " 사용자 접속함");

            String inputLine;
            while ((inputLine = in.readLine()) != null) {
                System.out.println(clientAddress + "로 부터 받은 메시지 :: " + inputLine);
                out.println("Echo::" + inputLine);

                if ("bye".equals(inputLine)) {
                    break;
                }
            }

            System.out.println(clientAddress + " 연결 종료!!");

        } catch (Exception e) {
            throw new RuntimeException(e);
        } finally {
            try {
                socket.close();
            } catch (IOException e) {
                System.out.println(e.getMessage() + "소켓 종료 오류!!");
            }
        }
    }
}

try (ServerSocket serverSocket = new ServerSocket(PORT)) {
    System.out.println("에코서버 시작");

    while (true) {
        Socket socket = serverSocket.accept();

        //클라이언트별로 각각 통신 할 수 있는 쓰레드가 필요할 것 같아요.
        Thread clientThread = new Thread(new ClientHandler(socket));
        clientThread.start();
    }
} catch (Exception e) {
    throw new RuntimeException(e);
}

ServerSocket serverSocket = new ServerSocket(PORT);
System.out.println("에코 서버 시작, 포트: " + PORT);

// 스레드 풀과 큐 생성
BlockingQueue<Runnable> queue = new ArrayBlockingQueue<>(10); // 큐 용량 10
ThreadPoolExecutor pool = new ThreadPoolExecutor(
        MAX_THREADS,
        MAX_THREADS,
        0L,
        TimeUnit.MILLISECONDS,
        queue
);

while (true) {
    Socket socket = serverSocket.accept();

    // 풀과 큐 상태 확인
    if (pool.getActiveCount() >= MAX_THREADS && queue.remainingCapacity() == 0) {
        // 스레드와 큐가 꽉 찼다면 대기 메시지 전송 후 연결 종료
        try (PrintWriter out = new PrintWriter(socket.getOutputStream(), true)) {
            out.println("서버 접속 대기 중입니다. 잠시 후 다시 시도해주세요.");
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            socket.close();
        }
    } else {
        // 처리 가능한 경우 스레드 풀에 제출
        pool.submit(new ClientHandler(socket));
    }
}

public class ChatServer {
	private static final int PORT = 7777;
	private static Set<ClientHandler> clients = ConcurrentHashMap.newKeySet();

	private static void broadcast(String message) {
		System.out.println(message);
		for (var client : clients)
			client.sendMessage(message);
	}

	public static void main(String[] args) {
		System.out.println("채팅 서버 시작");

		try (ServerSocket serverSocket = new ServerSocket(PORT)) {
			while (true) {
				Socket socket = serverSocket.accept();
				ClientHandler clientHandler = new ClientHandler(socket);
				clients.add(clientHandler);
				new Thread(clientHandler).start();
			}
		} catch (IOException e) {
			throw new RuntimeException(e);
		}
	}

	static class ClientHandler implements Runnable {
		private Socket socket;
		private PrintWriter pw;
		private String nickname;

		public ClientHandler(Socket socket) {
			this.socket = socket;
		}

		@Override
		public void run() {
			try(var br = new BufferedReader(new InputStreamReader(socket.getInputStream()))) {
				pw = new PrintWriter(new BufferedOutputStream(socket.getOutputStream()), true);

				String message;
				while ((message = br.readLine()) != null && message.trim().isEmpty())
					pw.println("올바르지 않은 닉네임입니다.");

				nickname = message;
				broadcast(nickname + "님이 들어왔습니다.");

				if (nickname != null)
					while ((message = br.readLine()) != null) {
						if (message.trim().isBlank()) continue;
						broadcast(nickname + "\t" + message);
					}

			} catch (IOException e) {
				System.err.println(e);

			} finally {
				broadcast(nickname + "님이 나갔습니다.");
				pw.close();

				try {
					socket.close();
				} catch (IOException e) {
					e.printStackTrace();
				}
			}
		}

		private void sendMessage(String message) {
			if (pw != null) pw.println(message);
		}
	}
}

public class ChatClient {
	private static final String HOST = "localhost";
	private static final int PORT = 7777;

	public static void main(String[] args) {
		try (Socket socket = new Socket(HOST, PORT);
		     BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
		     PrintWriter out = new PrintWriter(new BufferedOutputStream(socket.getOutputStream()), true);
		     Scanner sc = new Scanner(System.in);
		) {
			System.out.println("접속 성공 !");

			// receiver
			Thread thread = new Thread(() -> {
				String message;
				try {
					while ((message = in.readLine()) != null)
						System.out.println(message);
				} catch (IOException e) {
					System.out.println(e);
				}
			});

			thread.start();

			System.out.print("닉네임을 입력해주세요: ");
			out.println(sc.nextLine());

			// sender
			String message;
			while (true) {
				message = sc.nextLine();
				if ("bye".equalsIgnoreCase(message)) break;
				out.println(message);
			}

			System.out.println("종료 완료");
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}