fully implemented chat room that the admin can only send the message and the members can listen to them

Author: samydevv

out/production/Chat-Room-using-Java/AdminClient/AdminClient.class

@@ -11,7 +11,7 @@ public class AdminClient {
     public static final int BROADCAST_PORT = 3001;
     public static final String Section_1 = "1";
     public static final String Section_2 = "2";
-//    public static boolean end = false;
+
 
     public static void main(String[] args) throws IOException {
         System.out.println("Welcome, Which group do you want to broadcast your\n" +
@@ -27,14 +27,19 @@ public static void main(String[] args) throws IOException {
         out.println(groupSectionID);
         String messageInfo = null;
         String messageContent = null;
-        if ((messageInfo = massageReader.readLine()) != null) {
+        while ((messageInfo = massageReader.readLine()) != null) {
             System.out.println(messageInfo);
             BufferedReader consoleReader = new BufferedReader(new InputStreamReader(System.in));
             messageContent = consoleReader.readLine();
+            if (!"end".equals(messageContent)) {
+                out.println(messageContent);
+
+            }else{
+                out.println(messageContent);
+                break;
+            }
         }
-        while (!"end".equals(messageContent)) {
-            out.println(messageContent);
-        }
+
         scanner.close();
         massageReader.close();
         out.close();

out/production/Chat-Room-using-Java/MemberClient/MemberClient.class

@@ -4,6 +4,8 @@
 import java.io.IOException;
 import java.io.InputStreamReader;
 import java.io.PrintWriter;
+import java.net.DatagramPacket;
+import java.net.DatagramSocket;
 import java.net.Socket;
 import java.util.Scanner;
 
@@ -20,19 +22,35 @@ public static void main(String[] args) throws IOException {
         String groupSectionID = (scanner.nextInt()) == 1 ? Section_1 : Section_2;
 
         Socket s = new Socket("localhost", SUBSCRIBE_PORT);
-
         PrintWriter out = new PrintWriter(s.getOutputStream(), true);
         Scanner messageScanner = new Scanner(new InputStreamReader(s.getInputStream()));
+        Scanner ID =null;
         out.println(groupSectionID);
         String stateMassage = messageScanner.next();
 
         if (stateMassage.equals("SUCCESS")) {
-
-            String message = messageScanner.nextLine();
+            String message =  messageScanner.nextLine();
             System.out.println(message);
-            while(true){
+            if(groupSectionID.equals("1")){
 
+                ID = new Scanner(message).useDelimiter("\\s*You are successfully added to the group Section-1 with ID =\\s*");
+            }else{
+                ID = new Scanner(message).useDelimiter("\\s*You are successfully added to the group Section-2 with ID =\\s*");
+            }
+                int clientID = ID.nextInt();
+            DatagramSocket serverSocket = new DatagramSocket(clientID);
+
+
+            while (true){
+                byte[] receiveData = new byte[1024];
+                // prepare  packet container to receive the reply from the server
+                DatagramPacket receivePacket = new DatagramPacket(receiveData, receiveData.length);
+                // wait to receive the reply
+                serverSocket.receive(receivePacket);
+                String messageContent = new String(receivePacket.getData());
+                System.out.println("FROM Admin:" + messageContent);
             }
+//            serverSocket.close();
 
         }else{
             String message = messageScanner.nextLine();

out/production/Chat-Room-using-Java/Server/Server$1.class

@@ -4,8 +4,7 @@
 import java.io.IOException;
 import java.io.InputStreamReader;
 import java.io.PrintWriter;
-import java.net.ServerSocket;
-import java.net.Socket;
+import java.net.*;
 import java.util.ArrayList;
 
 
@@ -19,11 +18,20 @@ public class Server {
 
     public static void main(String[] args){
         System.out.println("The server started .. ");
+        /**
+         * in this server chat we assume that we have only two groups section-1 and section-2 and each section can handel
+         * a maximum member of 3 and here we initialize the group array list.the member client allow only to choose the
+         *  one group and listen to what will the admin send to this groups
+         */
         ArrayList<Members> groupSection_1 = new ArrayList<>();
         ArrayList<Members> groupSection_2 = new ArrayList<>();
         Groups Section_1 = new Groups("Section_1",groupSection_1),Section_2=new Groups("Section_2",groupSection_2) ;
         groupsArrayList.add(Section_1);
         groupsArrayList.add(Section_2);
+        /**
+         * we use this thread for subscription to either one of the two sections, and in the constructor we pass
+         * total client number + 600  , the groupe array list to choose between the 2 sections
+         */
         new Thread() {
             public void run() {
                 try {
@@ -36,13 +44,16 @@ public void run() {
                 }
             }
         }.start();
-
+        /**
+         * we use this thread fro broadcasting the message from the admins member  to the group that they will
+         * choose to send their message to.
+         */
         new Thread() {
             public void run() {
                 try {
                     ServerSocket ss = new ServerSocket(BROADCAST_PORT);
                     while (true) {
-                            new BROADCAST_Service(ss.accept()).start();
+                            new BROADCAST_Service(ss.accept(),groupsArrayList).start();
                     }
                 } catch (IOException e) {
                     e.printStackTrace();
@@ -52,25 +63,68 @@ public void run() {
     }
     private static class BROADCAST_Service extends Thread{
         Socket socket;
-
-        public BROADCAST_Service(Socket socket) {
+        ArrayList<Groups> groupsArrayList = new ArrayList<>();
+        public BROADCAST_Service(Socket socket,ArrayList<Groups> groupsArrayList)  {
             this.socket = socket;
+            this.groupsArrayList=groupsArrayList;
         }
 
         public void run() {
             try {
                 PrintWriter out = new PrintWriter(this.socket.getOutputStream(), true);
                 BufferedReader groupBR = new BufferedReader(new InputStreamReader(this.socket.getInputStream()));
                 String groupSectionID = groupBR.readLine();
-                if (groupSectionID.equals("1")) {
+                DatagramSocket clientSocket = new DatagramSocket();
+                while (groupSectionID.equals("1")) {
                     String str  = "What is the message to be broadcast?";
                     out.println(str);
                     String message = null;
-                    while((message=groupBR.readLine())!= null){
-                            System.out.println(message);
-
+                    Groups Section1 =groupsArrayList.get(0);
+                    System.out.println("Sending data to all client in this group");
+                    if ((message=groupBR.readLine())!= null && !message.equals("end")){
+                        System.out.println(message);
+                            // convert to byte
+                            byte[] sendData = new byte[1024];
+                            sendData=message.getBytes();
+                            // get the IP Address of the server
+                            InetAddress IPAddress = InetAddress.getByName("localhost");
+                            for (int i=0; i<Section1.membersArrayList.size() ;i++){
+                                int clientID= Section1.membersArrayList.get(i).getID();
+                                //create packet
+                                DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length, IPAddress, clientID);
+                                clientSocket.send(sendPacket);
+                            }
+                    }else{
+                        break;
                     }
                 }
+                while (groupSectionID.equals("2")) {
+                    String str  = "What is the message to be broadcast?";
+                    out.println(str);
+                    String message = null;
+                    Groups Section2 =groupsArrayList.get(1);
+                    System.out.println("Sending data to all client in this group");
+                    if ((message=groupBR.readLine())!= null && !message.equals("end")){
+                        System.out.println(message);
+                        // convert to byte
+                        byte[] sendData = new byte[1024];
+                        sendData=message.getBytes();
+                        // get the IP Address of the server
+                        InetAddress IPAddress = InetAddress.getByName("localhost");
+                        for (int i=0; i<Section2.membersArrayList.size() ;i++){
+                            int clientID= Section2.membersArrayList.get(i).getID();
+                            //create packet
+                            DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length, IPAddress, clientID);
+                            clientSocket.send(sendPacket);
+                        }
+                    }else{
+                        break;
+                    }
+                }
+                out.close();
+                groupBR.close();
+                socket.close();
+                clientSocket.close();
             } catch (IOException e) {
                 e.printStackTrace();
             }
@@ -86,7 +140,7 @@ public SUBSCRIBE_Service(Socket socket, int clientID, ArrayList<Groups> groupsAr
             this.socket = socket;
             this.clientID = clientID;
             this.groupsArrayList=groupsArrayList;
-            System.out.println("Connection with Client #" + clientID + "at socket " + socket);
+            System.out.println("Subscribe Service Connection with Client #" + clientID + "at socket " + socket);
         }
 
         public void run() {
@@ -103,6 +157,9 @@ public void run() {
                     if (State) {
                         String str  = "SUCCESS You are successfully added to the group Section-1 with ID =" + clientID;
                         out.println(str);
+                        while(true){
+
+                        }
 
                     }else{
                         String str  = "FAILURE Sorry, the group reached its maximum count";
@@ -116,6 +173,9 @@ public void run() {
                     if (State) {
                         String str  = "SUCCESS You are successfully added to the group Section-2 with ID =" + clientID;
                         out.println(str);
+                        while(true){
+
+                        }
                     }else{
                         String str  = "FAILURE Sorry, the group reached its maximum count";
                         out.println(str);
@@ -132,7 +192,9 @@ public void run() {
         }
     }
 
-
+    /**
+     * the server contain two inner class that it is implemented as required from the PDF
+     */
     public static final class Members {
         int ID;
 
@@ -157,7 +219,6 @@ public Groups(String name, ArrayList<Members> membersArrayList) {
         public boolean addMember(Members M){
             if (membersArrayList.size() != MaximumNumber){
                 membersArrayList.add(M);
-                System.out.println(membersArrayList.size());
                 return true;
             }
             return false;