文档章节

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

秦学强
 秦学强
发布于 2017/07/09 22:03
字数 1380
阅读 23
收藏 0
点赞 0
评论 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
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
CKEditor3.x 在Java项目中配置、包括图片上传(支持FTP、图片压缩)

CKEditor 3.x配置说明 一、基本使用: 1、所需文件架包 A. Ckeditor基本文件包,比如:ckeditor_3.6.2.zip 下载地址:http://ckeditor.com/download 2、配置使用 A.将下载下来的CKEditor压缩...

一枚Sir
2014/05/29
0
0
分享一个简单易用的RPC开源项目—Tatala

这个项目最早(2008年)是用于一个网络游戏的Cache Server,以及一个电子商务的Web Session服务。后来不断增加新的功能,除了Java还支持C#,到现在已经可以用它来开发网络游戏的服务器。等过些...

zijan
2014/04/08
0
1
java解析FoxPro DBF数据文件

前面的博文中提到过项目中有解析dbf数据文件做导入的需求,由于项目中用到的DBF文件由FoxPro产生,本文的重点也围绕FoxPro的DBF文件展开。 其实网上有相当多的java工具,用于解析dbf文件,尝...

彭苏云
2013/09/03
0
0
android volley框架

1 Volley发送get请求: [java] view plaincopy public void getJson() { String url = "http://"+host+":8080/web/json.jsp?username=xjs&password=123456"; mQueue.add(new JsonObjectRequ......

专注移动开发
2015/08/03
0
0
org.apache.commons.net.ftp包开发FTP客户端,实现断点续传,中文支持

利用org.apache.commons.net.ftp包实现一个简单的ftp客户端实用类。主要实现一下功能 1.支持上传下载。支持断点续传 2.支持进度汇报 3.支持对于中文目录及中文文件创建的支持。 具体请看代码...

御风林海
2013/11/29
0
0
《Java从小白到大牛精简版》之第1章 开篇综述

Java诞生到现在已经有20多年了,但是Java仍然是非常热门的编程语言之一,很多平台中使用Java开发。表1-1所示的是TIOBE社区发布的2016年5月和2017年5月的编程语言排行榜,可见Java语言的热度,...

tony关东升
06/26
0
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

Android 复制和粘贴功能

做了一回搬运工,原文地址:https://blog.csdn.net/kennethyo/article/details/76602765 Android 复制和粘贴功能,需要调用系统服务ClipboardManager来实现。 ClipboardManager mClipboardM...

她叫我小渝
23分钟前
0
0
拦截SQLSERVER的SSL加密通道替换传输过程中的用户名密码实现运维审计(一)

工作准备 •一台SQLSERVER 2005/SQLSERVER 2008服务 •SQLSERVER jdbc驱动程序 •Java开发环境eclipse + jdk1.8 •java反编译工具JD-Core 反编译JDBC分析SQLSERVER客户端与服务器通信原理 SQ...

紅顏為君笑
40分钟前
4
0
jQuery零基础入门——(六)修改DOM结构

《jQuery零基础入门》系列博文是在廖雪峰老师的博文基础上,可能补充了个人的理解和日常遇到的点,用我的理解表述出来,主干出处来自廖雪峰老师的技术分享。 在《零基础入门JavaScript》的时...

JandenMa
57分钟前
0
0
linux mint 1.9 qq 安装

转: https://www.jianshu.com/p/cdc3d03c144d 1. 下载 qq 轻聊版,可在百度搜索后下载 QQ7.9Light.exe 2. 去wine的官网(https://wiki.winehq.org/Ubuntu) 安装 wine . 提醒网页可以切换成中...

Canaan_
今天
0
0
PHP后台运行命令并管理运行程序

php后台运行命令并管理后台运行程序 class ProcessModel{ private $pid; private $command; private $resultToFile = ''; public function __construct($cl=false){......

colin_86
今天
1
0
数据结构与算法4

在此程序中,HighArray类中的find()方法用数据项的值作为参数传递,它的返回值决定是否找到此数据项。 insert()方法向数组下一个空位置放置一个新的数据项。一个名为nElems的字段跟踪记录着...

沉迷于编程的小菜菜
今天
1
1
fiddler安装和基本使用以及代理设置

项目需求 由于开发过程中客户端和服务器数据交互非常频繁,有时候服务端需要知道客户端调用接口传了哪些参数过来,这个时候就需要一个工具可以监听这些接口请求参数,已经接口的响应的数据,这种...

银装素裹
今天
0
0
Python分析《我不是药神》豆瓣评论

读取 Mongo 中的短评数据,进行中文分词 对分词结果取 Top50 生成词云 生成词云效果 看来网上关于 我不是药神 vs 达拉斯 的争论很热啊。关于词频统计就这些,代码中也会完成一些其它的分析任...

猫咪编程
今天
0
0
虚拟机怎么安装vmware tools

https://blog.csdn.net/tjcwt2011/article/details/72638977

AndyZhouX
昨天
1
0
There is no session with id[xxx]

参考网页 https://blog.csdn.net/caimengyuan/article/details/52526765 报错 2018-07-19 23:04:35,330 [http-nio-1008-exec-8] DEBUG [org.apache.shiro.web.servlet.SimpleCookie] - Found......

karma123
昨天
0
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部