使用来自Socket的InputStreamReader接收utf-8字符串？

Question

我正在尝试使用此代码从设备接收字符串：

        byte[] buf = new byte[4];
        int read = inFromDevice.read(buf);
        Logger.getLogger(Utill.class.getName() + " DEBUG_ERR01").log(Level.INFO, "Bytes read: {0}", read);
        int msgLength = ByteBuffer.wrap(buf).getInt();
        Logger.getLogger(Utill.class.getName() + " DEBUG_ERR01").log(Level.INFO, "Message length: {0}", msgLength);
        Reader r = new InputStreamReader(inFromDevice);
        char[] cb = new char[msgLength];
        int actualCharsRead = r.read(cb);
        Logger.getLogger(Utill.class.getName() + " DEBUG_ERR01").log(Level.INFO, "Actual chars read: {0} char array length: {1}", new Object[]{actualCharsRead, cb.length});
        String msgText = String.valueOf(cb, 0, cb.length);
        Logger.getLogger(Utill.class.getName() + "Messages Loggining recieve: ").log(Level.INFO, msgText);
        return msgText;

inFromDevice是从接受的ServerSocket获取的InputStream。

代码正在工作并且大部分时间都在返回消息，但有时我得到的消息小于msgLength（根据协议这是错误的）

日志中的一个例子是Actual chars read: 1020 char array length: 1391

我认为问题是外部的，因为网络问题或设备有问题，但我需要一些专家的见解。 Java中是否存在可能导致此问题的已知问题？

Answer 1

InputStreamReader只会阻塞，直到它可以将一个字符读入缓冲区或检测到EOF。无法保证缓冲区将被填充。

如果您的协议指示正在发送的字符串的长度，则接收器需要循环，跟踪剩余的字符数，直到所有字符都被读取。