jdk7 FTP连接

vgeejykiyd

　　使用jdk7用于连接和操作ftp服务器

package com.voiinnov.xingye.util;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.InetSocketAddress;
import java.net.SocketAddress;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.Iterator;
import sun.net.ftp.FtpClient;
import sun.net.ftp.FtpDirEntry;
import sun.net.ftp.FtpProtocolException;
public class FtpClientUtil {
private FtpClient ftpClient;   

public FtpClient getFtpClient(){
return this.ftpClient;
}
/**
* 连接FTP服务器
* @param ip  ip地址
* @param port 端口号
* @param user 用户名
* @param password  密码
* @param path  FTP的根目录
*/
public void connectServer(String ip, int port, String user, String password, String path) {
try {            
/* ******连接服务器的两种方法*******/            
ftpClient = FtpClient.create();            
try {               
SocketAddress addr = new InetSocketAddress(ip,port);
ftpClient.connect(addr);                 
ftpClient.login(user, password.toCharArray());
System.out.println("login success!");
//// 用2进制上传、下载
ftpClient.setBinaryType();
if (path!=null&&path.length() != 0){                        
//把远程系统上的目录切换到参数path所指定的目录                        
ftpClient.changeDirectory(path);
}            
} catch (FtpProtocolException e) {               
e.printStackTrace();            
}        
} catch (IOException ex) {            
ex.printStackTrace();            
}   
}  

/**     
* 关闭连接     
*/   
public void closeConnect() {        
try {            
ftpClient.close();            
System.out.println("disconnect success");        
} catch (IOException ex) {            
System.out.println("not disconnect");            
ex.printStackTrace();            
}   
}   
/**
* 上传文件使用流
* @param localFile
* @param remoteFile
*/
public void uploadStream(String localFile, String remoteFile){
FileInputStream is = null;
File file_in = new File(localFile);            
try {
is = new FileInputStream(file_in);
ftpClient.putFile(remoteFile, is);
} catch (FileNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}catch (FtpProtocolException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
/**     
* 上传文件     
* @param localFile 本地文件     
* @param remoteFile 远程文件     
*/   
public void upload(String localFile, String remoteFile) {
//this.localfilename = localFile;        
//this.remotefilename = remoteFile;        
OutputStream os = null;        
FileInputStream is = null;        
try {            
//将远程文件加入输出流中            
try {               
os = ftpClient.putFileStream(remoteFile);            
} catch (
FtpProtocolException e) {               
e.printStackTrace();            
}            
//获取本地文件的输入流            
File file_in = new File(localFile);            
is = new FileInputStream(file_in);            
//创建一个缓冲区            
byte[] bytes = new byte[1024];            
int c;            
while ((c = is.read(bytes)) != -1) {
os.write(bytes, 0, c);            
}            
System.out.println("upload success");        
} catch (IOException ex) {            
System.out.println("not upload");            
ex.printStackTrace();            
} finally{            
try {               
if(is != null){                    
is.close();               
}            
} catch (IOException e) {               
e.printStackTrace();            
} finally {               
try {                    
if(os != null){                        
os.close();                    
}               
} catch (IOException e) {                    
e.printStackTrace();               
}            
}        
}   
}  
/**     
* 下载文件     
* @param remoteFile 远程文件路径(服务器端)     
* @param localFile 本地文件路径(客户端)     
*/   
public void download(String remoteFile, String localFile) {        
InputStream is = null;        
FileOutputStream os = null;        
try {            
//获取远程机器上的文件filename，借助TelnetInputStream把该文件传送到本地。            
try {               
is = ftpClient.getFileStream(remoteFile);            
} catch (FtpProtocolException e) {                                
e.printStackTrace();            
}            
File file_in = new File(localFile);            
os = new FileOutputStream(file_in);            
byte[] bytes = new byte[1024];            
int c;            
while ((c = is.read(bytes)) != -1) {               
os.write(bytes, 0, c);            
}            
System.out.println("download success");        
} catch (IOException ex) {            
System.out.println("not download");            
ex.printStackTrace();            
} finally{            
try {               
if(is != null){                    
is.close();               
}            
} catch (IOException e) {               
e.printStackTrace();            
} finally {               
try {                    
if(os != null){                        
os.close();                    
}               
} catch (IOException e) {                    
e.printStackTrace();               
}            
}        
}   
}
/**
*
* @param remoteFile
* @return
*/
public String downFile2String(String remoteFile){
InputStream is = null;  
StringBuffer sb = null;
BufferedReader bufferReader = null;
try {
is = ftpClient.getFileStream(remoteFile);
sb = new StringBuffer();
bufferReader = new BufferedReader(new InputStreamReader(is));
String line = null;
while ((line = bufferReader.readLine()) != null) {
System.out.println("读取的数据："+line);
sb.append(line+"\n");
}
} catch (FtpProtocolException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return sb.toString();
}
/**
* 判断FTP服务器已经连接并且登陆
* @return
*/
private  boolean  isConAndLogin(){
boolean flag = false;
flag =ftpClient.isLoggedIn()&&ftpClient.isConnected();
return flag ;
}
/**
* 创建目录
* @param path  目录名
* <br/>
* 如果需要一次性创建多个目录，可以使用这种字符串“test/test1/test2”直接创建多个目录
*/
public  void makeDir(String path){
try {
if(isConAndLogin()){
ftpClient.makeDirectory(path);
}else{
System.out.println("FTP没有连接成功");
}
} catch (FtpProtocolException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
/**
* 重命名
* @param sPath  源文件名
* @param dPath  目标文件名
*/
public  void renameDir(String sPath , String dPath ){
try {
if(isConAndLogin()){
ftpClient.rename(sPath, dPath);
}else{
System.out.println("FTP没有连接成功");
}
} catch (FtpProtocolException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
/**
* 递归删除文件夹
* @param path
*/
public void deleteDirs(String path) {
try {
Iterator<FtpDirEntry> dirEntryI =getFtpClient().listFiles(path);
if(dirEntryI.hasNext()){
FtpDirEntry entry = null;
while(dirEntryI.hasNext()){
entry = dirEntryI.next();
//System.out.println(entry.getType()+"    "+entry.getName());
if(entry.getType()==FtpDirEntry.Type.DIR){
this.deleteDirs(path+File.separator+entry.getName());
getFtpClient().removeDirectory(path+File.separator+entry.getName());
}else{
getFtpClient().deleteFile(path+File.separator+entry.getName());
}
}
}
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}

/**
* 删除文件夹(删除的时候文件夹必须为空)
* @param path
*/
public  void delDir(String path){
try {
if(isConAndLogin()){
ftpClient.removeDirectory(path);
}else{
System.out.println("FTP没有连接成功");
}
} catch (FtpProtocolException e) {
System.out.println("没有连接");
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
/**
* 测试删除文件夹
*/
public static void testDleDir(){
FtpClientUtil fu = new FtpClientUtil();
/* 使用默认的端口号、用户名、密码以及根目录连接FTP服务器         */  
fu.connectServer("127.0.0.1", 21, "test", "test", null);
String path = "20140512_back";
fu.deleteDirs(path);
fu.delDir(path);
fu.closeConnect();
}
/**
* 测试重命名文件夹
*/
public static void testRenameDir(){
FtpClientUtil fu = new FtpClientUtil();
/* 使用默认的端口号、用户名、密码以及根目录连接FTP服务器         */  
fu.connectServer("127.0.0.1", 21, "test", "test", null);
String spath = "20150521";
String dpath = "20140512_back";
fu.renameDir(spath, dpath);
fu.closeConnect();
}

/**
* 测试单个文件上传
*/
public static void testSigleUplad(){
Date now = new Date();
SimpleDateFormat sDateFormat = new SimpleDateFormat();
sDateFormat.applyPattern("yyyyMMdd");
String dir = "/"+sDateFormat.format(now);
FtpClientUtil fu = new FtpClientUtil();
/* 使用默认的端口号、用户名、密码以及根目录连接FTP服务器         */  
fu.connectServer("127.0.0.1", 21, "test", "test", null);
dir=dir+"/xingyeblank";
//在FTP创建文件夹
fu.makeDir(dir);
//本地文件
String localfile = "E:/test/ZXRZ_900201_TKSQ_20150521.txt";  
//上传到ftp远程文件
String remotefile = dir+"/ZXRZ_900201_TKSQ_20150521.txt";
//上传        
sDateFormat.applyPattern("yyyy-MM-dd   hh:mm:ss");   
System.out.println(sDateFormat.format(new java.util.Date()));// new Date()为获取当前系统时间        
fu.upload(localfile, remotefile);        
System.out.println(sDateFormat.format(new java.util.Date()));// new Date()为获取当前系统时间        
fu.closeConnect();   
}
/**
* 测试单个文件上传
*/
public static void testSigleUplad2(){
Date now = new Date();
SimpleDateFormat sDateFormat = new SimpleDateFormat();
sDateFormat.applyPattern("yyyyMMdd");
String dir = "/"+sDateFormat.format(now);
FtpClientUtil fu = new FtpClientUtil();
/* 使用默认的端口号、用户名、密码以及根目录连接FTP服务器         */  
fu.connectServer("127.0.0.1", 21, "test", "test", null);
dir=dir+"/xingyeblank";
//在FTP创建文件夹
fu.makeDir(dir);
//本地文件
String localfile = "E:/test/ZXRZ_900201_TKSQ_20150521.txt";  
//上传到ftp远程文件
String remotefile = dir+"/ZXRZ_900201_TKSQ_20150521.txt";
//上传        
sDateFormat.applyPattern("yyyy-MM-dd   hh:mm:ss");   
System.out.println(sDateFormat.format(new java.util.Date()));// new Date()为获取当前系统时间        
fu.uploadStream(localfile, remotefile);  
System.out.println(sDateFormat.format(new java.util.Date()));// new Date()为获取当前系统时间        
fu.closeConnect();   
}
/**
* 测试文件加载
*/
public static void testDownFile(){
//下载到本地文件
String localfile = "E:/test/AESUtils副本3333.java";  
//ftp远程文件
String remotefile = "20150521/xingyeblank/AESUtils111.java";
FtpClientUtil fu = new FtpClientUtil();
/* 使用默认的端口号、用户名、密码以及根目录连接FTP服务器         */  
fu.connectServer("127.0.0.1", 21, "test", "test", null);
fu.download(remotefile, localfile);
}
public static void testDownFile2String(){
//ftp远程文件
String remoteFile = "20150521/xingyeblank/ZXRZ_900201_TKSQ_20150521.txt";
FtpClientUtil fu = new FtpClientUtil();
/* 使用默认的端口号、用户名、密码以及根目录连接FTP服务器         */  
fu.connectServer("127.0.0.1", 21, "test", "test", null);
String str = fu.downFile2String(remoteFile);
System.out.println(str);
}
/**
* 测试创建文件夹
*/
public static void testMakeDir(){
FtpClientUtil fu = new FtpClientUtil();
/* 使用默认的端口号、用户名、密码以及根目录连接FTP服务器         */  
fu.connectServer("127.0.0.1", 21, "test", "test", null);
try {
fu.getFtpClient().makeDirectory("20150521/test");
fu.getFtpClient().makeDirectory("20150521/test2");
fu.getFtpClient().makeDirectory("20150521/test3");
fu.getFtpClient().makeDirectory("20150521/test4");
fu.getFtpClient().makeDirectory("20150521/test5");
fu.closeConnect();
} catch (Exception e) {
e.printStackTrace();
}
}
public static void main(String agrs[]) {  
//testSigleUplad();
//testMakeDir();
//testRenameDir();
//testDleDir();
//testDownFile();
//testDownFile2String();
testSigleUplad2();
//---------------其他方法的说明----------------
//从FTP下载指定的文件到OutputStream下
//ftpClient.getFile(String remotePath, OutputStream);
//如果是文件名列出文件信息，如果是目录则列出文件列表
//ftpClient.list(path);
//列出指定目录内容
//ftpClient.nameList(path);
}
}