java代码实现ftp服务器的文件上传和下载

时间:2023-03-13 21:47:38

java代码实现文件上传到ftp服务器:

1:ftp服务器安装:

java代码实现ftp服务器的文件上传和下载

java代码实现ftp服务器的文件上传和下载java代码实现ftp服务器的文件上传和下载

java代码实现ftp服务器的文件上传和下载java代码实现ftp服务器的文件上传和下载

java代码实现ftp服务器的文件上传和下载java代码实现ftp服务器的文件上传和下载

java代码实现ftp服务器的文件上传和下载

2:ftp服务器的配置:

java代码实现ftp服务器的文件上传和下载java代码实现ftp服务器的文件上传和下载

java代码实现ftp服务器的文件上传和下载java代码实现ftp服务器的文件上传和下载

java代码实现ftp服务器的文件上传和下载

java代码实现ftp服务器的文件上传和下载

启动成功:

java代码实现ftp服务器的文件上传和下载

2:客户端:代码实现文件的上传与下载:

1:依赖jar包:

java代码实现ftp服务器的文件上传和下载

2:sftpTools   工具类:

只实现了简单的文件上传和下载,具体业务需根据实际情况再判断条件,使用:

 package com.floor.shop.util;

 import com.jcraft.jsch.*;
import org.slf4j.LoggerFactory; import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.util.Properties;
import java.util.Vector; public class SftpTools {
private static final org.slf4j.Logger logger = LoggerFactory.getLogger(SftpTools.class); /**
* 连接sftp服务器
*
* @param host 主机
* @param port 端口
* @param username 用户名
* @param password 密码
* @return
*/
public ChannelSftp connect(String host, int port, String username,
String password) {
ChannelSftp sftp = null;
try {
JSch jsch = new JSch();
jsch.getSession(username, host, port);
Session sshSession = jsch.getSession(username, host, port);
logger.info("Session created.");
sshSession.setPassword(password);
Properties sshConfig = new Properties();
sshConfig.put("StrictHostKeyChecking", "no");
sshSession.setConfig(sshConfig);
sshSession.connect();
logger.info("Session connected.");
logger.info("Opening Channel.");
Channel channel = sshSession.openChannel("sftp");
channel.connect();
sftp = (ChannelSftp) channel;
logger.info("Connected to " + host + ".");
} catch (Exception e) {
logger.error(e.getMessage());
}
return sftp;
} /*
*测试文件上传、下载:
* host:ftp服务器的IP地址;
* port:ftp服务器的端口号;
* username:ftp服务器的用户名;
* password:ftp服务器的密码;
* fileUrl:文件的上传路径;
*/
//ftp文件上传:
public static void fileUpload(String fileUrl,String host,int port,String username,String password)
throws FileNotFoundException {
SftpTools sftpTools = new SftpTools();
//连接ftp服务器:
ChannelSftp connect = sftpTools.connect(host, port, username, password);
//创建需要上传的文件对象: (fileUrl:上传文件的路径)
File file = new File(fileUrl);
try {
connect.put(new FileInputStream(file), file.getName());
} catch (SftpException e) {
e.printStackTrace();
}
}
/*
*ftp文件下载:
* saveUrl:保存文件的路径;
* saveName:保存文件的名字;
* downloadFileName:下载的文件名,需要加上后缀;
*/
public static void fileDownLoad(String saveUrl,String saveName,String host,int port,
String username,String password,String downloadFileName) {
SftpTools sftpTools = new SftpTools();
//调用连接ftp的方法:
ChannelSftp connect = sftpTools.connect(host, port, username, password);
try {
//获取ftp服务器存放或读取文件的目录:
String files = connect.pwd();
//进入服务器资源路径:
connect.cd(files);
//创建文件保存路径的对象:(保存的路径:saveUrl;自定义保存的文件名:saveName)
File file = new File(saveUrl+"\\"+saveName);
try {
//下载的文件名:test.jpg
connect.get(downloadFileName, new FileOutputStream(file));
} catch (FileNotFoundException e) {
e.printStackTrace();
}
} catch (SftpException e) {
e.printStackTrace();
}
} /**
* 删除文件
*
* @param directory 要删除文件所在目录
* @param deleteFile 要删除的文件
*/
public static void delete(String directory, String deleteFile,String host,int port,String username,
String password) {
SftpTools sftpTools = new SftpTools();
//连接ftp服务器:
ChannelSftp sftp = sftpTools.connect(host, port, username, password);
try {
sftp.cd(directory);
sftp.rm(deleteFile);
} catch (Exception e) {
e.printStackTrace();
}
} /**
* 检查文件夹是否存在
*
* @param dirPath 文件路径:完整
* @return true :存在; false: 不存在
* @throws SftpException
*/
public static String checkDir(String dirPath,String host,int port, String username, String password) {
SftpTools sftpTools = new SftpTools();
//连接ftp服务器:
ChannelSftp sftp = sftpTools.connect(host, port, username, password);
String exists = "";
try {
String files = sftp.pwd();
if (files.contains(dirPath)) {
return "true";
}
//判断日期目录
Vector content = sftp.ls(dirPath);
if (content == null) {
exists = "false";
} else {
exists = "true";
}
} catch (Exception e) {
exists = "false";
logger.error("判断日期目录出错: " + e.getMessage());
}
return exists; } //检查文件夹是否存在,不存在自动创建文件夹:
public static String checkDirMore(String dirPath,String host,int port, String username,String password) {
//检查//upload目录是否存在
String isDir = checkDir(dirPath,host,port,username,password);
if (isDir.equals("true")) {
return "true";
} else {
boolean isMake = makeDir(dirPath,host,port,username,password);
if (isMake == true) {
return "true";
} else {
return "false";
}
}
} //创建目录:
public static boolean makeDir(String dirPath,String host,int port, String username,String password) {
SftpTools sftpTools = new SftpTools();
//连接ftp服务器:
ChannelSftp sftp = sftpTools.connect(host,port,username,password);
try {
sftp.mkdir(dirPath);
return true;
} catch (SftpException e) {
e.printStackTrace();
logger.error("创建目录失败: " + dirPath);
return false;
}
}
}

详解可参考:http://www.cnblogs.com/longyg/archive/2012/06/25/2561332.html