java使用nio2拷贝文件的示例_java

这个程序只是为了更方便的进行拷贝文件(夹)而创造。
1.可以不用新建文件夹，就像windows的复制粘贴一样简单。
2.有简单的出错重连机制
3.不需要重复拷贝，差异化复制文件。
4.拷贝文件夹的时候可以不用复制全路径，只关注需要拷贝的文件夹。
5.程序做了简单的必要检查，效率也不算低。
6.使用的是7的nio2的新API。

复制代码 代码如下:

import java.io.IOException;
import java.nio.file.FileVisitResult;
import java.nio.file.FileVisitor;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.nio.file.StandardCopyOption;
import java.nio.file.attribute.BasicFileAttributes;
import java.nio.file.attribute.FileTime;
import java.util.Stack;

import org.apache.log4j.Logger;

import com.xyq.myfile.cope.entity.PathType;
import com.xyq.util.MD5Util;

/***
 * 基于jdk7的拷贝算法
 *
 * @author xyq
 *
 */
public class MyFiles2 {

 private String src;
 private String tar;
 private Path srcPath;
 private Path tarPath;
 private int reCount = 3;
 private boolean isCover = false;
 private boolean useMd5 = false;
 private int subNameNum = 0;
 // log4j对象
 private Logger logger;
 // 在文件夹-->文件夹模式中，是否拷贝全路径,默认不拷贝
 private boolean isCopeAllPath = false;

 public MyFiles2(String src, String tar) {

  this.src = src;
  this.tar = tar;
  this.srcPath = Paths.get(src);
  this.tarPath = Paths.get(tar);
 }

 public MyFiles2() {
 }

 public String getSrc() {
  return src;
 }

 public void setSrc(String src) {
  this.src = src;
  this.srcPath = Paths.get(src);
 }

 public String getTar() {
  return tar;
 }

 public void setTar(String tar) {
  this.tar = tar;
  this.tarPath = Paths.get(tar);
 }

 public int getReCount() {
  return reCount;
 }

 public void setReCount(int reCount) {
  this.reCount = reCount;
 }

 public boolean isCover() {
  return isCover;
 }

 public void setCover(boolean isCover) {
  this.isCover = isCover;
 }

 public Logger getLogger() {
  return logger;
 }

 public void setLogger(Logger logger) {
  this.logger = logger;
 }

 public boolean isUseMd5() {
  return useMd5;
 }

 public void setUseMd5(boolean useMd5) {
  this.useMd5 = useMd5;
 }

 public boolean isCopeAllPath() {
  return isCopeAllPath;
 }

 public void setCopeAllPath(boolean isCopeAllPath) {
  this.isCopeAllPath = isCopeAllPath;
 }

 public boolean copeFileCore(PathType... types) {

  if (initCheck() && initCheck2s(this.srcPath, false))
   return copeFileCore(this.srcPath, this.tarPath, reCount, isCover,
     types);
  return false;
 }

 private boolean initCheck() {

  if (this.srcPath == null) {
   logInfo("原始路径未设置,程序无法启动~~");
   return false;
  } else if (this.tarPath == null) {
   logInfo("目标路径未设置,程序无法启动~~");
   return false;
  } else if (!Files.exists(srcPath)) {
   logInfo("原始路径不存在,程序无法启动~~");
   return false;
  } else if (!Files.exists(tarPath.getRoot())) {
   logInfo("目标路径的根盘符不存在,程序无法启动~~");
   return false;
  }
  return true;
 }

 private boolean initCheck2s(Path path, boolean dOrF) {

  if (!Files.isDirectory(path)) {
   if (dOrF) {
    logInfo(path + "不是一个有效的文件夹");
    return false;
   }
  } else if (!dOrF) {
   logInfo(path + "不是一个有效的文件");
   return false;
  }
  return true;
 }

 /****
  * 拷贝文件算法
  *
  * @param path1
  *            原始路径
  * @param path2
  *            目标路径
  * @param reCount
  *            重复次数
  * @param isCover
  *            是否覆盖拷贝
  * @param types
  *            你所写的目标路径是文件还是文件夹，可以不写，默认是文件
  * @return
  */
 public boolean copeFileCore(Path path1, Path path2, int reCount,
   boolean isCover, PathType... types) {

  // 如果原始文件不存在，就直接异常
  if (!initCheck() || !initCheck2s(path1, false))
   return false;
  PathType type = PathType.FILES;
  if (types != null && types.length > 0) {
   type = types[0];
   // 如果目标是一个文件夹,并且指定是往一个文件夹拷贝的时候
   if (type.equals(PathType.DIRS)) {
    path2 = Paths.get(path2.toString(), path1.getFileName()
      .toString());
   }
  }
  // 如果目标文件已经存在，就判断是否相同，相同就不用拷贝了
  if (Files.exists(path2)) {
   if (Files.isDirectory(path2) && PathType.FILES.equals(type)) {
    logInfo(path2 + "已经存在,它是一个文件夹而不是文件");
    return false;
   }
   if (isSameFile(path1, path2, useMd5))
    return true;
  }
  // 当目标文件不存在的时候
  else {
   Path parPath = path2.getParent();
   // 如果目标文件的父类文件夹不存在,就尝试创建
   if (!Files.exists(parPath))
    for (int i = 1; i < reCount; i++) {
     try {
      Files.createDirectories(parPath);
      break;
     } catch (Exception e) {
      if (i == reCount) {
       logInfo(e);
       return false;
      }
     }
    }
  }

  for (int i = 1; i <= reCount; i++) {
   try {
    if (isCover)
     Files.copy(path1, path2,
       StandardCopyOption.REPLACE_EXISTING,
       StandardCopyOption.COPY_ATTRIBUTES);
    else
     Files.copy(path1, path2, StandardCopyOption.COPY_ATTRIBUTES);
    // 同步最后修改时间
    synLastFileTime(path1, path2);
    break;
   } catch (IOException e) {
    // 如果在指定时间内都无法完成拷贝，那么就果断记录到异常信息中
    if (i == reCount) {
     logInfo(e);
     return false;
    }
   }
  }
  return true;

 }

 public void copeDir() {

  if (!initCheck() || !initCheck2s(srcPath, true))
   return;
  copeDir(this.srcPath.toString(), this.tarPath.toString());
 }

 /***
  * 拷贝文件夹保护层
  *
  * @param path1
  * @param path2
  */
 public void copeDir(String path1, final String path2) {

  if (!initCheck() || !initCheck2s(srcPath, true))
   return;
  Path p1 = Paths.get(path1);
  final Path tarPath = Paths.get(path2);
  if (!isCopeAllPath)
   subNameNum = srcPath.getNameCount() - 1;
  try {
   Files.walkFileTree(p1, new FileVisitor<Path>() {

    Path p2 = null;
    Stack<Path> dirStack = new Stack<Path>();

    @Override
    public FileVisitResult preVisitDirectory(Path dir,
      BasicFileAttributes attrs) throws IOException {

     // 当使用不拷贝全路径时，作为本文件夹的名字节点的记录位置
     // if (!copeAllPath)
     /****
      * 如果是相同的文件夹，那么就跳过无需拷贝.
      */
     if (isSamePath(dir, tarPath)) {
      System.out.println("是相同的，跳过!!!!!!!!!!!!!!!!!");
      return FileVisitResult.SKIP_SUBTREE;
     }
     p2 = replacePath(dir, path2, subNameNum);
     if (dir.toFile().length() == 0 && !Files.exists(p2))
      Files.createDirectories(p2);
     dirStack.push(p2);
     return FileVisitResult.CONTINUE;

    }

    @Override
    public FileVisitResult visitFile(Path file,
      BasicFileAttributes attrs) throws IOException {

     Path toFilePath = Paths.get(dirStack.peek().toString(),
       file.getFileName().toString());
     copeFileCore(file, toFilePath, 3, true);
     return FileVisitResult.CONTINUE;

    }

    @Override
    public FileVisitResult visitFileFailed(Path file,
      IOException exc) throws IOException {

     return FileVisitResult.CONTINUE;
    }

    @Override
    public FileVisitResult postVisitDirectory(Path dir,
      IOException exc) throws IOException {
     if (!dirStack.isEmpty())
      dirStack.pop();
     return FileVisitResult.CONTINUE;
    }

   });
  } catch (IOException e) {
   logInfo(e);
  }
 }

 /***
  * 替换Path
  *
  * @param path1
  * @param path2
  * @return
  */
 private Path replacePath(Path path1, String path2, int nameCountNum) {

  if (path1.getNameCount() == 0 && path1.equals(path1.getRoot()))
   return Paths.get(path2);
  return Paths.get(path2,
    path1.subpath(nameCountNum, path1.getNameCount()).toString());
 }

 /***
  * 要么是地址完全相同，要么就是原始文件的父类与目标相同，因为程序支持拷贝到父类
  *
  * @param path1
  * @param path2
  * @return
  */
 private boolean isSamePath(Path path1, Path path2) {

  if (path1.equals(path2))
   return true;
  return false;
 }

 /***
  * 同步文件的修改时间
  *
  * @param path1
  * @param path2
  * @return
  */
 public boolean synLastFileTime(Path path1, Path path2) {

  FileTime srcPathTime;
  try {
   srcPathTime = Files.getLastModifiedTime(path1);
   Files.setLastModifiedTime(path2, srcPathTime);
   return srcPathTime.equals(Files.getLastModifiedTime(path2));
  } catch (IOException e) {
   logInfo(e);
   return false;
  }
 }

 /***
  * 判断两个文件是否相同
  *
  * @param path1
  * @param path2
  * @return
  */
 public boolean isSameFile(Path path1, Path path2, boolean useMd5) {

  try {
   // 只要两个文件长度不一致，就绝对不是一个文件
   if (Files.size(path1) != Files.size(path2))
    return false;
   // 如果是最后的修改时间不一样，就直接使用MD5验证
   else if (!Files.getLastModifiedTime(path1).equals(
     Files.getLastModifiedTime(path2))
     || useMd5)
    return MD5Util.getFileMD5String(path1.toFile()).equals(
      MD5Util.getFileMD5String(path2.toFile()));
   return true;
  } catch (Exception e) {
   logInfo(e);
   return false;
  }
 }

 /***
  * 针对异常处理的
  */
 private void logInfo(Exception e) {

  if (this.logger != null)
   logger.error(e.getMessage());
  else if (e != null)
   System.out.println("异常:" + e.getMessage());
 }

 private void logInfo(String errorMessage) {

  if (this.logger != null)
   logger.error(errorMessage);
  else
   System.out.println("异常:" + errorMessage);
 }

 public static void main(String[] args) {

  // new MyFiles2("e:/t/1.txt", "e:/3/33").copeFileCore();
  MyFiles2 my = new MyFiles2("e:/ttt/tt/t/1.txt", "e:/3/33.txt");
  my.copeFileCore(PathType.DIRS);
 }
}

复制代码 代码如下:

public enum PathType {

 FILES,DIRS;
}

复制代码 代码如下:

import java.io.Closeable;

public class CloseIoUtil {

 /***
  * 关闭IO流
  *
  * @param cls
  */
 public static void closeAll(Closeable... cls) {

  if (cls != null) {
   for (Closeable cl : cls) {
    try {
     if (cl != null)
      cl.close();
    } catch (Exception e) {

    } finally {
     cl = null;
    }
   }
  }
 }
}

复制代码 代码如下:

import java.io.BufferedInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;

public class MD5Util {

 protected static char hexDigits[] = { '0', '1', '2', '3', '4', '5', '6',
   '7', '8', '9', 'a', 'b', 'c', 'd', 'e', 'f' };
 protected static MessageDigest messagedigest = null;
 static {
  try {
   messagedigest = MessageDigest.getInstance("MD5");
  } catch (NoSuchAlgorithmException e) {
   e.printStackTrace();
  }
 }

 public static String getFileMD5String(File file) throws IOException {

  /***
   * MappedByteBuffer是NIO的API，使用这个API会有一个bug，
   * 当使用 FileChannel.map 方法时，MappedByteBuffer 已经在系统内占用了一个句柄，
   * 而使用 FileChannel.close 方法是无法释放这个句柄的，、
   * 且FileChannel有没有提供类似 unmap 的方法，因此会出现无法删除文件的情况。
   */
  // FileInputStream in = new FileInputStream(file);
  // FileChannel ch = in.getChannel();
  // MappedByteBuffer byteBuffer = ch.map(FileChannel.MapMode.READ_ONLY,
  // 0,
  // file.length());

  InputStream fis = null;
  BufferedInputStream bis = null;
        fis = new FileInputStream(file); 
        bis = new BufferedInputStream(fis);
        byte[] buffer = new byte[2048]; 
        int numRead = 0; 
        while ((numRead = bis.read(buffer)) > 0) { 
            messagedigest.update(buffer, 0, numRead); 
        } 
        CloseIoUtil.closeAll(bis,fis);
        return bufferToHex(messagedigest.digest()); 
 }

 public static String getMD5String(String s) {
  return getMD5String(s.getBytes());
 }

 public static String getMD5String(byte[] bytes) {
  messagedigest.update(bytes);
  return bufferToHex(messagedigest.digest());
 }

 private static String bufferToHex(byte bytes[]) {
  return bufferToHex(bytes, 0, bytes.length);
 }

 private static String bufferToHex(byte bytes[], int m, int n) {
  StringBuffer stringbuffer = new StringBuffer(2 * n);
  int k = m + n;
  for (int l = m; l < k; l++) {
   appendHexPair(bytes[l], stringbuffer);
  }
  return stringbuffer.toString();
 }

 private static void appendHexPair(byte bt, StringBuffer stringbuffer) {
  char c0 = hexDigits[(bt & 0xf0) >> 4];
  char c1 = hexDigits[bt & 0xf];
  stringbuffer.append(c0);
  stringbuffer.append(c1);
 }

 public static boolean checkPassword(String password, String md5PwdStr) {
  String s = getMD5String(password);
  return s.equals(md5PwdStr);
 }

 public static void main(String[] args) throws IOException {

  File big = new File("e:/sss.txt");
  String md5 = getFileMD5String(big);
  //
  // long end = System.currentTimeMillis();
  // System.out.println("md5:" + md5);
  // System.out.println("time:" + ((end - begin) / 1000) + "s");

  System.out.println(md5);

 }

}

复制代码 代码如下:

import java.io.BufferedInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;

public class MD5Util {

 protected static char hexDigits[] = { '0', '1', '2', '3', '4', '5', '6',
   '7', '8', '9', 'a', 'b', 'c', 'd', 'e', 'f' };
 protected static MessageDigest messagedigest = null;
 static {
  try {
   messagedigest = MessageDigest.getInstance("MD5");
  } catch (NoSuchAlgorithmException e) {
   e.printStackTrace();
  }
 }

 public static String getFileMD5String(File file) throws IOException {

  /***
   * MappedByteBuffer是NIO的API，使用这个API会有一个bug，
   * 当使用 FileChannel.map 方法时，MappedByteBuffer 已经在系统内占用了一个句柄，
   * 而使用 FileChannel.close 方法是无法释放这个句柄的，、
   * 且FileChannel有没有提供类似 unmap 的方法，因此会出现无法删除文件的情况。
   */
  // FileInputStream in = new FileInputStream(file);
  // FileChannel ch = in.getChannel();
  // MappedByteBuffer byteBuffer = ch.map(FileChannel.MapMode.READ_ONLY,
  // 0,
  // file.length());

  InputStream fis = null;
  BufferedInputStream bis = null;
        fis = new FileInputStream(file); 
        bis = new BufferedInputStream(fis);
        byte[] buffer = new byte[2048]; 
        int numRead = 0; 
        while ((numRead = bis.read(buffer)) > 0) { 
            messagedigest.update(buffer, 0, numRead); 
        } 
        CloseIoUtil.closeAll(bis,fis);
        return bufferToHex(messagedigest.digest()); 
 }

 public static String getMD5String(String s) {
  return getMD5String(s.getBytes());
 }

 public static String getMD5String(byte[] bytes) {
  messagedigest.update(bytes);
  return bufferToHex(messagedigest.digest());
 }

 private static String bufferToHex(byte bytes[]) {
  return bufferToHex(bytes, 0, bytes.length);
 }

 private static String bufferToHex(byte bytes[], int m, int n) {
  StringBuffer stringbuffer = new StringBuffer(2 * n);
  int k = m + n;
  for (int l = m; l < k; l++) {
   appendHexPair(bytes[l], stringbuffer);
  }
  return stringbuffer.toString();
 }

 private static void appendHexPair(byte bt, StringBuffer stringbuffer) {
  char c0 = hexDigits[(bt & 0xf0) >> 4];
  char c1 = hexDigits[bt & 0xf];
  stringbuffer.append(c0);
  stringbuffer.append(c1);
 }

 public static boolean checkPassword(String password, String md5PwdStr) {
  String s = getMD5String(password);
  return s.equals(md5PwdStr);
 }

 public static void main(String[] args) throws IOException {

  File big = new File("e:/sss.txt");
  String md5 = getFileMD5String(big);
  //
  // long end = System.currentTimeMillis();
  // System.out.println("md5:" + md5);
  // System.out.println("time:" + ((end - begin) / 1000) + "s");

  System.out.println(md5);

 }
}

时间： 2024-11-02 19:08:04

java使用nio2拷贝文件的示例_java的相关文章

java使用gzip实现文件解压缩示例_java

复制代码 代码如下: package com.cjonline.foundation.cpe.action; import java.io.ByteArrayInputStream;import java.io.ByteArrayOutputStream;import java.io.File;import java.io.FileInputStream;import java.io.FileOutputStream;import java.io.InputStream;import java.

java通过url读取文件内容示例_java

复制代码 代码如下: using System;  using System.Collections;  using System.ComponentModel;  using System.Data;  using System.Drawing;  using System.Web;  using System.Web.SessionState;  using System.Web.UI;  using System.Web.UI.WebControls;  using System.Web.

java中如何拷贝文件到另一个目录下只能使用

问题描述 java中如何拷贝文件到另一个目录下只能使用 在只能使用字节流ByteArrayInputStream和ByteArrayOutputStream 的情况下,如何复制指定路劲的文件夹到指定的路径下 解决方案 /** * 复制单个文件 * @param oldPath String 原文件路径 如:c:/fqf.txt * @param newPath String 复制后路径 如:f:/fqf.txt * @return boolean */ public void copyFile(

使用jdk7的nio2操作文件拷贝和剪切示例_java

复制代码 代码如下: package com.xyq.io.simply.core; import java.io.File;import java.io.IOException;import java.nio.file.FileVisitResult;import java.nio.file.FileVisitor;import java.nio.file.Files;import java.nio.file.Path;import java.nio.file.Paths;import jav

浅析Java基于Socket的文件传输案例_java

本文实例介绍了Java基于Socket的文件传输案例,分享给大家供大家参考,具体内容如下 1.Java代码 package com.wf.demo.socket.socketfile; import java.net.*; import java.io.*; /** * 2.socket的Util辅助类 * * @author willson * */ public class ClientSocket { private String ip; private int port; private

Java创建ZIP压缩文件的方法_java

本文实例讲述了Java创建ZIP压缩文件的方法.分享给大家供大家参考.具体如下: 这里注意:建议使用org.apache.tools.zip.*包下相关类,否则可能会出现中文乱码问题. /** * 压缩文件夹 * @param sourceDIR 文件夹名称(包含路径) * @param targetZipFile 生成zip文件名 * @author liuxiangwei */ public static void zipDIR(String sourceDIR, String target

Java中使用Apache POI读取word文件简单示例_java

Apache POI是Apache软件基金会的开放源码函式库,POI提供API给Java程序对Microsoft Office格式档案读和写的功能. 1.读取word 2003及word 2007需要的jar包 读取 2003 版本(.doc)的word文件相对来说比较简单,只需要 poi-3.5-beta6-20090622.jar 和 poi-scratchpad-3.5-beta6-20090622.jar 两个 jar 包即可, 而 2007 版本(.docx)就麻烦多,我说的这个麻烦不

java文件操作之java写文件简单示例_java

代码很简单,直接上代码,大家参考使用吧 复制代码 代码如下: package com.it.login.service; import java.io.BufferedReader;import java.io.File;import java.io.FileInputStream;import java.io.FileNotFoundException;import java.io.FileOutputStream;import java.io.InputStreamReader;import

java文件对话框过滤特定文件类型示例_java

思路分析: 因为是窗体应用,首先看视图层.需要一个按钮控件JButton用来选择文件夹:需要一个标签控件JLabel用来显示选择的路径:需要一个标签控件JLabel提示用户输入什么:需要一个文本框控件JTextField供用户输入文件类型:需要一个表格控件JTable显示选中目录下指定类型的文件.对于按钮控件,为其绑定事件处理方法,在该方法中首先创建JFileChooser文件选择器对象,为该对象设置选择器的过滤器,即通过JFileChoose类的setFileSelectionMode()方法