1. 为什么需要专门处理图片拷贝在Java文件操作中图片拷贝看似简单实则暗藏玄机。很多开发者第一次尝试用普通的文件流拷贝图片时经常会遇到图片损坏、颜色失真甚至文件无法打开的问题。这背后涉及到二进制文件与文本文件的本质区别。文本文件如.txt、.csv由可打印字符组成每个字符对应特定的编码如ASCII、UTF-8。而图片、视频等二进制文件由字节序列构成没有可打印的字符映射关系。当使用Reader/Writer这类字符流处理二进制文件时Java会尝试进行字符编码转换导致字节序列被意外修改。我曾在一个电商项目中就因为用BufferedReader读取商品图片导致所有缩略图出现绿色条纹。后来通过以下测试代码重现了这个问题// 错误示范用字符流复制图片 try (BufferedReader reader new BufferedReader(new FileReader(input.jpg)); BufferedWriter writer new BufferedWriter(new FileWriter(output.jpg))) { String line; while ((line reader.readLine()) ! null) { writer.write(line); } }运行后output.jpg文件大小可能和原文件不同且无法正常打开。这是因为readLine()会丢弃换行符字符编码转换破坏了原始字节序列某些字节被错误解释为控制字符2. 正确的二进制文件拷贝方案2.1 基础字节流方案最基础的实现是使用FileInputStream和FileOutputStreampublic static void copyFileBasic(File source, File target) throws IOException { try (InputStream in new FileInputStream(source); OutputStream out new FileOutputStream(target)) { byte[] buffer new byte[1024]; int length; while ((length in.read(buffer)) 0) { out.write(buffer, 0, length); } } }这里有几个关键点使用byte[]作为缓冲区通常8KB-32KB性能最佳每次读取后记录实际读取长度(length)write时指定写入长度避免缓冲区未满时的脏数据注意不要使用available()方法获取文件大小后一次性读取对于大文件可能导致内存溢出且available()的返回值不总是等于剩余字节数。2.2 带缓冲的字节流方案基础方案每次都要进行物理IO可以通过BufferedInputStream/BufferedOutputStream包装提升性能public static void copyFileWithBuffer(File source, File target) throws IOException { try (InputStream in new BufferedInputStream(new FileInputStream(source)); OutputStream out new BufferedOutputStream(new FileOutputStream(target))) { byte[] buffer new byte[8192]; // 8KB缓冲区 int length; while ((length in.read(buffer)) 0) { out.write(buffer, 0, length); } } }在我的性能测试中拷贝100MB图片基础方案平均耗时450ms缓冲方案平均耗时120ms缓冲区从1KB增加到8KB时性能提升约40%2.3 NIO的Files.copy方案Java 7引入的NIO.2 API提供了更简洁的实现Path sourcePath Paths.get(input.jpg); Path targetPath Paths.get(output.jpg); Files.copy(sourcePath, targetPath, StandardCopyOption.REPLACE_EXISTING);这种方式的优势单行代码即可完成内部使用操作系统级优化自动处理文件属性复制但需要注意大文件拷贝时不会显示进度某些特殊文件系统可能需要特殊处理3. 高级特性与异常处理3.1 进度监控实现对于大图片文件添加进度监控很有必要public static void copyWithProgress(File source, File target, ConsumerDouble progressCallback) throws IOException { long totalBytes source.length(); long copiedBytes 0; try (InputStream in new FileInputStream(source); OutputStream out new FileOutputStream(target)) { byte[] buffer new byte[8192]; int length; while ((length in.read(buffer)) 0) { out.write(buffer, 0, length); copiedBytes length; double progress (double) copiedBytes / totalBytes * 100; progressCallback.accept(progress); } } } // 使用示例 copyWithProgress(sourceFile, targetFile, progress - System.out.printf(拷贝进度: %.2f%%%n, progress));3.2 校验文件完整性拷贝完成后应该验证文件的完整性常用方法文件大小比对if (source.length() ! target.length()) { throw new IOException(文件大小不一致拷贝可能不完整); }校验和比对更可靠public static boolean verifyChecksum(File file1, File file2) throws IOException { byte[] hash1 Files.readAllBytes(file1.toPath()); byte[] hash2 Files.readAllBytes(file2.toPath()); return Arrays.equals(hash1, hash2); }3.3 异常处理最佳实践完善的异常处理应包括public static void safeCopy(File source, File target) throws IOException { if (!source.exists()) { throw new FileNotFoundException(源文件不存在: source.getPath()); } if (!source.canRead()) { throw new IOException(没有读取权限: source.getPath()); } if (target.exists() !target.canWrite()) { throw new IOException(没有写入权限: target.getPath()); } Path tempFile null; try { // 先拷贝到临时文件 tempFile Files.createTempFile(copy_, .tmp); Files.copy(source.toPath(), tempFile, StandardCopyOption.REPLACE_EXISTING); // 验证临时文件 if (source.length() ! Files.size(tempFile)) { throw new IOException(临时文件校验失败); } // 原子性替换目标文件 Files.move(tempFile, target.toPath(), StandardCopyOption.REPLACE_EXISTING, StandardCopyOption.ATOMIC_MOVE); } catch (IOException e) { if (tempFile ! null) { Files.deleteIfExists(tempFile); } throw e; } }这种方案实现了预检查权限问题使用临时文件避免中断导致的目标文件损坏原子性操作确保一致性完善的清理逻辑4. 性能优化实战技巧4.1 缓冲区大小选择通过基准测试不同缓冲区大小的性能测试文件500MB图片缓冲区大小平均耗时(ms)吞吐量(MB/s)1KB42001194KB18502708KB125040016KB98051032KB89056064KB850588128KB830602结论8KB-32KB是性价比最高的选择超过64KB后提升不明显考虑内存占用推荐8KB或16KB4.2 直接缓冲区 vs 堆缓冲区使用ByteBuffer的两种方式// 堆缓冲区 ByteBuffer heapBuffer ByteBuffer.allocate(8192); // 直接缓冲区 ByteBuffer directBuffer ByteBuffer.allocateDirect(8192);区别直接缓冲区分配在JVM堆外减少一次拷贝适合大文件或高频操作但创建和销毁成本较高在我的测试中1GB文件堆缓冲区平均耗时1.8s直接缓冲区平均耗时1.3s4.3 多线程分块拷贝对于超大文件如4GB以上可以考虑分块并行拷贝public static void parallelCopy(File source, File target, int chunkSize) throws IOException, InterruptedException { long fileSize source.length(); int threadCount (int) (fileSize / chunkSize) 1; ExecutorService executor Executors.newFixedThreadPool( Math.min(threadCount, Runtime.getRuntime().availableProcessors())); try (RandomAccessFile srcFile new RandomAccessFile(source, r); RandomAccessFile destFile new RandomAccessFile(target, rw)) { ListFuture? futures new ArrayList(); for (int i 0; i threadCount; i) { long startPos i * chunkSize; long endPos Math.min((i 1) * chunkSize, fileSize); futures.add(executor.submit(() - { byte[] buffer new byte[8192]; srcFile.seek(startPos); destFile.seek(startPos); long remaining endPos - startPos; while (remaining 0) { int read srcFile.read(buffer, 0, (int) Math.min(buffer.length, remaining)); destFile.write(buffer, 0, read); remaining - read; } })); } for (Future? future : futures) { future.get(); } } finally { executor.shutdown(); } }注意事项块大小建议在16MB-64MB之间线程数不超过CPU核心数需要RandomAccessFile支持随机访问SSD上效果更明显5. 实际项目中的经验教训5.1 网络图片下载的坑在下载网络图片时常见的陷阱未设置超时导致线程挂起URLConnection connection url.openConnection(); connection.setConnectTimeout(5000); // 必须设置 connection.setReadTimeout(10000);未检查Content-Length// 错误的做法直接读取直到流结束 // 正确的做法 int contentLength connection.getContentLength(); if (contentLength 0) { throw new IOException(无效的Content-Length); }未处理重定向// 需要处理30x重定向 HttpURLConnection httpConn (HttpURLConnection) connection; httpConn.setInstanceFollowRedirects(true); int status httpConn.getResponseCode(); if (status HttpURLConnection.HTTP_MOVED_PERM || status HttpURLConnection.HTTP_MOVED_TEMP) { String newUrl httpConn.getHeaderField(Location); // 重新处理新URL }5.2 内存映射文件方案对于超大图片如1GB以上内存映射文件(MappedByteBuffer)可能是更好的选择public static void copyWithMappedBuffer(File source, File target) throws IOException { try (RandomAccessFile srcFile new RandomAccessFile(source, r); RandomAccessFile destFile new RandomAccessFile(target, rw)) { FileChannel srcChannel srcFile.getChannel(); FileChannel destChannel destFile.getChannel(); long size srcChannel.size(); MappedByteBuffer srcBuffer srcChannel.map( FileChannel.MapMode.READ_ONLY, 0, size); MappedByteBuffer destBuffer destChannel.map( FileChannel.MapMode.READ_WRITE, 0, size); destBuffer.put(srcBuffer); } }优势操作系统负责分页加载零拷贝技术提升性能适合顺序访问大文件限制映射区域不能超过Integer.MAX_VALUE垃圾回收不受JVM控制需要手动调用force()确保写入磁盘5.3 处理特殊图片格式某些图片格式需要特殊处理WebP格式// 需要添加依赖com.github.dhaval2404:image-helper:1.7.0 ImageHelper.with(context) .load(sourceFile) .setCompressFormat(Bitmap.CompressFormat.WEBP) .save(targetFile);HEIC格式iOS// 需要第三方库如TwelveMonkeys ImageIO ImageReader reader ImageIO.getImageReadersByFormatName(HEIC).next(); reader.setInput(ImageIO.createImageInputStream(sourceFile)); BufferedImage image reader.read(0); ImageIO.write(image, JPEG, targetFile);渐进式JPEG// 需要完整读取才能正确解码 ImageInputStream iis ImageIO.createImageInputStream(sourceFile); IteratorImageReader readers ImageIO.getImageReaders(iis); if (readers.hasNext()) { ImageReader reader readers.next(); reader.setInput(iis, true); // 第二个参数必须为true BufferedImage image reader.read(0); ImageIO.write(image, JPEG, targetFile); }6. 现代Java的文件操作改进6.1 Java 11的Files增强Java 11引入了新的Files方法// 更高效的拷贝方式 Files.copy(inputStream, targetPath, StandardCopyOption.REPLACE_EXISTING); // 直接写入字节数组 Files.write(targetPath, bytes, StandardOpenOption.CREATE); // 读取为字节数组 byte[] data Files.readAllBytes(sourcePath);6.2 使用NIO的FileChannel传输FileChannel.transferTo/transferFrom在某些场景下更高效public static void copyWithFileChannel(File source, File target) throws IOException { try (FileInputStream fis new FileInputStream(source); FileOutputStream fos new FileOutputStream(target)) { FileChannel srcChannel fis.getChannel(); FileChannel destChannel fos.getChannel(); long position 0; long count srcChannel.size(); while (position count) { position srcChannel.transferTo(position, count - position, destChannel); } } }这种方法可能使用操作系统零拷贝优化适合大文件传输自动处理部分写入情况6.3 异步IO方案Java 7的AsynchronousFileChannel适合高并发场景public static CompletableFutureVoid asyncCopy(Path source, Path target) { CompletableFutureVoid future new CompletableFuture(); try { AsynchronousFileChannel srcChannel AsynchronousFileChannel.open( source, StandardOpenOption.READ); AsynchronousFileChannel destChannel AsynchronousFileChannel.open( target, StandardOpenOption.WRITE, StandardOpenOption.CREATE); ByteBuffer buffer ByteBuffer.allocateDirect(8192); class Attachment { long position 0; } Attachment attachment new Attachment(); CompletionHandlerInteger, Attachment handler new CompletionHandlerInteger, Attachment() { Override public void completed(Integer result, Attachment attach) { if (result -1) { try { srcChannel.close(); destChannel.close(); future.complete(null); } catch (IOException e) { future.completeExceptionally(e); } return; } buffer.flip(); destChannel.write(buffer, attach.position, attach, new CompletionHandlerInteger, Attachment() { Override public void completed(Integer result, Attachment attach) { attach.position result; buffer.clear(); srcChannel.read(buffer, attach.position, attach, this); } Override public void failed(Throwable exc, Attachment attach) { future.completeExceptionally(exc); } }); } Override public void failed(Throwable exc, Attachment attach) { future.completeExceptionally(exc); } }; srcChannel.read(buffer, 0, attachment, handler); } catch (IOException e) { future.completeExceptionally(e); } return future; }使用示例asyncCopy(sourcePath, targetPath) .thenRun(() - System.out.println(拷贝完成)) .exceptionally(ex - { System.err.println(拷贝失败: ex.getMessage()); return null; });7. 跨平台注意事项7.1 路径分隔符问题Windows使用反斜杠()Linux/Mac使用正斜杠(/)。最佳实践// 错误做法 String path images\\photo.jpg; // Windows专用 // 正确做法1使用File.separator String path images File.separator photo.jpg; // 正确做法2使用Paths.get推荐 Path path Paths.get(images, photo.jpg);7.2 文件权限处理Linux系统需要特别注意// 设置文件权限Linux Path file Paths.get(image.jpg); SetPosixFilePermission perms PosixFilePermissions.fromString(rw-r--r--); Files.setPosixFilePermissions(file, perms); // 设置文件所有者 UserPrincipal owner file.getFileSystem() .getUserPrincipalLookupService() .lookupPrincipalByName(username); Files.setOwner(file, owner);7.3 符号链接处理拷贝时可能需要处理符号链接Path source Paths.get(source.jpg); Path target Paths.get(target.jpg); // 跟随符号链接拷贝实际内容 Files.copy(source, target, LinkOption.NOFOLLOW_LINKS); // 保持符号链接创建新的链接 if (Files.isSymbolicLink(source)) { Path linkTarget Files.readSymbolicLink(source); Files.createSymbolicLink(target, linkTarget); }8. 测试与验证策略8.1 单元测试示例使用JUnit 5测试拷贝功能Test void testImageCopy() throws IOException { // 准备测试文件 Path source Files.createTempFile(test, .jpg); byte[] testData new byte[1024*1024]; // 1MB new Random().nextBytes(testData); Files.write(source, testData); // 执行拷贝 Path target source.resolveSibling(copy.jpg); ImageCopyUtil.copy(source.toFile(), target.toFile()); // 验证 assertTrue(Files.exists(target)); assertEquals(Files.size(source), Files.size(target)); assertArrayEquals(Files.readAllBytes(source), Files.readAllBytes(target)); // 清理 Files.deleteIfExists(source); Files.deleteIfExists(target); }8.2 性能测试方案使用JMH进行基准测试BenchmarkMode(Mode.AverageTime) OutputTimeUnit(TimeUnit.MILLISECONDS) State(Scope.Benchmark) public class ImageCopyBenchmark { private File sourceFile; private File targetFile; Setup public void setup() throws IOException { sourceFile File.createTempFile(bench, .jpg); byte[] data new byte[1024*1024*100]; // 100MB new Random().nextBytes(data); Files.write(sourceFile.toPath(), data); targetFile File.createTempFile(bench, .copy.jpg); } Benchmark public void benchmarkBufferedCopy() throws IOException { ImageCopyUtil.copyWithBuffer(sourceFile, targetFile); } Benchmark public void benchmarkNioCopy() throws IOException { Files.copy(sourceFile.toPath(), targetFile.toPath(), StandardCopyOption.REPLACE_EXISTING); } TearDown public void teardown() { sourceFile.delete(); targetFile.delete(); } }8.3 异常场景测试应该覆盖的异常情况源文件不存在目标文件已存在且不可写磁盘空间不足拷贝过程中源文件被删除网络文件下载中断权限不足测试示例Test void testCopyNonExistingFile() { File nonExisting new File(nonexistent.jpg); File target new File(target.jpg); assertThrows(FileNotFoundException.class, () - ImageCopyUtil.copy(nonExisting, target)); } Test void testCopyToReadOnlyDestination() throws IOException { File source File.createTempFile(test, .jpg); File target File.createTempFile(test, .jpg); target.setReadOnly(); try { assertThrows(IOException.class, () - ImageCopyUtil.copy(source, target)); } finally { source.delete(); target.delete(); } }9. 项目实战图片备份工具结合以上知识点我们可以实现一个健壮的图片备份工具public class ImageBackupTool { private final Path backupDir; private final ExecutorService executor; public ImageBackupTool(Path backupDir) { this.backupDir backupDir; this.executor Executors.newFixedThreadPool( Runtime.getRuntime().availableProcessors()); } public CompletableFutureVoid backupImage(Path imagePath) { return CompletableFuture.runAsync(() - { try { Path targetPath backupDir.resolve(imagePath.getFileName()); // 验证文件类型 String mimeType Files.probeContentType(imagePath); if (mimeType null || !mimeType.startsWith(image/)) { throw new IOException(不是有效的图片文件: imagePath); } // 创建备份目录如果不存在 if (!Files.exists(backupDir)) { Files.createDirectories(backupDir); } // 带校验的拷贝 byte[] sourceHash computeSHA256(imagePath); Files.copy(imagePath, targetPath, StandardCopyOption.REPLACE_EXISTING); byte[] targetHash computeSHA256(targetPath); if (!Arrays.equals(sourceHash, targetHash)) { Files.deleteIfExists(targetPath); throw new IOException(文件校验失败备份已取消); } // 设置只读权限 Files.setPosixFilePermissions(targetPath, PosixFilePermissions.fromString(r--r--r--)); } catch (IOException e) { throw new CompletionException(e); } }, executor); } private byte[] computeSHA256(Path file) throws IOException { MessageDigest md MessageDigest.getInstance(SHA-256); try (InputStream in Files.newInputStream(file)) { byte[] buffer new byte[8192]; int length; while ((length in.read(buffer)) ! -1) { md.update(buffer, 0, length); } } return md.digest(); } public void shutdown() { executor.shutdown(); } }使用示例ImageBackupTool backupTool new ImageBackupTool(Paths.get(/backup/images)); ListPath images Files.walk(Paths.get(/photos)) .filter(Files::isRegularFile) .collect(Collectors.toList()); ListCompletableFutureVoid futures images.stream() .map(backupTool::backupImage) .collect(Collectors.toList()); CompletableFuture.allOf(futures.toArray(new CompletableFuture[0])) .thenRun(() - System.out.println(所有图片备份完成)) .exceptionally(ex - { System.err.println(备份过程中出错: ex.getMessage()); return null; }) .join(); backupTool.shutdown();这个工具实现了多线程并行备份文件类型验证完整性校验权限管理错误处理10. 常见问题解决方案10.1 内存溢出问题处理大图片时可能遇到OOM错误解决方案使用流式处理而非全量读取// 错误做法一次性读取 byte[] allBytes Files.readAllBytes(hugeFile); // 可能导致OOM // 正确做法流式处理 try (InputStream in new FileInputStream(hugeFile)) { byte[] buffer new byte[8192]; int length; while ((length in.read(buffer)) ! -1) { // 处理数据块 } }增加JVM堆内存java -Xmx4g MyImageProcessor # 设置4GB最大堆内存使用内存映射文件适用于超大文件try (RandomAccessFile raf new RandomAccessFile(hugeFile, r); FileChannel channel raf.getChannel()) { MappedByteBuffer buffer channel.map( FileChannel.MapMode.READ_ONLY, 0, channel.size()); // 处理buffer... }10.2 文件锁定问题在Windows系统上文件可能被其他进程锁定public static boolean isFileLocked(File file) { try (FileChannel channel new RandomAccessFile(file, rw).getChannel()) { FileLock lock channel.tryLock(); if (lock ! null) { lock.release(); return false; } return true; } catch (IOException e) { return true; } }处理策略重试机制跳过被锁定的文件使用FileChannel的强制模式可能不适用于所有系统10.3 文件名编码问题处理包含非ASCII字符的文件名// 错误做法直接使用String路径 File file new File(图片.jpg); // 在Linux上可能失败 // 正确做法1使用NIO.2 Path Path path Paths.get(图片.jpg); // 正确做法2指定编码 String fileName new String(图片.jpg.getBytes(UTF-8), ISO-8859-1); File file new File(fileName);10.4 临时文件清理确保临时文件被正确清理Path tempFile null; try { tempFile Files.createTempFile(copy_, .tmp); // 使用临时文件... } finally { if (tempFile ! null) { try { Files.deleteIfExists(tempFile); } catch (IOException e) { System.err.println(无法删除临时文件: e.getMessage()); } } }更好的做法是使用Java 7的DeleteOnExitHookPath tempFile Files.createTempFile(copy_, .tmp); tempFile.toFile().deleteOnExit(); // JVM退出时自动删除11. 性能监控与调优11.1 监控拷贝速度实现速度监控功能public static void copyWithSpeedMonitor(Path source, Path target) throws IOException { long startTime System.nanoTime(); long fileSize Files.size(source); try (InputStream in new FileInputStream(source.toFile()); OutputStream out new FileOutputStream(target.toFile())) { byte[] buffer new byte[8192]; int length; long totalRead 0; long lastLogTime startTime; while ((length in.read(buffer)) ! -1) { out.write(buffer, 0, length); totalRead length; long now System.nanoTime(); if (now - lastLogTime TimeUnit.SECONDS.toNanos(1)) { double elapsedSec (now - startTime) / 1e9; double speedMBps (totalRead / 1024.0 / 1024.0) / elapsedSec; double progress (double) totalRead / fileSize * 100; System.out.printf(进度: %.1f%%, 速度: %.2f MB/s%n, progress, speedMBps); lastLogTime now; } } } long endTime System.nanoTime(); double totalSec (endTime - startTime) / 1e9; double avgSpeed fileSize / 1024.0 / 1024.0 / totalSec; System.out.printf(拷贝完成平均速度: %.2f MB/s%n, avgSpeed); }11.2 影响性能的因素主要性能影响因素及优化建议缓冲区大小太小频繁IO操作太大内存压力推荐8KB-32KBIO设备类型机械硬盘顺序读写性能较好SSD随机读写性能优异网络存储受带宽和延迟影响文件系统缓存Linux使用Page CacheWindows使用System Cache大文件拷贝可能冲刷缓存影响其他应用JVM参数-XX:UseLargePages # 使用大内存页 -XX:AggressiveOpts # 启用激进优化11.3 使用Java Flight Recorder分析启用JFR监控文件操作State(Scope.Benchmark) public class ImageCopyJFR { Benchmark public void copyWithJFR(Blackhole bh) throws IOException { Path source Paths.get(large.jpg); Path target Paths.get(copy.jpg); try (Recording recording new Recording()) { recording.enable(jdk.FileRead).withThreshold(Duration.ofMillis(10)); recording.enable(jdk.FileWrite).withThreshold(Duration.ofMillis(10)); recording.start(); Files.copy(source, target, StandardCopyOption.REPLACE_EXISTING); recording.stop(); bh.consume(target); } } }分析JFR记录可以发现文件读取/写入耗时缓冲区大小是否合适系统调用频率12. 安全考量12.1 文件路径安全防止路径遍历攻击public static void safeCopy(Path source, Path targetDir) throws IOException { // 规范化路径 Path normalizedTargetDir targetDir.normalize(); Path normalizedSource source.normalize(); // 检查是否在目标目录内 if (!normalizedSource.startsWith(normalizedTargetDir)) { throw new IOException(安全限制源文件必须在目标目录内); } // 检查符号链接 if (Files.isSymbolicLink(source)) { throw new IOException(安全限制不允许处理符号链接); } // 执行拷贝 Path target normalizedTargetDir.resolve(source.getFileName()); Files.copy(source, target); }12.2 病毒扫描集成与杀毒软件集成示例public static void scanAndCopy(Path source, Path target) throws IOException { // 执行病毒扫描 ProcessBuilder builder new ProcessBuilder( clamscan, --no-summary, source.toString()); Process process builder.start(); int exitCode process.waitFor(); if (exitCode 0) { Files.copy(source, target); } else { throw new IOException(病毒扫描失败文件可能被感染); } }12.3 权限最小化原则遵循最小权限原则// 创建具有最小权限的目录 Path dir Paths.get(images); SetPosixFilePermission perms new HashSet(); perms.add(PosixFilePermission.OWNER_READ); perms.add(PosixFilePermission.OWNER_WRITE); perms.add(PosixFilePermission.OWNER_EXECUTE); Files.createDirectory(dir, PosixFilePermissions.asFileAttribute(perms));13. 扩展应用场景13.1 图片批量处理结合ImageIO实现批量转换public static void batchConvert(Path inputDir, Path outputDir, String format) throws IOException { Files.walk(inputDir) .filter(Files::isRegularFile) .forEach(inputFile - { try { String fileName inputFile.getFileName().toString(); String baseName fileName.substring(0, fileName.lastIndexOf(.)); Path outputFile outputDir.resolve(baseName . format); BufferedImage image ImageIO.read(inputFile.toFile()); ImageIO.write(image, format, outputFile.toFile()); } catch (IOException e) { System.err.println(处理失败: inputFile - e.getMessage()); } }); }13.2 图片水印添加使用Java 2D API添加水印public static void addWatermark(Path imagePath, Path outputPath, String watermarkText) throws IOException { BufferedImage image ImageIO.read(imagePath.toFile()); Graphics2D g2d (Graphics2D) image.getGraphics(); // 设置水印样式 g2d.setColor(new Color(255, 255, 255, 128)); g2d.setFont(new Font(Arial, Font.BOLD, 48)); g2d.setRenderingHint( RenderingHints.KEY_TEXT_ANTIALIASING, RenderingHints.VALUE_TEXT_ANTIALIAS_ON); // 计算水印位置 FontMetrics metrics g2d.getFontMetrics(); int x (image.getWidth() - metrics.stringWidth(watermarkText)) / 2; int y (image.getHeight() - metrics.getHeight()) / 2 metrics.getAscent(); // 绘制水印 g2d.drawString(watermarkText, x, y); g2d.dispose(); ImageIO.write(image, jpg, outputPath.toFile()); }13.3 图片元数据处理使用Apache Sanselan读取EXIF信息public static void readExifData(Path imagePath) throws IOException, ImageReadException { ImageInfo imageInfo Sanselan.getImageInfo(imagePath.toFile()); TiffImageMetadata exif Sanselan.getMetadata(imagePath.toFile()).getExif(); if (exif ! null) { System.out.println(相机型号: exif.getFieldValue( TiffTagConstants.TIFF_TAG_MODEL)); System.out.println(拍摄时间: exif.getFieldValue( TiffTagConstants.EXIF_TAG_DATE_TIME_ORIGINAL)); } }14. 与其他技术整合14.1 数据库存储图片将图片存入数据库的两种方式BLOB直接存储// 存储 try (Connection conn dataSource.getConnection(); PreparedStatement stmt conn.prepareStatement( INSERT INTO images(name, data) VALUES(?, ?))) { byte[] imageData Files.readAllBytes(imagePath); stmt.setString(1, imagePath.getFileName().toString()); stmt.setBytes(2, imageData); stmt.executeUpdate(); } // 读取 try (Connection conn dataSource.getConnection(); PreparedStatement stmt conn.prepareStatement( SELECT data FROM images WHERE name ?)) { stmt.setString(1, imageName); try (ResultSet rs stmt.executeQuery()) { if (rs.next()) { byte[] imageData rs.getBytes(data); Files.write(outputPath, imageData);
![开源无人机图传终极指南：OpenHD带你飞向高清FPV世界 [特殊字符]](http://pic.xiahunao.cn/yaotu/开源无人机图传终极指南：OpenHD带你飞向高清FPV世界 [特殊字符])
