android java和套接字

Question

我编写客户端-服务器应用程序。客户端将在普通 java 上运行在 android 和服务器上。我需要从客户端到服务器再从服务器到客户端交换数据。我的问题是，当我从客户端向服务器发送文件时，服务器卡在从套接字接收数据上。这是我的代码:

客户端发送文件:

    Log.i("======", "sendToServer==============");
    OutputStream output = sk.getOutputStream();     

    String pathToOurFile = directory + File.separator + file;

    FileInputStream fileInputStream = new FileInputStream(pathToOurFile);
    byte[] buffer = new byte[sk.getSendBufferSize()];
    int bytesRead = 0;

    while((bytesRead = fileInputStream.read(buffer))>0)
    {
        output.write(buffer,0,bytesRead);
    }

    fileInputStream.close();

服务器获取数据:

    System.out.println("I get data");
    File file=null;

    InputStream input = sk.getInputStream();

    file = new File("C://protocolFIle/" + "temp.xml");
    FileOutputStream out = new FileOutputStream(file);

    byte[] buffer = new byte[sk.getReceiveBufferSize()];

    int bytesReceived = 0;

    while((bytesReceived = input.read(buffer))>0) {
        out.write(buffer,0,bytesReceived);
    }

    return file;

服务器卡住

while((bytesReceived = input.read(buffer))>0) {
        out.write(buffer,0,bytesReceived);
    }

在服务器端。我想当我完成发送数据时，我需要在客户端以某种方式发出信号。我知道我可以在客户端编写“output.close()”，然后服务器获取文件并中断 while 循环，但我以后需要这个输出。有谁知道我怎样才能发送这个服务器没有卡住的文件？也许我需要用另一种方式发送这个文件。谢谢你的帮助。

Answer 1

在客户端使用 close() 实际上不会有太大帮助，因为像 close() 这样的 TCP/IP API 方法几乎没有用，因为一种在应用层发出消息结束信号的方法。这样做的原因是在客户端关闭 TCP 流并不会立即关闭整个 TCP 连接，直到对面的客户端。这都与 TCP 的底层架构有关。

您需要做的是实现一个应用程序协议(protocol)级别的方法来识别消息的长度，或者实现一些其他的消息“框架”方法。您要做的最简单的事情可能是在消息的开头实现一个基本的 header ，它可以只包含四个字节，表示 U32 消息长度(仅作为示例)。

我要再次强调的关于 TCP 的一个非常重要的事情是 TCP 协议(protocol)本身，尤其是 close() 之类的调用，不提供可靠地发出应用程序启动/停止信号的方法您通过 TCP 发送的消息。 TCP 必须被认为是一种流 协议(protocol)，因为它就是这样；因此，您还必须在该流中放置一些带有长度字段的特殊 header ，或成帧字符，或指示接收端何时从 .read() 调用中读取足够信息的其他方式，例如它有一个完整的消息。

我最近创建了一个 Android 应用程序，它使用 TCP 套接字与服务器 C# 应用程序通信，即使我只是通过流发送简单且相对较短的消息，我发现实现非常基本的消息框架和消息头绝对是基本的。

应该在应用程序协议(protocol)级别用信号通知消息的长度或结尾。

另外，两端应该关闭 TCP 连接的信号也应该在应用程序协议(protocol)级别完成。当您搜索 StackOverflow 时，您经常会遇到许多人在检测 TCP 连接是否“已关闭”时遇到问题。问题在于，这是一种本质上错误的处理方式。任何语言的 TCP 套接字 API 都无法可靠地告诉您流已关闭。

如果您查看 HTTP，它是使用 TCP 套接字的流行协议(protocol)的一个示例，您会看到该协议(protocol)使用指示长度的 header 、指示连接应关闭以及消息是否 fragment 的标志， 等等。

回到您的特定问题，您应该在 Android 端的第一个 write() 中构造并编写一个包含长度字段的简单消息 header 。在服务器端，第一个 read() 应该期望在文件负载开始之前看到这个 header 。然后使用该 header 中提供的长度来确定您何时拥有 read() 整个文件。

您稍后可以扩展您的 header 以包含诸如 CRC 值之类的内容。