Релизная версия чата

Client/pom.xml

@@ -17,4 +17,17 @@
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
     </properties>
 
+    <dependencies>
+        <dependency>
+            <groupId>org.openjfx</groupId>
+            <artifactId>javafx-controls</artifactId>
+            <version>23.0.2</version>
+        </dependency>
+        <dependency>
+            <groupId>org.openjfx</groupId>
+            <artifactId>javafx-base</artifactId>
+            <version>23.0.2</version>
+        </dependency>
+    </dependencies>
+
 </project>

Client/src/main/java/ru/project/ChatClientGUI.java

@@ -0,0 +1,115 @@
+package ru.project;
+import javafx.application.Application;
+import javafx.application.Platform;
+import javafx.scene.Scene;
+import javafx.scene.control.Button;
+import javafx.scene.control.TextArea;
+import javafx.scene.control.TextField;
+import javafx.scene.layout.VBox;
+import javafx.stage.Stage;
+import javafx.geometry.Insets;
+import java.io.DataInputStream;
+import java.io.DataOutputStream;
+import java.io.IOException;
+import java.net.Socket;
+
+public class ChatClientGUI extends Application {
+    private TextArea chatArea;
+    private TextField inputField;
+    private Button sendButton;
+    private Socket socket;
+    private DataInputStream in;
+    private DataOutputStream out;
+    private boolean isBanned = false;
+
+    @Override
+    public void start(Stage primaryStage) {
+        chatArea = new TextArea();
+        chatArea.setEditable(false);
+        chatArea.setWrapText(true);
+
+        inputField = new TextField();
+        inputField.setPromptText("Введите сообщение...");
+
+        Button sendButton = new Button("Отправить");
+        sendButton.setOnAction(e -> sendMessage());
+
+        VBox root = new VBox(10,chatArea, inputField, sendButton);
+        root.setPadding(new Insets(10, 10, 10, 10));
+        Scene scene = new Scene(root, 400, 300);
+
+        primaryStage.setTitle("Чат-клиент");
+        primaryStage.setScene(scene);
+        primaryStage.show();
+
+        connectToServer();
+    }
+
+    public static void main(String[] args) {
+        launch(args);
+    }
+
+    private void sendMessage() {
+        String message = inputField.getText().trim();
+        if (!message.isEmpty() && !isBanned) {
+            try {
+                out.writeUTF(message); // Отправляем на сервер
+                inputField.clear(); // Очищаем поле
+            } catch (IOException e) {
+                chatArea.appendText("Ошибка отправки сообщения\n");
+            }
+        } else if (isBanned) {
+            chatArea.appendText("Вы не можете писать сообщения, так как заблокированы.\n");
+        }
+    }
+    private void connectToServer() {
+        try {
+            socket = new Socket("localhost", 8189);
+            in = new DataInputStream(socket.getInputStream());
+            out = new DataOutputStream(socket.getOutputStream());
+            chatArea.appendText("Подключено к серверу\n");
+
+            new Thread(() -> {
+                try {
+                    while (true) {
+                        String message = in.readUTF();
+                        Platform.runLater(() -> processServerMessage(message));
+                    }
+                } catch (Exception e) {
+                    Platform.runLater(() -> chatArea.appendText(e.getMessage() + "\n"));
+                }
+            }).start();
+        } catch (Exception e) {
+            chatArea.appendText(e.getMessage() + "\n");
+        }
+    }
+    private void processServerMessage(String message) {
+        if (message.startsWith("/")) {
+            if (message.equalsIgnoreCase("/exitok")) {
+                disconnect();
+            } else if (message.startsWith("/authOK ")) {
+                chatArea.appendText("Авторизация успешна! Ваш ник: " + message.split(" ")[1] + "\n");
+            } else if (message.startsWith("/regOK ")) {
+                chatArea.appendText("Регистрация успешна! Ваш ник: " + message.split(" ")[1] + "\n");
+            } else if (message.equalsIgnoreCase("/banok")) {
+                isBanned = true;
+                chatArea.appendText("Вы были заблокированы администратором.\n");
+            } else if (message.equalsIgnoreCase("/unbanok")) {
+                isBanned = false;
+                chatArea.appendText("Вы теперь разбанены и можете писать сообщения.\n");
+            }
+        } else {
+            chatArea.appendText(message + "\n"); // Обычное сообщение
+        }
+    }
+    private void disconnect() {
+        try {
+            if (socket != null) socket.close();
+            if (in != null) in.close();
+            if (out != null) out.close();
+            chatArea.appendText("Отключено от сервера\n");
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+}

Client/src/main/java/ru/project/Client.java

@@ -0,0 +1,96 @@
+package ru.project;
+
+import java.io.DataInputStream;
+import java.io.DataOutputStream;
+import java.io.IOException;
+import java.net.Socket;
+import java.net.SocketException;
+import java.util.Scanner;
+
+public class Client {
+    private Socket socket;
+    private DataOutputStream out;
+    private DataInputStream in;
+    private Scanner scanner;
+    private boolean isBanned = false;
+
+    public Client() throws IOException {
+        scanner = new Scanner(System.in);
+        socket = new Socket("localhost", 8189);
+        out = new DataOutputStream(socket.getOutputStream());
+        in = new DataInputStream(socket.getInputStream());
+
+        new Thread(() -> {
+            try {
+                while (!socket.isClosed()) {
+                    String message = in.readUTF();
+                    if (message.startsWith("/")) {
+                        if (message.equalsIgnoreCase("/exitok")) {
+                            break;
+                        }
+                        if (message.startsWith("/authOK ")) {
+                            System.out.println("Авторизация прошла успешно! Имя пользователя: "
+                                    + message.split(" ")[1]);
+                        }
+                        if (message.startsWith("/regOK ")) {
+                            System.out.println("Регистрация прошла успешно! Имя пользователя: "
+                                    + message.split(" ")[1]);
+                        }
+                        if (message.equalsIgnoreCase("/banok")) {
+                            isBanned = true;
+                            System.out.println("Вы были заблокированы администратором.");
+                        }
+                        if (message.equalsIgnoreCase("/unbanok")) {
+                            isBanned = false;
+                            System.out.println("Теперь вы не заблокированы. Вам доступна отправка сообщений в чат.");
+                        }
+                    } else {
+                        System.out.println(message);
+                    }
+                }
+            } catch (IOException e) {
+                e.printStackTrace();
+            } finally {
+                disconnect();
+            }
+        }).start();
+
+        while (!socket.isClosed()) {
+            String message = scanner.nextLine();
+            try {
+                if (!isBanned) {
+                    out.writeUTF(message);
+                } else System.out.println("Вы не можете писать сообщения.");
+            } catch (SocketException e) {
+                System.out.println("Вы были отключены от сервера.");
+            }
+            if (message.equalsIgnoreCase("/exit")) {
+                break;
+            }
+        }
+    }
+
+    public void disconnect() {
+        try {
+            if (in != null) {
+                in.close();
+            }
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        try {
+            if (out != null) {
+                out.close();
+            }
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        try {
+            if (socket != null) {
+                socket.close();
+            }
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+}

Client/src/main/java/ru/project/ClientApplication.java

@@ -0,0 +1,14 @@
+package ru.project;
+
+import java.io.IOException;
+
+
+public class ClientApplication {
+    public static void main(String[] args) {
+        try {
+            new Client();
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+}

Server/src/main/java/ru/project/Authenticator.java

@@ -0,0 +1,7 @@
+package ru.project;
+
+public interface Authenticator {
+    void initialize();
+    boolean authenticate(ClientHandler clientHandler, String login, String password);
+    boolean registration(ClientHandler clientHandler, String username, String login, String password);
+}