Java套接字读取输入流而不阻塞

Question

我在实现 Android 和 IOS 之间的套接字连接时遇到了一点问题。当我使用我的应用程序连接两个运行 Android 的设备时，一切正常。但是当我必须从 Iphone 应用程序接收一些数据时，我的 readStream 函数被阻塞，我可以在另一部分关闭套接字后接收所有数据，这样我就无法返回任何响应。这是我用来听的：

try {
    serverSocket = new ServerSocket(5000);
    Log.d("","CREATE SERVER SOCKET");
} catch (IOException e) {
     e.printStackTrace();
}

while(state){
    try {
        if(serverSocket!=null){
            client = serverSocket.accept();
            client.setKeepAlive(true);
            client.setSoTimeout(10000);

            // LOGS
            Log.w("READ","is connected : "+client.isConnected());
            Log.w("READ","port : "+client.getPort());
            Log.w("READ","ipadress : "+client.getInetAddress().toString());



            InputStream is = client.getInputStream();

            Log.w("READ","is Size : "+is.available());

            byte[] bytes = DNSUtils.readBytes(is);
            Log.v("","-------------------------");
            for(int i=0;i<bytes.length;i++){
                Log.w("READ","bytes["+i+"] : "+bytes[i]);
            }
            Log.v("","-------------------------");

            try {
                Log.w("READ","packetType : "+bytes[4]);

                if(bytes!=null)
                    DNSUtils.getPacketType(bytes[4], bytes, client);

            } catch(Exception e){
                e.printStackTrace();
            }
        }
    } catch (IOException e) {
        e.printStackTrace();
        Log.v("","IOException");
        ResponseERR pack = new ResponseERR();
        ResponseERR.errorMsg = "Socket TimeOut exception!";
        byte[] packet = pack.createNewPacket();

        try {
            if(client!=null){
                OutputStream out = client.getOutputStream();
                out.write(packet);
                out.flush();
                client.shutdownOutput();
                client.close();
                Log.e("READDATAFROMSOCKET","ResponseERR Send.");
            }
        } catch (Exception e1) {
            e1.printStackTrace();
        }
    }
}

这是我用来将InputStream 转换为Byte Array 的函数：

public static byte[] readBytes(InputStream inputStream) throws IOException {
    // this dynamically extends to take the bytes you read
    ByteArrayOutputStream byteBuffer = new ByteArrayOutputStream();

    // this is storage overwritten on each iteration with bytes
    int bufferSize = 1024;
    byte[] buffer = new byte[bufferSize];

    // we need to know how may bytes were read to write them to the byteBuffer
    int len = 0;
    while ((len = inputStream.read(buffer)) != -1) {
        byteBuffer.write(buffer, 0, len);
    }

    // and then we can return your byte array.
    return byteBuffer.toByteArray();
}

Iphone / Android 应用程序的工作方式如下：

• 首先它创建 Socket 并将数据发送到其他设备并关闭 OutputStream。
• 第二部分是解析字节数组，然后使用同一个套接字返回响应。

任何想法如何更改我的功能，以便我可以读取输入流而不会阻塞？

编辑：

所以问题出在 IOS 方面，似乎 Apple API 需要 关闭创建的套接字的两个流：读/写所以字节 可以发送数组，这看起来很愚蠢，因为这样 iphone 应用无法接收和解析我的回复。

Answer 1

与您编辑中的评论相反，这是您的错，而不是 Apple 的。你需要重新设计你的 API。您的 readBytes() 方法读取流直到其结束，这仅在对等方关闭连接时发生。如果您只想读取 一些 字节，read(byte[]) 已经这样做了，并告诉您有多少，而无需结束流。我只想把这个方法扔掉。

Answer 2

凭借 RIM OS 的编程经验，我认为所有这些 IO 操作都应该在不同的线程中执行。将要求主 UI 线程使用 invokeLater() 类型的方法调用另一个应用程序线程，您可以在其中检查异步操作是否完成并采取适当的操作。这样，您读取输入流的代码必须在单独的线程中运行。