java代码实现文件上传到ftp服务器：
1：ftp服务器安装：
2：ftp服务器的配置：
启动成功：
2：客户端：代码实现文件的上传与下载：
1：依赖jar包：
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