Java - TCP/IP - 服务器无法将消息发送回客户端？

Question

我想将一个对象从我的客户端发送到我的本地主机服务器以添加到数据库中，并将结果发送回该对象是否发送成功。对象已成功发送，但我的服务器没有将结果发送回客户端，并导致我的客户端框架表单因等待服务器响应而挂起。我不知道我的代码有什么问题。你能告诉我一些解决这个问题的方法吗？

这是发送结果的函数：

public void sendResult(String result) {
    try {
        Socket clientSocket = myServer.accept();
        System.out.println("Connected to client");
        ObjectOutputStream os = new ObjectOutputStream(clientSocket.getOutputStream());

        os.writeObject(result);
        System.out.println("Result sent");
    } catch (Exception ex) {
        ex.printStackTrace();
    }
}

调用发送结果函数的地方：

public void service() {
    try {
        if (receiveStudent() != null) {
            Student std = receiveStudent();
            if (dao.addStudent(std)) {
                System.out.println("OK");
                sendResult("OK");
            } else {
                System.out.println("FAILED");
                sendResult("FAILED");
            }
        }
    } catch (Exception ex) {
        ex.printStackTrace();
    }
}

另外，在Service函数中，控制台打印“OK”，表示满足if条件。

接收学生方法：

public Student receiveStudent() {
    Student s = new Student();

    try {
        Socket clientSocket = myServer.accept();
        System.out.println("Connect to client successfully");
        ObjectInputStream ois = new ObjectInputStream(clientSocket.getInputStream());

        Object o = ois.readObject();
        if (o instanceof Student) {
            s = (Student) o;
            return s;
        }
    } catch (Exception ex) {
        ex.printStackTrace();
    }
    return null;
}

Answer 1

由于sendResult() 中的myServer.accept()，服务器再次等待传入的客户端连接，而这已经在receiveStudent() 中发生。重复使用该连接。

共享您在receiveStudent() 中获得的客户端套接字，例如，将其转换为字段。

public Student receiveStudent() {
    ...

    try {
        clientSocket = myServer.accept();
        ...
    } catch (Exception ex) {
        ...
    }
    ...
}

然后在sendResult() 中重用该套接字以将结果发送给客户端。

public static void sendResult(String result) {
    try {
        ...
        ObjectOutputStream os = new ObjectOutputStream(clientSocket.getOutputStream());
        ...
    } catch (Exception ex) {
        ...
    }
}

Answer 2

如果你想发送一个字符串作为对象，你为什么不直接使用这样的东西：

PrintWriter out = new PrintWriter(clientSocket.getOutputStream(), true); //for sending String messages
BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream())); //for getting String messages

...然后当您需要发送时，您可以这样做：

out.println(textToServer");  // send to server - don't forget LN in println.
out.flush(); // to clean buffer

它应该做你需要做的事情。
并确保您的客户端类正在等待获取您发送的InputStream，不要忘记这一点，因为这可能是客户端的问题。
也许客户端不接受传入的Socket，无论是ObjectInputStream 还是BufferedReader 都会接受传入的套接字对象。

您可以为我们提供一个 Client 类，以便我们查看是否缺少对传入套接字的接受。

确保在方法结束时关闭流和套接字。

out.close();
in.close();
socket.close();

更多详情请查看this、this 和this。希望对您有所帮助:)

Answer 3

您拨打了两次accept()。这是没有意义的。您需要：

1. 接受连接。这会返回一个Socket。
2. 读取请求并创建响应。
3. 通过您在 (1) 中接受的同一 Socket 发送响应。

您还希望为每个接受的套接字创建一个新线程，并且您还希望在该线程中执行所有 I/O，包括创建ObjectInputStream 和ObjectOutputStream。否则，您的服务器不是正确的多线程和多客户端。