Создание, запуск и выключение сервера

package sample;
 
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.URL;
import java.util.ResourceBundle;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
 
import javafx.fxml.FXML;
import javafx.scene.control.Button;
import javafx.scene.control.TextArea;
 
public class Controller {
 
    @FXML
    private ResourceBundle resources;
 
    @FXML
    private URL location;
 
    @FXML
    private TextArea ta;
 
    @FXML
    private Button stopBut;
 
    @FXML
    private Button startBut;
 
    class Server{
        ExecutorService executeIt = Executors.newFixedThreadPool(2);
 
        ServerSocket server = new ServerSocket(3345);
        BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
 
        Server() throws IOException {
        }
 
        void serverStart(){
            try {
                {
                    System.out.println("Server socket created, command console reader for listen to server commands");
 
                    while (!server.isClosed()) {
                        if (br.ready()) {
                            System.out.println("Main Server found any messages in channel, let's look at them.");
                        }
 
                        Socket client = server.accept();
 
                        executeIt.execute(new MonoThreadClientHandler(client));
                        System.out.print("Connection accepted.");
                    }
                    executeIt.shutdown();
                }
            }
            catch (IOException e){
                e.printStackTrace();
            };
        }
 
        void serverClose() throws IOException {
            server.close();
        }
    }
 
 
    @FXML
    void initialize() throws IOException {
        Server server = new Server();
        startBut.setOnAction(event -> {
            server.serverStart();
        });
        stopBut.setOnAction(event -> {
            try {
                server.serverClose();
            } catch (IOException e) {
                e.printStackTrace();
            }
        });
    }
}

package sample;
 
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
 
public class MonoThreadClientHandler implements Runnable {
 
    private static Socket clientDialog;
 
    public MonoThreadClientHandler(Socket client) {
        MonoThreadClientHandler.clientDialog = client;
    }
 
    @Override
    public void run() {
 
        try {
            DataOutputStream out = new DataOutputStream(clientDialog.getOutputStream());
            DataInputStream in = new DataInputStream(clientDialog.getInputStream());
 
            while (!clientDialog.isClosed()) {
                System.out.println("Server reading from channel");
 
                String entry = in.readUTF();
                System.out.println("READ from clientDialog message - " + entry);
 
                if (entry.equalsIgnoreCase("quit")) {
                    System.out.println("Client initialize connections suicide ...");
                    out.writeUTF("Server reply - " + entry + " - OK");
                    break;
                }
 
                System.out.println("Server try writing to channel");
                out.writeUTF("Server reply - " + entry + " - OK");
                System.out.println("Server Wrote message to clientDialog.");
 
                out.flush();
            }
            System.out.println("Client disconnected");
            System.out.println("Closing connections & channels.");
 
            in.close();
            out.close();
 
            clientDialog.close();
 
            System.out.println("Closing connections & channels - DONE.");
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

package sample;
 
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("Hello World");
        primaryStage.setScene(new Scene(root, 300, 275));
        primaryStage.show();
    }
 
 
    public static void main(String[] args) {
        launch(args);
    }
}