Java语言实现简单FTP软件 FTP上传下载管理模块实现(11)

本文为大家分享了FTP上传下载管理模块的实现方法，供大家参考，具体内容如下

1、上传本地文件或文件夹到远程FTP服务器端的功能。

当用户在本地文件列表中选择想要上传的文件后，点击上传按钮，将本机上指定的文件上传到FTP服务器当前展现的目录，下图为上传子模块流程图

选择好要上传的文件或文件夹，点击“上传”按钮，会触发com.oyp.ftp.panel.local.UploadAction类的actionPerformed(ActionEvent e)方法，其主要代码如下

 
public void actionPerformed(java.awt.event.ActionEvent evt) { 
 // 获取用户选择的多个文件或文件夹 
 int[] selRows = this.localPanel.localDiskTable.getSelectedRows(); 
 if (selRows.length < 1) { 
  JOptionPane.showMessageDialog(this.localPanel, "请选择上传的文件或文件夹"); 
  return; 
 } 
 // 获取FTP服务器的当前路径 
 String pwd = this.localPanel.frame.getFtpPanel().getPwd(); 
 // 创建FTP当前路径的文件夹对象 
 FtpFile ftpFile = new FtpFile("", pwd, true); 
 // 遍历本地资源的表格 
 for (int i = 0; i < selRows.length; i++) { 
  Object valueAt = this.localPanel.localDiskTable.getValueAt( 
    selRows[i], 0); // 获取表格选择行的第一列数据 
  if (valueAt instanceof DiskFile) { 
   final DiskFile file = (DiskFile) valueAt; 
   // 获取本地面板类中的队列，该队列是linkedList类的实例对象 
   Queue queue = this.localPanel.queue; 
   queue.offer(new Object[] { file, ftpFile });// 执行offer方法向队列尾添加对象 
  } 
 } 
} 

在com.oyp.ftp.panel.local.UploadThread线程类的run()方法，会判断上传队列是否有对象，如果有则调用其copyFile(File file, FtpFile ftpFile)方法实现上传文件的功能，上传完后刷新远程FTP文件管理的面板。其run()方法主要代码如下

 * 线程的主体方法 
 */ 
public void run() { // 线程的主体方法 
 while (conRun) { 
  try { 
   Thread.sleep(1000); // 线程休眠1秒 
   Queue queue = localPanel.queue; // 获取本地面板的队列对象 
   queuevalues = queue.peek(); // 获取队列首的对象 
   if (queuevalues == null) { // 如果该对象为空 
    continue; // 进行下一次循环 
   } 
   File file = (File) queuevalues[0]; // 获取队列中的本队文件对象 
   FtpFile ftpFile = (FtpFile) queuevalues[1]; // 获取队列中的FTP文件对象 
   if (file != null) { 
    selPath = file.getParent(); 
    copyFile(file, ftpFile); // 调用递归方法上传文件 
    FtpPanel ftpPanel = localPanel.frame.getFtpPanel(); 
    ftpPanel.refreshCurrentFolder(); // 刷新FTP面板中的资源 
   } 
   Object[] args = queue.peek(); 
   // 判断队列顶是否为处理的上一个任务。 
   if (queuevalues == null || args == null 
     || !queuevalues[0].equals(args[0])) { 
    continue; 
   } 
   queue.remove(); // 移除队列首元素 
  } catch (Exception e) { 
   e.printStackTrace(); 
  } 
 } 
} 

其中调用的copyFile(File file, FtpFile ftpFile)方法代码如下

   
 private void copyFile(File file, FtpFile ftpFile) { // 递归遍历文件夹的方法 
  // 判断队列面板是否执行暂停命令 
  while (localPanel.frame.getQueuePanel().isStop()) { 
   try { 
    Thread.sleep(1000); 
   } catch (InterruptedException e) { 
    e.printStackTrace(); 
   } 
  } 
 
  Object[] args = localPanel.queue.peek(); 
  // 判断队列顶是不是上一个处理的任务。 
  if (queuevalues == null || args == null 
    || !queuevalues[0].equals(args[0])) 
   return; 
  try { 
//   System.out.println("selPath："+selPath); 
   path = file.getParentFile().getPath().replace(selPath, ""); 
//   System.out.println("path："+path); 
   ftpFile.setName(path.replace("\", "/")); 
   path = ftpFile.getAbsolutePath(); 
//   System.out.println("ftpFile.getAbsolutePath()："+path); 
   if (file.isFile()) { 
    UploadPanel uploadPanel = localPanel.frame.getUploadPanel();//上传面板 
    String remoteFile = path + "/" + file.getName(); // 远程FTP的文件名绝对路径 
//    System.out.println("remoteFile:" + remoteFile); 
    double fileLength = file.length() / Math.pow(1024, 2); 
    ProgressArg progressArg = new ProgressArg( 
      (int) (file.length() / 1024), 0, 0);//进度参数 
    String size = String.format("%.4f MB", fileLength); 
    Object[] row = new Object[] { file.getAbsoluteFile(), size, 
      remoteFile, ftpClient.getServer(), progressArg }; 
    uploadPanel.addRow(row); //添加列 
    OutputStream put = ftpClient.put(remoteFile); // 获取服务器文件的输出流 
    FileInputStream fis = null; // 本地文件的输入流 
    try { 
     fis = new FileInputStream(file); // 初始化文件的输入流 
    } catch (Exception e) { 
     e.printStackTrace(); 
     return; 
    } 
    int readNum = 0; 
    byte[] data = new byte[1024]; // 缓存大小 
    while ((readNum = fis.read(data)) > 0) { // 读取本地文件到缓存 
     Thread.sleep(0, 30); // 线程休眠 
     put.write(data, 0, readNum); // 输出到服务器 
     progressArg.setValue(progressArg.getValue() + 1);// 累加进度条 
    } 
    progressArg.setValue(progressArg.getMax()); // 结束进度条 
    fis.close(); // 关闭文件输入流 
    put.close(); // 关闭服务器输出流 
   } else if (file.isDirectory()) { 
    path = file.getPath().replace(selPath, ""); 
    ftpFile.setName(path.replace("\", "/")); 
//    System.out.println("Dirpath："+path); 
     
    ftpClient.cd(this.localPanel.frame.getFtpPanel().getPwd());  // /media目录 
     
    ftpClient.sendServer("MKD " + path + "rn"); //创建 /media/audio 目录 
    ftpClient.readServerResponse(); 
     
     
    //创建一个文件夹对象，检查该文件是否存在 
    File fileRemote=new File(this.localPanel.frame.getFtpPanel().getPwd()+path); //path：audio 
    //该目录不存在 
    if (!fileRemote.exists()) { 
     path=this.localPanel.frame.getFtpPanel().getPwd(); 
    } 
     
     
    File[] listFiles = file.listFiles(); 
    for (File subFile : listFiles) { 
     Thread.sleep(0, 50); 
     copyFile(subFile, ftpFile); 
    } 
   } 
  } catch (FileNotFoundException e1) { 
   e1.printStackTrace(); 
   System.exit(0); 
   // JOptionPane.showMessageDialog(localPanel, e1.getMessage()); 
  } catch (Exception ex) { 
   ex.printStackTrace(); 
  } 
 } 

2、下载远程FTP服务器端的文件或文件夹到本地

当用户在远程FTP服务器文件列表中选择想要下载的文件后，点击下载按钮，将服务器上的文件下载至本机，下图为下载子模块流程图。

选择好要下载的文件或文件夹，点击“下载”按钮，会触发com.oyp.ftp.panel.ftp.DownAction类的actionPerformed(ActionEvent e)方法，其主要代码如下

   
@Override 
public void actionPerformed(ActionEvent e) { 
 // 获取FTP资源表格的所有选择行 
 final int[] selRows = ftpPanel.ftpDiskTable.getSelectedRows(); 
 if (selRows.length < 1) 
  return; 
 // 遍历表格的所有选择行 
 for (int i = 0; i < selRows.length; i++) { 
  // 获取每行的第一个单元值并转换成FtpFile类的对象 
  final FtpFile file = (FtpFile) ftpPanel.ftpDiskTable.getValueAt( 
    selRows[i], 0); 
  if (file != null) { 
   // 获取本地资源管理面板的当前文件夹 
   File currentFolder = ftpPanel.frame.getLocalPanel() 
     .getCurrentFolder(); 
   // 把FTP文件对象和本地当前文件夹对象定义成数组添加到下载队列中 
   ftpPanel.queue.offer(new Object[] { file, currentFolder }); 
  } 
 } 
} 

在com.oyp.ftp.panel.ftp.DownThread线程类的run()方法，会判断下载队列是否有对象，如果有则调用其downFile(FtpFile file, File localFolder)方法实现上传文件的功能，上传完后刷新远程FTP文件管理的面板。其run()方法代码如下

public void run() { // 线程业务方法 
  while (conRun) { 
   try { 
    Thread.sleep(1000); 
    ftpClient.noop(); 
    queuevalues = ftpPanel.queue.peek(); 
    if (queuevalues == null) { 
     continue; 
    } 
    FtpFile file = (FtpFile) queuevalues[0]; 
    File localFolder = (File) queuevalues[1]; 
    if (file != null) { 
     path = file.getPath(); 
     ftpClient.cd(path); 
     downFile(file, localFolder); 
     path = null; 
     ftpPanel.frame.getLocalPanel().refreshCurrentFolder(); 
    } 
    Object[] args = ftpPanel.queue.peek(); 
    // 判断队列顶是否为处理的上一个任务。 
    if (queuevalues == null || args == null 
      || !queuevalues[0].equals(args[0])) 
     continue; 
    ftpPanel.queue.poll(); 
   } catch (Exception e) { 
    e.printStackTrace(); 
   } 
  } 
 } 

其中调用的downFile(FtpFile file, File localFolder)方法代码如下

 
 private void downFile(FtpFile file, File localFolder) { 
  // 判断队列面板是否执行暂停命令 
  while (ftpPanel.frame.getQueuePanel().isStop()) { 
   try { 
    Thread.sleep(1000); 
   } catch (InterruptedException e) { 
    e.printStackTrace(); 
   } 
  } 
  Object[] args = ftpPanel.queue.peek(); 
  // 判断队列顶是否为处理的上一个任务。 
  if (queuevalues == null || args == null 
    || !queuevalues[0].equals(args[0])) 
   return; 
  try { 
   String ftpFileStr = file.getAbsolutePath().replaceFirst(path + "/", 
     ""); 
   if (file.isFile()) { 
    // 获取服务器指定文件的输入流 
    TelnetInputStream ftpIs = ftpClient.get(file.getName()); 
    if (ftpIs == null) { 
     JOptionPane.showMessageDialog(this.ftpPanel, file.getName() 
+ "无法下载"); 
     return; 
    } 
    // 创建本地文件对象 
    File downFile = new File(localFolder, ftpFileStr); 
    // 创建本地文件的输出流 
    FileOutputStream fout = new FileOutputStream(downFile, true); 
    // 计算文件大小 
    double fileLength = file.getLongSize() / Math.pow(1024, 2); 
    ProgressArg progressArg = new ProgressArg((int) (file 
      .getLongSize() / 1024), 0, 0); //进度参数 
    String size = String.format("%.4f MB", fileLength); 
    //"文件名", "大小", "本地文件名","主机", "状态" 
    Object[] row = new Object[] { ftpFileStr, size, 
      downFile.getAbsolutePath(), ftpClient.getServer(), 
      progressArg }; 
    DownloadPanel downloadPanel = ftpPanel.frame.getDownloadPanel(); //下载队列面板 
    downloadPanel.addRow(row); //添加列 
    byte[] data = new byte[1024]; // 定义缓存 
    int read = -1; 
    while ((read = ftpIs.read(data)) > 0) { // 读取FTP文件内容到缓存 
     Thread.sleep(0, 30); // 线程休眠 
     fout.write(data, 0, read); // 将缓存数据写入本地文件 
     // 累加进度条 
     progressArg.setValue(progressArg.getValue() + 1); 
    } 
    progressArg.setValue(progressArg.getMax());// 结束进度条 
    fout.close(); // 关闭文件输出流 
    ftpIs.close(); // 关闭FTP文件输入流 
   } else if (file.isDirectory()) { // 如果下载的是文件夹 
    // 创建本地文件夹对象 
    File directory = new File(localFolder, ftpFileStr); 
    directory.mkdirs(); // 创建本地的文件夹 
    ftpClient.cd(file.getName()); // 改变FTP服务器的当前路径 
    // 获取FTP服务器的文件列表信息 
    TelnetInputStream telnetInputStream=ftpClient.list(); 
    byte[]names=new byte[2048]; 
    int bufsize=0; 
    bufsize=telnetInputStream.read(names, 0, names.length); 
    int i=0,j=0; 
    while(i

功能效果图可以查看以下两篇文章。
Java语言实现简单FTP软件------>FTP软件效果图预览之上传功能（三）
Java语言实现简单FTP软件------>FTP软件效果图预览之下载功能（二）
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持考高分网。