Kommentare

.gitignore

@@ -7,4 +7,5 @@ nbbuild/
 dist/
 nbdist/
 .nb-gradle/
-
+**/.~lock.*
+**/*~

src/client/Client.java

@@ -1,311 +0,0 @@
-package client;
-
-import java.awt.EventQueue;
-import javax.swing.JFrame;
-import javax.swing.JPanel;
-import javax.swing.border.EmptyBorder;
-import utils.Message;
-import javax.swing.JTextField;
-import javax.swing.JButton;
-import javax.swing.JTextArea;
-import java.awt.Color;
-import java.awt.event.ActionListener;
-import java.io.IOException;
-import java.io.ObjectInputStream;
-import java.io.ObjectOutputStream;
-import java.net.Socket;
-import java.net.SocketException;
-import java.util.Scanner;
-import java.awt.event.ActionEvent;
-
-/**
- * Hauptklasse des Clients
- *
- * @version 0.1.3
- * @author berdan
- */
-public class Client1 extends JFrame {
-
-    /**
-     * Hier werden Objekte und Variablen deklariert, damit diese in allen
-     * Methoden genutzt werden können.
-     */
-    private static JPanel contentPane;
-    JTextField txtMessage;
-    private static JTextField txtUsername;
-    public static String currentText = " ";
-    public static int i = 0;
-    public static Object tosend = new Message("Leer", "Leer");
-    public static Client1 t1;
-    public static Socket socket;
-    public static ObjectInputStream obinstr;
-    public static ObjectOutputStream oboust;
-    public static boolean verbunden = false;
-    public static JTextArea textArea = new JTextArea();
-    public static int anzahlVersuche = 0; //Ist gleich die AN
-    public static int anzahlRekursionen = 0;
-    public static Message temp = new Message("leer", "leer");
-
-    /**
-     * In der main Methode wird das GUI erstellt und die start() Methode
-     * aufgerufen.
-     */
-    public static void main(String[] args) throws InterruptedException {
-        t1 = new Client1();
-        EventQueue.invokeLater(new Runnable() {
-            public void run() {
-                try {
-                    Client1 frame = new Client1();
-                    frame.setVisible(true);
-                } catch (Exception e) {
-                    e.printStackTrace();
-                }
-            }
-        });
-
-        try {
-            start();
-        } catch (ClassNotFoundException e) {
-            // TODO Auto-generated catch block
-            e.printStackTrace();
-        } catch (IOException e) {
-            // TODO Auto-generated catch block
-            e.printStackTrace();
-        }
-    }
-
-    /**
-     * In der Methode Client1() wird das GUI und die Befehle die durch einen
-     * Click des Button's ausgelöst werden festgelegt
-     */
-    public Client1() {
-        setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
-        setBounds(100, 100, 450, 300);
-        contentPane = new JPanel();
-        contentPane.setBorder(new EmptyBorder(5, 5, 5, 5));
-        setContentPane(contentPane);
-        contentPane.setLayout(null);
-
-        txtMessage = new JTextField();
-        txtMessage.setText("Message");
-        txtMessage.setBounds(20, 230, 218, 20);
-        contentPane.add(txtMessage);
-        txtMessage.setColumns(10);
-
-        txtUsername = new JTextField();
-        txtUsername.setText("Username");
-        txtUsername.setBounds(20, 11, 86, 20);
-        contentPane.add(txtUsername);
-        txtUsername.setColumns(10);
-
-        /**
-         * Der Button "Send" nimmt die aktuelle Nachricht, welche im Textfeld
-         * "message" geschrieben wurde und schreibt diese als ein Message-Objekt
-         * in den Output-Stream an den Server, falls die Socket bereits
-         * verbunden ist.
-         *
-         * Falls die Nachricht "exit" sein sollte, wird die GUI beendet.
-         */
-        JButton btnSend = new JButton("Send");
-        btnSend.addActionListener(new ActionListener() {
-            public void actionPerformed(ActionEvent arg0) {
-
-                if (verbunden) {
-
-                    String themessage = txtMessage.getText();
-                    String theusername = txtUsername.getText();
-
-                    tosend = new Message(theusername, themessage);
-                    i = 1;
-
-                    temp = new Message(theusername, themessage);
-                    System.out.println("Button pressed");
-
-                    setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
-
-                    try {
-                        try {
-                            oboust.writeObject(tosend);
-                            oboust.flush();
-                        } catch (IOException e) {
-                            e.printStackTrace();
-                        }
-                    } catch (Exception k) {
-                        print("KEINE VERBINDUNG");
-                    }
-
-                    if (temp.getMessage().equals("exit")) {
-                        System.exit(0);
-                    }
-
-                    txtMessage.setText("");
-
-                }
-
-            }
-        });
-
-        btnSend.setBounds(264, 229, 79, 23);
-        contentPane.add(btnSend);
-
-        /**
-         * Hier wird die textArea, auf welcher der Text ausgegeben wird
-         * initialisiert
-         *
-         */
-        textArea = new JTextArea(currentText);
-        textArea.setLineWrap(true);
-        textArea.setForeground(Color.BLACK);
-        textArea.setBackground(Color.LIGHT_GRAY);
-        textArea.setBounds(20, 42, 323, 176);
-        contentPane.add(textArea);
-
-        /**
-         * Der Start Button sorgt sorgt dafür, dass der Username festgesetzt
-         * wird, wodurch er nicht veränderlich ist. Außerdem wird die globale
-         * Variabel j von 0 auf 1 gestzt, wodurch die start-Methode weiß, dass
-         * sie eine Verbindung aufbauen soll.
-         *
-         */
-        JButton btnStart = new JButton("Start");
-        btnStart.addActionListener(new ActionListener() {
-            public void actionPerformed(ActionEvent arg0) {
-
-                txtUsername.setEditable(false);
-                txtUsername.setEnabled(false);
-                verbunden = true;
-
-            }
-        });
-        btnStart.setBounds(116, 10, 89, 23);
-        contentPane.add(btnStart);
-
-    }
-
-    /**
-     * In der Print-Methode wird der neue Text (also eine neue Nachricht) auf
-     * die textArea abgebildet.
-     */
-    public static void print(String neuerText) {
-        currentText = neuerText + "\n" + currentText;
-
-        textArea.setText(currentText);
-    }
-
-    /**
-     * Die start-Methode wartet, bis die Variable verbunden durch Klicken des
-     * Start Buttons auf true gesetzt wird, erst dann beginnt die eigentliche
-     * Methode.
-     *
-     * Es wird dann eine Verbindung zum Socket über den Port 1236 aufgebaut.
-     * Sollte dies nicht Möglich sein, wird die Fehlermeldung in der GUI
-     * ausgegeben, sodass der Nutzer weiß, dass keine Vebrindung möglich ist.
-     *
-     * Es wird im Sekundentakt nach einer neuen Verbindung gesucht.
-     *
-     */
-    public static void start() throws IOException, ClassNotFoundException, InterruptedException {
-
-        while (!verbunden) {
-            Thread.sleep(100);
-        }
-
-        txtUsername.setEnabled(false);
-        Scanner scan = new Scanner(System.in);
-
-        try {
-            socket = new Socket("localhost", 1236);
-            oboust = new ObjectOutputStream(socket.getOutputStream());
-            obinstr = new ObjectInputStream(socket.getInputStream());
-            print("VERBINDUNG HERGESTELLT");
-        } catch (Exception KeineSocket) {
-            print("SERVER ANTWORTET NICHT");
-            try {
-                Thread.sleep(5000);
-            } catch (InterruptedException e) {
-                // TODO Auto-generated catch block
-                e.printStackTrace();
-            }
-            anzahlRekursionen++;
-            if (anzahlRekursionen == 10) {
-                print("KEINE ANTWORT, CLIENT WIRD BEENDET");
-                Thread.sleep(10000);
-                System.exit(0);
-            }
-            start();
-            System.exit(0);
-
-        }
-
-        Object erhalten = null;
-        Message message = new Message("leer", "leer");
-
-        /**
-         * Die While Schleife ist der Listener, dieser wartet auf Nachrichten
-         * aus dem Server und gibt diese dann aus.
-         *
-         * Im Falle eines Verindungsabbruches versucht er es 5 mal im Abstand
-         * von 2 Sekunden nochmal eine Nachricht zu senden und ruft dann wieder
-         * die start() Methode auf. wodurch die Verbindung nochmal neu
-         * hergestellt wird.
-         *
-         * Die While-Schleife wird abgebrochen, sobald die Nachricht, welche der
-         * Benutzer über das GUI sendet "exit" lautet.
-         *
-         */
-        while (!temp.getMessage().equals("exit")) {
-            //System.out.println("WHILE");
-            try {
-                //System.out.println("hile4");
-                System.out.println("Nachricht erhalten");
-                erhalten = obinstr.readObject(); //Bleibt hier stehen, bis ein neues Object reinkommt
-
-                message = (Message) erhalten;
-                System.out.println("[" + message.getUsername() + "]  " + message.getMessage());
-                String Ausgeben = message.getTime() + " [" + message.getUsername() + "]  " + message.getMessage();
-                print(Ausgeben);
-                //System.out.println("[CLIENT] NACHRICHT ERHALTEN");
-
-                oboust.flush();
-
-            } catch (SocketException h) {
-                System.out.println(h);
-                print("VERBINDUNGSABBRUCH");
-                anzahlVersuche++;
-
-                Thread.sleep(2000);
-
-                if (anzahlVersuche == 5) {
-                    anzahlVersuche = 0;
-                    anzahlRekursionen++;
-
-                    if (anzahlRekursionen == 10) {
-                        print("KEINE ANTWORT, CLIENT WIRD BEENDET");
-                        Thread.sleep(10000);
-                        System.exit(0);
-
-                    }
-
-                    start();
-                    System.exit(0);
-                }
-
-            } catch (Exception f) {
-                Thread.sleep(1000);
-            }
-
-        }
-
-        /**
-         * Nach dem Abbruch der While Schleife, was nur bei der Nachricht exit
-         * passiert, schließt der Client den ObjectOutputstream,
-         * Objectinputstream und den Socket und beendet dann das Programm
-         */
-        oboust.close();
-        obinstr.close();
-        socket.close();
-
-        System.exit(0);
-
-    }
-}

src/client/Client1.java

@@ -1,3 +1,20 @@
+/*
+ * Copyright (C) 2021 berdan
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ */
+
 package client;
 
 import java.awt.EventQueue;
@@ -46,13 +63,14 @@ public class Client1 extends JFrame {
     private static int anzahlVersuche = 0; //Ist gleich die AN
     private static int anzahlRekursionen = 0;
     private static Message temp = new Message("leer", "leer");
+    private static User user;
     
     /**
      * In der main Methode wird das GUI erstellt und die start() Methode
      * aufgerufen.
      * 
-     * @param args
-     * @throws InterruptedException 
+     * @param args Standard Main-Methode
+     * @throws InterruptedException Wirft die Exception
      */
     public static void main(String[] args) throws InterruptedException {
         t1 = new Client1();
@@ -98,6 +116,37 @@ public class Client1 extends JFrame {
         txtUsername.setBounds(20, 11, 86, 20);
         contentPane.add(txtUsername);
         txtUsername.setColumns(10);
+        
+        
+        /**
+         * Der Start Button sorgt sorgt dafür, dass der Username festgesetzt
+         * wird, wodurch er nicht veränderlich ist. Außerdem wird die globale
+         * Variabel j von 0 auf 1 gestzt, wodurch die start-Methode weiß, dass
+         * sie eine Verbindung aufbauen soll.
+         */
+        
+        JButton btnStart = new JButton("Start");
+        btnStart.addActionListener(new ActionListener() {
+            public void actionPerformed(ActionEvent arg0) {
+                
+                /**
+                 * Hier wird ein User-Objekt hergestellt
+                 */
+                
+                String name = txtUsername.getText();
+                String nachricht = txtMessage.getText();
+                
+                user = new User(name, nachricht);
+
+                txtUsername.setEditable(false);
+                txtUsername.setEnabled(false);
+                verbunden = true;
+
+            }
+        });
+        btnStart.setBounds(116, 10, 89, 23);
+        contentPane.add(btnStart);
+        
 
         /**
          * Der Button "Send" nimmt die aktuelle Nachricht, welche im Textfeld
@@ -114,12 +163,13 @@ public class Client1 extends JFrame {
                 if (verbunden) {
 
                     String themessage = txtMessage.getText();
-                    String theusername = txtUsername.getText();
+                    //String theusername = user.getUsername();
 
-                    tosend = new Message(theusername, themessage);
+                    tosend = new Message(user.getUsername(), themessage);
                     i = 1;
 
-                    temp = new Message(theusername, themessage);
+                    temp = new Message(user.getUsername(), themessage);
+                    
                     System.out.println("Button pressed");
 
                     setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
@@ -132,12 +182,16 @@ public class Client1 extends JFrame {
                     } catch (Exception k) {
                         print("KEINE VERBINDUNG");
                     }
+                    
+                    user.setMessage(themessage);
 
                     if (temp.getMessage().equals("exit")) {
                         System.exit(0);
                     }
                     txtMessage.setText("");
                     
+
+                    
                 }
 
             }
@@ -157,24 +211,7 @@ public class Client1 extends JFrame {
         textArea.setBounds(20, 42, 323, 176);
         contentPane.add(textArea);
 
-        /**
-         * Der Start Button sorgt sorgt dafür, dass der Username festgesetzt
-         * wird, wodurch er nicht veränderlich ist. Außerdem wird die globale
-         * Variabel j von 0 auf 1 gestzt, wodurch die start-Methode weiß, dass
-         * sie eine Verbindung aufbauen soll.
-         */
-        JButton btnStart = new JButton("Start");
-        btnStart.addActionListener(new ActionListener() {
-            public void actionPerformed(ActionEvent arg0) {
 
-                txtUsername.setEditable(false);
-                txtUsername.setEnabled(false);
-                verbunden = true;
-
-            }
-        });
-        btnStart.setBounds(116, 10, 89, 23);
-        contentPane.add(btnStart);
 
     }
 
@@ -182,7 +219,7 @@ public class Client1 extends JFrame {
      * In der Print-Methode wird der neue Text (also eine neue Nachricht) auf
      * die textArea abgebildet.
      * 
-     * @param neuerText
+     * @param neuerText Text als String, wird auf textArea abgebildet
      */
     public static void print(String neuerText) {
         currentText = neuerText + "\n" + currentText;
@@ -201,9 +238,9 @@ public class Client1 extends JFrame {
      *
      * Es wird im Sekundentakt nach einer neuen Verbindung gesucht.
      *
-     * @throws IOException
-     * @throws ClassNotFoundException
-     * @throws InterruptedException
+     * @throws IOException Wirft die Exception
+     * @throws ClassNotFoundException Wirft die Exception
+     * @throws InterruptedException Wirft die Exception
      */
     public static void start() throws IOException, ClassNotFoundException, InterruptedException {
 

src/client/User.java

@@ -0,0 +1,60 @@
+/*
+ * Copyright (C) 2021 berdan
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ */
+package client;
+
+/**
+ * Die Klasse ist für das User Objekt verantwortlich
+ * 
+ * @version 0.0.1
+ * @author berdan
+ */
+
+public class User {
+    
+    private String username;
+    private String currentmessage;
+    
+    /**
+     * Der Konstrukter des User-Objektes
+     * @param username1 Der Nutzername
+     * @param message1 Die Nachricht
+     */
+    public User(String username1, String message1){
+        this.username = username1;
+        this.currentmessage = message1;
+    }
+    
+    /**
+     * 
+     * @param newMessage Die neue Nachricht
+     */
+    public void setMessage(String newMessage){
+        this.currentmessage = newMessage;
+    }
+    
+    /**
+     * Die get-Methode für den Username
+     * @return Der Nutzernamen
+     */
+    
+    public String getUsername(){
+        return this.username;
+    }
+    
+    
+    
+}

src/test/MainClient.java

@@ -26,6 +26,12 @@ import utils.Message;
  * @author berdan, eichehome
  */
 public class MainClient {
+    
+    /**
+     * 
+     * @throws IOException Wirft die Exception
+     * @throws ClassNotFoundException Wirft die Exception 
+     */
 
     public MainClient() throws IOException, ClassNotFoundException {
         System.out.println("[CLIENT] START");

src/test/PipeTest.java

@@ -26,6 +26,10 @@ import utils.Message;
  */
 public class PipeTest {
 
+    /**
+     * 
+     * @param args Standard String der Main-Methode
+     */
     public static void main(String[] args) {
         FifoPipe pipe = new FifoPipe();
 //        System.out.println("Erstes Element: " + pipe.firstElement);

src/utils/Message.java

@@ -1,3 +1,20 @@
+/*
+ * Copyright (C) 2021 berdan
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ */
+
 package utils;
 
 import java.io.Serializable;
@@ -14,17 +31,21 @@ import java.util.Date;
  */
 
 
+/**
+ * 
+ * @author berda
+ */
 public class Message implements Serializable {
 
-    String username;
-    String message;
-    String time = "00:00";
+    private String username;
+    private String message;
+    private String time = "00:00";
     
     /**
      * Konstruktor des Message Objektes
      * 
-     * @param username
-     * @param message 
+     * @param username Der Benutzername, welcher gewählt wurde
+     * @param message Die Nachricht, welche geschrieben wurde
      * 
      */
     
@@ -36,7 +57,7 @@ public class Message implements Serializable {
     
     /**
      * toString Methode
-     * @return 
+     * @return Ein String, welcher die Informationen der Nachricht ausgibt
      */
     @Override
     public String toString() {
@@ -48,7 +69,7 @@ public class Message implements Serializable {
 
     /**
      * Funktion gibt false aus, sobald der Text der Nachricht "exit" ist
-     * @return 
+     * @return Einen Boolean, welcher false ausgibt, fals die Nachricht exit ist
      */
     public boolean exit() {
         return !message.equalsIgnoreCase("exit");
@@ -56,14 +77,14 @@ public class Message implements Serializable {
     
     /**
      * Funktion, welche die Nachricht des Message Objektes zurück gibt
-     * @return 
+     * @return String, der die Nachricht enthält
      */
     public String getMessage() {
         return message;
     }
     /**
      * Funktion, welche den Usernamen des Message Objektes zurück gibt
-     * @return 
+     * @return String, welcher den Nutzernamen enthält
      */
     public String getUsername() {
         return username;
@@ -71,7 +92,7 @@ public class Message implements Serializable {
     
     /**
      * 
-     * @return 
+     * @return String, welcher den Absendezeitpunkt enthält
      */
     public String getTime(){
         return time;