- 浏览: 249534 次
- 性别:
- 来自: 北京
文章分类
- 全部博客 (171)
- maven (19)
- eclipse (10)
- java (16)
- js控件 (11)
- web前端开发 (6)
- hibernate (3)
- java异常 (1)
- 数据库 (21)
- cxf (3)
- linux (11)
- shiro、cas集成 (19)
- mybatis (7)
- spring (7)
- soa (7)
- web服务器 (4)
- windows (1)
- Markdown (1)
- UML (1)
- 其他 (1)
- mina (1)
- 服务器被黑 (1)
- 设计模式相关 (1)
- docker (7)
- java桌面程序 (2)
- vue系列 (1)
- java并发编程相关 (1)
- 架构例子 (1)
最新评论
-
lijunxian0114:
<?xml version="1.0" ...
java redis使用之利用jedis实现redis消息队列 -
feiteyizu:
YbhLzz 写道你好,请问下config.xml 能提供下载 ...
java redis使用之利用jedis实现redis消息队列 -
YbhLzz:
你好,请问下config.xml 能提供下载吗?
java redis使用之利用jedis实现redis消息队列
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包
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包
发表评论
-
sonarqube 应用
2016-10-13 09:40 718sonarqube6.0 新版 需要 jdk8支持 ... -
jwt--JSON Web Token
2016-08-08 19:45 743JSON Web Token(JWT)是一个非常轻巧的规范 ... -
jvm 调优
2016-06-30 18:12 593http://www.cnblogs.com/edwardla ... -
jconsole.exe 远程连接jvm
2016-06-30 13:42 10901.远程主机 (1)修改JMX服务的配置文件: 在JD ... -
java 字符串 大小写转换
2016-04-14 16:15 918str转化为 大写 org.apache.commo ... -
java.util.concurrent 线程安全类
2016-04-14 15:40 702线程安全map: Concurrent ... -
java HttpURLConnection http 请求
2016-04-09 17:07 536例子: URL connec ... -
List map 初始化方式
2015-12-04 13:24 1386一.通常方式 //初始化List Lis ... -
验证码 kaptcha
2015-11-30 17:06 675无边框 <prop key="kapt ... -
java 不同系统不同换行符
2015-10-15 10:53 1026在Windows中要使用"\r\n" ... -
java命令 打 war包、解压war包
2015-09-12 08:41 6197有时 war包内修改参数后,需要从新打war包 ... -
Java HashMap
2015-09-09 09:19 441内部存储 Java HashMap类实现了Map<K ... -
利用jackson插件 处理json,配置 忽略序列化的字段
2015-06-26 16:36 5158三种方式: 一种:利用注解@JsonFilter(&q ... -
jdk 7u75 / 76 --- CPU / PSU 区别?
2015-06-17 16:50 1569Critical Patch Updates (CPU) ... -
java 定时器Timer应用
2014-08-10 11:34 763import java.io.IOException; ...
相关推荐
对FTP服务器文件的基本操做:上传下载递归目录遍历等。
JAVA获取FTP文件列表,功能齐全。包括:链接到服务器,上传文件到FTP服务器,从FTP服务器上下载文件并返回下载文件长度,返回FTP目录下的文件列表,删除FTP上的文件及目录,关闭链接。
Java ftp工具类,可以实现ftp上传,读取,目录切换,内容创建,目录创建、检查文件是否存在,支持主动方式和被动方式读取
已经测试 完全没问题 大可以满足你的简单需求 修改液很容易 里面有详细的注释说明
java ftp上传进行文件的读取和上传 上传单个文件的文件流 创建远程服务器目录 删除指定文件 上传单个文件 获取指定ftp目录下文件名
一款由java实现ftp自动上传整个磁盘所有文件,包括目录,下面的JTextArea读取Log4j及命令行的信息,采用第三方ftpClient.不过下载的部分还没有时间去做.
完整实现ftp上传与下载并解析csv文件,并实现对文件内容进行分析及错误信息的提示及保存日志,并可以实现多个文件同时下载,并且同时解析
读取jdbc,表数据,生成文件打包,上传FTP,备份文件
②快速知道如何使用java操作ftp文件,避免踩坑,多种操作方式。③ftp文件到底可如何操作。如何获取,如何上传。 阅读建议:此资源以让工作中的同学快速学习使用,直接复制代码即可直接使用,不需要太多改造,当然也...
ftp文件传输 2个目标文件,FTP的目标是:(1)提高文件的共享性(计算机程序和/或数据),(2)鼓励间接地(通过程序)使用远程计算机,(3)保护用户因主机之间的文件存储系统导致的变化,(4)为了可靠和高效地...
java 读取和写入csv文件 (自动提取和转换成对象数据)-附件资源
构建了一个ftp服务器,通过命令ftp可登录,登录后,无法下载,上传,ls也无法执行。 通过 passive 开启和关闭 PASV模式,再ls 也是同样的问题, # 主动模式 $ pftp -v -A -d 211.159.185.xxx Connected to 211...
里面包含FTP搭建步骤和具体的Java实现代码