package order;
import java.io.BufferedReader;
import java.io.FileNotFoundException;
import java.io.FileReader;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.logging.Level;
import java.util.logging.Logger;
public class Server {
private String ip;
private int port;
private int connectTimeOut;
private int sendTimeOut;
private int receiveTimeOut;
private ExecutorService pool = Executors.newFixedThreadPool(50);
public Server() {
FileReader reader = null;
BufferedReader bufferedReader = null;
try {
reader = new FileReader("config/SocketConfig.txt");
bufferedReader = new BufferedReader(reader);
String line;
ArrayList list = new ArrayList<>();
while ((line = bufferedReader.readLine()) != null) {
list.add(line.trim());
}
this.ip = list.get(0);
this.port = Integer.parseInt(list.get(1));
this.connectTimeOut = Integer.parseInt(list.get(2));
this.sendTimeOut = Integer.parseInt(list.get(3));
this.receiveTimeOut = Integer.parseInt(list.get(4));
} catch (FileNotFoundException ex) {
Logger.getLogger(Server.class.getName()).log(Level.SEVERE, null, ex);
} catch (IOException ex) {
Logger.getLogger(Server.class.getName()).log(Level.SEVERE, null, ex);
} finally {
try {
reader.close();
} catch (IOException ex) {
Logger.getLogger(Server.class.getName()).log(Level.SEVERE, null, ex);
}
if (bufferedReader != null) {
try {
bufferedReader.close();
} catch (IOException ex) {
Logger.getLogger(Server.class.getName()).log(Level.SEVERE, null, ex);
}
}
}
}
@SuppressWarnings("resource")
public void serve() {
try {
// Start server
ServerSocket server = new ServerSocket(port);
System.out.println("Server is ready...");
int count = 0;
while (true) {
Socket socket = server.accept();
// Received from a client
System.out.println(count);
pool.submit(new ServerThread(socket));
count++;
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public static void main(String[] args) {
Server server = new Server();
server.serve();
}
public String getIp() {
return ip;
}
public int getPort() {
return port;
}
public int getConnectTimeOut() {
return connectTimeOut;
}
public int getSendTimeOut() {
return sendTimeOut;
}
public int getReceiveTimeOut() {
return receiveTimeOut;
}
}