Java套接字读取inputstream而不阻塞

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并将数据发送到其他设备，并关闭输出流。
• 第二部分是解析字节数组，然后使用相同的套接字返回响应。

有没有办法改变我的函数，这样我就可以在不阻塞的情况下读取输入流？

所以问题出在IOS方面，苹果应用编程接口似乎需要关闭创建的套接字的两个流：读/写，这样字节数组就可以发送，这看起来真的很愚蠢，因为这样iphone应用程序就不能接收和解析我的响应。

Answer 1

有了为RIM操作系统编程的经验，我认为所有这些IO操作都应该在不同的线程中执行。主用户界面线程将被要求调用另一个应用程序线程，在那里您将检查异步操作是否完成并采取适当的操作。这样，读取输入流的代码必须在单独的线程中运行。

Answer 2

与编辑中的评论相反，这是你的错，不是苹果的错。你需要重新设计你的API。您的readBytes（）方法会一直读取流，直到流结束，这只有在对等方关闭连接时才会发生。如果您只想读取一些字节，read（byte[]）已经可以读取，并告诉您有多少字节，而无需流结束。我会抛弃这种方法。