**
 
一、使用docker 安装 vsftpd**
 
参考文档：https://blog.csdn.net/qq_41201816/article/details/83930133
 使用docker部署文件服务器：
 
1.1 获取镜像
 
#寻找vsftpd的镜像
 
1.1.1.docker search vsftpd
 
 
1.1.2.docker pull fauria/vsftpd
 
 
1.2 创建vsftpd容器
 
docker run -d -p 21:21 -p 20:20 -p 21100-21110:21100-21110 -v /Ftpfile:/home/vsftpd -e FTP_USER=连接用户名 -e FTP_PASS=连接密码 -e PASV_ADDRESS=你的ip -e PASV_MIN_PORT=21100 -e PASV_MAX_PORT=21110 --name vsftpd --restart=always fauria/vsftpd
 
 
注释说明：
 #FTP_USER : 设置远程连接的账户名
 #FTP_PASS : 远程连接的密码
 #-p进行端口绑定映射
 -v进行文件目录的映射 FTP_UESR 和FTP_PASS如果设定了会在container里面的
 #/etc/vsftpd/virtual_users.txt
 #PASV_MIN_PORT和PASV_MAX_PORT映射的是被动模式下端口使用范围
 #PASV_ADDRESS指的的宿主机地址
 
1.3 修改配置
 
1、我们先进入container里面
 docker exec -i -t vsftpd bash
 2、修改并生成虚拟用户模式下的用户db文件
 vi /etc/vsftpd/virtual_users.txt
 #编辑配置文件写入用户跟密码
 3、假如我们添加了user用户
 mkdir /home/vsftpd/user #建立新用户文件夹
 /usr/bin/db_load -T -t hash -f /etc/vsftpd/virtual_users.txt /etc/vsftpd/virtual_users.db
 #把登录的验证信息写入数据库
 
1.4 重启，使用Xftp验证连接
 
先退出容器 ：Ctrl +d
 重启vsftpd 服务： docker restart vsftpd
 
二、Java 实现文件上传**
 
2.1 引入maven 依赖
 
<dependency>
        <groupId>commons-net</groupId>
        <artifactId>commons-net</artifactId>
        <version>3.3</version>
</dependency>
 
2.2 编写文件上传方法
 
/**
 
 
保存图片到文件服务器
 
 
@param file
 
 
@return
 */
 public static String uploadImageToFileServer(MultipartFile file) {
 
     if(file.getSize() > EViewConstant.FtpFileServer.SIZE){
         log.info("上传的文件大小超过10mb");
         return  "";
     }
     InputStream inputStream = null;
 
     String fileName = file.getOriginalFilename();
     //获取文件的格式
     String fileType = fileName.substring(fileName.indexOf(".")).toLowerCase().trim();
     //生成一个随机的文件名，避免重名覆盖
     String randomString= UUID.randomUUID().toString().replaceAll("-","");
     String fileNewName = randomString+fileType;
 
     FTPClient ftpClient = new FTPClient();
     try{
         //连接到FTP 服务器
         ftpClient.connect(EViewConstant.FtpFileServer.HOST, EViewConstant.FtpFileServer.PORT);
         ftpClient.login(EViewConstant.FtpFileServer.USER_NAME,EViewConstant.FtpFileServer.PASSWORD);
         //ftpClient.setFileTransferMode(FTP.STREAM_TRANSFER_MODE);
         ftpClient.changeWorkingDirectory("/Ftpfile/eiot");
         //ftp上传文件是以文本形式传输的，所以多媒体文件会失真，需要转为二进制形式传输
         ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
         if (!FTPReply.isPositiveCompletion(ftpClient.getReplyCode())) {
             log.info("未连接到FTP，用户名或密码错误。");
             ftpClient.disconnect();
         } else {
             log.info("FTP连接成功");
         }
         long start = System.currentTimeMillis();
         inputStream = file.getInputStream();
         //转码后可以文件名可以为中文ftpClient.storeFile(new String(fileNewName.getBytes("GBK"), "iso-8859-1"), inputStream);
        // ftpClient.enterLocalPassiveMode();
         boolean fig = ftpClient.storeFile(fileNewName, inputStream);
         if(fig){
             long end = System.currentTimeMillis();
             log.info(String.format("文件:%s上传成功,耗时：%d毫秒",fileNewName,(end-start)));
         }else {
             log.info("上传失败");
             return  "";
         }
     }catch (IOException io){
          io.printStackTrace();
          log.error("保存图片到文件服务器ERROR:"+io.getMessage());
          return  "";
     }finally {
         //关闭资源
         try {
             if(null != inputStream){
                 inputStream.close();
             }
             //退出
             ftpClient.logout();
             //断开连接
             ftpClient.disconnect();
         }catch (IOException io){
             log.error("保存图片到文件服务器关闭资源ERROR"+io.getMessage());
         }
     }
     return  EViewConstant.FtpFileServer.IMAGE_URL+fileNewName;
 
 
}
 上传成功
 
 
 
三、图片展示
 
3.1 文件展示需要配置nginx 的配置文件
 
/etc/nginx/conf.d
 vi default.conf
 增加一个server配置
 
 #图片配置
 server{
 listen 90;
 server_name localhost;
 location ~ .(gif|jpg|jpeg|png|bmp|swf)$ {
 root /Ftpfile;
 proxy_temp_path /Ftpfile;
 }
 }
 设置nginx 访问权限（修改为root）：
 
 浏览器地址直接输入：ip +端口+图片路径
 

有时候我们会有一些需求需要上传一些图片或者一些文件,我们写一个小例子来实现这个功能.
 
我这次是针对上传图片来做的,其实就是后缀名限制,返回自己定义
 
import java.io.File;
import java.io.IOException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;
import java.util.Random;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;

@RestController
@RequestMapping("/company/public")
public class PublicController {

    /**
     * 上传用户反馈图片
     * @param file
     * @param request
     * @param response
     * @author sunran
     * @return
     */
    @ResponseBody
    @RequestMapping("/upload")
    public Object uploadPicture(@RequestParam(value="file",required=false)MultipartFile file,HttpServletRequest request,HttpServletResponse response){
    	ResultResp result = new ResultResp();
    	int maxSize = 1024*1024*1;    //上传最大为1MB
    	if (file.getSize()>maxSize) {
    		result.setMsg("最大上传限制1Mb");
            return result;
		}
		Map<String, Object> map = new HashMap<String, Object>();
        File targetFile=null;
        String url="";//返回存储路径
        String fileName=file.getOriginalFilename();//获取文件名加后缀
        if(fileName!=null&&fileName!=""){
            String path = "/data/file/";
            //String path = "D:/data/file/";
            String fileF = fileName.substring(fileName.lastIndexOf("."), fileName.length());//文件后缀
            if (!(fileF.equals(".jpg") || fileF.equals(".jpeg") || fileF.equals(".png") || fileF.equals(".image"))) {
                result.setMsg("只能上传jpg,jpeg,png,image格式");
                return result;
			}
            //新的文件名
            fileName=new Date().getTime()+"_"+new Random().nextInt(1000)+fileF;
            //获取文件夹路径
            File file1=new File(path); 
            //如果文件夹不存在则创建    
            if(!file1.exists()  && !file1.isDirectory()){       
                file1.mkdirs();  
            }
            //将图片存入文件夹
            targetFile = new File(file1, fileName);
            try {
            	//将上传的文件写到服务器上指定的文件。
            	file.transferTo(targetFile);
				//赋予权限
                String command = "chmod 775 -R " + targetFile;
        		Runtime runtime = Runtime.getRuntime();
        		Process proc = runtime.exec(command);
                //生成文件地址
                url="http://XXXXXXXXX.cn"+path+"/"+fileName;
                result.setCode(200+"");
                result.setMsg("图片上传成功");
                System.out.println("图片上传成功 url:"+url);
                map.put("url", url);
                result.setData(map);
            } catch (Exception e) {
                e.printStackTrace();
                result.setMsg("系统异常，图片上传失败");
            }
        }
        return result;
    }
}
 
我们可以本地测试一下,把路径改成我们电脑本地就行了
 

 
 
测试一下
 

 
 

一，实现文件上传（图片，文件，音视频）
 
普通的上传
 
@Override
public Object uploadImage(MultipartFile file) {
    //获取文件名
    String originalFilename = file.getOriginalFilename();
    //获取文件后缀名
    String substring = originalFilename.substring(originalFilename.lastIndexOf(".") + 1);
    System.out.println(substring);
    //使用时间戳改变文件名
    String fileName = System.currentTimeMillis()+"."+substring;
    String filePath = "E:\\data\\";
    String fileUrl = filePath+fileName;
    File dest = new File(fileUrl);
    //判断是否存在此目录,不存在则创建此目录
    if (!dest.getParentFile().exists()){
        dest.getParentFile().mkdirs();
    }
    try {
        file.transferTo(dest);
    }catch (Exception e){
        e.printStackTrace();
        return CommonResult.failed(originalFilename+"上传失败！");
    }
    return CommonResult.success("上传成功！  "+fileUrl);
}
 
二，文件上传到OSS服务器
 
需要引入的依赖
 
<!--OSS-->
        <dependency>
            <groupId>com.aliyun.oss</groupId>
            <artifactId>aliyun-sdk-oss</artifactId>
            <version>2.4.0</version>
        </dependency>
        <dependency>
            <groupId>commons-fileupload</groupId>
            <artifactId>commons-fileupload</artifactId>
            <version>1.3.1</version>
        </dependency>
        <dependency>
            <groupId>org.jdom</groupId>
            <artifactId>jdom</artifactId>
            <version>1.1.3</version>
        </dependency>
 
具体的代码，不包含业务逻辑
 
 @Override
    public Object uploadImageOss(MultipartFile file) throws Exception {
        // Endpoint以北京为例，其它Region请按实际情况填写。
        String endpoint = "http://oss-cn-beijing.aliyuncs.com";
        // 阿里云主账号AccessKey拥有所有API的访问权限，风险很高。强烈建议您创建并使用RAM账号进行API访问或日常运维，请登录 https://ram.console.aliyun.com 创建RAM账号。
        String accessKeyId = "xxxxxxxx";
        String accessKeySecret = "xxxxxxx";
        //创建的bucket名
        String bucketName = "xxxxxx";
		//获取文件名
        String originalFilename = file.getOriginalFilename();
        //获取文件后缀名
        String substring = originalFilename.substring(originalFilename.lastIndexOf(".") + 1);
        //使用uuid作为文件名防止重复
        String uuid = UUID.randomUUID().toString().replaceAll("-", "");
        String fileName = uuid+"."+substring;
        final File tempFile = File.createTempFile(uuid, substring);
        //MultipartFile  转换为 File
        file.transferTo(tempFile);
        // 创建OSSClient实例。
        OSSClient ossClient = new OSSClient(endpoint, accessKeyId, accessKeySecret);
        try {
            //容器不存在，就创建
            if(! ossClient.doesBucketExist(bucketName)){
                ossClient.createBucket(bucketName);
                CreateBucketRequest createBucketRequest = new CreateBucketRequest(bucketName);
                createBucketRequest.setCannedACL(CannedAccessControlList.PublicRead);
                ossClient.createBucket(createBucketRequest);
            }
            String fileHost = "upload";
            //上传文件
            //File file1 = multipartFileToFile(file);
            //创建文件路径
            String fileUrl= fileHost+"/"+fileName;
            PutObjectResult result = ossClient.putObject(new PutObjectRequest(bucketName, fileUrl, tempFile));
            //设置权限 这里是公开读
            ossClient.setBucketAcl(bucketName,CannedAccessControlList.PublicRead);
            if(null != result){
                log.info("==========>OSS文件上传成功,OSS地址："+fileUrl);
                return CommonResult.success(fileUrl);
            }
        }catch (OSSException oe){
            log.error(oe.getMessage());
        }catch (ClientException ce){
            log.error(ce.getMessage());
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            //关闭
            ossClient.shutdown();
        }
        //删除临时生成的文件
        deleteFile(tempFile);
        return null;
    }

    /**
     * 删除
     *
     * @param files
     */
    private void deleteFile(File... files) {
        for (File file : files) {
            if (file.exists()) {
                file.delete();
            }
        }
    }

Runtime.getRuntime().exec("chmod 777 -R " + filepath);//这里的filepath写基础路径也可以