`

java上传、读取FTP上的txt文件

    博客分类:
  • java
阅读更多
package com.xes.util;

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.BufferedReader;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.util.ArrayList;
import java.util.List;
import java.util.Properties;
import org.apache.commons.net.ftp.FTP;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPClientConfig;
import org.apache.commons.net.ftp.FTPReply;
import org.apache.log4j.Logger;

import com.xes.util.file.PropertiesUtil;


public class FTPServerUtils {

Logger logger=Logger.getLogger(FTPServerUtils.class);

private String username;

private String password;

private String ip;

private int port;

private Properties property = null;// 配置

private String configFile;// 配置文件的路径名

private FTPClient ftpClient = null;


public FTPServerUtils(String configFile){

this.configFile = configFile;

}
/**
* 设置参数
*
* @param configFile
*            --参数的配置文件
*/
private void setArg(String configFile) {

PropertiesUtil rc = new PropertiesUtil(configFile);
username = rc.getValue("username");
password = rc.getValue("password");
ip = rc.getValue("ip");
port = Integer.parseInt(rc.getValue("port"));

}

/**
* 设置FTP客服端的配置--一般可以不设置
*
* @return
*/
private FTPClientConfig getFtpConfig() {
FTPClientConfig ftpConfig = new FTPClientConfig(
FTPClientConfig.SYST_UNIX);
ftpConfig.setServerLanguageCode(FTP.DEFAULT_CONTROL_ENCODING);
return ftpConfig;
}

/**
* 连接到服务器
*/
public void connectServer() {
if (ftpClient == null) {
int reply;
try {
setArg(configFile);
ftpClient = new FTPClient();
// ftpClient.configure(getFtpConfig());
ftpClient.connect(ip);
ftpClient.login(username, password);
ftpClient.setDefaultPort(port);
ftpClient.setControlEncoding("GBK");
        ftpClient.enterLocalPassiveMode();
reply = ftpClient.getReplyCode();
                
if (!FTPReply.isPositiveCompletion(reply)) {
ftpClient.disconnect();
logger.error("FTP server refused connection....................");
}

} catch (Exception e) {
logger.error("登录ftp服务器【" + ip + "】失败");
e.printStackTrace();
}
}
}

/**
* 进入到服务器的某个目录下
*
* @param directory
*/
public void changeWorkingDirectory(String filedir) {
try {
ftpClient.changeWorkingDirectory(filedir);
} catch (IOException ioe) {
ioe.printStackTrace();
}
}

/**
* 上传文件
*
* @param inputStream--文件输入流
* @param newFileName--新的文件名
*/
public void uploadFile(InputStream inputStream, String newFileName) {
// 上传文件
BufferedInputStream buffIn = null;
try {
buffIn = new BufferedInputStream(inputStream);
boolean flag = ftpClient.storeFile(newFileName, buffIn);
if(flag){
logger.info("文件上传ftp文件成功");
}else {
logger.info("文件上传ftp文件失败");

}
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
if (buffIn != null)
buffIn.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
/**
* 上传文件
*
* @param inputFileName--要上传的文件 路径+名称
* @param newFileName--新的文件名
*/
public void uploadFile(String inputFileName, String newFileName) {

BufferedInputStream buffIn = null;
try {
buffIn = new BufferedInputStream(new FileInputStream(inputFileName));
ftpClient.storeFile(newFileName, buffIn);
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
if (buffIn != null)
buffIn.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
/**
     * 下载文件
     * @param remoteFileName --服务器上的文件名
     * @param localFileName--本地文件名
     */
    public void loadFile(String remoteFileName,String localFileName){
        //下载文件
        BufferedOutputStream buffOut=null;
        try{
            buffOut=new BufferedOutputStream(new FileOutputStream(localFileName));
            ftpClient.retrieveFile(remoteFileName, buffOut);
        }catch(Exception e){
            e.printStackTrace();
        }finally{
            try{
                if(buffOut!=null)
                    buffOut.close();
            }catch(Exception e){
                e.printStackTrace();
            }
        }
    }
   
    public List<String> readFile(String fileName) {
      InputStream ins = null;
       List<String> refundList = new ArrayList<String>(); 
      try {
       // 从服务器上读取指定的文件
       ins = ftpClient.retrieveFileStream(fileName);
       if(ins != null){
           BufferedReader reader = new BufferedReader(new InputStreamReader(ins));
           String line = "";
           while ((line = reader.readLine()) != null) {
           refundList.add(line);
           }
           reader.close();
           ins.close();
           // 主动调用一次getReply()把接下来的226消费掉. 这样做是可以解决这个返回null问题
           ftpClient.getReply();
       }else {
       logger.error("读取ftp文件不存在");
       }
      } catch (IOException e) {
       e.printStackTrace();
      }
      return refundList;
    }
    /**
     * 删除文件
     */
    public void deleteFile(String filename){
        try{
            ftpClient.deleteFile(filename);
        }catch(IOException ioe){
            ioe.printStackTrace();
        }
    }
    /**
     * 关闭连接
     */
    public void closeConnect(){
        try{
            if(ftpClient!=null){
                ftpClient.logout();
                ftpClient.disconnect();
                System.out.println("Ftp have closed");
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
public String getConfigFile() {
return configFile;
}

public void setConfigFile(String configFile) {
this.configFile = configFile;
}

public FTPClient getFtpClient() {
return ftpClient;
}

public void setFtpClient(FTPClient ftpClient) {
this.ftpClient = ftpClient;
}

public String getIp() {
return ip;
}

public void setIp(String ip) {
this.ip = ip;
}

public String getPassword() {
return password;
}

public void setPassword(String password) {
this.password = password;
}

public int getPort() {
return port;
}

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

public Properties getProperty() {
return property;
}

public void setProperty(Properties property) {
this.property = property;
}

public String getUsername() {
return username;
}

public void setUsername(String username) {
this.username = username;
}

}
// 应用
1.上传文件:
//退费文件上传FTP服务器
FTPServerUtils ftpUtil = new FTPServerUtils("/bocmRefund.properties");
ftpUtil.connectServer();
ftpUtil.changeWorkingDirectory(propertie.getProperty("uploadFilePath"));
ftpUtil.uploadFile(new FileInputStream(new File(pathName + fileName)), fileName);
ftpUtil.closeConnect();

2.下载分析文件:
FTPServerUtils ftpUtil = new FTPServerUtils("/bocmRefund.properties");
ftpUtil.connectServer();
ftpUtil.changeWorkingDirectory(loadFilePath);
List<String> stringList = ftpUtil.readFile(fileName);
ftpUtil.closeConnect();
3.在项目中使用commons-net-3.0.1.jar实现FTP文件的下载,在windows xp上运行正常,但是放到linux上,却出现问题,程序运行到

FTPClient.listFiles()或者FTPClient.retrieveFile()方法时,就停止在那里,什么反应都没有,出现假死状态。google一把,发现很多人也出现了此类问题,最终在一个帖子里找到了解决办法。在调用这两个方法之前,调用FTPClient.enterLocalPassiveMode();这个方法的意思就是每次数据连接之前,ftp client告诉ftp server开通一个端口来传输数据。为什么要这样做呢,因为ftp server可能每次开启不同的端口来传输数据,但是在linux上或者其他服务器上面,由于安全限制,可能某些端口没有开启,所以就出现阻塞。OK,问题解决。



另外,如果程序部署在weblogic上, 也有可能出现一些问题,为什么,因为weblogic自己也有commons-net包,如果weblogic的jar包版本低于你使用的版本,就设置weblogic 的classpath,优先加载工程里的jar包
分享到:
评论

相关推荐

    java 读取FTP服务器文件

    在Java编程环境中,读取FTP(File Transfer Protocol)服务器上的文件是一项常见的任务,尤其是在Web服务器和Linux系统环境下。FTP提供了一种可靠的方式来传输文件,使得应用程序可以远程访问和操作存储在FTP服务器...

    Java解析FTP服务器文本文件

    Java解析FTP服务器文本文件是指使用Java语言连接FTP服务器,上传、下载、递归目录遍历等基本操作的集合。在这个过程中,我们需要引入相关的jar包,例如cpdetector.jar、jchardet-1.0.jar、antlr.jar、commons-...

    Java上传下载ftp上的文件

    本文将深入探讨如何使用Java实现FTP文件的上传和下载功能,以满足标题和描述中的需求。作者宋海康提供的案例将为我们提供一个基础,帮助我们理解这个过程。 首先,我们需要导入Java FTP库,通常是`commons-net`库,...

    java 读取Ftp指定位置的文件解析并入库

    标题 "java 读取Ftp指定位置的文件解析并入库" 涉及到的是使用Java编程语言通过FTP(File Transfer Protocol)协议从远程服务器上下载文件,然后对下载的文件进行解析,并将解析得到的数据存储到数据库中。...

    JAVA获取FTP文件列表

    ### JAVA获取FTP文件列表知识点详解 #### 一、概述 在现代软件开发中,FTP(File Transfer Protocol)是一种广泛使用的协议,用于在网络上进行文件传输。本文档将详细介绍一个基于Java的实用工具类`FtpClientUtil`...

    java 读取FTP服务器文件(二)

    在Java编程环境中,读取FTP(File Transfer Protocol)服务器上的文件是一项常见的任务,尤其是在Web服务器和Linux系统环境下。本文将详细讲解如何实现这一功能,并提供实际应用中的注意事项和最佳实践。 首先,要...

    Java FTP 指定下载文件和上传文件到指定的服务器目录

    ### Java FTP 指定下载文件和上传文件到指定的服务器目录 #### 一、概述 在本篇文章中,我们将详细介绍如何使用Java编程语言通过FTP(文件传输协议)实现文件的上传与下载功能,并能够将文件指定上传或下载到特定...

    java定时从ftp服务器更新相关文件

    `needToUpdate()`方法应根据实际需求实现,通常会比较本地文件和FTP文件的最后修改时间。最后,确保正确关闭和断开FTP连接。 这个例子只是一个基本的起点,实际应用中可能需要处理更复杂的逻辑,如错误处理、断点续...

    JavaFtp实例,实现文件下载和读取

    本实例主要探讨如何使用Java实现FTP文件下载以及读取文件内容。这个简单示例可以帮助初学者理解如何通过Java FTP客户端库与FTP服务器进行交互,进而完成实际的业务需求。 首先,我们需要导入Java FTP客户端库,通常...

    JAVA处理FTP上的文件

    以上步骤提供了处理FTP文件的基本流程,但实际应用中可能需要根据具体需求进行调整,例如添加文件列表的遍历、断点续传、文件重命名等功能。总的来说,Java结合适当的库,能够高效、灵活地处理FTP上的文件操作。

    Java ftp工具类,可以实现ftp上传,读取,目录切换,内容创建,目录创建、检查文件是否存在,支持主动方式和被动方式读取

    Java ftp工具类,可以实现ftp上传,读取,目录切换,内容创建,目录创建、检查文件是否存在,支持主动方式和被动方式读取

    java实现ftp自动上传文件

    本文将深入探讨如何使用Java编程语言来构建一个FTP文件上传系统,同时结合Log4j日志框架和命令行信息的处理。 首先,我们需要引入FTP客户端库。在Java中,可以使用开源的Apache Commons Net库,它提供了完善的FTP...

    java大文件上传至ftp服务器带进度条显示的

    在Java中,我们可以使用`java.net`或`org.apache.commons.net`库来实现FTP文件上传。Apache Commons Net库提供了丰富的FTP功能,包括文件上传、下载、目录管理等,同时它也支持断点续传,对于大文件上传非常实用。 ...

    java实现文件上传到ftp

    下面是一个简单的FTP文件上传的步骤: 1. **创建FTPClient对象**:`FTPClient ftp = new FTPClient();` 2. **连接到FTP服务器**:`ftp.connect(server, port);` 需要指定服务器的IP地址(server)和端口号(port...

    java下载ftp文件.txt

    ### Java下载FTP文件 在实际应用开发中,经常需要与FTP服务器进行交互,比如上传文件、下载文件等操作。Java提供了一套强大的工具和API来实现这些功能。下面我们将通过一个具体的示例来了解如何用Java实现从FTP...

    pdf.js在java web项目中远程预览ftp上的pdf文件.docx

    "pdf.js在java web项目中远程预览ftp上的pdf文件" 标题:pdf.js在java web项目中远程预览ftp上的pdf文件 描述:本文档详细介绍了使用pdf.js在Java web项目中远程预览FTP服务器上的PDF文件的方法。通过配置pdf.js...

    完整实现ftp上传与下载并解析csv文件

    通过以上步骤,我们可以构建一个完整的FTP文件传输系统,它不仅能上传和下载文件,还能解析CSV内容,对数据进行分析,并在出现问题时提供反馈和记录。这样的系统在数据处理、报告生成、自动化工作流等场景中非常有用...

    java ftp上传进行文件

    java ftp上传进行文件的读取和上传 上传单个文件的文件流 创建远程服务器目录 删除指定文件 上传单个文件 获取指定ftp目录下文件名

    java实现ftp上传jar包

    以上就是关于"java实现ftp上传jar包"的相关知识点,涵盖了FTP协议、相关库的使用、JAR文件的处理以及基本的Java FTP操作。在实际项目中,你可能还需要考虑其他因素,如连接超时、重试策略、文件权限管理等。

Global site tag (gtag.js) - Google Analytics