上传下载文件实例（vsftp服务器+nginx）

页面（上传+下载）

<form action="/pic/upload" enctype="multipart/form-data" method="post">

<input type="text" name="username"><br>

<input type="password" name="password"><br>

<input type="file" name="pic"><br>

<input type="submit" value="提交">

</form>

写实体类（pojo）

public class User {

private Integer uid;

private String username;

private String password;

private String picture;}}

写mapper接口

public interface UserMapper {

int insert(User record);

List<User> select();

}

写mapper.xml

<?xml version="1.0" encoding="UTF-8"?>

<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >

<mapper namespace="com.example.dao.UserMapper">

<insert id="insert" parameterType="User">

insert into imageupload(username,password,picture) values

(#{username,jdbcType=CHAR},#{password,jdbcType=CHAR},#{picture,jdbcType=CHAR})

</insert>

<select id="select" resultMap="User">

select * from imageupload

</select>

</mapper>

 

写UserService

public interface UserService {

public void insertUser(User user);

public List<User> selectUser();

}

写UserServiceImpl

@Service

public class UserServiceImpl implements UserService{

@Autowired(required=true)

private UserMapper userMapper;

@Override

public void insertUser(User user) {

userMapper.insert(user);

}

@Override

public List<User> selectUser() {

return userMapper.select();

}

}

写工具类IDUtils（用来生成文件名）

public class IDUtils {

public static String genImageName() {

//取当前时间的长整型值包含毫秒

long millis=System.currentTimeMillis();

//long millis=System.nanoTime();

//加上三位随机数

Random random=new Random();

int end3=random.nextInt(999);//返回从这个随机数生成器的序列中抽取的一个伪随机数，

//如果不足三位前面补0

String str=millis+String.format("%03d", end3);

return str;

}

}

写操作文件上传下载类FtpUtils

public class FtpUtils {

/**

* Description:向FTP服务器上传文件

* @param host FTP服务器ip

* @param port FTP服务器端口

* @param username FTP登录账号

* @param password FTP登录密码

* @param basePath FTP服务器基础目录，/home/ftpuser/images

* @param filePath FTP服务器文件存放路径。例如分日期存放：、2018/05/28.文件的路径为basePath+filePath

* @param fileName 上传到F服务器上的文件名

* @param input 输入流

* @return 成功返回true。否则返回false

*/

public static boolean uploadFile(String host,int port,String username,String password,String basePath,

String filePath,String fileName,InputStream input) {

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();//返回最后一个FTP应答的应答代码的整数值。

System.out.println("reply="+reply);

if(!FTPReply.isPositiveCompletion(reply)) {//如果应答代码是一个正完成响应(以2开头的230)，则为True;如果不是，则为false。

ftp.disconnect();

return result;

}

if(!ftp.changeWorkingDirectory(basePath+fileName)) {//如果目录不存在的话就创建目录

String[] dirs=filePath.split("/");

String tempPath=basePath;///home/ftpuser/images

for(String dir:dirs) {

if(null==dir||"".equals(dir)) {

continue;

}

tempPath+=""+dir;

if(!ftp.changeWorkingDirectory(tempPath)) {//如果更改FTP会话的当前工作目录失败

if(!ftp.makeDirectory(tempPath)) {//如果创建一个新的子目录失败的话。

return result;//返回false

}else {

ftp.changeWorkingDirectory(tempPath);//如果创建成功则更改FTP会话的当前工作目录

}

}

}//整合for循环是为了

}//整个if是为了创建设置的目录

//设置为被动模式

ftp.enterLocalPassiveMode();

//设置上传文件的类型为二进制类型

ftp.setFileType(FTP.BINARY_FILE_TYPE);

//上传文件

if(!ftp.storeFile(fileName, input)) {//读取本地文件失败

return result;

}

input.close();

ftp.logout();//通过发送QUIT命令退出FTP服务器

result=true;

} catch (IOException e) {

e.printStackTrace();

}finally {

if(ftp.isConnected()) {//如果客户机当前连接到服务器

try {

ftp.disconnect();//关闭到FTP服务器的连接，并将连接参数恢复到默认值。

} catch (IOException e) {

e.printStackTrace();

}

}

}

return result;

}

}

些控制台类UserController

@Controller

public class UserController {

@Value("${FTP.PORT}")

private int port;//端口

@Value("${FTP.USERNAME}")

private String userName;//用户名

@Value("${FTP.PASSWORD}")

private String passWord;//密码

@Value("${FTP.BASEPATH}")

private String basePath;//文件在服务器端保存的主目录

@Value("${IMAGE.BASE.URL}")

private String baseUrl;//访问图片时的基础url

@Autowired

private UserService userService;

@RequestMapping("/test")

public String index() {

return "index";

}

@RequestMapping("/pic/upload")

@ResponseBody

public String pictureUpload2(@RequestParam("pic")MultipartFile uploadFile,@RequestParam("username")String username,@RequestParam("password")String password) {

//给上传的图片生成新的文件名

try {

//获取原始文件名

String oldName = uploadFile.getOriginalFilename(); //返回客户机文件系统中的原始文件名。

//使用IDUtils工具类生成新的文件名，新文件名=newName+文件名后缀

String newName=IDUtils.genImageName();

newName=newName+oldName.substring(oldName.lastIndexOf("."));

//生成文件在服务器daunt存储的子目录

String filePath=new Date().toString();

//服务器ip

String host="192.168.172.128";

//把前端输入信息，包括图片的url保存到数据库

User user=new User();

user.setUsername(username);

user.setPassword(password);

user.setPicture(baseUrl+"/"+filePath+"/"+newName);

userService.insertUser(user);

//把图片上传搭配图片服务器

//获取上传的io流

InputStream input=uploadFile.getInputStream();

//调用FtpUtil工具类进行上传

boolean result=FtpUtils.uploadFile(host, port, userName, passWord, basePath, filePath, newName, input);

if(result) {

return "success";

}else {

return "false";

}

} catch (IOException e) {

return "false";

}

}