赞
踩
controller 类
@PostMapping(value = "uploadImg")
@ResponseBody
public Object uploadImg(MultipartFile[] files){
return new DataResult("保存成功!",StatusCode.SUCCESS.getCode(),service.uploadImage(files));
}
service类:
配置文件里:
ImageUpload:
address: /usr/local/nginx/html/images/
imageport: 8088
server: 192.168.7.109
FTP_PORT: 21
FTP_USERNAME: root
FTP_PASSWORD: root
@Service
public class ImageConfigService {
private Logger log=LogManager.getLogger(ImageConfigService.class);
@Value("${ImageUpload.FTP_PORT}")
private String ftpPort ;
@Value("${ImageUpload.FTP_USERNAME}")
private String ftpUsername ;
@Value("${ImageUpload.FTP_PASSWORD}")
private String ftpPassword ;
@Value("${ImageUpload.address}")
String imageAddress;
@Value("${ImageUpload.imageport}")
private String imageport;
@Value("${ImageUpload.server}")
private String server;
@Value("${spring.datasource.primary.driverClassName}")
String driverName;
@Resource
@Qualifier("primaryJdbcTemplate")
JdbcTemplate jdbcTemplate;
public Object uploadImage(MultipartFile[] files) {
String tableName=getTableName("gsa_data_homeimage");
Map<String, String> resObj = new HashMap<>();
String urlImage="";
try {
String images="";
for(MultipartFile file:files) {
String path = "homeImage/";//存储路径+file.getOriginalFilename()
urlImage="http://"+server+":"+imageport+"/images/homeImage/"+file.getOriginalFilename();
log.info("urlImage:"+urlImage);
FtpUtil.uploadFile(server, ftpPort, ftpUsername, ftpPassword, imageAddress, path, file.getOriginalFilename(), file.getInputStream());
images+=urlImage+",";
}
images=images.substring(0,images.length()-1);
String sql="insert into "+tableName+"(imageurl,createtime) values('"+images+"','"+DateUtil.format()+"')";
jdbcTemplate.execute(sql);
} catch (IOException e) {
e.printStackTrace();
}
return resObj;
}
}
FtpUtil 工具类:
public class FtpUtil {
/**
* 得到真实文件名
*
* @param fileName
* @return
*/
public static String subFileName(String fileName) {
// 查找最后一个 \ (文件分隔符)位置
int index = fileName.lastIndexOf(File.separator);
if (index == -1) {
// 没有分隔符,说明是真实名称
return fileName;
} else {
return fileName.substring(index + 1);
}
}
/**
* 获得随机UUID文件名
*
* @param fileName
* @return
*/
public static String generateRandonFileName(String fileName) {
// 首相获得扩展名,然后生成一个UUID码作为名称,然后加上扩展名
String ext = fileName.substring(fileName.lastIndexOf("."));
return UUID.randomUUID().toString() + ext;
}
public static String generateRandonFileName() {
return UUID.randomUUID().toString();
}
/**
* 获得hashcode 生成二级目录
*
* @param uuidFileName
* @return
*/
public static String generateRandomDir(String uuidFileName) {
int hashCode = uuidFileName.hashCode();// 得到它的hashcode编码
// 一级目录
int d1 = hashCode & 0xf;
// 二级目录
int d2 = (hashCode >> 4) & 0xf;
return "/" + d1 + "/" + d2;
}
/**
* Description: 向FTP服务器上传文件
*
* @param host
* FTP服务器hostname
* @param port
* FTP服务器端口
* @param username
* FTP登录账号
* @param password
* FTP登录密码
* @param basePath
* FTP服务器基础目录
* @param filePath
* FTP服务器文件存放路径。
* @param filename
* 上传到FTP服务器上的文件名
* @param input
* 输入流
* @return 成功返回true,否则返回false
*/
public static boolean uploadFile(String host, String ftpPort, String username, String password, String basePath,
String filePath, String filename, InputStream input) {
int port = Integer.parseInt(ftpPort);
boolean result = false;
FTPClient ftp = new FTPClient();
try {
int reply;
ftp.connect(host, port);// 连接FTP服务器
// 如果采用默认端口,可以使用ftp.connect(host)的方式直接连接FTP服务器
ftp.login(username, password);// 登录
reply = ftp.getReplyCode();
if (!FTPReply.isPositiveCompletion(reply)) {
ftp.disconnect();
return result;
}
// 切换到上传目录
if (!ftp.changeWorkingDirectory(basePath + filePath)) {
// 如果目录不存在创建目录
String[] dirs = filePath.split("/");
String tempPath = basePath;
for (String dir : dirs) {
if (null == dir || "".equals(dir))
continue;
tempPath += "/" + dir;
if (!ftp.changeWorkingDirectory(tempPath)) {
if (!ftp.makeDirectory(tempPath)) {
return result;
} else {
ftp.changeWorkingDirectory(tempPath);
}
}
}
}
// 设置上传文件的类型为二进制类型
ftp.setFileType(FTP.BINARY_FILE_TYPE);
ftp.enterLocalPassiveMode();// 这个设置允许被动连接--访问远程ftp时需要
// 上传文件
if (!ftp.storeFile(filename, input)) {
return result;
}
reply = ftp.getReplyCode();
input.close();
ftp.logout();
result = true;
} catch (IOException e) {
e.printStackTrace();
} finally {
if (ftp.isConnected()) {
try {
ftp.disconnect();
} catch (IOException ioe) {
}
}
}
return result;
}}
解决 vsftp上传553 Could not create file错误 https://blog.csdn.net/u010194538/article/details/80481691
553还有可能就是没有权限,如果是别人搭建的ftp可能会设置只给某个路径有权限,其它路径都上传不了
先运行getsebool -a | grep ftp (查看selinux里有哪些关于ftp的)
allow_ftpd_anon_write –> off
allow_ftpd_full_access –> off
allow_ftpd_use_cifs –> off
allow_ftpd_use_nfs –> off
ftp_home_dir –> off
ftpd_connect_db –> off
httpd_enable_ftp_server –> off
sftpd_anon_write –> off
sftpd_enable_homedirs –> off
sftpd_full_access –> off
sftpd_write_ssh_home –> off
tftp_anon_write –> off
接下来我们allow_ftpd_anon_write allow_ftpd_full_access 这两个ON掉。
setsebool -P allow_ftpd_anon_write on
setsebool -P allow_ftpd_full_access on
参考下面这个地址,有各种文件状态码说明,解决连接不上ftp的错误
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。