《互联网程序设计》 -- 第2周网络对话程序的设计

　　经历了上一周的学习java，发现自己就是一个five，很多都忘了，还有很多底层也是不会的。很烦。不过还是一点一点地去学一下。来到第二周的互联网程序设计课，这周的任务就是设计一个网络对话程序。

　　一、总览

就是说通过窗体程序登录到客户端，然后向服务器发送消息（字符串），并能读取字符串返回的消息。

　　二、TCPServer，服务器的建立

这个还没有看懂下次说，

　　三、TCPClient，客户端

1、连接对方，先向服务器发起三次握手。

socket = new Socket(host,port); //向服务进程发起TCP三次握手连接

然后获取字节流，（输入和输出）Socket连接成功后，通过调用socket.getXXXXXStream( )方法，可获得字节输出流和字节输入流，输出流用于发送信息，输入流用于接收信息。并可通过以下组合方式封装为输入输出的字符流：

new PrintWriter( // 设置最后一个参数为true，表示自动flush数据
    new OutputStreamWriter(//设置utf-8编码
        outputStream, "utf-8"), true);
new BufferedReader(
    new InputStreamReader(inputStream, "utf-8"));

这里采用自动flush的方法，如果没有flush则会在缓存区一直出不来，阻塞运行。

2、发送信息给服务器

 public void send(String msg) {
  //输出字符流，由Socket调用系统底层函数，经网卡发送字节流
  pw.println(msg);
}

3、服务器接收信息

public String receive() {
  String msg = null;
  try {
    //从网络输入字符流中读信息，每次只能接受一行信息
    //如果不够一行（无行结束符），则该语句阻塞，
    // 直到条件满足，程序才往下运行
    msg = br.readLine();
  } catch (IOException e) {
    e.printStackTrace();
  }
  return msg;
}

4、关闭网络连接

public void close() {
  try {
if (socket != null) {
      //关闭socket连接及相关的输入输出流,实现四次握手断开，如图2.3所示
      socket.close();
    }
  } catch (IOException e) {
    e.printStackTrace();
  }
}

四、TCPClientFX，窗体的构建

这个大体上和上一周的simplefx差不多，我就略说了。不过有些是需要注意的点。

public void start(Stage primaryStage) {
        taDisplay.setEditable(false);
        btnUnConnect.setDisable(true);
        btnSend.setDisable(true);
        btnUnConnect.setStyle("-fx-color: RED");
        btnExit.setStyle("-fx-color: RED");
        BorderPane mainPane = new BorderPane();

        mainPane.setCenter(getVBox());
        mainPane.setBottom(getHBoxBottom());
        mainPane.setTop(getHBoxTop());



        //这里是按钮的控制：
        btnConnect.setOnAction(event -> {
            String ip = tfIP.getText().trim();
            String port = tfPort.getText().trim();

            try {
                //tcpClient不是局部变量，是本程序定义的一个TCPClient类型的成员变量
                tcpClient = new TCPClient(ip,port);
                //成功连接服务器，接收服务器发来的第一条欢迎信息
                String firstMsg = tcpClient.receive();
                taDisplay.appendText(firstMsg + "
");

                btnConnect.setDisable(true);//连接服务器之后不能再次连接
                btnSend.setDisable(false);//连接服务器成功之后才可以发送信息
                btnUnConnect.setDisable(false);//可以启用断开连接按钮

            } catch (Exception e) {
                taDisplay.appendText("服务器连接失败！" + e.getMessage() + "
");
            }
        });



        //退出按钮的设置
        btnExit.setOnAction(event -> {
            if(tcpClient != null){
                //向服务器发送关闭连接的约定信息
                taDisplay.appendText("bye" + "
");
//                TimeUnit.SECONDS.sleep(2);
                tcpClient.send("bye");
                tcpClient.close();
            }
            System.exit(0);
        });

        btnUnConnect.setOnAction(event -> {
            if(tcpClient != null){
                //向服务器发送关闭连接的约定信息
                taDisplay.appendText("bye,断开连接，拜拜了您嘞！" + "
");
                tcpClient.send("bye");
                tcpClient.close();
                btnUnConnect.setDisable(true);
                btnConnect.setDisable(false);
                btnSend.setDisable(true);
            }
        });

        //点x的设置
        primaryStage.setOnCloseRequest(event -> {
            String ip = tfIP.getText().trim();
            String port = tfPort.getText().trim();
            try {
                tcpClient = new TCPClient(ip,port);
                if(tcpClient != null){
                    //向服务器发送关闭连接的约定信息
                    tcpClient.send("bye");
                    tcpClient.close();
                }
                System.exit(0);
            }catch (Exception e){
                taDisplay.appendText("退出失败！" + e.getMessage() + "
");
            }
        });

        //点x的设置
        primaryStage.setOnCloseRequest(event -> {
            String ip = tfIP.getText().trim();
            String port = tfPort.getText().trim();
            try {
                TCPClient tcpClient = new TCPClient(ip,port);
                if(tcpClient != null){
                    //向服务器发送关闭连接的约定信息
                    tcpClient.send("bye");
                    tcpClient.close();
                }
                System.exit(0);
            }catch (Exception e){
                taDisplay.appendText("退出失败！" + e.getMessage() + "
");
            }
        });

        //发送按钮的设置；
        btnSend.setOnAction(event -> {
            String sendMsg = tfSend.getText();
            tcpClient.send(sendMsg);//向服务器发送一串字符
            if (sendMsg.equals("bye")){
                btnUnConnect.setDisable(true);
                btnConnect.setDisable(false);
                btnSend.setDisable(true);
                btnSend.setDisable(true);
            }
            taDisplay.appendText("客户端发送：" + sendMsg + "
");
            String receiveMsg = tcpClient.receive();//从服务器接收一行字符
            taDisplay.appendText(receiveMsg + "
");
            tfSend.clear();
        });

//        btnSend.requestFocus();
        tfSend.requestFocus();//聚焦一定是在发送框，因为输入信息后焦点就在发送框，而不是按钮或其他
        tfSend.setOnKeyPressed(event -> {

            if(event.isShiftDown() == true && event.getCode().equals(KeyCode.ENTER )){
                String sendMsg = tfSend.getText();
                tcpClient.send("echo:" + sendMsg);//向服务器发送一串字符
                taDisplay.appendText("客户端发送：echo:" + sendMsg + "
");
                String receiveMsg = tcpClient.receive();//从服务器接收一行字符
                taDisplay.appendText(receiveMsg + "
");
                tfSend.clear();
            }
            else if (event.getCode().equals(KeyCode.ENTER)) {
                String sendMsg = tfSend.getText();
                tcpClient.send(sendMsg);//向服务器发送一串字符
                taDisplay.appendText("客户端发送：" + sendMsg + "
");
                if (sendMsg.equals("bye")){
                    btnUnConnect.setDisable(true);
                    btnConnect.setDisable(false);
                    btnSend.setDisable(true);
                }
                String receiveMsg = tcpClient.receive();//从服务器接收一行字符
                taDisplay.appendText(receiveMsg + "
");
                tfSend.clear();
            }
        });

        Scene scene = new Scene(mainPane,900,500);
        primaryStage.setTitle("网络通信测试111");
        primaryStage.setScene(scene);
        primaryStage.show();
    }

    private VBox getVBox(){
        VBox vBox = new VBox(10);
        vBox.setPadding(new Insets(10,20,10,20));
        vBox.getChildren().addAll(new Label("信息显示:") , taDisplay, new Label("信息输入:"), tfSend);
        VBox.setVgrow(taDisplay, Priority.ALWAYS);

        return vBox;
    }

    private HBox getHBoxBottom(){
        HBox hBox = new HBox(10);
        hBox.setPadding(new Insets(10,20,10,20));
        hBox.setAlignment(Pos.CENTER_RIGHT);
        hBox.getChildren().addAll(btnSend,btnExit);

        return hBox;
    }

    private HBox getHBoxTop(){
        HBox hBox = new HBox(10);
        hBox.setPadding(new Insets(10,20,10,20));
        hBox.setAlignment(Pos.CENTER);
        hBox.getChildren().addAll(new Label("IPAdress:") , tfIP, new Label("Interface:"), tfPort, btnConnect,btnUnConnect);

        return hBox;
    }

btnConnect的按钮是连接服务器，还没懂不谈。其他类似

这里注意的点有，你需要在窗体类TCPClientFX下声明好TCPClient，不然后面的退出按钮的功能你可用不了。

还有的是

在TCPClientFX客户端窗体程序中，连接成功服务器后，如果用户再次点击“连接”按钮，会造成服务器资源浪费，还可能使程序运行不正常，无法正常发送信息；

没有连接服务器时，或者发送bye以后，点击“发送”按钮，控制台也会产生异常；

当已连接上服务器时候，直接就可以在btnConnect连接的代码那里加入这三行代码就可以解决啦。

                btnConnect.setDisable(true);//连接服务器之后不能再次连接
                btnSend.setDisable(false);//连接服务器成功之后才可以发送信息
                btnUnConnect.setDisable(false);//可以启用断开连接按钮        

当发送bye的信息给服务器之后，在btnSend按钮的点击动作加入下面的判断代码

if (sendMsg.equals("bye")){
                btnUnConnect.setDisable(true);
                btnConnect.setDisable(false);
                btnSend.setDisable(true);
            }

好了，今天就这样理解到这里。

下面是完整程序的代码连接：

https://wws.lanzous.com/iFgtWgmi9mh