这里有新鲜出炉的 Java 并发编程示例, 程序狗速度看过来!
Java 程序设计语言
java 是一种可以撰写跨平台应用软件的面向对象的程序设计语言, 是由 Sun Microsystems 公司于 1995 年 5 月推出的 Java 程序设计语言和 Java 平台 (即 JavaEE(j2ee), JavaME(j2me), JavaSE(j2se)) 的总称
本篇文章主要介绍了 Apache FTP 实现文件上传下载修改文件名删除, 实现了 FTP 文件上传(断点续传)FTP 文件下载 FTP 文件重命名 FTP 文件删除等功能, 有需要的可以了解一下
Apache FTP 是应用比较广泛的 FTP 上传客户端工具, 它易于操作, 代码简略, 结构清晰, 是做 FTP 文件客户端管理软件的优先之选 FTP 的操作包括: FTP 文件上传(断点续传)FTP 文件下载 FTP 文件重命名 FTP 文件删除, 这些操作已经将 FTP 应用管理的方式发挥的淋漓尽致了, So 我一直都用此种方式来实现 FTP 文件服务器的管理工作; 下附 FTP 工具代码
1FTP 文件操作状态枚举类
- package com.scengine.wtms.utils.ftp;
- public enum FTPStatus
- {
- File_Exits(0), Create_Directory_Success(1), Create_Directory_Fail(2), Upload_From_Break_Success(3), Upload_From_Break_Faild(4), Download_From_Break_Success(5), Download_From_Break_Faild(6), Upload_New_File_Success(7), Upload_New_File_Failed(8), Delete_Remote_Success(9), Delete_Remote_Faild(10),Remote_Bigger_Local(11),Remote_smaller_local(12),Not_Exist_File(13),Remote_Rename_Success(14),Remote_Rename_Faild(15),File_Not_Unique(16);
- private int status;
- public int getStatus()
- {
- return status;
- }
- public void setStatus(int status)
- {
- this.status = status;
- }
- FTPStatus(int status)
- {
- this.status = status;
- }
- }
2FTP 文件操作工具代码
- package com.scengine.wtms.utils.ftp;
- import java.io.File;
- import java.io.FileInputStream;
- import java.io.FileOutputStream;
- import java.io.IOException;
- import java.io.InputStream;
- import java.io.OutputStream;
- import java.io.PrintWriter;
- import javax.servlet.http.HttpServletResponse;
- import org.apache.commons.net.PrintCommandListener;
- import org.apache.commons.net.ftp.FTP;
- import org.apache.commons.net.ftp.FTPClient;
- import org.apache.commons.net.ftp.FTPFile;
- import org.apache.commons.net.ftp.FTPReply;
- import com.scengine.wtms.utils.Log;
- public class FTPUtils
- {
- private FTPClient ftpClient = new FTPClient();
- /**
- * 对象构造 设置将过程中使用到的命令输出到控制台
- */
- public FTPUtils()
- {
- this.ftpClient.addProtocolCommandListener(new PrintCommandListener(new PrintWriter(System.out)));
- }
- /**
- *
- * java 编程中用于连接到 FTP 服务器
- *
- * @param hostname
- * 主机名
- *
- * @param port
- * 端口
- *
- * @param username
- * 用户名
- *
- * @param password
- * 密码
- *
- * @return 是否连接成功
- *
- * @throws IOException
- */
- public boolean connect(String hostname, int port, String username, String password) throws IOException
- {
- ftpClient.connect(hostname, port);
- if (FTPReply.isPositiveCompletion(ftpClient.getReplyCode()))
- {
- if (ftpClient.login(username, password))
- {
- return true;
- }
- }
- disconnect();
- return false;
- }
- /**
- * 删除远程 FTP 文件
- *
- * @param remote
- * 远程文件路径
- * @return
- * @throws IOException
- */
- public FTPStatus delete(String remote) throws IOException
- {
- ftpClient.enterLocalPassiveMode();
- ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
- FTPStatus result = null;
- FTPFile[] files = ftpClient.listFiles(remote);
- if (files.length == 1)
- {
- boolean status = ftpClient.deleteFile(remote);
- result = status ? FTPStatus.Delete_Remote_Success : FTPStatus.Delete_Remote_Faild;
- }
- else
- {
- result = FTPStatus.Not_Exist_File;
- }
- Log.getLogger(this.getClass()).info("FTP 服务器文件删除标识:"+result);
- return result;
- }
- /**
- * 重命名远程 FTP 文件
- *
- * @param name
- * 新远程文件名称(路径 - 必须保证在同一路径下)
- *
- * @param remote
- * 远程文件路径
- *
- * @return 是否成功
- *
- * @throws IOException
- */
- public FTPStatus rename(String name,String remote) throws IOException
- {
- ftpClient.enterLocalPassiveMode();
- ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
- FTPStatus result = null;
- FTPFile[] files = ftpClient.listFiles(remote);
- if (files.length == 1)
- {
- boolean status = ftpClient.rename(remote, name);
- result = status ? FTPStatus.Remote_Rename_Success : FTPStatus.Remote_Rename_Faild;
- }
- else
- {
- result = FTPStatus.Not_Exist_File;
- }
- Log.getLogger(this.getClass()).info("FTP 服务器文件名更新标识:"+result);
- return result;
- }
- /**
- *
- * 从 FTP 服务器上下载文件
- *
- * @param fileName
- * 下载文件的名字(包括后缀名)
- *
- * @param remote
- * 远程文件路径
- *
- * @param local
- * 本地文件路径
- *
- * @return 是否成功
- *
- * @throws IOException
- */
- public FTPStatus download(String fileName,String remote,HttpServletResponse response) throws IOException
- {
- // 开启输出流弹出文件保存路径选择窗口
- response.setContentType("application/octet-stream");
- response.setContentType("application/OCTET-STREAM;charset=UTF-8");
- response.setHeader("Content-Disposition", "attachment;filename=" +fileName);
- ftpClient.enterLocalPassiveMode();
- ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
- FTPStatus result;
- OutputStream out = response.getOutputStream();
- boolean status = ftpClient.retrieveFile(remote, out);
- result=status?FTPStatus.Download_From_Break_Success:FTPStatus.Download_From_Break_Faild;
- Log.getLogger(this.getClass()).info("FTP 服务器文件下载标识:"+result);
- out.close();
- return result;
- }
- /**
- *
- * 从 FTP 服务器上下载文件
- *
- * @param remote
- * 远程文件路径
- *
- * @param local
- * 本地文件路径
- *
- * @return 是否成功
- *
- * @throws IOException
- */
- @SuppressWarnings("resource")
- public FTPStatus download(String remote, String local) throws IOException
- {
- ftpClient.enterLocalPassiveMode();
- ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
- FTPStatus result;
- File f = new File(local);
- FTPFile[] files = ftpClient.listFiles(remote);
- if (files.length != 1)
- {
- Log.getLogger(this.getClass()).info("远程文件不唯一");
- return FTPStatus.File_Not_Unique;
- }
- long lRemoteSize = files[0].getSize();
- if (f.exists())
- {
- OutputStream out = new FileOutputStream(f, true);
- Log.getLogger(this.getClass()).info("本地文件大小为:" + f.length());
- if (f.length() >= lRemoteSize)
- {
- Log.getLogger(this.getClass()).info("本地文件大小大于远程文件大小, 下载中止");
- return FTPStatus.Remote_smaller_local;
- }
- ftpClient.setRestartOffset(f.length());
- boolean status = ftpClient.retrieveFile(remote, out);
- result=status?FTPStatus.Download_From_Break_Success:FTPStatus.Download_From_Break_Faild;
- out.close();
- } else
- {
- OutputStream out = new FileOutputStream(f);
- boolean status = ftpClient.retrieveFile(remote, out);
- result=status?FTPStatus.Download_From_Break_Success:FTPStatus.Download_From_Break_Faild;
- out.close();
- }
- return result;
- }
- /**
- *
- * 上传文件到 FTP 服务器, 支持断点续传
- *
- * @param local
- * 本地文件名称, 绝对路径
- *
- * @param remote
- * 远程文件路径, 使用 / home/directory1/subdirectory/file.ext
- * 按照 Linux 上的路径指定方式, 支持多级目录嵌套, 支持递归创建不存在的目录结构
- *
- * @return 上传结果
- *
- * @throws IOException
- */
- @SuppressWarnings("resource")
- public FTPStatus upload(String local, String remote) throws IOException
- {
- // 设置 PassiveMode 传输
- ftpClient.enterLocalPassiveMode();
- // 设置以二进制流的方式传输
- ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
- FTPStatus result;
- // 对远程目录的处理
- String remoteFileName = remote;
- if (remote.contains("/"))
- {
- remoteFileName = remote.substring(remote.lastIndexOf("/") + 1);
- String directory = remote.substring(0, remote.lastIndexOf("/") + 1);
- if (!directory.equalsIgnoreCase("/") && !ftpClient.changeWorkingDirectory(directory))
- {
- // 如果远程目录不存在, 则递归创建远程服务器目录
- int start = 0;
- int end = 0;
- if (directory.startsWith("/"))
- {
- start = 1;
- } else
- {
- start = 0;
- }
- end = directory.indexOf("/", start);
- while (true)
- {
- String subDirectory = remote.substring(start, end);
- if (!ftpClient.changeWorkingDirectory(subDirectory))
- {
- if (ftpClient.makeDirectory(subDirectory))
- {
- ftpClient.changeWorkingDirectory(subDirectory);
- } else
- {
- Log.getLogger(this.getClass()).info("创建目录失败");
- return FTPStatus.Create_Directory_Fail;
- }
- }
- start = end + 1;
- end = directory.indexOf("/", start);
- // 检查所有目录是否创建完毕
- if (end <= start)
- {
- break;
- }
- }
- }
- }
- // 检查远程是否存在文件
- FTPFile[] files = ftpClient.listFiles(remoteFileName);
- if (files.length == 1)
- {
- long remoteSize = files[0].getSize();
- File f = new File(local);
- long localSize = f.length();
- if (remoteSize == localSize)
- {
- return FTPStatus.File_Exits;
- } else if (remoteSize > localSize)
- {
- return FTPStatus.Remote_Bigger_Local;
- }
- // 尝试移动文件内读取指针, 实现断点续传
- InputStream is = new FileInputStream(f);
- if (is.skip(remoteSize) == remoteSize)
- {
- ftpClient.setRestartOffset(remoteSize);
- if (ftpClient.storeFile(remote, is))
- {
- return FTPStatus.Upload_From_Break_Success;
- }
- }
- // 如果断点续传没有成功, 则删除服务器上文件, 重新上传
- if (!ftpClient.deleteFile(remoteFileName))
- {
- return FTPStatus.Delete_Remote_Faild;
- }
- is = new FileInputStream(f);
- if (ftpClient.storeFile(remote, is))
- {
- result = FTPStatus.Upload_New_File_Success;
- } else
- {
- result = FTPStatus.Upload_New_File_Failed;
- }
- is.close();
- } else
- {
- InputStream is = new FileInputStream(local);
- if (ftpClient.storeFile(remoteFileName, is))
- {
- result = FTPStatus.Upload_New_File_Success;
- } else
- {
- result = FTPStatus.Upload_New_File_Failed;
- }
- is.close();
- }
- return result;
- }
- /**
- *
- * 断开与远程服务器的连接
- *
- * @throws IOException
- */
- public void disconnect() throws IOException
- {
- if (ftpClient.isConnected())
- {
- ftpClient.disconnect();
- }
- }
- public static void main(String[] args)
- {
- FTPUtils myFtp = new FTPUtils();
- try
- {
- myFtp.connect("192.168.1.200", 21, "duser", "HTPDuserXP32");
- Log.getLogger(FTPUtils.class).info(myFtp.upload("C:\\Users\\Administrator\\Desktop\\swing.drawer.jar", "/jars/swing.drawer.jar"));
- myFtp.disconnect();
- } catch (IOException e)
- {
- Log.getLogger(FTPUtils.class).info("FTP 上传文件异常:" + e.getMessage());
- }
- }
- }
来源: http://www.phperz.com/article/18/0212/359544.html