/*
 *  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);
    }
}