java实现ftp上传下载(jdk1.7以上)

java实现ftp上传下载(jdk1.7以上)

网上有很多关于java实现ftp的上传与下载，但都是jdk1.7以下的，最近在做java实现ftp文件上传与下在，搜到的代码不是jdk1.7一下的，就是apache的。将我测试通过的代码与大家共享。

完整代码，复制可用

FTP实现代码：

package com.pifeng.util;

import java.io.File;

import java.io.FileInputStream;

import java.io.FileOutputStream;

import java.io.IOException;

import java.io.InputStream;

import java.io.OutputStream;

import java.net.InetSocketAddress;

import java.net.SocketAddress;

import sun.net.ftp.FtpClient;

import sun.net.ftp.FtpProtocolException;

/**

*

* @author 皮锋 java自带的API对FTP的操作

*

*/

public class FtpUtil {

// FTP客户端

private FtpClient ftpClient;

/**

* 服务器连接

* @param ip 服务器IP

* @param port 服务器端口

* @param user 用户名

* @param password 密码

* @param path 服务器路径

*/

public void connectServer(String ip, int port, String user,String password, String path) {

try {

ftpClient = FtpClient.create();

try {

SocketAddress addr = new InetSocketAddress(ip, port);

this.ftpClient.connect(addr);

this.ftpClient.login(user, password.toCharArray());

System.out.println("login success!");

if (path.length() != 0) {

// 把远程系统上的目录切换到参数path所指定的目录

this.ftpClient.changeDirectory(path);

}

} catch (FtpProtocolException e) {

e.printStackTrace();

}

} catch (IOException ex) {

ex.printStackTrace();

throw new RuntimeException(ex);

}

}

/**

* 上传文件

* @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 = this.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();

throw new RuntimeException(ex);

} 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 {

try {

// 获取远程机器上的文件filename，借助TelnetInputStream把该文件传送到本地

is = this.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();

throw new RuntimeException(ex);

} finally {

try {

if (is != null) {

is.close();

}

} catch (IOException e) {

e.printStackTrace();

} finally {

try {

if (os != null) {

os.close();

}

} catch (IOException e) {

e.printStackTrace();

}

}

}

}

/**

* 关闭连接

*/

public void closeConnect() {

try {

this.ftpClient.close();

System.out.println("disconnect success");

} catch (IOException ex) {

System.out.println("not disconnect");

ex.printStackTrace();

throw new RuntimeException(ex);

}

}

}

测试代码：

package test;

import java.text.SimpleDateFormat;

import com.pifeng.util.FtpUtil;

public class TestFtpUtil {

public static void main(String agrs[]) {

FtpUtil fu=new FtpUtil();
String filepath[] = { "AWC1002972G020-1.dwg", "AWC1002974G020-1.cgm" };
String localfilepath[] = { "D:\\AWC1002972G020-1.dwg","D:\\AWC1002974G020-1.cgm" };
/* * 使用默认的端口号、用户名、密码以及根目录连接FTP服务器 */

fu.connectServer("127.0.0.1", 21, "pifeng", "19920720", "/");
// 下载

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

fu.download(filepath[i], localfilepath[i]);

}
String localfile = "D:\\WorkToolKit\\PDF\\ReadMe.htm";
String remotefile = "ReadMe.htm";
// 上传

SimpleDateFormat sDateFormat = new SimpleDateFormat("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();

}

}