java中可通过继承inputstream封装真实流并维护已读字节数与总长度，重写read()等方法更新进度，提供getprogress()返回0.0–1.0值及onprogressupdate()回调，配合swingworker与jprogressbar实现线程安全的带进度条输入流。

Java 中可以通过继承 InputStream 并包装一个真实输入流（如 FileInputStream），在每次读取时更新进度状态，从而实现带进度条的输入流。核心在于重写 read() 和 read(byte[]) 等方法，在读取数据的同时计算并通知当前进度。

封装原始流并维护进度信息

自定义类需持有底层输入流引用，并记录总长度（用于计算百分比）和已读字节数：

• 构造时传入原始 InputStream 和可选的总大小（若为文件，可用 File.length() 获取）
• 用 AtomicLong 或同步变量维护 bytesRead，保证多线程读取时进度准确
• 提供 getProgress() 方法返回 0.0–1.0 的浮点进度值

重写关键读取方法并更新进度

所有读取入口都要更新计数器，并支持回调通知（例如 Swing 进度条或日志）：

Alibabacloud Sdk Client Initialization For Java

在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。

下载

• read()：读 1 字节后递增 bytesRead
• read(byte[] b) 和 read(byte[] b, int off, int len)：仅在实际读到字节后累加返回值
• 可在每次更新后调用 onProgressUpdate() 回调，比如 SwingUtilities.invokeLater 安全刷新 UI

配合 UI 使用示例（Swing）

将该流用于文件复制或解压等耗时操作时，绑定到 JProgressBar：

• 初始化进度条：progressBar.setIndeterminate(false); progressBar.setMinimum(0); progressBar.setMaximum(100);
• 在读取循环中每处理一次（或定时）调用 progressBar.setValue((int)(stream.getProgress() * 100));
• 注意：不要在事件分发线程（EDT）中直接阻塞读取，应放在 SwingWorker 后台线程执行

注意事项与优化点

避免常见陷阱，提升实用性与健壮性：

• 若原始流不支持 available() 或长度未知，可设为 -1，此时进度条显示为“不确定”或使用自增式估算（如按块数）
• 重写 close() 时确保关闭底层流，并可触发完成回调
• 考虑实现 ProgressListener 接口，支持注册多个监听器（如同时更新进度条和状态栏）
• 对大文件建议设置缓冲区（如 BufferedInputStream 包装本类），减少频繁回调开销

Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南