文章目录
- 安装 vsftpd
- 通过windows下的资源管理器访问
- 使用java连接ftp服务器上传文件(注意主动模式和被动模式)
- 其他
- 参考文档
安装 vsftpd
yum install -y vsftpd
cd /etc/vsftpd
systemctl enable vsftpd.service
systemctl start vsftpd.service
systemctl stop firewalld
通过windows下的资源管理器访问
- 如果安装成功，并不需要任何账号密码，就能直接读取。默认在服务器上的文件夹是 /var/ftp，一般只有一个默认文件夹 pub。
- 这里的资源管理器只拥有读的权限，增删改都不具备。
ftp://119.24.12.211/
使用java连接ftp服务器上传文件(注意主动模式和被动模式)
- java连接必须创建用户密码连接
- 创建的用户ljj默认存储的根文件夹路径为 /home/ljj
- 创建ftp用户ljj
useradd ljj
- 给用户ljj赋予密码，输入完后连续输入两次您需要的密码（它可能会提示你过于简单，不用管它）
passwd ljj
其他
- vsftpd 安装后默只支持匿名 FTP 登录，用户如果试图使用 Linux 操作系统中的账号登录服务器，将会被 vsftpd 拒绝，但可以在 vsftpd 里配置用户账号和密码登录。
- java程序ftp连接参考工具类
package com.yj.oa.common.utils.ftp;
import com.yj.oa.common.utils.DateUtils;
import com.yj.oa.common.utils.HttpHeaderUtil;
import org.apache.commons.net.ftp.FTP;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPFile;
import org.apache.commons.net.ftp.FTPReply;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpStatus;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import java.io.*;
import java.net.URLEncoder;
import java.util.*;
public class FtpUtil{
private static Logger log = LoggerFactory.getLogger(FtpUtil.class);
private static final String host = "171.24.165.240";
private static final int port = 21;
private static final String username = "ljj";
private static final String password = "1";
private static final String basePath = "/home/ljj/images";
public static final String filePath = "http://171.24.165.240:7777";
public static boolean uploadFile(Map FileMap) throws IOException
{
boolean result = false;
FTPClient ftp = new FTPClient();
InputStream input = null;
//如果某个上传失败，将当前集合上传成功的图片删除
List uploadS = new ArrayList<>();
//if连接成功
if (getConnect(ftp))
{
//执行上传,遍历集合取值
int i = 0;
String fileName = "";
for (Map.Entry entry : FileMap.entrySet())
{
//文件名
fileName = entry.getKey();
//文件流
input = entry.getValue();
try
{
//上传操作
result = ftp.storeFile(fileName, input);
//上传成功
if (result)
{
i++;
uploadS.add(fileName);
}
}
catch (IOException e)
{
ftp.disconnect();
ftp.logout();
input.close();
return false;
}
finally
{
log.info("已成功上传" + (i) + " 个");
}
}
}
closeConnect(ftp);
input.close();
return result;
}
public static ResponseEntity fileDown(String fileId, String fileName) throws IOException
{
FTPClient ftp = new FTPClient();
boolean b = false;
if (getConnect(ftp))
{
//拿到服务器的所有文件
FTPFile[] fs = ftp.listFiles();
for (FTPFile ff : fs)
{
//比较名字相同的就下载
if (ff.getName().equals(fileId))
{
log.info("$$$$$ 开始下载", DateUtils.DateToSTr(new Date()));
InputStream in = null;
ByteArrayOutputStream outputStream = null;
try
{
in = ftp.retrieveFileStream(ff.getName());
int len = 0;
byte[] buffer = new byte[1024];
outputStream = new ByteArrayOutputStream();
while ((len = in.read(buffer)) > 0)
{
outputStream.write(buffer, 0, len);
}
byte[] bytes = outputStream.toByteArray();
HttpHeaders httpHeaders = new HttpHeaders();
httpHeaders.setContentDispositionFormData("attachment", getFileName(fileName));
httpHeaders.setContentType(MediaType.APPLICATION_OCTET_STREAM);
log.info("$$$$$ 下载完成", DateUtils.DateToSTr(new Date()));
return new ResponseEntity(bytes, httpHeaders, HttpStatus.OK);
}
catch (IOException e)
{
e.printStackTrace();
}finally
{
closeConnect(ftp);
in.close();
outputStream.close();
}
}
}
}
return new ResponseEntity(null, new HttpHeaders(), HttpStatus.BAD_REQUEST);
}
public static boolean isHashFile(String filename) throws IOException
{
FTPClient ftp = new FTPClient();
boolean b = false;
if (getConnect(ftp))
{
//拿到服务器的所有文件
FTPFile[] fs = ftp.listFiles();
for (FTPFile ff : fs)
{
if (ff.getName().equals(filename))
{
return true;
}
}
}
closeConnect(ftp);
return false;
}
public static boolean deleteFile(String[] FileName) throws IOException
{
FTPClient ftp = new FTPClient();
boolean bol = false;
if (getConnect(ftp))
{
int count = 0;
for (String fileName : FileName)
{
try
{
bol = ftp.deleteFile(fileName);
if (bol)
{
count++;
}
}
catch (IOException e)
{
e.printStackTrace();
}
finally
{
System.out.println("删除了：" + count + "个");
}
}
closeConnect(ftp);
}
return bol;
}
public static void closeConnect(FTPClient ftp) throws IOException
{
//登出
ftp.logout();
//断开连接
if (ftp.isConnected())
{
ftp.disconnect();
}
}
public static boolean getConnect(FTPClient ftp) throws IOException
{
ftp.setControlEncoding("UTF-8");
try
{
int reply;
// 连接FTP服务器
ftp.connect(host, port);
// 如果采用默认端口，可以使用ftp.connect(host)的方式直接连接FTP服务器
// 登录
ftp.login(username, password);
reply = ftp.getReplyCode();
if (!FTPReply.isPositiveCompletion(reply))
{
ftp.disconnect();
log.error("连接失败");
return false;
}
}
catch (IOException e)
{
e.printStackTrace();
}
//切换到上传目录
ftp.changeWorkingDirectory(basePath);
//设置为被动模式
// ftp.enterLocalPassiveMode();
ftp.enterLocalActiveMode();//主动模式
//设置上传文件的类型为二进制类型
ftp.setFileType(FTP.BINARY_FILE_TYPE);
return true;
}
//创建下载的位置
public static void mkdirs(String localPath)
{
java.io.File file2 = new java.io.File(localPath);
if (!file2.exists() && !file2.isDirectory())
{
// 没有则创建
file2.mkdirs();
}
}
public static String getFileName(String fileName) throws UnsupportedEncodingException
{
String[] IEBrowserKeyWords = {"MSIE", "Trident", "Edge"};
//获取请求头代理
String userAgent = HttpHeaderUtil.getUserAgent();
for (String keyWord : IEBrowserKeyWords)
{
if (userAgent.contains(keyWord))
{
//IE内核统一 UTF-8
return URLEncoder.encode(fileName, "UTF-8");
}
}
//火狐等其他 ISO-8859-1
return new String(fileName.getBytes("UTF-8"), "ISO-8859-1");
}
// public static void main(String[] a) throws IOException
// {
// java.io.File file = new java.io.File("F:\win桌面文件\Desktop\OA规划\管理员权限.png");
// FileInputStream fileInputStream = new FileInputStream(file);
// Map map = new HashMap();
// map.put(file.getName(), fileInputStream);
// uploadFile(map);
// }
}
参考文档
- 阿里云服务器配置ftp
- FTP服务器端口说明
- 连接FTP服务器问题, java 超时 。 chrome 可以访问， FileZilla可以访问
