/*

 *  TCPClientThreadFX.java

 * Copyright (c) 2020-10-25

 * author : Charzous

 * All right reserved.

 */

import javafx.application.Application;

import javafx.application.Platform;

import javafx.event.EventHandler;

import javafx.geometry.Insets;

import javafx.geometry.Pos;

import javafx.scene.Scene;

import javafx.scene.control.Button;

import javafx.scene.control.Label;

import javafx.scene.control.TextArea;

import javafx.scene.control.TextField;

import javafx.scene.input.KeyCode;

import javafx.scene.input.KeyEvent;

import javafx.scene.layout.BorderPane;

import javafx.scene.layout.HBox;

import javafx.scene.layout.Priority;

import javafx.scene.layout.VBox;

import javafx.stage.Stage;

public class TCPClientThreadFX extends Application {

    private Button btnExit=new Button("退出");

    private Button btnSend = new Button("发送");

    private TextField tfSend=new TextField();//输入信息区域

    private TextArea taDisplay=new TextArea();//显示区域

    private TextField ipAddress=new TextField();//填写ip地址

    private TextField tfport=new TextField();//填写端口

    private Button btConn=new Button("连接");

    private TCPClient tcpClient;

    private Thread readThread;

    public static void main(String[] args) {

        launch(args);

    }

    @Override

    public void start(Stage primaryStage) {

        BorderPane mainPane=new BorderPane();

        //连接服务器区域

        HBox hBox1=new HBox();

        hBox1.setSpacing(10);

        hBox1.setPadding(new Insets(10,20,10,20));

        hBox1.setAlignment(Pos.CENTER);

        hBox1.getChildren().addAll(new Label("ip地址："),ipAddress,new Label("端口："),tfport,btConn);

        mainPane.setTop(hBox1);

        VBox vBox=new VBox();

        vBox.setSpacing(10);

        vBox.setPadding(new Insets(10,20,10,20));

        vBox.getChildren().addAll(new javafx.scene.control.Label("信息显示区"),taDisplay,new Label("信息输入区"),tfSend);

        VBox.setVgrow(taDisplay, Priority.ALWAYS);

        mainPane.setCenter(vBox);

        HBox hBox=new HBox();

        hBox.setSpacing(10);

        hBox.setPadding(new Insets(10,20,10,20));

        hBox.setAlignment(Pos.CENTER_RIGHT);

        hBox.getChildren().addAll(btnSend,btnExit);

        mainPane.setBottom(hBox);

        Scene scene =new Scene(mainPane,700,500);

        primaryStage.setScene(scene);

        primaryStage.show();

        //连接按钮

        btConn.setOnAction(event -> {

            String ip=ipAddress.getText().trim();

            String port=tfport.getText().trim();

            try {

                //tcpClient是本程序定义的一个TCPClient类型的成员变量

                tcpClient = new TCPClient(ip, port);

                //用于接收服务器信息的单独线程

                readThread = new Thread(()->{

                    String receiveMsg=null;//从服务器接收一串字符

                    while ((receiveMsg=tcpClient.receive())!=null){

                        //lambda表达式不能直接访问外部非final类型局部变量，需要定义一个临时变量

                        //若将receiveMsg定义为类成员变量，则无需临时变量

                        String msgTemp = receiveMsg;

                        Platform.runLater(()->{

                            taDisplay.appendText(msgTemp+"\n");

                        });

                    }

                    Platform.runLater(()->{

                        taDisplay.appendText("对话已关闭！\n");

                    });

                });

                readThread.start();

                //连接服务器之后未结束服务前禁用再次连接

                btConn.setDisable(true);

                //重新连接服务器时启用输入发送功能

                tfSend.setDisable(false);

                btnSend.setDisable(false);

            }catch (Exception e){

                taDisplay.appendText("服务器连接失败！"+e.getMessage()+"\n");

            }

        });

//        btConn.defaultButtonProperty();

        //发送按钮事件

        btnSend.setOnAction(event -> {

            String msg=tfSend.getText();

            tcpClient.send(msg);//向服务器发送一串字符

            taDisplay.appendText("客户端发送："+msg+"\n");

            if (msg.equalsIgnoreCase("bye")){

                btnSend.setDisable(true);//发送bye后禁用发送按钮

                tfSend.setDisable(true);//禁用Enter发送信息输入区域

                //结束服务后再次启用连接按钮

                btConn.setDisable(false);

            }

            tfSend.clear();

        });

        //对输入区域绑定键盘事件

        tfSend.setOnKeyPressed(new EventHandler<KeyEvent>() {

            @Override

            public void handle(KeyEvent event) {

               if(event.getCode()==KeyCode.ENTER){

                   String msg=tfSend.getText();

                   tcpClient.send(msg);//向服务器发送一串字符

                   taDisplay.appendText("客户端发送："+msg+"\n");

                   if (msg.equalsIgnoreCase("bye")){

                       tfSend.setDisable(true);//禁用Enter发送信息输入区域

                       btnSend.setDisable(true);//发送bye后禁用发送按钮

                       //结束服务后再次启用连接按钮

                       btConn.setDisable(false);

                   }

                   tfSend.clear();

                }

            }

        });

        btnExit.setOnAction(event -> {

            try {

                exit();

            } catch (InterruptedException e) {

                e.printStackTrace();

            }

        });

        //窗体关闭响应的事件,点击右上角的×关闭,客户端也关闭

        primaryStage.setOnCloseRequest(event -> {

            try {

                exit();

            } catch (InterruptedException e) {

                e.printStackTrace();

            }

        });

    }

    private void exit() throws InterruptedException {

        if (tcpClient!=null){

            tcpClient.send("bye");

            readThread.sleep(1000);//多线程等待，关闭窗口时还有线程等待IO，设置1s间隔保证所有线程已关闭

            tcpClient.close();

        }

        System.exit(0);

    }

}