当前位置: 开源爱好者 » 编程教程 » Java教程 » 正文

Java FTP相关操作实例

Java FTP相关操作实例,汇集了一些FTP操作函数,比如 连接到FTP服务器,上传文件到FTP服务器,支持断点续传,检查远程是否存在文件,断开与远程服务器的连接,递归创建远程服务器目录,上传文件到服务器,新上传和断点续传,断点续传成功后删除文件等。

import java.io.File;
import java.io.IOException;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.io.RandomAccessFile;
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 org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import cn.healthin.uc.action.ReportAction;
public class ContinueFTP {
	 public FTPClient ftpClient = new FTPClient();
	 private static final Logger logger = LoggerFactory.getLogger(ReportAction.class);
	 private HttpServletResponse response;
	    public ContinueFTP(){
	        //设置将过程中使用到的命令输出到控制台
	        this.ftpClient.addProtocolCommandListener(new PrintCommandListener(new PrintWriter(System.out)));
	    }
	    public ContinueFTP(HttpServletResponse response){
	    	this.response=response;
	    }
	    /** *//**
	     * 连接到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);
	        ftpClient.setControlEncoding("utf-8");
	        if(FTPReply.isPositiveCompletion(ftpClient.getReplyCode())){
	            if(ftpClient.login(username, password)){
	                return true;
	            }
	        }
	        disconnect();
	        return false;
	    }
	    /** *//**
	     * 上传文件到FTP服务器,支持断点续传
	     * @param local 本地文件名称,绝对路径
	     * @param remote 远程文件路径,使用/home/directory1/subdirectory/file.ext或是 http://www.guihua.org /subdirectory/file.ext 按照Linux上的路径指定方式,支持多级目录嵌套,支持递归创建不存在的目录结构
	     * @return 上传结果
	     * @throws IOException
	     */
	    public UploadStatus upload(String local,String remote) throws IOException{
	        //设置PassiveMode传输
	        ftpClient.enterLocalPassiveMode();
	        //设置以二进制流的方式传输
	        ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
	        ftpClient.setControlEncoding("GBK");
	        UploadStatus result;
	        //对远程目录的处理
	        String remoteFileName = remote;
	        if(remote.contains("/")){
	            remoteFileName = remote.substring(remote.lastIndexOf("/")+1);
	            //创建服务器远程目录结构,创建失败直接返回
	            if(CreateDirecroty(remote, ftpClient)==UploadStatus.Create_Directory_Fail){
	                return UploadStatus.Create_Directory_Fail;
	            }
	        }
	        //检查远程是否存在文件
	        FTPFile[] files = ftpClient.listFiles(new String(remoteFileName.getBytes("GBK"),"iso-8859-1"));
	        if(files.length == 1){
	            long remoteSize = files[0].getSize();
	            File f = new File(local);
	            long localSize = f.length();
	            if(remoteSize==localSize){
	            	if(null!=response)
	            	{
	            		logger.debug("上传完成!");
	            		//文件删除操作
	            	}
	                return UploadStatus.File_Exits;
	            }else if(remoteSize > localSize){
	                return UploadStatus.Remote_Bigger_Local;
	            }
	            //尝试移动文件内读取指针,实现断点续传
	            result = uploadFile(remoteFileName, f, ftpClient, remoteSize);
	            //如果断点续传没有成功,则删除服务器上文件,重新上传
	            if(result == UploadStatus.Upload_From_Break_Failed){
	                if(!ftpClient.deleteFile(remoteFileName)){
	                    return UploadStatus.Delete_Remote_Faild;
	                }
	                result = uploadFile(remoteFileName, f, ftpClient, 0);
	            }
	        }else {
	            result = uploadFile(remoteFileName, new File(local), ftpClient, 0);
	        }
	        return result;
	    }
	    /** *//**
	     * 断开与远程服务器的连接
	     * @throws IOException
	     */
	    public void disconnect() throws IOException{
	        if(ftpClient.isConnected()){
	            ftpClient.disconnect();
	        }
	    }
	    /** *//**
	     * 递归创建远程服务器目录
	     * @param remote 远程服务器文件绝对路径
	     * @param ftpClient FTPClient对象
	     * @return 目录创建是否成功
	     * @throws IOException
	     */
	    public UploadStatus CreateDirecroty(String remote,FTPClient ftpClient) throws IOException{
	        UploadStatus status = UploadStatus.Create_Directory_Success;
	        String directory = remote.substring(0,remote.lastIndexOf("/")+1);
	        if(!directory.equalsIgnoreCase("/")&&!ftpClient.changeWorkingDirectory(new String(directory.getBytes("GBK"),"iso-8859-1"))){
	            //如果远程目录不存在,则递归创建远程服务器目录
	            int start=0;
	            int end = 0;
	            if(directory.startsWith("/")){
	                start = 1;
	            }else{
	                start = 0;
	            }
	            end = directory.indexOf("/",start);
	            while(true){
	                String subDirectory = new String(remote.substring(start,end).getBytes("GBK"),"iso-8859-1");
	                if(!ftpClient.changeWorkingDirectory(subDirectory)){
	                    if(ftpClient.makeDirectory(subDirectory)){
	                        ftpClient.changeWorkingDirectory(subDirectory);
	                    }else {
	                        System.out.println("创建目录失败");
	                        return UploadStatus.Create_Directory_Fail;
	                    }
	                }
	                start = end + 1;
	                end = directory.indexOf("/",start);
	                //检查所有目录是否创建完毕
	                if(end <= start){
	                    break;
	                }
	            }
	        }
	        return status;
	    }
	    /** *//**
	     * 上传文件到服务器,新上传和断点续传
	     * @param remoteFile 远程文件名,在上传之前已经将服务器工作目录做了改变
	     * @param localFile 本地文件File句柄,绝对路径
	     * @param progressStep 需要显示的处理进度步进值
	     * @param ftpClient FTPClient引用
	     * @return
	     * @throws IOException
	     */
	    public UploadStatus uploadFile(String remoteFile,File localFile,FTPClient ftpClient,long remoteSize) throws IOException{
	        UploadStatus status;
	        //显示进度的上传
	        long step = localFile.length();
	        long localreadbytes = 0L;
	        RandomAccessFile raf = new RandomAccessFile(localFile,"r");
	        OutputStream out = ftpClient.appendFileStream(new String(remoteFile.getBytes("GBK"),"iso-8859-1"));
	        //断点续传
	        if(remoteSize>0){
	            ftpClient.setRestartOffset(remoteSize);
	            raf.seek(remoteSize);
	            localreadbytes = remoteSize;
	        }
	        byte[] bytes = new byte[1024];
	        int c;
	        while((c = raf.read(bytes))!= -1){
	            out.write(bytes,0,c);
	            localreadbytes+=c;
	            if(localreadbytes==step){
	            	break;
	            }
	        }
	        out.flush();
	        raf.close();
	        out.close();
	        if(null!=response)
        	{
        		responseContent();
        	}
	        boolean result =ftpClient.completePendingCommand();
	        if(remoteSize > 0){
	            status = result?UploadStatus.Upload_From_Break_Success:UploadStatus.Upload_From_Break_Failed;
	        }else {
	            status = result?UploadStatus.Upload_New_File_Success:UploadStatus.Upload_New_File_Failed;
	        }
	        return status;
	    }
	   public void responseContent()
	   {
			   logger.debug("已经完成");
			   //断点续传成功后删除文件
	   }
}
相关内容:

CopyRight 2018© 开源爱好者 All Rights Reserved 豫ICP备16030607号 隐私声明 网站地图