Untitled
unknown
plain_text
a month ago
1.7 kB
1
Indexable
Never
import java.io.*; import java.net.*; public class TCPServer { private static final int PORT = 12345; // Port number to listen on public static void main(String[] args) { try (ServerSocket serverSocket = new ServerSocket(PORT)) { System.out.println("Server is listening on port " + PORT); while (true) { // Accept an incoming connection Socket clientSocket = serverSocket.accept(); System.out.println("New client connected: " + clientSocket.getInetAddress()); // Handle the client in a new thread new Thread(new ClientHandler(clientSocket)).start(); } } catch (IOException e) { e.printStackTrace(); } } } class ClientHandler implements Runnable { private Socket clientSocket; public ClientHandler(Socket socket) { this.clientSocket = socket; } @Override public void run() { try (BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream())); PrintWriter out = new PrintWriter(clientSocket.getOutputStream(), true)) { String message; while ((message = in.readLine()) != null) { // Print the received message and send a response System.out.println("Received: " + message); out.println("Server received: " + message); } } catch (IOException e) { e.printStackTrace(); } finally { try { clientSocket.close(); } catch (IOException e) { e.printStackTrace(); } } } }
Leave a Comment