-import java.net.*;\r
-import java.io.*;\r
-\r
-public class Main {\r
- public static void main(String[] args) {\r
- ServerSocket listenSocket = null;\r
- try {\r
- listenSocket = new ServerSocket(Integer.parseInt(args[0])); // port\r
- while (true) { // le dispatcher est le thread qui execute main()\r
- Socket clientSocket = listenSocket.accept();\r
- System.out.println("Connexion de :" + clientSocket.getInetAddress());\r
- Thread serviceThread = new Thread(new EchoServerThreadService(clientSocket));\r
- serviceThread.start();\r
- }\r
- }\r
- catch (Exception e) {\r
- System.err.println("IOException : " + e);\r
- e.printStackTrace();\r
- }\r
- finally {\r
- try {\r
- if (listenSocket != null)\r
- listenSocket.close();\r
- } catch (IOException e) {\r
- System.err.println("IOException : " + e);\r
- e.printStackTrace();\r
- }\r
- }\r
- }\r
-\r
-}\r
+import java.net.*;
+import java.io.*;
+
+public class Main {
+ public static void main(String[] args) {
+ ServerSocket listenSocket = null;
+ try {
+ listenSocket = new ServerSocket(Integer.parseInt(args[0])); // port
+ while (true) { // le dispatcher est le thread qui execute main()
+ Socket clientSocket = listenSocket.accept();
+ System.out.println("Connexion de :" + clientSocket.getInetAddress());
+ Thread serviceThread = new Thread(new BroadcastThreadService(clientSocket));
+ serviceThread.start();
+ }
+ }
+ catch (Exception e) {
+ System.err.println("IOException : " + e);
+ e.printStackTrace();
+ }
+ finally {
+ try {
+ if (listenSocket != null)
+ listenSocket.close();
+ } catch (IOException e) {
+ System.err.println("IOException : " + e);
+ e.printStackTrace();
+ }
+ }
+ }
+
+}