| | |
| | | import org.apache.commons.lang3.StringUtils; |
| | | import org.apache.commons.net.ftp.FTPClient; |
| | | import org.apache.commons.net.ftp.FTPClientConfig; |
| | | import org.apache.commons.net.ftp.FTPFile; |
| | | import org.apache.commons.net.ftp.FTPReply; |
| | | import org.springframework.stereotype.Component; |
| | | |
| | |
| | | ftpClient.connect(FtpFileConfig.getHostname(), FtpFileConfig.getPort()); |
| | | if (FTPReply.isPositiveCompletion(ftpClient.getReplyCode())) { |
| | | log.info("连接ftp成功!"); |
| | | ftpClient.login(FtpFileConfig.getUsername(), FtpFileConfig.getPassword()); |
| | | boolean login = ftpClient.login(FtpFileConfig.getUsername(), FtpFileConfig.getPassword()); |
| | | log.info("登录ftp成功:{}",login); |
| | | if (FTPReply.isPositiveCompletion(ftpClient.getReplyCode())) { |
| | | // 设置以二进制方式传输 |
| | | ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE); |
| | |
| | | ftpClient.setFileTransferMode(FTPClient.STREAM_TRANSFER_MODE); |
| | | // 设置缓冲区大小 |
| | | ftpClient.setBufferSize(1024); |
| | | |
| | | log.info("登录ftp成功!"); |
| | | flag = true; |
| | | } else { |
| | |
| | | try { |
| | | fileName = new String(fileName.getBytes("UTF-8"), "iso-8859-1"); |
| | | log.info("上传文件名为:" + fileName); |
| | | ftpClient.storeFile(fileName, fileInputStream); |
| | | boolean b = ftpClient.storeFile(fileName, fileInputStream); |
| | | String status = ftpClient.getStatus(); |
| | | log.info("上传状态:{},{}" ,b, status); |
| | | int reply = ftpClient.getReplyCode(); |
| | | if (FTPReply.isPositiveCompletion(reply)) { |
| | | flag = true; |