5

我是 Java 和 JavaFX 的新手,所以请原谅我的新手问题。在过去的几天里,我一直在寻找我正在尝试做的事情的例子,但一直找不到任何答案。这是我想要做的:我正在尝试使用场景构建器创建一个简单的 javafx GUI 客户端套接字应用程序,该应用程序将连接到服务器并发送/接收数据。很简单,但是当我尝试在 Java FX 中实现它时,我的 GUI 冻结了。我研究并发现原因是套接字通信一直在占用所有时间,并且 javafx GUI 无法更新。我的研究表明我使用任务。所以,我创建了一个简单的应用程序,它创建一个任务,连接到一个互联网套接字(端口 80),发送命令“GET / HTTP/1.1\r\n\r\n”,它将请求页面然后打印出来收到的每一行。问题是我想一遍又一遍地这样做(每 3 秒)。该任务成功运行一次,但随后停止。在下面的代码中,永远不会到达使线程进入睡眠状态的行,但打印任何错误的行也不会发送到 system.out。

这是控制器代码

package clientSocketExample;

import java.io.*;
import java.net.*;
import java.util.ResourceBundle;
import javafx.event.ActionEvent;
import javafx.event.EventHandler;
import javafx.fxml.FXML;
import javafx.fxml.Initializable;
import javafx.scene.control.*;
import javafx.concurrent.Task;

/**
 * Controller class of the HelloWorld sample.
 */
public class ClientSocketExampleController implements Initializable
{

    @FXML
    Button button;

    private boolean keepRunning = true;

    /**
     * Initializes the controller class.
     */
    @Override
    public void initialize(URL url, ResourceBundle rsrcs)
    {
            if (button != null)
        {
            button.setOnAction(new EventHandler<ActionEvent>()
            {
                @Override
                public void handle(ActionEvent event)
                {
                    keepRunning = false;
                    System.out.println("Hello World\n");
                }
            });
        }

        // Create a background task to handle the Client-Server socket
        // This is needed because JavaFX is not thread safe
        Task<Integer> task = new Task<Integer>()
        {
             @Override
            protected Integer call() throws Exception
            {
                Socket s = new Socket();
//                String host = "www.google.com";
//                String host = "www.amazon.com";
                String host = "www.yahoo.com";
                PrintWriter s_out = null;
                BufferedReader s_in = null;
                int lineNums = 0;

                try
                {
                    s.connect(new InetSocketAddress(host, 80));
                    System.out.println("Connected\n");

                    // Create writer for socket
                    s_out = new PrintWriter(s.getOutputStream(), true);

                    // Create reader for socket
                    s_in = new BufferedReader(new     InputStreamReader(s.getInputStream()));
                }
                catch (IOException e)
                {
                    // Host not found, so print error
                    System.err.println("Don't know about host : " + host);
                    System.exit(1);
                }

                // Loop forever waiting for task to be cancelled
                while (isCancelled() == false)
                {
                    // Send message to server
                    String message = "GET / HTTP/1.1\r\n\r\n";
                    s_out.println(message);

                    System.out.println("Message sent\n");
                    // Get response from server
                    try
                    {
                        String response;
                        while ((response = s_in.readLine()) != null)
                        {
                            System.out.print("Line #: "+lineNums+" ");
                            System.out.println(response);
                            lineNums++;
                        }
                    } catch (IOException e)
                    {
                        System.err.println("Couldn't get response from host");
                    }

                    System.out.println("Thread going to sleep\n\n\n");
                    Thread.sleep(3000);
                    System.out.println("Thread waking up from sleep\n\n\n");
                } // End while

                return lineNums;
            }           
        }; // End Initialize

        // start the background task
        Thread th = new Thread(task);
        th.setDaemon(true);
        System.out.println("Starting background task...");
        th.start();
    }
}`

Main.java 类如下所示:

package clientSocketExample;

import java.util.logging.Level;
import java.util.logging.Logger;
import javafx.application.Application;
import javafx.fxml.FXMLLoader;
import javafx.scene.Scene;
import javafx.scene.layout.AnchorPane;
import javafx.stage.Stage;

public class Main extends Application
{
/**
 * @param args the command line arguments
 */
public static void main(String[] args)
{
    Application.launch(Main.class, (java.lang.String[]) null);
}

@Override
public void start(Stage primaryStage)
{
    try
    {
        AnchorPane page = (AnchorPane) FXMLLoader.load(Main.class
                .getResource("ClientSocketExample.fxml"));
        Scene scene = new Scene(page);
        primaryStage.setScene(scene);
        primaryStage.setTitle("Hello World Sample");
        primaryStage.show();
    } catch (Exception ex)
    {
        Logger.getLogger(Main.class.getName()).log(Level.SEVERE, null, ex);
    }
}

}`

最后 FXML 文件如下所示:

<?xml version="1.0" encoding="UTF-8"?>

<?import java.lang.*?>
<?import java.util.*?>
<?import javafx.scene.control.*?>
<?import javafx.scene.layout.*?>
<?import javafx.scene.paint.*?>

<AnchorPane id="AnchorPane" prefHeight="365.0" prefWidth="378.0"     xmlns:fx="http://javafx.com/fxml"     fx:controller="clientSocketExample.ClientSocketExampleController">
  <children>
    <Button fx:id="button" layoutX="147.0" layoutY="28.0" text="Connect" />
    <TitledPane animated="false" layoutY="159.0" prefWidth="378.0" text="Received Data">
      <content>
        <AnchorPane id="Content" minHeight="0.0" minWidth="0.0" prefHeight="180.0" prefWidth="200.0">
          <children>
            <TextArea fx:id="textAreaField" prefHeight="180.0" prefWidth="374.0" wrapText="true" />
          </children>
        </AnchorPane>
      </content>
    </TitledPane>
  </children>
</AnchorPane>

提前感谢您的帮助韦恩

4

2 回答 2

0

根据您的要求,有几件事需要更改:

  1. 将此插入您的请求中

    "\r\nHost: <host>\r\nConnection: keep-alive"
    

    这将确保服务器在响应您的请求后不会关闭您的连接。

  2. 将您的 while 循环更改为:

    while (s_in.ready() && (response = s_in.readLine()) != null)
    

    这将确保可以从 BufferedReader 中读取某些内容。查看这些帖子,了解 BufferedReader 为何会挂起:https ://stackoverflow.com/a/7855911/1359765和https://stackoverflow.com/a/15510821/1359765

于 2014-03-26T22:03:33.270 回答
0

冻结的 Gui 遇到的问题是因为它的“控制器”类连接到套接字。当我使用 JavaFx 和 JavaFx 场景构建器创建自己的聊天程序时,我遇到了同样的问题。

你可以做两件事:

  1. 创建一个SocketConnector()将您连接到套接字的新类 ( )。

  2. 连接到主类中的套接字,而不是controller

无论您无法连接到控制器类中的套接字,很抱歉,我无法描述为什么您不能详细说明我只是知道我曾多次遇到此问题,这是解决此问题的方法!

于 2013-02-25T09:50:43.957 回答