文档章节

java ftp 上传 下载 byte[] 多线程

秦学强
 秦学强
发布于 2017/07/09 22:03
字数 1380
阅读 31
收藏 0
<dependency>
            <groupId>commons-net</groupId>
            <artifactId>commons-net</artifactId>
            <version>3.4</version>
        </dependency>
package common.utils;
import java.io.*;
import java.sql.Timestamp;
import java.text.DateFormat;
import java.text.ParseException;
import java.util.Properties;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;


import common.PropertiesFileUtil;
import dto.Ftp;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPReply;
import org.apache.log4j.Logger;

/**
 * ftp文件服务
 */

public class FtpUtil {

    private  Logger logger=Logger.getLogger(FtpUtil.class);


    private static  FTPClient ftp;


    private ThreadLocal<FTPClient> ftpClientThreadLocal = new ThreadLocal<FTPClient>(); //线程局部变量

    private static class FTPUtilInstance {
        private static FtpUtil ftpUtil = new FtpUtil();
    }

    public static FtpUtil getInstance() {
        return FTPUtilInstance.ftpUtil;
    }

  /*  private FtpUtil(){
        try{
            if(!connectFtp(getFtp())){
                throw new RuntimeException("FTP客户端链接出错!");
            }
        }catch (Exception e){
            e.printStackTrace();
            throw new RuntimeException("FTP客户端链接出错!", e);
        }

    }*/

    /**
     * 获取ftp连接
     * @param f
     * @return
     * @throws Exception
     */
    public  boolean connectFtp(Ftp f) throws Exception{
        ftp=new FTPClient();
        boolean flag=false;
        int reply;
        if (f.getPort()==null) {
            ftp.connect(f.getIpAddr(),21);
        }else{
            ftp.connect(f.getIpAddr(),f.getPort());
        }
        ftp.login(f.getUserName(), f.getPwd());
        ftp.setFileType(FTPClient.BINARY_FILE_TYPE);
        reply = ftp.getReplyCode();
        if (!FTPReply.isPositiveCompletion(reply)) {
            ftp.disconnect();
            return flag;
        }
      /*  ftp.setDataTimeout(60000);       //设置传输超时时间为60秒
        ftp.setConnectTimeout(60000);*/
        ftp.changeWorkingDirectory("/");
        flag = true;
        return flag;
    }



    /**
     * 关闭ftp连接
     */
    public  void closeFtp(){
        if (ftp!=null && ftp.isConnected()) {
            try {
                ftp.logout();
                ftp.disconnect();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    /**
     * 获取ftp连接(多线程)
     * @return
     * @throws Exception
     */
    public  FTPClient getFTPClient() throws Exception{
        if (ftpClientThreadLocal.get() != null && ftpClientThreadLocal.get().isConnected()) {
            return ftpClientThreadLocal.get();
        }
        Ftp f = getFtp();
        FTPClient ftpClient=new FTPClient();
        boolean flag=false;
        int reply;
        if (f.getPort()==null) {
            ftpClient.connect(f.getIpAddr(),21);
        }else{
            ftpClient.connect(f.getIpAddr(),f.getPort());
        }
        ftpClient.login(f.getUserName(), f.getPwd());
        ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);
        reply = ftpClient.getReplyCode();
        if (!FTPReply.isPositiveCompletion(reply)) {
            ftpClient.disconnect();
            return ftpClient;
        }
        ftpClient.changeWorkingDirectory("/");
        ftpClientThreadLocal.set(ftpClient);
        return ftpClient;
    }

    /**
     * 断开ftp连接(多线程)
     *
     * @throws Exception
     */
    public void disconnect() throws Exception {
        try {
            FTPClient ftpClient = getFTPClient();
            ftpClient.logout();
            if (ftpClient.isConnected()) {
                ftpClient.disconnect();
                ftpClient = null;
                }
        } catch (IOException e) {
            throw new Exception("Could not disconnect from server.", e);
        }
    }



    /**
     * 获取ftp链接常量
     * @return
     */
    public  Ftp getFtp(){
        Ftp f=new Ftp();
        Properties properties = PropertiesFileUtil.getProperties("properties/ftp.properties");
        f.setIpAddr(properties.getProperty("ftp.ipAddr"));
        f.setUserName(properties.getProperty("ftp.userName"));
        f.setPwd(properties.getProperty("ftp.pwd"));
        f.setPort(Integer.parseInt(properties.getProperty("ftp.port")));
        f.setSysFile(properties.getProperty("ftp.sysFile"));
        f.setHeadImgFile(properties.getProperty("ftp.headimage"));
        f.setIdApprRead(properties.getProperty("ftp.ipAddrRead"));
        f.setUserNameRead(properties.getProperty("ftp.userNameRead"));
        f.setPwdRead(properties.getProperty("ftp.pwdRead"));
        return f;
    }

    /**
     * InputStream-->byte[]
     * @throws IOException
     */
    public  byte[] readInputStream(InputStream inputStream) throws Exception{
        byte[] buffer = new byte[1024];
        int len = -1;
        ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
        while((len = inputStream.read(buffer)) != -1){
            outputStream.write(buffer, 0, len);
        }
        outputStream.close();
        inputStream.close();
        return outputStream.toByteArray();
    }

    /*
     * 下载获得文件的二进制流信息
     * @param key
     * @return
     * @throws java.io.IOException
     */
    public  byte[] download(String key) throws Exception {
        return download(key, null);
    }
 /*   public  byte[] download(String key,String type) {
        byte[] objFile=null;
        Ftp f =  getFtp();
        String cacheFile = "/cache_"+key;
        if(null == type){
            //设置目录
            key=f.getSysFile()+key;
        }else{
            //设置目录
            key=f.getHeadImgFile()+key;
        }
        try {
            if (!(ftp!=null && ftp.isConnected())) {
                connectFtp(f);
            }
            if (ftp!=null && ftp.isConnected()) {
                try {
                    ftp.changeWorkingDirectory("/");
                    File localFile = new File(cacheFile);
                    if(localFile.exists()){
                        localFile.createNewFile();//创建文件
                    }
                    OutputStream outputStream = new FileOutputStream(localFile);
                    ftp.enterLocalPassiveMode();
                    ftp.setUseEPSVwithIPv4(true);
//                    ftp.retrieveFile("1.jpg", outputStream);
                    ftp.retrieveFile(key, outputStream);
                    InputStream inputStream = new FileInputStream(localFile);
                    objFile = readInputStream(inputStream);
                    outputStream.close();
                    inputStream.close();
                    localFile.delete();

                } catch (Exception e) {
                    logger.error(e);
                    logger.error("下载过程中出现异常");
                }

            }else{
                logger.error("链接失败!");
            }
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            closeFtp();
        }
        return objFile;
    }*/

    /**
     * 多线程下载
     * @param key
     * @param type
     * @return
     */
   public  byte[] download(String key,String type) {
       byte[] objFile=null;
       Ftp f =  getFtp();
       String cacheFile = "/cache_"+key;
       if(null == type){
           //设置目录
           key=f.getSysFile()+key;
       }else{
           //设置目录
           key=f.getHeadImgFile()+key;
       }
       FTPClient ftpClient = null;
       try {
           ftpClient = getFTPClient();
           if (ftpClient!=null && ftpClient.isConnected()) {
               try {
                   ftpClient.changeWorkingDirectory("/");
                   File localFile = new File(cacheFile);
                   if(localFile.exists()){
                       localFile.createNewFile();//创建文件
                   }
                   OutputStream outputStream = new FileOutputStream(localFile);
                   ftpClient.enterLocalPassiveMode();
                   ftpClient.setUseEPSVwithIPv4(true);
//                    ftp.retrieveFile("1.jpg", outputStream);
                   ftpClient.retrieveFile(key, outputStream);
                   InputStream inputStream = new FileInputStream(localFile);
                   objFile = readInputStream(inputStream);
                   outputStream.close();
                   inputStream.close();
                   localFile.delete();

               } catch (Exception e) {
                   logger.error(e);
                   logger.error("下载过程中出现异常");
               }

           }else{
               logger.error("链接失败!");
           }
       }catch (Exception e){
           e.printStackTrace();
       }finally {
           try{
               disconnect();
           }catch (Exception e){
               e.printStackTrace();
           }

       }
       return objFile;
   }

    /**
     * 上传文件
     * @param key 实为文件名,可以为:upload/20150306/text.txt
     * @param input 文件流
     * @return
     */
    public  String upload(String key, InputStream input){
        return upload(key, input, null);
    }
/*    public  String upload(String key, InputStream input, String type)  {
        String etag="";
        Ftp f =  getFtp();
        if(null == type){
            //设置目录
            key=f.getSysFile()+key;
        }else{
            //设置目录
            key=f.getHeadImgFile()+key;
        }

        try{
            if (connectFtp(f)) {
                ftp.enterLocalPassiveMode();
                ftp.setUseEPSVwithIPv4(true);
                ftp.storeFile(key,input);
                input.close();
                etag="succ";
            }
        }catch (Exception e){
            e.printStackTrace();
            throw new RuntimeException("FTP客户端出错!", e);
        }finally {
            closeFtp();
        }
        return etag;
    }*/

    /**
     * 多线程上传
     * @param key
     * @param input
     * @param type
     * @return
     */
    public  String upload(String key, InputStream input, String type)  {
        String etag="";
        Ftp f =  getFtp();
        if(null == type){
            //设置目录
            key=f.getSysFile()+key;
        }else{
            //设置目录
            key=f.getHeadImgFile()+key;
        }

        FTPClient ftpClient = null;
        try {
            ftpClient = getFTPClient();
            if (ftpClient!=null && ftpClient.isConnected()) {
                ftpClient.enterLocalPassiveMode();
                ftpClient.setUseEPSVwithIPv4(true);
                ftpClient.storeFile(key,input);
                input.close();
                etag="succ";
            }
        }catch (Exception e){
            e.printStackTrace();
            throw new RuntimeException("FTP客户端出错!", e);
        }finally {
            try{
                disconnect();
            }catch (Exception e){
                e.printStackTrace();
            }
        }
        return etag;
    }



    /**
     * 删除一个存储在FTP服务器上的文件
     * @param key
     */
    public  void delete(String key){
        Ftp f =  getFtp();
        key=f.getSysFile()+key;
        try{
            if (connectFtp(f)) {
                ftp.deleteFile(key);
            }

        }catch (Exception e){
            e.printStackTrace();
        }finally {
            closeFtp();
        }

    }

    /*public  Object[] getDownLoadStream(String fileName){

        Long dataLength = null;
        byte[] objFile=null;
        Ftp f =  getFtp();
        fileName=f.getSysFile()+fileName;
        try {
            if (connectFtp(f)) {

                File localFile = new File("/cache_"+fileName);
                if(localFile.exists()){
                    localFile.createNewFile();//创建文件
                }
                OutputStream outputStream = new FileOutputStream(localFile);
                ftp.enterLocalPassiveMode();
                ftp.setUseEPSVwithIPv4(true);
//                    ftp.retrieveFile("1.jpg", outputStream);
                ftp.retrieveFile(fileName, outputStream);
                InputStream inputStream = new FileInputStream(localFile);
                objFile = readInputStream(inputStream);
                dataLength = (long)inputStream.available();
                outputStream.close();
                inputStream.close();
                localFile.delete();
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {

            closeFtp();
        }
        Object[] res = new Object[]{objFile,dataLength};

        return res;
    }*/

    /**
     * 多线程下载
     * @param fileName
     * @return
     */
    public  Object[] getDownLoadStream(String fileName){

        Long dataLength = null;
        byte[] objFile=null;
        Ftp f =  getFtp();
        fileName=f.getSysFile()+fileName;
        FTPClient ftpClient = null;
        try {
            ftpClient = getFTPClient();
            if (ftpClient!=null && ftpClient.isConnected()) {

                File localFile = new File("/cache_"+fileName);
                if(localFile.exists()){
                    localFile.createNewFile();//创建文件
                }
                OutputStream outputStream = new FileOutputStream(localFile);
                ftpClient.enterLocalPassiveMode();
                ftpClient.setUseEPSVwithIPv4(true);
//                    ftp.retrieveFile("1.jpg", outputStream);
                ftpClient.retrieveFile(fileName, outputStream);
                InputStream inputStream = new FileInputStream(localFile);
                objFile = readInputStream(inputStream);
                dataLength = (long)inputStream.available();
                outputStream.close();
                inputStream.close();
                localFile.delete();
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try{
                disconnect();
            }catch (Exception e){
                e.printStackTrace();
            }
        }
        Object[] res = new Object[]{objFile,dataLength};

        return res;
    }

    /**
     * 获取Ftp下载路径
     * @param key
     * @return
     */
    public  String getObjectUrl(String key){
        Ftp f =  getFtp();
        key=f.getSysFile()+key;
        String alpath = "ftp://"+f.getUserNameRead()+":"+f.getPwdRead()+"@"+f.getIdApprRead()+":"+f.getPort() + key;
        return alpath;
    }




}
#FTP配置信息
#ip地址 本地:172.16.230.161  
ftp.ipAddr=172.16.230.161
#用户名
ftp.userName=ftp
#密码
ftp.pwd=123456
#端口号  ftp默认21
ftp.port=21
#命名名空间下使用的文件夹
ftp.sysFile=/KsrzSysFile/
ftp.headImgFile=/headimage/

#ip地址 本地:172.16.230.161  
ftp.ipAddrRead=172.16.230.161  
#用户名
ftp.userNameRead=ftpread
#密码
ftp.pwdRead=123456

package dto;

/**
 * ftp链接常量
 */
public class Ftp {

    private String ipAddr;//ip地址

    private Integer port;//端口号

    private String userName;//用户名

    private String pwd;//密码

    private String path;//aaa路径

    private String sysFile;//项目中内容所要上传的文件夹地址

    private String headImgFile;//用户头像文件夹地址

    private String idApprRead;//只读ip地址

    private String userNameRead;//只读用户名

    private String pwdRead;//只读密码

    public String getIpAddr() {
        return ipAddr;
    }

    public void setIpAddr(String ipAddr) {
        this.ipAddr = ipAddr;
    }

    public Integer getPort() {
        return port;
    }

    public void setPort(Integer port) {
        this.port = port;
    }

    public String getUserName() {
        return userName;
    }

    public void setUserName(String userName) {
        this.userName = userName;
    }

    public String getPwd() {
        return pwd;
    }

    public void setPwd(String pwd) {
        this.pwd = pwd;
    }

    public String getPath() {
        return path;
    }

    public void setPath(String path) {
        this.path = path;
    }

    public String getSysFile() {
        return sysFile;
    }

    public void setSysFile(String sysFile) {
        this.sysFile = sysFile;
    }

    public String getHeadImgFile() {
        return headImgFile;
    }

    public void setHeadImgFile(String headImgFile) {
        this.headImgFile = headImgFile;
    }


    public String getIdApprRead() {
        return idApprRead;
    }

    public void setIdApprRead(String idApprRead) {
        this.idApprRead = idApprRead;
    }

    public String getUserNameRead() {
        return userNameRead;
    }

    public void setUserNameRead(String userNameRead) {
        this.userNameRead = userNameRead;
    }

    public String getPwdRead() {
        return pwdRead;
    }

    public void setPwdRead(String pwdRead) {
        this.pwdRead = pwdRead;
    }


}


本文转载自:http://blog.csdn.net/u014481096/article/details/50611206

共有 人打赏支持
秦学强

秦学强

粉丝 0
博文 69
码字总数 0
作品 0
海淀
程序员
私信 提问
Java中实现FTP上传下载文件的功能,完整代码

一个JAVA 实现FTP功能的代码,包括了服务器的设置模块,并包括有上传文件至FTP的通用方法、下载文件的通用方法以及删除文件、在ftp服务器上穿件文件夹、检测文件夹是否存在等,里面的有些代码...

Carl_
2014/11/12
0
4
Java使用SFTP和FTP两种连接方式实现对服务器的上传下载

一、Java实现对SFTP服务器的文件的上传下载 1、添加maven依赖: 2、SFTPUtils工具类: 二、Java实现对FTP服务器的文件的上传下载 有时系统可能要兼容ftp和sftp,而ftp的端口一般是21,sftp对...

灌南高手No1
09/12
0
0
libcurl在android下的移植、编译与测试以及java接口的封装

curl是利用URL语法在命令行方式下工作的文件传输工具 它支持很多协议:FTP, FTPS, HTTP, HTTPS, GOPHER, TELNET, DICT, FILE 以及 LDAP。 curl同样支持HTTPS认证,HTTP POST方法, HTTP PUT...

zhoulc
2013/03/05
0
2
Linux下如何配置FineReport报表工程

电脑操作系统:linux 服务器:resin 报表工程应用:FineReport 操作步棸: 一:安装jdk 二:安装服务器,以resin为例 三:配置报表工程 一:安装jdk 1.首先在相关官网上下载jdk 例如jdk1.6,...

finereport
2011/11/16
0
0
Apache commons ftp API 的Spike

由于公司给了我一个传FTP的任务,刚好可以学习一下,同时也进行了一些单元测试,spike了一把,哈哈。分享一下。 这里只对最简单常用的FtpClient的上传下载列表功能进行测试学习使用^-^ 创建一...

XzhiF
2013/12/13
0
9

没有更多内容

加载失败,请刷新页面

加载更多

binlog2sql mysql数据库闪回工具

binlog2sql工具比mysqlbinlog+sed恢复更快捷。 1、安装: 从github上下载:https://github.com/danfengcao/binlog2sql shell> git clone https://github.com/danfengcao/binlog2sql.git && c......

mickelfeng
2分钟前
0
0
SpringCloud 复杂对象接收时候对象变成LinkeHashMap

如果定义feign接口为 @PostMapping("/user/queryUserByAccountStatus") BaseResult queryUserByAccountStatus(@RequestBody AccountsTenantIdStatusArg arg); 其中BaseResult的范性应该为Lis......

xiaomin0322
2分钟前
0
0
Android/Java 读、写MP3文件ID3V1信息

MP3的歌曲信息一般分两个大版本,分别是ID3V1和ID3V2,其中V2又分为好几个版本,具体百度一下,下方的代码仅仅是支持ID3V1。 需要用到的一个辅助工具(juniversalchardet)用于解决乱码问题,...

她叫我小渝
2分钟前
0
0
thymeleaf的onclick标签传参异常

异常 org.thymeleaf.exceptions.TemplateProcessingException: Only variable expressions returning numbers or booleans are allowed in this context, any other datatypes are not trust......

EasyProgramming
3分钟前
0
0
前端杂谈: CSS 权重 (Specificity)

前端杂谈: CSS 权重 (Specificity) css 权重想必大家都听说过, 一些简单的规则大部分人也都知道: 较长的 css selector 权重会大于较短的 css selector id selector 权重高于 class selector...

ssthouse_hust
10分钟前
2
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部