class userThread extends Thread {

	ConnectNodeJs cnj = new ConnectNodeJs();
	ConnectNodeJsQ cnQ = new ConnectNodeJsQ();
	PublicArr pa = new PublicArr();
		
	Socket SS;
	String ID;
	String getID;
	int class4 = 25;
	
	userThread(Socket SS) {
		this.SS = SS;
	}
	
	public String Checking(ArrayList<String> check) {
		String notConnectStudents = "";
		int count = 0;
		if(check.size() == 0) return "ALL";
		
		for (int i = 0; i < class4; i++) {
			if(count == check.size()) {
				notConnectStudents = notConnectStudents + Integer.toString(i + 1) + " ";
				continue;
			}
			if(i + 1 == Integer.parseInt(check.get(count))) {
				count++;
				continue;
			}
			else {
				notConnectStudents = notConnectStudents + Integer.toString(i + 1) + " ";
			}
		}
		
		return notConnectStudents;
	}
	
	@Override
	public void run() {
		try {
			while (true) {
				InputStream IS = SS.getInputStream();
				byte[] bt = new byte[256];
				int size = IS.read(bt);

				String output = new String(bt, 0, size, "UTF-8");
				if (output.substring(output.length() - 1).equals("0")) {
					ID = output.substring(0, output.length() - 1);
					int index = ID.indexOf("2");
					getID = ID.substring(index + 3, index + 5);
					pa.check.add(getID);
				} else {
					System.out.println(ID + "> " + output);
//                	cnj.conn(ID, output); soket.io 접속 코드
					pa.check.sort(Comparator.naturalOrder());
					String id = Checking(pa.check);
					cnQ.connectionQ(ID, output, id); // rabbitmq로 nodejs 연결
					
				}
			}
		} catch (IOException | TimeoutException e) {
			pa.check.remove(getID);
			System.out.println("--" + ID + " user OUT");
		}
	}

}//

class connectThread extends Thread {

	ServerSocket MSS;
	int Count = 1;

	connectThread(ServerSocket MSS) {
		this.MSS = MSS;
	}

	@Override
	public void run() {
		try {
			while (true) {
				Socket SS = MSS.accept();

				userThread ust = new userThread(SS);
				ust.start();
				Count++;
			}

		} catch (IOException e) {
			System.out.println("--SERVER CLOSE");
		}
	}
}//

public class ThreadServer {
	
	ArrayList<String> check = new ArrayList<String>();

	public static void main(String[] args) {
		Scanner input = new Scanner(System.in);
		ServerSocket MSS = null;

		try {
			MSS = new ServerSocket();
			MSS.bind(new InetSocketAddress(InetAddress.getLocalHost(), 30001));

			System.out.println("--SERVER Close : input num");
			System.out.println("--SERVER Waiting...");
			connectThread cnt = new connectThread(MSS);
			cnt.start();
			int temp = input.nextInt();

		} catch (Exception e) {
			System.out.println(e);
		}

		try {
			MSS.close();
		} catch (Exception e) {
			System.out.println(e);
		}

	}// MAIN
}