yum install vsftpd 安裝
yum remove vsftpd 卸載

# Example config file /etc/vsftpd/vsftpd.conf
#
#
# 禁止匿名登錄
anonymous_enable=NO
# 是否允許本地用戶(即linux系統(tǒng)中的用戶帳號(hào))登錄FTP服務(wù)器，默認(rèn)設(shè)置為YES允許
# 本地用戶登錄后會(huì)進(jìn)入用戶主目錄，而匿名用戶登錄后進(jìn)入匿名用戶的下載目錄/var/ftp/pub
# 若只允許匿名用戶訪問，前面加上 #注釋掉即可阻止本地用戶訪問FTP服務(wù)器
local_enable=YES
#
# 是否允許本地用戶對(duì)FTP服務(wù)器文件具有寫權(quán)限，默認(rèn)設(shè)置為YES允許
write_enable=YES
#
# 掩碼，本地用戶默認(rèn)掩碼為077
# 你可以設(shè)置本地用戶的文件掩碼為缺省022，也可根據(jù)個(gè)人喜好將其設(shè)置為其他值
local_umask=022
#
# 是否允許匿名用戶上傳文件，須將全局的write_enable=YES。默認(rèn)為YES
#anon_upload_enable=YES
#
#是否允許匿名用戶創(chuàng)建新文件夾
#anon_mkdir_write_enable=YES

# 是否激活目錄歡迎信息功能
# 當(dāng)用戶用CMD模式首次訪問服務(wù)器上某個(gè)目錄時(shí)，F(xiàn)TP服務(wù)器將顯示歡迎信息
# 默認(rèn)情況下，歡迎信息是通過(guò)該目錄下的.message文件獲得的
# 此文件保存自定義的歡迎信息，由用戶自己建立
dirmessage_enable=YES
#
# 是否讓系統(tǒng)自動(dòng)維護(hù)上傳和下載的日志文件
# 默認(rèn)情況該日志文件為/var/log/vsftpd.log,也可以通過(guò)下面的xferlog_file選項(xiàng)對(duì)其進(jìn)行設(shè)定
# 默認(rèn)值為NO
xferlog_enable=YES
#
# 是否設(shè)定FTP服務(wù)器將啟用FTP數(shù)據(jù)端口的連接請(qǐng)求
# ftp-data數(shù)據(jù)傳輸，21為連接控制端口
connect_from_port_20=YES
#
# 設(shè)定是否允許改變上傳文件的屬主，與下面一個(gè)設(shè)定項(xiàng)配合使用
# 注意，不推薦使用root用戶上傳文件
#chown_uploads=YES
# 設(shè)置想要改變的上傳文件的屬主，如果需要，則輸入一個(gè)系統(tǒng)用戶名
# 可以把上傳的文件都改成root屬主。whoever：任何人
#chown_username=whoever
#
# 設(shè)定系統(tǒng)維護(hù)記錄FTP服務(wù)器上傳和下載情況的日志文件
#xferlog_file=/var/log/xferlog
#
#如果你想，你可以有一個(gè)標(biāo)準(zhǔn)的ftpd xferlog格式的日志文件。
#注意默認(rèn)的日志文件位置是/var/log/xferlog。
xferlog_std_format=YES
#
#您可以更改默認(rèn)值，以使空閑會(huì)話超時(shí)。
#idle_session_timeout=600
#
# #您可以更改數(shù)據(jù)連接超時(shí)的默認(rèn)值。
#data_connection_timeout=120
#
#運(yùn)行vsftpd需要的非特權(quán)系統(tǒng)用戶，缺省是nobody
#nopriv_user=ftpsecure
#
# 是否識(shí)別異步ABOR請(qǐng)求。
# 如果FTP client會(huì)下達(dá)“async ABOR”這個(gè)指令時(shí)，這個(gè)設(shè)定才需要啟用
# 而一般此設(shè)定并不安全，所以通常將其取消
#async_abor_enable=YES
#
# 是否以ASCII方式傳輸數(shù)據(jù)。默認(rèn)情況下，服務(wù)器會(huì)忽略ASCII方式的請(qǐng)求。
# 啟用此選項(xiàng)將允許服務(wù)器以ASCII方式傳輸數(shù)據(jù)
# 不過(guò)，這樣可能會(huì)導(dǎo)致由"SIZE /big/file"方式引起的DoS攻擊
#ascii_upload_enable=YES
#ascii_download_enable=YES

# 登錄FTP服務(wù)器時(shí)顯示的歡迎信息
# 如有需要，可在更改目錄歡迎信息的目錄下創(chuàng)建名為.message的文件，并寫入歡迎信息保存后
#ftpd_banner=Welcome to blah FTP service.

# 黑名單設(shè)置。如果很討厭某些email address，就可以使用此設(shè)定來(lái)取消他的登錄權(quán)限
# 可以將某些特殊的email address抵擋住。
#deny_email_enable=YES

# 當(dāng)上面的deny_email_enable=YES時(shí)，可以利用這個(gè)設(shè)定項(xiàng)來(lái)規(guī)定哪些郵件地址不可登錄vsftpd服務(wù)器
# 此文件需用戶自己創(chuàng)建，一行一個(gè)email address即可
#banned_email_file=/etc/vsftpd/banned_emails

# You may specify an explicit list of local users to chroot() to their home
# directory. If chroot_local_user is YES, then this list becomes a list of
# users to NOT chroot().
# (Warning! chroot'ing can be very dangerous. If using chroot, make sure that
# the user does not have write access to the top level directory within the
# chroot)
chroot_local_user=YES

#  允許 chroot 用戶具備寫權(quán)限
allow_writeable_chroot=YES
#當(dāng)chroot_list_enable=YES，chroot_local_user=YES時(shí)，在/etc/vsftpd.chroot_list文件中列出的用戶，可以切換到其他目錄；未在文件中列出的用戶，不能切換到其他目錄。
#當(dāng)chroot_list_enable=YES，chroot_local_user=NO時(shí)，在/etc/vsftpd.chroot_list文件中列出的用戶，不能切換到其他目錄；未在文件中列出的用戶，可以切換到其他目錄。
#當(dāng)chroot_list_enable=NO，chroot_local_user=YES時(shí)，所有的用戶均不能切換到其他目錄。
#當(dāng)chroot_list_enable=NO，chroot_local_user=NO時(shí)，所有的用戶均可以切換到其他目錄。
chroot_list_enable=YES

# 被列入此文件的用戶，在登錄后將不能切換到自己目錄以外的其他目錄
# 從而有利于FTP服務(wù)器的安全管理和隱私保護(hù)。此文件需自己建立
#chroot_list_file=/etc/vsftpd/chroot_list
#
# 是否允許遞歸查詢。默認(rèn)為關(guān)閉，以防止遠(yuǎn)程用戶造成過(guò)量的I/O
#ls_recurse_enable=YES
#
# 是否允許監(jiān)聽。
# 如果設(shè)置為YES，則vsftpd將以獨(dú)立模式運(yùn)行，由vsftpd自己監(jiān)聽和處理IPv4端口的連接請(qǐng)求
listen=YES
#
# 設(shè)定是否支持IPV6。如要同時(shí)監(jiān)聽I(yíng)Pv4和IPv6端口，
# 則必須運(yùn)行兩套vsftpd，采用兩套配置文件
# 同時(shí)確保其中有一個(gè)監(jiān)聽選項(xiàng)是被注釋掉的
# listen_ipv6=NO

# 設(shè)置是否阻扯user_list文件中的用戶登錄FTP服務(wù)器，默認(rèn)為YES
#userlist_deny=YES/NO

# 設(shè)置PAM外掛模塊提供的認(rèn)證服務(wù)所使用的配置文件名，即/etc/pam.d/vsftpd文件
# 此文件中file=/etc/vsftpd/ftpusers字段，說(shuō)明了PAM模塊能抵擋的帳號(hào)內(nèi)容來(lái)自文件/etc/vsftpd/ftpusers中
pam_service_name=vsftpd

# 是否允許ftpusers文件中的用戶登錄FTP服務(wù)器，默認(rèn)為NO
# 若此項(xiàng)設(shè)為YES，則user_list文件中的用戶允許登錄FTP服務(wù)器
# 而如果同時(shí)設(shè)置了userlist_deny=YES，則user_list文件中的用戶將不允許登錄FTP服務(wù)器，甚至連輸入密碼提示信息都沒有
userlist_enable=YES
# 是否使用tcp_wrappers作為主機(jī)訪問控制方式。
# tcp_wrappers可以實(shí)現(xiàn)linux系統(tǒng)中網(wǎng)絡(luò)服務(wù)的基于主機(jī)地址的訪問控制
# 在/etc目錄中的hosts.allow和hosts.deny兩個(gè)文件用于設(shè)置tcp_wrappers的訪問控制
# 前者設(shè)置允許訪問記錄，后者設(shè)置拒絕訪問記錄。
# 如想限制某些主機(jī)對(duì)FTP服務(wù)器192.168.57.2的匿名訪問，編緝/etc/hosts.allow文件，如在下面增加兩行命令：
# vsftpd:192.168.57.1:DENY 和vsftpd:192.168.57.9:DENY
# 表明限制IP為192.168.57.1/192.168.57.9主機(jī)訪問IP為192.168.57.2的FTP服務(wù)器
# 此時(shí)FTP服務(wù)器雖可以PING通，但無(wú)法連接
tcp_wrappers=YES

#開啟被動(dòng)模式
pasv_enable=YES
# 傳輸文件的端口范圍，如果是云服務(wù)器記得開放端口，linux服務(wù)器本身也要開放端口
pasv_min_port=9000
pasv_max_port=9005

connect_from_port_20=NO(默認(rèn)為YES) #設(shè)置是否允許主動(dòng)模式
pasv_enable=YES(默認(rèn)為YES) #設(shè)置是否允許被動(dòng)模式
pasv_min_port=50000(default:0(use any port))
pasv_max_port=60000(default:0(use any port))

connect_from_port_20=YES
pasv_enable=NO

useradd -d /home/ftp/compass -s /sbin/nologin  compass
passwd compass

mkdir -p /home/ftp/compass

chown -R compass:compass /home/ftp/compass

[root@master ~]# setsebool -P allow_ftpd_full_access on
[root@master ~]# setsebool -P tftp_home_dir on

[root@master ~]# systemctl restart vsftpd

    chroot_local_user=YES  #原本就有，取掉注釋就好
    allow_writeable_chroot=YES   #添加
    chown compass:compass -R /home/ftp/compass

       <!--    ftp上傳下載-->
        <dependency>
            <groupId>commons-net</groupId>
            <artifactId>commons-net</artifactId>
            <version>3.7</version>
        </dependency>

import javax.servlet.http.HttpServletResponse;
import java.io.InputStream;
import java.io.OutputStream;

/**
 * ftp文件服務(wù)器操作接口
 *
 * @author compass
 * @date 2022/10/19 15:00
 * @since 1.0.0
 **/
public interface FtpService {

    /**
     * 上傳文件到ftp
     *
     * @param inputStream 輸入流
     * @param fileName    新的文件名，包含拓展名
     * @param filePath    保存路徑
     * @return
     * @author compass
     */
    Boolean uploadFile(InputStream inputStream, String fileName, String filePath);

    /**
     * 下載ftp文件，直接轉(zhuǎn)到輸出流
     * @author compass
     * @param ftpFilePath
     * @author compass
     */
    byte[] downloadFileBytes(String ftpFilePath, HttpServletResponse response);

    /**
     * 刪除ftp文件
     * @author compass
     * @param ftpFilePath ftp下文件路徑，根目錄開始
     * @return
     */
    Boolean deleteFile(String ftpFilePath);
}

/**
 * @author compass
 * @date 2022-10-19
 * @since 1.0
 **/

import java.io.*;

import compass.token.pocket.com.common.AjaxResult;
import compass.token.pocket.com.entity.FtpInstanceEntity;
import compass.token.pocket.com.service.FtpService;
import compass.token.pocket.com.utils.ResponseUtil;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.net.ftp.FTP;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPReply;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletResponse;

@Slf4j
@Service
public class FtpServiceImpl implements FtpService {

    @Resource
    FtpInstanceEntity ftpInstanceEntity;

    /**
     * 上傳文件到ftp
     *
     * @param inputStream 輸入流
     * @param fileName    新的文件名，包含拓展名
     * @param filePath    保存路徑
     * @return
     * @author compass
     */
    @Override
    public Boolean uploadFile(InputStream inputStream, String fileName, String filePath) {
        // 定義保存結(jié)果
        boolean isSuccess = false;
        // 初始化連接
        FTPClient ftp = connectFtpServer();
        if (ftp != null) {
            try {
                // 設(shè)置文件傳輸模式為二進(jìn)制，可以保證傳輸?shù)膬?nèi)容不會(huì)被改變
                ftp.setFileType(FTP.BINARY_FILE_TYPE);
                //注：上傳文件都為0字節(jié)，設(shè)置為被動(dòng)模式即可
                ftp.enterLocalPassiveMode();
                // 跳轉(zhuǎn)到指定路徑，逐級(jí)跳轉(zhuǎn)，不存在的話就創(chuàng)建再進(jìn)入
                toPathOrCreateDir(ftp, filePath);
                // 上傳文件 參數(shù)：上傳后的文件名，輸入流,,返回Boolean類型，上傳成功返回true
                isSuccess = ftp.storeFile(fileName, inputStream);
                // 關(guān)閉輸入流
                inputStream.close();
                // 退出ftp
                ftp.logout();
            } catch (IOException e) {
                log.error(e.toString());
            } finally {
                if (ftp.isConnected()) {
                    try {
                        // 斷開ftp的連接
                        ftp.disconnect();
                    } catch (IOException ioe) {
                        log.error(ioe.toString());
                    }
                }
            }
        }
        return isSuccess;
    }

    /**
     * 下載ftp文件，直接轉(zhuǎn)到輸出流
     *
     * @param ftpFilePath
     * @author compass
     */
    @Override
    public byte[] downloadFileBytes(String ftpFilePath , HttpServletResponse response) {
        FTPClient ftp = connectFtpServer();
        try {
            ByteArrayOutputStream stream = new ByteArrayOutputStream();
            ftp.setFileType(FTPClient.BINARY_FILE_TYPE);
            ftp.enterLocalPassiveMode();
            boolean retrieveFile = ftp.retrieveFile(ftpFilePath, stream);
            if (!retrieveFile){
                throw new RuntimeException("FTP文件下載失敗");
            }
            ftp.logout();
            return stream.toByteArray();
        } catch (Exception e) {
            log.error("FTP文件下載失敗！" + e.toString());
            ResponseUtil.response(response,AjaxResult.businessError(e.getMessage(), "-1"));
            throw new RuntimeException(e.getMessage());
        } finally {
            if (ftp.isConnected()) {
                try {
                    ftp.disconnect();
                } catch (IOException ioe) {
                    log.error(ioe.toString());
                }
            }

        }
    }

    /**
     * 刪除ftp文件
     * @param ftpFilePath 文件路徑
     * @return java.lang.Boolean
     * @author compass
     * @date 2022/10/19 18:35
     * @since 1.0.0
     **/
    @Override
    public Boolean deleteFile(String ftpFilePath ) {
        FTPClient ftp = connectFtpServer();
        boolean result = false;
        try {
            result = ftp.deleteFile(ftpFilePath);
            ftp.logout();
            return result;
        } catch (Exception e) {
            log.error("FTP文件刪除失??！" + e.toString());
        } finally {
            if (ftp.isConnected()) {
                try {
                    ftp.disconnect();
                } catch (IOException ioe) {
                    log.error(ioe.toString());
                }
            }
        }
        return result;
    }

    /**
     * 創(chuàng)建FTPClient對(duì)象
     *
     * @return org.apache.commons.net.ftp.FTPClient
     * @author compass
     * @date 2022/10/19 18:35
     * @since 1.0.0
     **/
    private FTPClient connectFtpServer() {
        // 創(chuàng)建FTPClient對(duì)象（對(duì)于連接ftp服務(wù)器，以及上傳和上傳都必須要用到一個(gè)對(duì)象）
        FTPClient ftpClient = new FTPClient();
        // 設(shè)置連接超時(shí)時(shí)間
        ftpClient.setConnectTimeout(1000 * 10);
        // 設(shè)置ftp字符集
        ftpClient.setControlEncoding("utf-8");
        // 設(shè)置被動(dòng)模式，文件傳輸端口設(shè)置,否則文件上傳不成功，也不報(bào)錯(cuò)
        ftpClient.enterLocalPassiveMode();
        try {
            // 定義返回的狀態(tài)碼
            int replyCode;
            // 連接ftp(當(dāng)前項(xiàng)目所部署的服務(wù)器和ftp服務(wù)器之間可以相互通訊，表示連接成功)
            ftpClient.connect(ftpInstanceEntity.getHost());
            // 輸入賬號(hào)和密碼進(jìn)行登錄
            ftpClient.login(ftpInstanceEntity.getUsername(), ftpInstanceEntity.getPassword());
            // 接受狀態(tài)碼(如果成功，返回230，如果失敗返回503)
            replyCode = ftpClient.getReplyCode();
            // 根據(jù)狀態(tài)碼檢測(cè)ftp的連接，調(diào)用isPositiveCompletion(reply)-->如果連接成功返回true，否則返回false
            if (!FTPReply.isPositiveCompletion(replyCode)) {
                log.info("connect ftp {} failed", ftpInstanceEntity.getHost());
                // 說(shuō)明連接失敗，需要斷開連接
                ftpClient.disconnect();
                throw new RuntimeException(String.format("connect ftp %s failed", ftpInstanceEntity.getHost()));
            }
            log.info("連接狀態(tài)碼:" + replyCode);
        } catch (IOException e) {
            log.error("connect fail:" + e.toString());
            throw new RuntimeException(String.format("connect ftp %s error", ftpInstanceEntity.getHost()));
        }
        return ftpClient;
    }

    /**
     * 跳轉(zhuǎn)到指定路徑 不存在就創(chuàng)建
     *
     * @param ftp      操作ftp對(duì)象
     * @param filePath 文件路徑
     * @return void
     * @author compass
     * @date 2022/10/19 15:05
     * @since 1.0.0
     **/
    private void toPathOrCreateDir(FTPClient ftp, String filePath) throws IOException {
        String[] dirs = filePath.split("/");
        for (String dir : dirs) {
            if (StringUtils.isEmpty(dir)) {
                continue;
            }
            if (!ftp.changeWorkingDirectory(dir)) {
                ftp.makeDirectory(dir);
                ftp.changeWorkingDirectory(dir);
            }
        }
    }

}

ftp:
  #ftp服務(wù)器的地址
  host: 127.0.0.1
  #ftp服務(wù)器的端口號(hào)（連接端口號(hào)）
  port: 21
  #ftp的用戶名
  username: compass
  #ftp的密碼
  password: 6317738ef8324199a24602308f3a9a18
  #ftp上傳的根目錄
  basePath: /home/ftp/compass
  #回顯地址
  httpPath: ftp://127.0.0.1

import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;

@Data
@Configuration
@ConfigurationProperties(prefix = "ftp")
public class FtpInstanceEntity {
    /**
     * ftp服務(wù)器的地址
     */
    private String host;
    /**
     * ftp服務(wù)器的端口號(hào)（連接端口號(hào)）
     */
    private String port;
    /**
     * ftp的用戶名
     */
    private String username;
    /**
     * ftp的密碼
     */
    private String password;
    /**
     * ftp上傳的根目錄
     */
    private String basePath;
    /**
     * 回顯地址
     */
    private String httpPath;

}

package compass.token.pocket.com.controller;

import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.IdUtil;
import compass.token.pocket.com.common.AjaxResult;
import compass.token.pocket.com.entity.FtpInstanceEntity;
import compass.token.pocket.com.service.FtpService;
import compass.token.pocket.com.utils.FileUtils;
import compass.token.pocket.com.utils.ResponseUtil;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.io.FilenameUtils;
import org.apache.commons.lang3.StringUtils;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;

import javax.annotation.Resource;
import javax.servlet.ServletOutputStream;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.*;
import java.net.URLEncoder;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;

/**
 * 文件測(cè)試控制器
 * @author compass
 * @date 2022/10/27 22:41
 * @since 1.0.0
 **/
@Slf4j
@RestController
@RequestMapping("/fileTestController")
public class FileTestController {

    @Resource
    private FtpService ftpService;

    @Resource
    FtpInstanceEntity ftpInstanceEntity;


    /**
     * ftp服務(wù)器文件上傳
     * @param file 需要上傳的文件
     * @return compass.token.pocket.com.common.AjaxResult<java.lang.String>
     * @author compass
     * @date 2022/10/19 14:51
     * @since 1.0.0
     **/
    @PostMapping(value = "/pdfUpload")
    public AjaxResult<String> pdfUpload(@RequestParam("file") MultipartFile file) {
        try {
            String fileDir = DateUtil.format(new Date(), "yyyy-MM-dd");
            boolean upload = ftpService.uploadFile(file.getInputStream(), file.getOriginalFilename(), fileDir);
            if (upload) {
                String savePath = ftpInstanceEntity.getBasePath() + "/" + fileDir + "/" + file.getOriginalFilename();
                return AjaxResult.success("上傳成功", savePath);
            } else {
                return new AjaxResult<>("file upload error");
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
        return new AjaxResult<>("file upload error");
    }

    /**
     * ftp服務(wù)器文件下載
     * @param ftpPath 需要下載的文件路徑
     * @return compass.token.pocket.com.common.AjaxResult<java.lang.String>
     * @author compass
     * @date 2022/10/19 14:51
     * @since 1.0.0
     **/
    @GetMapping(value = "/pdfDownload", produces = "application/octet-stream")
    public void downloadFile(@RequestParam("ftpPath") String ftpPath, HttpServletRequest request, HttpServletResponse response) {
        String userAgent = request.getHeader("User-Agent");
        String fileName = ftpPath.substring(ftpPath.lastIndexOf('/') + 1);
        try {
            if (userAgent.contains("MSIE") || userAgent.contains("Trident")) {
                //IE瀏覽器處理
                fileName = URLEncoder.encode(fileName, "UTF-8");
            } else {
                // 非IE瀏覽器的處理：
                fileName = new String(fileName.getBytes("UTF-8"), "ISO-8859-1");
            }
            response.setHeader("Content-Disposition", "attachment; filename=" + fileName);
            response.setContentType("application/octet-stream; charset=UTF-8");
            byte[] bytes = ftpService.downloadFileBytes( ftpPath,response);
            ServletOutputStream outputStream = response.getOutputStream();
            outputStream.write(bytes);
            outputStream.flush();

        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
     * ftp服務(wù)器文件刪除
     * @param ftpPath 需要?jiǎng)h除的文件路徑
     * @return compass.token.pocket.com.common.AjaxResult<java.lang.Boolean>
     * @author compass
     * @date 2022/10/19 14:51
     * @since 1.0.0
     **/
    @PostMapping("ftpDeleteFile")
    public AjaxResult<Boolean> ftpDeleteFile(@RequestParam("ftpPath") String ftpPath){
        Boolean isSuccess = ftpService.deleteFile(ftpPath);
        if (isSuccess){
             return  AjaxResult.success("刪除成功", true);
        }else {
            return  AjaxResult.businessError("刪除失敗", false);
        }

    }

}