java - Android Socket 读取问题

标签 java android sockets

我创建了一个连接到 Raspberry pi 热点的套接字。我能够成功连接到它并向 pi 发送一个字符串。但是,由于我尝试实现读取功能以从 pi 获取数据,因此我遇到了一些问题。

每次我运行 while 循环或只有“response = myBufRead.readLine()”时,程序都会停止。

private class StatusCheck extends AsyncTask<Void, Void, Void> {


    @Override
    protected Void doInBackground(Void... params) {
        //debug vibrations and text
        if(vibrate) {
            Vibrator vib = (Vibrator) getSystemService(Context.VIBRATOR_SERVICE);
            vib.vibrate(100);
        }
        try {
            InetAddress serverAddr = InetAddress.getByName(SERVER_IP);
            Log.d(debugStr, "In initial connect");
            mySocket = new Socket(serverAddr, SERVERPORT);

        } catch (UnknownHostException e1) {
            e1.printStackTrace();
        } catch (IOException e1) {
            e1.printStackTrace();
        } finally {
            if (mySocket == null) {
                str1 = "Socket became null";
                return null;
            }
            str1 = "Connected";
            try {
                PrintWriter myPrintWriter = new PrintWriter(mySocket.getOutputStream(), true);
                InputStreamReader myInputStreamRead = new InputStreamReader(mySocket.getInputStream());
                BufferedReader myBufRead = new BufferedReader(myInputStreamRead);
                Log.d(debugStr, "In out created");

                myPrintWriter.write(recordName);

                Log.d(debugStr, String.valueOf(myBufRead.ready()));
                Log.d(debugStr, "About to enter while loop");
                while((response = myBufRead.readLine()) != null) {
                    Log.d(debugStr, "in while loop");
                    response = myBufRead.readLine();
                    Log.d(debugStr, String.valueOf(myBufRead.ready()));
                    Log.d(debugStr, myBufRead.readLine());
                    Log.d(debugStr, String.valueOf(myBufRead.ready()));
                }
                Log.d(debugStr, "out of while loop");
                myPrintWriter.close();
                myInputStreamRead.close();
                myBufRead.close();


            } catch (IOException e1) {
                e1.printStackTrace();
            }
            try {
                mySocket.close();
            } catch (IOException e1) {
                e1.printStackTrace();
            }
            return null;
        }

    }


}

有人知道为什么会这样吗?感谢任何帮助,谢谢!

最佳答案

BuffereadReader.readLine() 是一种阻塞方法,因此它将等待,并且如您所说,“暂停”其线程,直到有内容可读。从 pi 写入流后,您是否调用了 flush()

另一个问题可能是 readLine() 将等待一个完整的行,即它会等到它读取一个行分隔符。你是从你的 pi 发送行分隔符吗?参见 Socket Multithreading - Reading input stream pauses thread

您可以这样做(从 pi 端开始,假设您使用的是 BufferedWriter ):

bufferedWriter.write(text);
bufferedWriter.newLine();
bufferedWriter.flush();

关于java - Android Socket 读取问题,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/42464787/

相关文章:

android - 在android中将一个布局滑动到另一个布局上

c - 如何在win32中使用socket

windows - lua套接字客户端

c - pf_ring 和 libpcap if_index 没有返回

java - MVC - 我如何理解它? ( java )

android - 从 BroadcastReceiver 驱动服务 API

android - 方向改变时保存 `RadioButton` 状态

java - 修改库存程序以使用 GUI

java 类属性绑定(bind)到 swing 组件

java - 在 Pojo/对象上使用 @Value 的 Spring 可能性