3

我对 Java 套接字很陌生，并且在使用同一个套接字发送和接收数据时遇到了问题。

服务器位于 Android 设备上：

    ServerSocket listenSocket = null;
    OutputStream dataOutStream = null;
    Socket socket = null;
    InputStream dataInputStream = null;

    // Listen
    System.out.println("Start listening");
    try {
        listenSocket = new ServerSocket(4370);
        socket = listenSocket.accept();
        System.out.println("Connection accepted");
        dataInputStream = socket.getInputStream();
        dataOutStream = socket.getOutputStream();
        while (dataInputStream.read() != -1);
    } catch (IOException e) {
        e.printStackTrace();
        close(listenSocket, socket);
        return;
    }

    // Answer
    System.out.println("Answering...");
    byte[] answer = {(byte) 0x82, (byte) 0xf8, 0, 0};
    try {
        dataOutStream.write(answer);
    } catch (IOException e) {
        e.printStackTrace();
        close(listenSocket, socket);
        return;
    }

    close(listenSocket, socket);
    System.out.println("Finished");

客户端在装有 Java 6 的 Linux 机器上运行：

    Socket socket = new Socket("192.168.1.33", 4370);
    OutputStream dataOutputStream = socket.getOutputStream();
    InputStream dataInputStream = socket.getInputStream();
    byte[] bufferOut = {1, 2, 3, 4, 5, 6, 7, 8, 9, 10};
    dataOutputStream.write(bufferOut);
    System.out.println("Sent");

    while (dataInputStream.read() != -1);       
    socket.close();
    System.out.println("Finished");

这里的问题是服务器卡住了while (dataInputStream.read() != -1);。看起来客户端永远不会关闭发送。

如果我dataOutputStream.close()在客户端部分这样做（当然是在编写之后），那么它确实可以工作，但是客户端会在while (dataInputStream.read() != -1);说套接字已关闭时死掉。

我想保持整个套接字打开，以便在同一个套接字上进行更多数据交换，直到发送关闭命令。

我显然在这里做错了什么，有什么见解吗？提前致谢！

4

3 回答 3

12

您既不关闭套接字也不关闭输出流。您在客户端执行shutdownOutput() ：

...
dataOutputStream.write(bufferOut);
System.out.println("Sent");
socket.shutdownOutput();
...

这称为半关闭，因为它只关闭一个方向而使另一方向保持打开状态。

于 2012-10-15T17:00:22.637 回答
2

编辑：Olaf 展示了一种内置方法来实现问题中的请求-响应场景。

关闭从套接字获得的流也会关闭套接字（另见）。另一方面，只要流/套接字打开，从套接字获得的 InputStream 就不可能查看是否发送了所有数据（可能在路上会有更多的东西！）。除非使用 Olafs 示例，否则 2-way 通信不能以这种方式工作。这允许等待服务器响应。

您可以做的是自己定义一个结束信号（例如字符串“END”），并且任何一方都在监听，直到读取该结束信号，然后写入。但这伴随着您肯定会遇到的各种其他问题（如果发送的文本包含结束信号怎么办？如果合作伙伴在发送结束之前死了怎么办？超时？...）。也可以看看

我会尝试查看在 Java 中得到很好支持的 SOAP 或 RESTful 服务（但我不知道在 Android 上有多好）。通常有许多库可以为您解决这些问题，并使您从低级网络中解脱出来。使用现有解决方案几乎总能带来回报。

于 2012-10-15T16:53:12.890 回答
0

尝试通过执行刷新 OutputStreamdataOutStream.flush()

于 2012-10-15T16:52:02.060 回答