-
Notifications
You must be signed in to change notification settings - Fork 0
/
Main.java
29 lines (27 loc) · 990 Bytes
/
Main.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
import handler.ClientHandler;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
public class Main {
public static void main(String[] args) {
ServerSocket serverSocket = null;
int port = 6379;
try {
serverSocket = new ServerSocket(port);
serverSocket.setReuseAddress(true);
while (!serverSocket.isClosed() && !Thread.currentThread().isInterrupted()) {
Socket clientSocket = serverSocket.accept();
// Create a new thread for the client.
new Thread(new ClientHandler(clientSocket)).start();
}
} catch (IOException e) {
System.out.println("IOException: " + e.getMessage());
} finally {
try {
if (serverSocket != null) serverSocket.close();
} catch (IOException e) {
System.out.println("IOException: " + e.getMessage());
}
}
}
}