SpringBoot集成FTP文件服务器简单应用方式

	 	<dependency>
            <groupId>commons-net</groupId>
            <artifactId>commons-net</artifactId>
            <version>3.10.0</version>
        </dependency>

import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;

/**
 * FTP参数配置文件
 *
 * @author chenlirun
 * @since 2024/3/25
 */
@Data
@Component
@ConfigurationProperties(prefix = "spring.ftp")
public class FtpProperties {

	/**
	 * 服务器地址
	 */
	private String host;

	/**
	 * 服务器端口
	 */
	private int port;

	/**
	 * 用户名
	 */
	private String userName;

	/**
	 * 密码
	 */
	private String password;

	/**
	 * 工作目录
	 */
	private String baseUrl;
}

spring:
  ftp:
    host: localhost
    port: 21
    user-name: root
    password: root
    base-url: /demoFile

import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.io.IOUtils;
import org.apache.commons.net.ftp.FTPClient;
import org.springframework.beans.factory.annotation.Value;
import java.io.InputStream;
import java.nio.charset.StandardCharsets;
import java.time.Duration;

@Slf4j
public class FTPServer {

	@Value("${spring.ftp.host}")
	private String host;

	@Value("${spring.ftp.port}")
	private int port;

	@Value("${spring.ftp.username}")
	private String userName;

	@Value("${spring.ftp.password}")
	private String password;

	@Value("${spring.ftp.base-url}")
	private String baseUrl;


	@SneakyThrows
	public void uploadFile() {
		// FTP服务器初始化属性
		FTPClient ftpClient = new FTPClient();
		// 连接FTP服务器
		ftpClient.connect(host, port);
		if (!ftpClient.isConnected()) {
			log.error("FTP服务器连接失败");
		}
		// 登录FTP服务器
		boolean login = ftpClient.login(userName, password);
		if (!login) {
			ftpClient.logout();
			ftpClient.disconnect();
			log.error("FTP服务器登录失败");
		}
		// 设置FTP字符编码
		ftpClient.setControlEncoding("utf-8");
		//设置超时时间
		ftpClient.setDataTimeout(Duration.ofSeconds(3));
		//设置传输文件的类型，这里我设置成二进制，保证文件不丢包
		ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);

		// 设置被动模式
		ftpClient.enterLocalPassiveMode();

		//切换FTP工作目录
		boolean isChangeWorkingDir = ftpClient.changeWorkingDirectory(baseUrl);
		if (!isChangeWorkingDir) {
			log.error("切换指定工作目录失败了！！！");
		}

		/**
		 * 上传文件到FTP服务器
		 */
		// 将字符串转成InputStream
		InputStream inputStream = IOUtils.toInputStream("aaaa", StandardCharsets.UTF_8);//
		String fileName = "demo.txt";
		//将InputStream流上传到FTP并保存成alarm.txt
		boolean b = ftpClient.storeFile(fileName, inputStream);
		if (!b) {
			log.error("文件上传FTP服务器失败！！！");
		}
		// 关闭流，释放资源
		inputStream.close();
		// 如果FTP处于连接状态，则关闭连接和登录
		if (ftpClient.isConnected()) {
			ftpClient.logout();
			ftpClient.disconnect();
		}
	}
}