76 lines
1.7 KiB
Java
76 lines
1.7 KiB
Java
import java.io.*;
|
|
import java.net.*;
|
|
import java.util.concurrent.ExecutorService;
|
|
import java.util.concurrent.Executors;
|
|
|
|
class Server {
|
|
public static void main(String[] args) {
|
|
ServerSocket server = null;
|
|
try {
|
|
// start server
|
|
server = new ServerSocket(8080);
|
|
server.setReuseAddress(true);
|
|
|
|
while (true) {
|
|
Socket client = server.accept();
|
|
System.out.println("New client: " + client.getInetAddress().getHostAddress());
|
|
|
|
ClientHandler clientSock = new ClientHandler(client);
|
|
ExecutorService executorService = Executors.newFixedThreadPool(2);
|
|
executorService.submit(clientSock);
|
|
}
|
|
} catch (IOException e) {
|
|
e.printStackTrace();
|
|
} finally {
|
|
if (server != null) {
|
|
try {
|
|
server.close();
|
|
} catch (IOException e) {
|
|
e.printStackTrace();
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
private static class ClientHandler implements Runnable {
|
|
|
|
private Socket clientSocket;
|
|
|
|
public ClientHandler(Socket socket) {
|
|
this.clientSocket = socket;
|
|
}
|
|
|
|
public void run() {
|
|
PrintWriter out = null;
|
|
BufferedReader in = null;
|
|
try {
|
|
out = new PrintWriter(clientSocket.getOutputStream(), true);
|
|
in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
|
|
|
|
String line;
|
|
while ((line = in.readLine()) != null) {
|
|
System.out.printf("From the client: %s\n", line);
|
|
out.println(line);
|
|
|
|
}
|
|
} catch (IOException e) {
|
|
e.printStackTrace();
|
|
} finally {
|
|
try {
|
|
if (out != null) {
|
|
out.close();
|
|
}
|
|
if (in != null) {
|
|
in.close();
|
|
System.out.println("closing socket " + clientSocket.getInetAddress().getHostAddress());
|
|
clientSocket.close();
|
|
}
|
|
} catch (IOException e) {
|
|
e.printStackTrace();
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
}
|