实现FTP上传下载

实现FTP上传下载

package com.cotel.service.gather;




import java.io.BufferedReader;


import java.io.DataOutputStream;


import java.io.File;


import java.io.FileInputStream;


import java.io.FileOutputStream;


import java.io.IOException;


import java.io.InputStream;


import java.io.InputStreamReader;


import java.text.ParseException;


import java.util.ArrayList;


import java.util.Properties;


import org.apache.log4j.*;


import com.cotel.parse.ParseXML;


import com.cotel.util.FileFinder;




import sun.net.TelnetInputStream;


import sun.net.TelnetOutputStream;


import sun.net.ftp.FtpClient;








/** *//**


*


* 功能描述：FTP上传和下载


*


* @author mjun2001@version 1.0


* Creation date: 2007-12-01 下午04:57:32


*/




public class GatherServiceImpl implements IGatherService

{


//引入日志


private static Logger log = (Logger)Logger.getLogger(GatherServiceImpl.class);




/** *//**


* 类的初始化，建立ftp的连接，用户登录，指定ftp的传输流


* @param host


* @param port


* @param user


* @param psw


*/


// 建立一条与指定主机、指定端口上的FTP服务器的连接


private FtpClient aftp = new FtpClient();


private DataOutputStream outputs;


private TelnetOutputStream outs;


private TelnetInputStream inps;




//此路径只应用于在java Application里面进行调试


private static String path = System.getProperty("user.dir") + "\\WebRoot\\WEB-INF\\classes\\charging\\";




//在tomcat里面运行时用下面路径－－－－


// private static String path = GatherServiceImpl.class.getClass().getResource("/").getPath()+ "charging";








public void FTPClass(String host,String port,String user,String psw,String url)

{






try

{


// 注册到FTP服务器


aftp.openServer(host);


log.debug("登陆

.");


aftp.login(user,psw);


log.debug("登录FTP服务器成功！");


aftp.binary();




}catch(IOException e)

{


log.debug("连接FTP服务器失败！");


e.printStackTrace();


}


}






/** *//**


* 通过ftp上传文件到服务器上


* @param localFile 本地所要上传的文件


* @param remoteFile 传到服务器上的文件名称


*/




public boolean upFile(String localFile,String remoteFile)

{


boolean result = true;




if(aftp != null)

{


log.debug("正在上传文件"+localFile+",请稍等

.");




try

{


File file = new File(localFile);


outs = aftp.put(remoteFile);


FileInputStream in = new FileInputStream(file);


byte[] bytes = new byte[1024];


int c;




while((c = in.read(bytes))!=-1)

{


outs.write(bytes,0,c);


}


outs.close();


in.close();


log.debug("上传文件"+localFile+"成功！");


log.debug("上传文件所在目录："+remoteFile+"");




}catch(Exception e)

{


e.printStackTrace();


log.debug("上传文件"+localFile+"失败！");


result = false;


}




}else

{


result = false;


}


return result;


}






/** *//**


* 下载FTP服务器上的文件


* @param localFile 本地文件名


* @param remoteFile 远程服务器文件名


*/




public boolean downFile(String remoteFile,String localFile)

{


boolean result = true;


log.debug("begin");




if(aftp!=null)

{


log.debug("正在下载文件"+remoteFile+",请等待

");




try



log.debug("===" + remoteFile);


inps = aftp.get(remoteFile);


FileInputStream in = null;


FileOutputStream os;




if(inps != null)

{


os = new FileOutputStream(localFile);


byte[] bytes = new byte [1024];


int c ;




while ((c = inps.read(bytes))!=-1)

{


os.write(bytes,0,c);


log.debug(c);


}


inps.close();


os.close();


}else


log.debug("file not exist!");


inps.close();




log.debug("下载文件"+localFile+"成功！");


log.debug("下载文件所在目录："+localFile+"");




}catch(Exception e)

{


e.printStackTrace();


log.debug("下载文件"+localFile+"失败！");


result = false;


}


}


return false;


}






/** *//**


* 断开ftp连接


* @throws IOException


*


*/




public void disconnect() throws IOException

{


aftp.closeServer();


log.debug("FTP服务器连接断开！");


}




// 返回当前目录的所有文件及文件夹




public ArrayList getFileList() throws IOException

{


BufferedReader dr = new BufferedReader(new InputStreamReader(aftp.nameList("*.txt")));


ArrayList al = new ArrayList();


String s = "";




while ((s=dr.readLine())!=null)

{


al.add(s);


}


return al;


}






/** *//** main方法测试


* @param args


* @throws IOException


* @author */




public static void main(String[] args) throws IOException

{


GatherServiceImpl gatherService = new GatherServiceImpl();


log.debug("begin");




//从配置文件中获得监听端口和发送端口


Properties p = new Properties();


//读取配置文件


InputStream in = GatherServiceImpl.class.getResourceAsStream(


"/config.properties");


p.load(in);


in.close();


String ftpHostIP = p.getProperty("ftpHostIP");


String ftpPort = p.getProperty("ftpPort");


String ftpUserName = p.getProperty("ftpUserName");


String ftpPassWord = p.getProperty("ftpPassWord");


String ftpPath = p.getProperty("ftpPath");


gatherService.FTPClass(ftpHostIP, ftpPort, ftpUserName, ftpPassWord, ftpPath);




//文件批量下载，把扩展名为.txt的所有文件一次下载到服务器


ArrayList list = gatherService.getFileList();




for(int i = 0; i < list.size(); i++)

{


String fileName = null;


fileName = (String)list.get(i);


//System.out.println("-------"+fileName);


gatherService.downFile(fileName,path+fileName);


}




//文件进行批量上传，把扩展名为.txt的所有文件一次上传到服务器


FileFinder fileFinder = new FileFinder();


File[] files = fileFinder.getFilesBySuffix(".txt", path);




for (int i = 0; i < files.length; i++)

{


System.out.println("-------"+files[i].getName());


gatherService.upFile(path+files[i].getName(),files[i].getName());


}




//从ftp服务器下载文件


// gatherService.downFile("地标信息.txt",path+"地标信息.txt");


//上传文件到ftp服务器


//ftpClient.upFile(path+"地标信息.txt", "ftproot/地标信息.txt");




//与FTP服务器连接断开


gatherService.disconnect();




}