소켓 통신

netsh advfirewall firewall add rule name="Java Socket Port 9999" dir=in action=allow protocol=TCP localport=9999

netstat -an | findstr :9999

import java.io.*; import java.net.*; public class SimpleServer { public static void main(String[] args) { int port = 9999; try (ServerSocket serverSocket = new ServerSocket(port)) { System.out.println("서버가 포트 " + port + "에서 대기 중..."); // 클라이언트 연결 대기 Socket clientSocket = serverSocket.accept(); System.out.println("클라이언트 연결됨: " + clientSocket.getInetAddress()); // 입출력 스트림 생성 BufferedReader in = new BufferedReader( new InputStreamReader(clientSocket.getInputStream()) ); PrintWriter out = new PrintWriter( clientSocket.getOutputStream(), true ); // 메시지 수신 및 응답 String message = in.readLine(); System.out.println("받은 메시지: " + message); out.println("서버 응답: " + message); // 연결 종료 clientSocket.close(); } catch (IOException e) { e.printStackTrace(); } } }

import java.io.*; import java.net.*; public class SimpleClient { public static void main(String[] args) { String serverAddress = "localhost"; int port = 9999; try (Socket socket = new Socket(serverAddress, port)) { System.out.println("서버에 연결됨"); // 입출력 스트림 생성 PrintWriter out = new PrintWriter( socket.getOutputStream(), true ); BufferedReader in = new BufferedReader( new InputStreamReader(socket.getInputStream()) ); // 메시지 전송 out.println("안녕하세요, 서버!"); // 응답 수신 String response = in.readLine(); System.out.println("서버 응답: " + response); } catch (IOException e) { e.printStackTrace(); } } }

import java.io.*; import java.net.*; public class MultiThreadServer { public static void main(String[] args) { int port = 9999; try (ServerSocket serverSocket = new ServerSocket(port)) { System.out.println("다중 클라이언트 서버 시작..."); while (true) { Socket clientSocket = serverSocket.accept(); System.out.println("새 클라이언트 연결: " + clientSocket.getInetAddress()); // 각 클라이언트를 별도 스레드에서 처리 ClientHandler handler = new ClientHandler(clientSocket); Thread thread = new Thread(handler); thread.start(); } } catch (IOException e) { e.printStackTrace(); } } } class ClientHandler implements Runnable { private Socket socket; public 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 ) ) { String message; while ((message = in.readLine()) != null) { System.out.println("받은 메시지: " + message); out.println("에코: " + message); if (message.equalsIgnoreCase("bye")) { break; } } } catch (IOException e) { e.printStackTrace(); } finally { try { socket.close(); } catch (IOException e) { e.printStackTrace(); } } } }

package socket; import java.io.*; import java.net.*; import java.util.List; import java.util.concurrent.CopyOnWriteArrayList; public class ChatServer { // 모든 클라이언트들의 출력 스트림을 저장할 리스트 (Thread safe) private static List<PrintWriter> clientWriterList = new CopyOnWriteArrayList<>(); public static void main(String[] args) { int port = 9999; try (ServerSocket serverSocket = new ServerSocket(port)) { System.out.println("서버 대기 중: " + port); // 여러 클라이언트를 계속 받기 위해 무한 루프 while (true) { Socket clientSocket = serverSocket.accept(); System.out.println("클라이언트 연결됨: " + clientSocket.getInetAddress()); // 각 클라이언트를 별도 스레드로 처리 new Thread(new ClientHandler(clientSocket)).start(); } } catch (IOException e) { e.printStackTrace(); } } // main() 끝 // 브로드캐스트 : 모든 클래이언트에 메시지 전송 public static void broadcast(String message, PrintWriter sender) { for (PrintWriter writer : clientWriterList) { if( writer != sender ) { writer.println(message); } } } // 클라이언트와의 통신을 담당하는 클래스 static class ClientHandler implements Runnable { private Socket socket; private PrintWriter out; private BufferedReader in; private String clientName; public ClientHandler(Socket socket) { this.socket = socket; } @Override public void run() { try { in = new BufferedReader( new InputStreamReader(socket.getInputStream()) ); out = new PrintWriter(socket.getOutputStream(), true); // 개별 클라이언트의 출력스트림을 리스트에 추가 clientWriterList.add(out); out.println("이름 : "); clientName = in.readLine(); System.out.println("* " + clientName + "님 입장!"); // 입장 broadcast("* " + clientName + "님 입장!", out); // 계속 채팅 String message; while ((message = in.readLine()) != null) { System.out.println("[" + clientName + "] 메시지: " + message); // 브로드캐스트 broadcast("[" + clientName + "] 메시지: " + message, out); if (message.equalsIgnoreCase("exit")) { System.out.println("[" + socket.getInetAddress() + "] 연결 종료 요청"); break; } } } catch (IOException e) { System.out.println("클라이언트 연결 오류: " + e.getMessage()); } finally { try { if(out != null) clientWriterList.remove(out); if( clientName != null ) { broadcast(clientName + "님이 퇴장했습니다.", out); } socket.close(); System.out.println("클라이언트 연결 종료됨: " + socket.getInetAddress()); } catch (IOException e) { e.printStackTrace(); } } } } }

package socket; import java.io.BufferedReader; import java.io.InputStreamReader; import java.io.PrintWriter; import java.net.Socket; import java.util.Scanner; public class SimpleClient { public static void main(String[] args) { String serverAddress = "localhost"; int port = 9999; try ( Socket socket = new Socket(serverAddress, port); Scanner sc = new Scanner(System.in); PrintWriter out = new PrintWriter(socket.getOutputStream(), true); BufferedReader in = new BufferedReader( new InputStreamReader(socket.getInputStream()) ); ) { System.out.println("서버에 연결됨"); // 서버에서 오는 메시지 입력 Thread receiver = new Thread(() -> { try { String response; while( (response = in.readLine() ) != null ) { System.out.println(response); } } catch (Exception e) { System.out.println("서버 연결 종료"); } }); receiver.start(); // 서버로 출력 while(true) { String input = sc.nextLine(); out.println(input); // 서버로 채팅 보냄 } } catch (Exception e) { e.printStackTrace(); } } }

// 연결 타임아웃 (밀리초) socket.connect(new InetSocketAddress(host, port), 5000); // 읽기 타임아웃 socket.setSoTimeout(10000);