diff --git a/.gitignore b/.gitignore
index bdd4439..e4316fc 100644
--- a/.gitignore
+++ b/.gitignore
@@ -1,3 +1,4 @@
*.pdf
/out/
/Homeworks/
+*.zip
diff --git a/.idea/libraries/sqlite_jdbc_3_21_0.xml b/.idea/libraries/sqlite_jdbc_3_21_0.xml
new file mode 100644
index 0000000..7ab8ea7
--- /dev/null
+++ b/.idea/libraries/sqlite_jdbc_3_21_0.xml
@@ -0,0 +1,9 @@
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/Java2.iml b/Java2.iml
index c90834f..050079b 100644
--- a/Java2.iml
+++ b/Java2.iml
@@ -7,5 +7,6 @@
+
\ No newline at end of file
diff --git a/JavaFX_chat.db b/JavaFX_chat.db
new file mode 100644
index 0000000..4c5da40
Binary files /dev/null and b/JavaFX_chat.db differ
diff --git a/src/ru/geekbrains/java2/lesson_06/Classwork/client/Controller.java b/src/ru/geekbrains/java2/lesson_06/Classwork/client/Controller.java
new file mode 100644
index 0000000..ff76fa0
--- /dev/null
+++ b/src/ru/geekbrains/java2/lesson_06/Classwork/client/Controller.java
@@ -0,0 +1,74 @@
+package ru.geekbrains.java2.lesson_06.Classwork.client;
+
+import javafx.fxml.FXML;
+import javafx.fxml.Initializable;
+import javafx.scene.control.Button;
+import javafx.scene.control.TextArea;
+import javafx.scene.control.TextField;
+
+import java.io.DataInputStream;
+import java.io.DataOutputStream;
+import java.io.IOException;
+import java.net.Socket;
+import java.net.URL;
+import java.util.ResourceBundle;
+
+public class Controller implements Initializable {
+ public static final String SERVER_IP = "localhost";
+ public static final int SERVER_PORT = 8189;
+
+ @FXML
+ public TextArea chatArea;
+ @FXML
+ public TextField msgField;
+// public Button sendButton;
+
+ private Socket socket;
+ private DataOutputStream out;
+
+ @Override
+ public void initialize(URL location, ResourceBundle resources) {
+ try {
+ socket = new Socket(SERVER_IP, SERVER_PORT);
+ DataInputStream in = new DataInputStream(socket.getInputStream());
+ out = new DataOutputStream(socket.getOutputStream());
+ Thread thread = new Thread(() -> {
+ String msg = "";
+ try {
+ while (!msg.equals("echo answer: /end")) {
+ msg = in.readUTF();
+ chatArea.appendText(msg + "\n");
+ }
+ chatArea.appendText("соединение разорвано\n");
+ } catch (IOException e) {
+ System.err.println("Сервер рвзорвал соединение");
+ e.printStackTrace();
+// System.exit(0);
+ }
+ try {
+ socket.close();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ });
+ thread.setDaemon(true);
+ thread.start();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ }
+
+ public void sendMsg() {
+ if (!msgField.getText().equals(""))
+ try {
+ out.writeUTF(msgField.getText());
+ out.flush();
+ msgField.clear();
+ msgField.requestFocus();
+ } catch (IOException e) {
+ chatArea.appendText("нет связи с сервером\n");
+ }
+ }
+
+}
+
diff --git a/src/ru/geekbrains/java2/lesson_06/Classwork/client/Main.java b/src/ru/geekbrains/java2/lesson_06/Classwork/client/Main.java
new file mode 100644
index 0000000..4c4e59b
--- /dev/null
+++ b/src/ru/geekbrains/java2/lesson_06/Classwork/client/Main.java
@@ -0,0 +1,23 @@
+package ru.geekbrains.java2.lesson_06.Classwork.client;
+
+import javafx.application.Application;
+import javafx.fxml.FXMLLoader;
+import javafx.scene.Parent;
+import javafx.scene.Scene;
+import javafx.stage.Stage;
+
+public class Main extends Application {
+
+ @Override
+ public void start(Stage primaryStage) throws Exception{
+ Parent root = FXMLLoader.load(getClass().getResource("sample.fxml"));
+ primaryStage.setTitle("Geek JavaFX chat");
+ primaryStage.setScene(new Scene(root, 400, 600));
+ primaryStage.show();
+ }
+
+
+ public static void main(String[] args) {
+ launch(args);
+ }
+}
diff --git a/src/ru/geekbrains/java2/lesson_06/Classwork/client/sample.fxml b/src/ru/geekbrains/java2/lesson_06/Classwork/client/sample.fxml
new file mode 100644
index 0000000..13236a6
--- /dev/null
+++ b/src/ru/geekbrains/java2/lesson_06/Classwork/client/sample.fxml
@@ -0,0 +1,14 @@
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/src/ru/geekbrains/java2/lesson_06/Classwork/server/ServerMain.java b/src/ru/geekbrains/java2/lesson_06/Classwork/server/ServerMain.java
new file mode 100644
index 0000000..0824ea7
--- /dev/null
+++ b/src/ru/geekbrains/java2/lesson_06/Classwork/server/ServerMain.java
@@ -0,0 +1,34 @@
+package ru.geekbrains.java2.lesson_06.Classwork.server;
+
+import java.io.*;
+import java.net.ServerSocket;
+import java.net.Socket;
+
+public class ServerMain {
+ public static void main(String[] args) {
+ try {
+ ServerSocket serverSocket = new ServerSocket(8189);
+ System.out.println("Server started...");
+ Socket socket = serverSocket.accept();
+ System.out.println("Client connected.");
+
+ DataInputStream scanner = new DataInputStream(socket.getInputStream());
+ DataOutputStream writer = new DataOutputStream(socket.getOutputStream());
+
+ String msg = "";
+ while (!msg.equals("/end")) {
+ msg = scanner.readUTF();
+ System.out.println("Client said: " + msg);
+ writer.writeUTF("echo answer: " + msg);
+ writer.flush();
+ }
+ System.out.println("Command for disconnect");
+ socket.close();
+ System.out.println("Server stopped...");
+ } catch (IOException e) {
+ System.err.println("Потеря связи");
+ e.printStackTrace();
+ }
+
+ }
+}
diff --git a/src/ru/geekbrains/java2/lesson_06/Client.java b/src/ru/geekbrains/java2/lesson_06/Client.java
new file mode 100644
index 0000000..430ea4a
--- /dev/null
+++ b/src/ru/geekbrains/java2/lesson_06/Client.java
@@ -0,0 +1,24 @@
+package ru.geekbrains.java2.lesson_06;
+
+import java.io.IOException;
+import java.net.Socket;
+
+public class Client {
+ public static final String SERVER_IP = "localhost";
+ public static final int SERVER_PORT = 8189;
+
+ public static void main(String[] args) {
+ Socket socket;
+ try {
+ socket = new Socket(SERVER_IP, SERVER_PORT);
+ System.out.println("Connected to server...");
+
+ NetTransceiver netTransceiver = new NetTransceiver("Client", socket);
+ netTransceiver.start();
+
+ socket.close();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ }
+}
diff --git a/src/ru/geekbrains/java2/lesson_06/NetTransceiver.java b/src/ru/geekbrains/java2/lesson_06/NetTransceiver.java
new file mode 100644
index 0000000..d923297
--- /dev/null
+++ b/src/ru/geekbrains/java2/lesson_06/NetTransceiver.java
@@ -0,0 +1,88 @@
+// ВОПРОС: не могу прервать поток, который заблокирован Scanerом, как это можно сделать
+// может вместо Scanera чтот-то прерываемое можно использовать
+// если можно уделите на уроке этому пару минут пожалуйста
+
+package ru.geekbrains.java2.lesson_06;
+
+import java.io.*;
+import java.net.Socket;
+import java.util.Scanner;
+
+public class NetTransceiver {
+ private String name;
+ private Socket socket;
+ private DataInputStream inputStream;
+ private DataOutputStream outputStream;
+ private Scanner scanner;
+ private Thread listner;
+ private Thread sender;
+
+ public NetTransceiver(String name, Socket socket) {
+ this.name = name;
+ this.socket = socket;
+ }
+
+ public void start() {
+ try {
+ inputStream = new DataInputStream(socket.getInputStream());
+ outputStream = new DataOutputStream(socket.getOutputStream());
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+
+ listner = new Thread(new Runnable() {
+ @Override
+ public void run() {
+ String message = "";
+ while (!Thread.interrupted()) {
+ try {
+ message = inputStream.readUTF();
+ } catch (IOException e) {
+ System.out.println("program is stopped");
+ break;
+ }
+ System.out.println(message);
+ if (message.contains("/end"))
+ Thread.currentThread().interrupt();
+ }
+ sender.interrupt();
+ scanner.close(); // ни как не могу прервать поток
+ }
+ });
+
+ sender = new Thread(new Runnable() {
+ @Override
+ public void run() {
+ scanner = new Scanner(System.in);
+ String message = "";
+ while (!Thread.interrupted()) {
+ message = scanner.nextLine();
+ try {
+ outputStream.writeUTF(name + ": " + message);
+ outputStream.flush();
+ } catch (IOException e) {
+ System.out.println("program is stoped");
+ break;
+ }
+ if (message.contains("/end"))
+ Thread.currentThread().interrupt();
+ }
+ listner.interrupt();
+ try {
+ inputStream.close(); // а этот рвется, правда, на мой взгляд, грубо
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ }
+ });
+
+ listner.start();
+ sender.start();
+ try {
+ listner.join();
+ sender.join();
+ } catch (InterruptedException e) {
+ e.printStackTrace();
+ }
+ }
+}
diff --git a/src/ru/geekbrains/java2/lesson_06/Server.java b/src/ru/geekbrains/java2/lesson_06/Server.java
new file mode 100644
index 0000000..2f9ddcb
--- /dev/null
+++ b/src/ru/geekbrains/java2/lesson_06/Server.java
@@ -0,0 +1,29 @@
+package ru.geekbrains.java2.lesson_06;
+
+import java.io.IOException;
+import java.net.ServerSocket;
+import java.net.Socket;
+
+public class Server {
+ public static final int SERVER_PORT = 8189;
+ public static void main(String[] args) {
+ Socket socket;
+ try {
+ ServerSocket serverSocket = new ServerSocket(SERVER_PORT);
+ System.out.println("Server started...");
+ socket = serverSocket.accept();
+ System.out.println("Client connected...");
+
+ NetTransceiver netTransceiver = new NetTransceiver("Server", socket);
+ netTransceiver.start();
+
+ serverSocket.close();
+ socket.close();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+
+ }
+
+
+}
diff --git a/src/ru/geekbrains/java2/lesson_06/metodichka/Client.java b/src/ru/geekbrains/java2/lesson_06/metodichka/Client.java
new file mode 100644
index 0000000..b5fcd4a
--- /dev/null
+++ b/src/ru/geekbrains/java2/lesson_06/metodichka/Client.java
@@ -0,0 +1,8 @@
+package ru.geekbrains.java2.lesson_06.metodichka;
+
+public class Client {
+ public static void main(String[] args) {
+ new MyWindow();
+ }
+}
+
diff --git a/src/ru/geekbrains/java2/lesson_06/metodichka/MyWindow.java b/src/ru/geekbrains/java2/lesson_06/metodichka/MyWindow.java
new file mode 100644
index 0000000..6db6c75
--- /dev/null
+++ b/src/ru/geekbrains/java2/lesson_06/metodichka/MyWindow.java
@@ -0,0 +1,96 @@
+package ru.geekbrains.java2.lesson_06.metodichka;
+
+import javax.swing.*;
+import java.awt.*;
+import java.awt.event.ActionEvent;
+import java.awt.event.ActionListener;
+import java.awt.event.WindowAdapter;
+import java.awt.event.WindowEvent;
+import java.io.IOException;
+import java.io.PrintWriter;
+import java.net.Socket;
+import java.util.Scanner;
+
+public class MyWindow extends JFrame {
+ private JTextField textField;
+ private JTextArea textArea;
+ private final String SERVER_ADDR = "localhost";
+ private final int SERVER_PORT = 8189;
+ private Socket sock;
+ private Scanner in;
+ private PrintWriter out;
+
+ public MyWindow() {
+ try {
+ sock = new Socket(SERVER_ADDR, SERVER_PORT);
+ in = new Scanner(sock.getInputStream());
+ out = new PrintWriter(sock.getOutputStream());
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ setBounds(600, 300, 500, 500);
+ setTitle("Client");
+ setDefaultCloseOperation(WindowConstants.EXIT_ON_CLOSE);
+
+ textArea = new JTextArea();
+ textArea.setEditable(false);
+ textArea.setLineWrap(true);
+
+ JScrollPane scrollPane = new JScrollPane(textArea);
+ add(scrollPane, BorderLayout.CENTER);
+
+ JPanel bottomPanel = new JPanel(new BorderLayout());
+ add(bottomPanel, BorderLayout.SOUTH);
+
+ JButton sendButton = new JButton("SEND");
+ bottomPanel.add(sendButton, BorderLayout.EAST);
+
+ textField = new JTextField();
+ bottomPanel.add(textField, BorderLayout.CENTER);
+
+ sendButton.addActionListener(e -> sendMsg());
+ textField.addActionListener(e -> sendMsg());
+
+ new Thread(new Runnable() {
+ @Override
+ public void run() {
+ try {
+ while (true) {
+ if (in.hasNext()) {
+ String w = in.nextLine();
+ if (w.equalsIgnoreCase("end session")) break;
+ textArea.append(w);
+ textArea.append("\n");
+ }
+ }
+ } catch (Exception e) {
+ }
+ }
+ }).start();
+
+ addWindowListener(new WindowAdapter() {
+ @Override
+ public void windowClosing(WindowEvent e) {
+ super.windowClosing(e);
+ try {
+ out.println("end");
+ out.flush();
+ sock.close();
+ out.close();
+ in.close();
+ } catch (IOException exc) {
+ }
+ }
+ });
+ setVisible(true);
+ }
+
+ public void sendMsg() {
+ if (!textField.getText().trim().isEmpty()) {
+ out.println(textField.getText());
+ out.flush();
+ textField.setText("");
+ textField.grabFocus();
+ }
+ }
+}
diff --git a/src/ru/geekbrains/java2/lesson_06/metodichka/Server.java b/src/ru/geekbrains/java2/lesson_06/metodichka/Server.java
new file mode 100644
index 0000000..8c78aa5
--- /dev/null
+++ b/src/ru/geekbrains/java2/lesson_06/metodichka/Server.java
@@ -0,0 +1,37 @@
+package ru.geekbrains.java2.lesson_06.metodichka;
+
+import java.io.IOException;
+import java.io.PrintWriter;
+import java.net.ServerSocket;
+import java.net.Socket;
+import java.util.Scanner;
+
+public class Server {
+ public static void main(String[] args) {
+ ServerSocket serv = null;
+ Socket sock = null;
+ try {
+ serv = new ServerSocket(8189);
+ System.out.println("Сервер запущен, ожидаем подключения...");
+ sock = serv.accept();
+ System.out.println("Клиент подключился");
+ Scanner sc = new Scanner(sock.getInputStream());
+ PrintWriter pw = new PrintWriter(sock.getOutputStream());
+ while (true) {
+ String str = sc.nextLine();
+ if (str.equals("end")) break;
+ pw.println("Эхо: " + str);
+ pw.flush();
+ }
+ } catch (IOException e) {
+ System.out.println("Ошибка инициализации сервера");
+ } finally {
+ try {
+ assert serv != null;
+ serv.close();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ }
+ }
+}
\ No newline at end of file
diff --git a/src/ru/geekbrains/java2/lesson_07/Homework.java b/src/ru/geekbrains/java2/lesson_07/Homework.java
new file mode 100644
index 0000000..80224bc
--- /dev/null
+++ b/src/ru/geekbrains/java2/lesson_07/Homework.java
@@ -0,0 +1,4 @@
+package ru.geekbrains.java2.lesson_07;
+
+public class Homework {
+}
diff --git a/src/ru/geekbrains/java2/lesson_07/javaFXChat/JavaFX_chat.db b/src/ru/geekbrains/java2/lesson_07/javaFXChat/JavaFX_chat.db
new file mode 100644
index 0000000..eada1c5
Binary files /dev/null and b/src/ru/geekbrains/java2/lesson_07/javaFXChat/JavaFX_chat.db differ
diff --git a/src/ru/geekbrains/java2/lesson_07/javaFXChat/client/Controller.java b/src/ru/geekbrains/java2/lesson_07/javaFXChat/client/Controller.java
new file mode 100644
index 0000000..e315333
--- /dev/null
+++ b/src/ru/geekbrains/java2/lesson_07/javaFXChat/client/Controller.java
@@ -0,0 +1,186 @@
+package ru.geekbrains.java2.lesson_07.javaFXChat.client;
+
+import javafx.application.Platform;
+import javafx.collections.FXCollections;
+import javafx.collections.ObservableList;
+import javafx.fxml.FXML;
+import javafx.fxml.Initializable;
+import javafx.scene.control.*;
+import javafx.scene.input.MouseEvent;
+import javafx.scene.layout.HBox;
+import javafx.util.Callback;
+
+import java.io.DataInputStream;
+import java.io.DataOutputStream;
+import java.io.IOException;
+import java.net.Socket;
+import java.net.URL;
+import java.util.ResourceBundle;
+
+public class Controller implements Initializable {
+ @FXML
+ TextArea textArea;
+ @FXML
+ TextField msgField;
+ @FXML
+ HBox loginPanel;
+ @FXML
+ HBox messagePanel;
+ @FXML
+ TextField loginField;
+ @FXML
+ PasswordField passFiead;
+ @FXML
+ ListView clientsListArea;
+ private ObservableList clientsObsvList;
+
+ private Socket socket;
+ private DataOutputStream out;
+ private DataInputStream in;
+ private String myNick;
+
+ final String SERVER_IP = "localhost";
+ final int SERVER_PORT = 8189;
+
+ public void setAutorized(boolean autorized) {
+ if (autorized) {
+ loginPanel.setVisible(false);
+ loginPanel.setManaged(false);
+ messagePanel.setVisible(true);
+ messagePanel.setManaged(true);
+ } else {
+ loginPanel.setVisible(true);
+ loginPanel.setManaged(true);
+ messagePanel.setVisible(false);
+ messagePanel.setManaged(false);
+ myNick = "";
+ }
+ }
+
+ @Override
+ public void initialize(URL location, ResourceBundle resources) {
+ setAutorized(false);
+ clientsObsvList = FXCollections.observableArrayList();
+ clientsListArea.setItems(clientsObsvList);
+ clientsListArea.setCellFactory(new Callback, ListCell>() {
+ @Override
+ public ListCell call(ListView param) {
+ return new ListCell() {
+ @Override
+ protected void updateItem(String item, boolean empty) {
+ super.updateItem(item, empty);
+ if (!empty) {
+ setText(item);
+ if (item.equals(myNick)) {
+ setStyle("-fx-font-weight: bold;" +
+ " -fx-background-color: #ffead4");
+ }
+ } else {
+ setGraphic(null);
+ setText(null);
+ }
+ }
+ };
+ }
+ });
+ }
+
+ public void connect() {
+ try {
+ socket = new Socket(SERVER_IP, SERVER_PORT);
+ in = new DataInputStream(socket.getInputStream());
+ out = new DataOutputStream(socket.getOutputStream());
+
+ Thread t = new Thread(() -> {
+ try {
+ while (true) {
+ String s = in.readUTF();
+ if (s.startsWith("/")) {
+ if (s.startsWith("/authok")) {
+ setAutorized(true);
+ myNick = s.split("\\s")[1];
+ textArea.appendText("успешная авторизация\n");
+ break;
+ }
+ if (s.startsWith("/timeout")) {
+ Platform.runLater(() -> showAlert("Соединение закрыто по таймауту"));
+ }
+ continue;
+ }
+ textArea.appendText(s + "\n");
+ }
+ while (true) {
+ String msg = in.readUTF();
+ if (msg.startsWith("/clients")) {
+ String[] clientsString = msg.substring(9).split(" ");
+ Platform.runLater(() -> {
+ clientsObsvList.clear();
+ clientsObsvList.addAll(clientsString);
+ });
+ continue;
+ }
+ textArea.appendText(msg + "\n");
+ }
+ } catch (IOException e) {
+ showAlert("Соединение с сервером разорвано.");
+ } finally {
+ setAutorized(false);
+ try {
+ socket.close();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ }
+ });
+ t.setDaemon(true);
+ t.start();
+ } catch (IOException e) {
+ showAlert("Не удалось подключиться к серверу. Проверьте сетевое соединение.");
+ }
+ }
+
+ public void authorization() {
+ if (!loginField.getText().isEmpty() && !passFiead.getText().isEmpty()) {
+ if (socket == null || socket.isClosed()) connect();
+ try {
+ out.writeUTF("/auth " +
+ loginField.getText() + " " +
+ passFiead.getText());
+ loginField.clear();
+ passFiead.clear();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ } else {
+ showAlert("Неполные данные для авторизации!");
+ }
+ }
+
+ public void sendMsg() {
+ try {
+ out.writeUTF(msgField.getText());
+ msgField.clear();
+ msgField.requestFocus();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ }
+
+ public void showAlert(String message) {
+ Platform.runLater(() -> {
+ Alert alert = new Alert(Alert.AlertType.INFORMATION);
+ alert.setTitle("Ой! Проблемка нарисавалася!");
+ alert.setHeaderText(null);
+ alert.setContentText(message);
+ alert.showAndWait();
+ });
+ }
+
+ public void clientChoise(MouseEvent event) {
+ if (event.getClickCount() == 2) {
+ msgField.setText("/w " + clientsListArea.getSelectionModel().getSelectedItem() + " ");
+ msgField.requestFocus();
+ msgField.selectEnd();
+ }
+ }
+}
diff --git a/src/ru/geekbrains/java2/lesson_07/javaFXChat/client/Main.java b/src/ru/geekbrains/java2/lesson_07/javaFXChat/client/Main.java
new file mode 100644
index 0000000..d5e0391
--- /dev/null
+++ b/src/ru/geekbrains/java2/lesson_07/javaFXChat/client/Main.java
@@ -0,0 +1,23 @@
+package ru.geekbrains.java2.lesson_07.javaFXChat.client;
+
+import javafx.application.Application;
+import javafx.fxml.FXMLLoader;
+import javafx.scene.Parent;
+import javafx.scene.Scene;
+import javafx.stage.Stage;
+
+public class Main extends Application {
+
+ @Override
+ public void start(Stage primaryStage) throws Exception{
+ Parent root = FXMLLoader.load(getClass().getResource("sample.fxml"));
+ primaryStage.setTitle("JavaFX project Client");
+ primaryStage.setScene(new Scene(root, 550, 800));
+ primaryStage.show();
+ }
+
+
+ public static void main(String[] args) {
+ launch(args);
+ }
+}
diff --git a/src/ru/geekbrains/java2/lesson_07/javaFXChat/client/mystyle.css b/src/ru/geekbrains/java2/lesson_07/javaFXChat/client/mystyle.css
new file mode 100644
index 0000000..1f3a574
--- /dev/null
+++ b/src/ru/geekbrains/java2/lesson_07/javaFXChat/client/mystyle.css
@@ -0,0 +1,3 @@
+.list-cell:even{
+ -fx-background-color: #ddffe2;
+}
\ No newline at end of file
diff --git a/src/ru/geekbrains/java2/lesson_07/javaFXChat/client/sample.fxml b/src/ru/geekbrains/java2/lesson_07/javaFXChat/client/sample.fxml
new file mode 100644
index 0000000..adc6f7e
--- /dev/null
+++ b/src/ru/geekbrains/java2/lesson_07/javaFXChat/client/sample.fxml
@@ -0,0 +1,25 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/src/ru/geekbrains/java2/lesson_07/javaFXChat/server/AuthService.java b/src/ru/geekbrains/java2/lesson_07/javaFXChat/server/AuthService.java
new file mode 100644
index 0000000..86a0aff
--- /dev/null
+++ b/src/ru/geekbrains/java2/lesson_07/javaFXChat/server/AuthService.java
@@ -0,0 +1,35 @@
+package ru.geekbrains.java2.lesson_07.javaFXChat.server;
+
+import java.sql.*;
+
+public class AuthService {
+ private Connection connection;
+ private Statement statement;
+
+ public void connect() throws ClassNotFoundException, SQLException{
+ Class.forName("org.sqlite.JDBC");
+ // как подключить базу, расположение которой отличается от корня проекта
+ connection = DriverManager.getConnection("jdbc:sqlite:JavaFX_chat.db");
+ statement = connection.createStatement();
+ }
+
+ public String getNickByLoginAndPass(String login, String pass){
+ try {
+ ResultSet rs = statement.executeQuery("SELECT nick FROM users where login='"+ login +"' and password='"+ pass +"';");
+ while (rs.next()){
+ return rs.getString("nick");
+ }
+ } catch (SQLException e) {
+ e.printStackTrace();
+ }
+ return null;
+ }
+
+ public void disconnect(){
+ try {
+ connection.close();
+ } catch (SQLException e) {
+ e.printStackTrace();
+ }
+ }
+}
diff --git a/src/ru/geekbrains/java2/lesson_07/javaFXChat/server/ClientHandler.java b/src/ru/geekbrains/java2/lesson_07/javaFXChat/server/ClientHandler.java
new file mode 100644
index 0000000..beaaf29
--- /dev/null
+++ b/src/ru/geekbrains/java2/lesson_07/javaFXChat/server/ClientHandler.java
@@ -0,0 +1,103 @@
+package ru.geekbrains.java2.lesson_07.javaFXChat.server;
+
+import java.io.DataInputStream;
+import java.io.DataOutputStream;
+import java.io.IOException;
+import java.net.Socket;
+
+public class ClientHandler {
+ private static final long TIMEOUT = 120_000;
+ private DataInputStream in;
+ private DataOutputStream out;
+ private String nick;
+
+ public String getNick() {
+ return nick;
+ }
+
+ public ClientHandler(Server server, Socket socket) {
+ try {
+ in = new DataInputStream(socket.getInputStream());
+ out = new DataOutputStream(socket.getOutputStream());
+ new Thread(() -> {
+ try {
+ while (true) {
+ String msg = in.readUTF();
+ if (msg.startsWith("/auth")) {
+ String[] authData = msg.split("\\s");
+
+ String newNick = null;
+
+ // fix bug (отправка пустых логина и пароля приводит к выходу за границы массива)
+ if (authData.length == 3)
+ newNick = server.getAuthService().getNickByLoginAndPass(authData[1], authData[2]);
+ if (newNick != null) {
+ if (server.isNickBusy(newNick)) {
+ sendMessage("данный пользователь уже авторизован");
+ continue;
+ }
+ nick = newNick;
+ sendMessage("/authok " + nick);
+ server.subscribe(this);
+ break;
+ } else {
+ sendMessage("Неверный логин/пароль");
+ }
+ }
+ }
+ while (true) {
+ String msg = in.readUTF();
+ System.out.println(nick + ": " + msg);
+
+ if (msg.startsWith("/")) {
+ if (msg.equals("/end")) break;
+ if (msg.startsWith("/w")) {
+ String[] data = msg.split("\\s", 3);
+ server.privateSender(this, data[1], data[2]);
+ }
+ continue;
+ }
+ server.broadcastSender(nick + ": " + msg);
+ }
+ } catch (IOException e) {
+ e.printStackTrace();
+ } finally {
+ server.unsubscribe(this);
+ try {
+ socket.close();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ }
+ }).start();
+ new Thread(() -> {
+ try {
+ Thread.sleep(TIMEOUT);
+ } catch (InterruptedException e) {
+ e.printStackTrace();
+ }
+ if(nick == null){
+ try {
+ sendMessage("/timeout");
+ socket.close();
+ in.close();
+ out.close();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ System.out.println("timeout");
+ }
+ }).start();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ }
+
+ public void sendMessage(String message) {
+ try {
+ out.writeUTF(message);
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ }
+}
diff --git a/src/ru/geekbrains/java2/lesson_07/javaFXChat/server/Server.java b/src/ru/geekbrains/java2/lesson_07/javaFXChat/server/Server.java
new file mode 100644
index 0000000..74303e1
--- /dev/null
+++ b/src/ru/geekbrains/java2/lesson_07/javaFXChat/server/Server.java
@@ -0,0 +1,90 @@
+package ru.geekbrains.java2.lesson_07.javaFXChat.server;
+
+import java.io.IOException;
+import java.net.ServerSocket;
+import java.net.Socket;
+import java.sql.SQLException;
+import java.util.Vector;
+
+public class Server {
+ private Vector clientList;
+ private AuthService authService;
+
+ public AuthService getAuthService() {
+ return authService;
+ }
+
+ public Server(int port) {
+ try (ServerSocket serverSocket = new ServerSocket(port)) {
+ clientList = new Vector<>();
+
+ authService = new AuthService();
+ authService.connect();
+
+ System.out.println("Server started...Waiting for clients");
+ while (true) {
+ Socket socket = serverSocket.accept();
+ System.out.println("Client connected" +
+ socket.getInetAddress() + ":" +
+ socket.getPort() + ":" +
+ socket.getLocalPort());
+ new ClientHandler(this, socket);
+ }
+ } catch (IOException e) {
+ System.err.println("Запрашиваемый порт занят");
+ } catch (ClassNotFoundException | SQLException e) {
+ System.out.println("Не удалось запустить сервис авторизации");
+ } finally {
+ authService.disconnect();
+ }
+ }
+
+ public void subscribe(ClientHandler clientHandler) {
+ clientList.add(clientHandler);
+ broadcastClientListSender();
+ }
+
+ public void unsubscribe(ClientHandler clientHandler) {
+ clientList.remove(clientHandler);
+ broadcastClientListSender();
+ }
+
+ public boolean isNickBusy(String nick) {
+ for (ClientHandler ch : clientList)
+ if (ch.getNick().equals(nick)) return true;
+
+ return false;
+ }
+
+ public void broadcastSender(String message) {
+ for (ClientHandler ch :
+ clientList) {
+ ch.sendMessage(message);
+ }
+ }
+
+ public void privateSender(ClientHandler sender, String destNnick, String message) {
+ for (ClientHandler ch :
+ clientList) {
+ if (destNnick.equals(ch.getNick())) {
+ ch.sendMessage(sender.getNick() + " private: " + message);
+ sender.sendMessage("private to " + destNnick + ": " + message);
+ return;
+ }
+ }
+ sender.sendMessage("клиент с ником " + destNnick + " не найден");
+ }
+
+ private void broadcastClientListSender() {
+ StringBuilder sb = new StringBuilder("/clients ");
+ for (ClientHandler ch :
+ clientList) {
+ sb.append(ch.getNick()).append(" ");
+ }
+ String clientsListMsg = sb.toString();
+ for (ClientHandler ch :
+ clientList) {
+ ch.sendMessage(clientsListMsg);
+ }
+ }
+}
diff --git a/src/ru/geekbrains/java2/lesson_07/javaFXChat/server/ServerMain.java b/src/ru/geekbrains/java2/lesson_07/javaFXChat/server/ServerMain.java
new file mode 100644
index 0000000..3aa2580
--- /dev/null
+++ b/src/ru/geekbrains/java2/lesson_07/javaFXChat/server/ServerMain.java
@@ -0,0 +1,7 @@
+package ru.geekbrains.java2.lesson_07.javaFXChat.server;
+
+public class ServerMain {
+ public static void main(String[] args) {
+ new Server(8189);
+ }
+}
diff --git a/src/ru/geekbrains/java2/lesson_07/javaFXChat/sqlite-jdbc-3.21.0.jar b/src/ru/geekbrains/java2/lesson_07/javaFXChat/sqlite-jdbc-3.21.0.jar
new file mode 100644
index 0000000..56b627d
Binary files /dev/null and b/src/ru/geekbrains/java2/lesson_07/javaFXChat/sqlite-jdbc-3.21.0.jar differ