Java/Android中如何持续监听InputStream并在新数据到达时获取通知

你当前的实现不合理，存在几个明显问题： #

• 对InputStream.read()的行为认知错误：read()是阻塞方法，没有数据到达时会一直阻塞当前线程，不会抛出异常。只有连接中断、流关闭等异常场景才会抛出异常，你当前catch分支的逻辑完全不符合实际运行逻辑，还会吞掉断连异常，无法感知连接失效。
• 资源浪费：每次循环都新建ByteArray，会触发频繁GC，在Android端会导致卡顿、内存抖动问题。
• 无退出机制：死循环没有停止入口，页面销毁、连接断开时无法正常释放线程和流资源，会造成内存泄漏。
• 未处理读取结束标记：read()返回-1时代表流已经被对端正常关闭，你当前没有判断这个返回值，会一直读到无效数据。

更优的实现方案 #

1. 基础优化版（BIO模式，适合单连接简单场景） #

改动最小，稳定性足够，适合大多数普通场景：

private var isListening = false
// 复用固定大小的缓冲区，避免频繁创建对象
private val readBuffer = ByteArray(2048)

fun startStreamListener() {
    // 必须在子线程执行IO操作，禁止在主线程运行
    Thread {
        isListening = true
        while (isListening) {
            try {
                val readCount = inputStream.read(readBuffer, 0, readBuffer.size)
                // 返回-1代表对端已经关闭流，直接退出循环
                if (readCount == -1) break
                // 只处理实际读取到的有效长度字节
                val validData = readBuffer.copyOf(readCount)
                // 此处添加你的数据处理逻辑，要更新UI的话请切到主线程
                processData(validData)
            } catch (e: IOException) {
                // 连接异常断开，此处可添加重连或错误提示逻辑
                e.printStackTrace()
                break
            }
        }
        // 退出循环后统一释放流资源
        runCatching { inputStream.close() }
    }.start()
}

// 在页面销毁、主动断开连接时调用，停止监听释放资源
fun stopStreamListener() {
    isListening = false
    // 主动关闭流可以打断阻塞的read()调用，快速结束监听线程
    runCatching { inputStream.close() }
}

2. 高性能版（NIO模式，适合多连接/高并发场景） #

如果需要同时管理多个连接、避免多线程开销，可以用Java NIO的Selector机制实现非阻塞监听：

• 将连接对应的SocketChannel配置为非阻塞模式
• 注册到Selector上监听OP_READ可读事件
• 单线程轮询Selector，只有事件触发时才读取数据，资源利用率远高于BIO的单连接单线程模式

额外注意点 #

• 你需要自行处理TCP粘包拆包问题：TCP是流式传输，不会按照你发送的数据包大小分段到达，建议自定义通信协议，比如在每个包头添加固定长度的数据包长度字段，读取到完整包后再处理业务逻辑。
• 不要在主线程执行任何网络IO操作，Android高版本会直接抛出NetworkOnMainThreadException强制崩溃。

内容的提问来源于stack exchange，提问作者Mohammad Elsayed