InputStream 无法正常工作

Question

我是安卓初学者。我正在尝试处理套接字。但是我的InputStream 没有按预期读取数据。在j = inputStream.read(arrayOfByte, 0, i);之后它正在退出方法请帮助我。

public void readinputstreamforid(final String ip, final int port){
    AsyncTask asyncTask = new AsyncTask() {

        @Override
        protected Object doInBackground(Object[] objects) {

            try {
                socket=new Socket(ip,port);
            } catch (IOException e) {
                e.printStackTrace();
            }
            final byte[] arrayOfByte = new byte[10000];

            InputStream inputStream = null;
            try {
                inputStream = socket.getInputStream();
            } catch (IOException e) {
                e.printStackTrace();
            }

            while (socket.isConnected()) {
                int j = 0;
                int i = arrayOfByte.length;
                try {
                    j = inputStream.read(arrayOfByte, 0, i);
                    if (j == -1)
                        throw new IOException("not working");
                    if (j == 0)
                        continue;
                } catch (IOException e) {
                    e.printStackTrace();
                }
                final String strData = new String(arrayOfByte, 0, j).replace("\r", "").replace("\n", "");
                Log.d("hello","recieved: "+strData);

            }
            try {
                IOUtils.write("!#@\n",socket.getOutputStream());
            } catch (IOException e) {
                e.printStackTrace();
            }
            return null;
        }
    };

    asyncTask.execute();
}

Answer 1

如果发生错误，您正在记录它，但随后您继续执行代码，然后可能会发生更多错误。当发生错误时，STOP 循环并退出函数。 InputStream.read() 在到达流的末尾时返回 -1。对于套接字，这意味着连接关闭时。这并不是真正的错误情况，因此您不需要抛出异常。只是打破循环。您可以将InputStream 包装在BufferedReader 内，这样您就可以使用它的readLine() 方法而不是手动读取字节。

另外，您正在尝试写入套接字的OutputStream 在套接字已经断开连接之后。那永远都行不通。

试试这样的：

public void readinputstreamforid(final String ip, final int port){
    AsyncTask asyncTask = new AsyncTask() {

        @Override
        protected Object doInBackground(Object[] objects) {

            try {
                socket = new Socket(ip, port);

                BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream(), StandardCharsets.UTF_8));
                OutputDataStream out = socket.getOutputStream();

                do {
                    String data = in.readLine();
                    if (data == null)
                        break;

                    Log.d("hello", data);
                    IOUtils.write("!#@\n", out, StandardCharsets.UTF_8);
                }
                while (true);

            } catch (IOException e) {
                e.printStackTrace();
            }

            return null;
        }
    };

    asyncTask.execute();
}