java实现文件上传的详细步骤_Java

一、文件上传——简介

文件上传的简介：文件上传是指将本地计算机中的文件传输到网络上的服务器或另一台计算机上的过程。在 web 开发中，文件上传通常指的是将用户通过 web 页面提交的文件（如图像、文档、音频、视频等）传输到服务器端的操作。
- 简单来说，文件上传是指将本地图片、视频、音频等文件上传到服务器上，供其他用户浏览或下载的过程。
文件上传通常涉及以下几个主要组件：
- 客户端：指的是文件上传的发起方，通常是用户在 web 浏览器中通过表单提交文件。
- 服务器端：指的是接收并处理文件上传请求的计算机系统或服务器。
- 上传表单：通过 html 表单元素来实现文件上传功能。表单需要设置 enctype 属性为 “multipart/form-data”，并包含一个文件输入框用于选择要上传的文件。
- 文件处理逻辑：服务器端接收到文件上传请求后，需要将上传的文件保存到指定的位置，并可能进行进一步的处理，如文件存储、文件重命名、文件格式验证等。
- 文件上传控制器：在 web 开发框架中，通常需要编写文件上传的处理逻辑，这些逻辑通常由服务器端的控制器或处理器来处理。
文件上传在 web 开发中非常常见，常见的应用场景包括但不限于用户头像上传、文件分享、数据备份等。

二、文件上传——入门

文件上传的步骤：
- 先创建一个springboot工程（这个常识了，不展示了）
- 编写一个上传文件的前端html文件
- 编写一个controller
项目结构
文件上传前端的三要素：
- 请求方式是：post
- 需要设置 enctype=“multipart/form-data” 属性以支持文件上传
- <form> 元素应该包含一个 <input type="file"> 元素，用于让用户选择要上传的文件。

编写的html文件：

<!doctype html>
<html lang="en">
<head>
    <meta charset="utf-8">
    <meta name="viewport" content="width=device-width, initial-scale=1.0">
    <title>文件上传</title>
</head>
<body>

<h2>上传文件</h2>

<form action="/upload" method="post" enctype="multipart/form-data">
    <input type="file" name="file" id="filetoupload">
    <input type="submit" value="上传" name="submit">
</form>

</body>
</html>

编写的controller

package com.knife.controller;

import org.springframework.web.bind.annotation.postmapping;
import org.springframework.web.bind.annotation.restcontroller;
import org.springframework.web.multipart.multipartfile;

@restcontroller
public class uploadcontroller {

    @postmapping("/upload")
    public void upload(multipartfile file){
        system.out.println("file == " + file);

    }
}

运行截图：（通过xml配置的路径去访问html文件，然后点击上传文件）

file内容不等于null，说明文件上传成功。

总结：服务端要想接收到从前端页面上传的文件，需要使用到一个api：multipartfile，通过该api来接收上传的文件。而上传上来的文件是一个临时文件，当文件上传这次请求完成之后，这些临时文件会自动删除。因此，在上传文件的同时，应该把文件保存起来。

三、文件上传——本地存储—第一版

在服务端，接收到上传上来的文件之后，将文件存储在本地服务器磁盘中。
基础实现：在上面的文件上传——入门的基础上，修改一下controller就行。

package com.knife.controller;

import org.springframework.web.bind.annotation.postmapping;
import org.springframework.web.bind.annotation.restcontroller;
import org.springframework.web.multipart.multipartfile;

import java.io.file;
import java.io.ioexception;

@restcontroller
public class uploadcontroller {

    @postmapping("/upload")
    public void upload(multipartfile file) throws ioexception {
        system.out.println("file == " + file);

        // 获取源文件的文件名
        string originalfilename = file.getoriginalfilename();

//        把上传上来的文件存储到磁盘上:transferto的参数是一个文件
        file.transferto(new file("e:\\images\\"+ originalfilename));
        
    }
}

只需把上面的controller改成上面一样，然后运行，然后如果你的路径不对，或者你盘符的目录不存在，就会报错了（因为这里没有对异常处理，只是简单地把异常抛出去了）

最快的解决办法就是，修改本地存储的路径，输入一个存在的目录的路径。

最佳解决办法：如下更改controller

package com.knife.controller;

import org.springframework.web.bind.annotation.postmapping;
import org.springframework.web.bind.annotation.restcontroller;
import org.springframework.web.multipart.multipartfile;

import java.io.file;
import java.io.ioexception;
import java.util.uuid;

@restcontroller
public class uploadcontroller {

    @postmapping("/upload")
    public void upload(multipartfile file) throws ioexception {
        system.out.println("file == " + file);
        // 1. 获取源文件的文件名
        string originalfilename = file.getoriginalfilename();

//        定义要上传的路径
       string  fileuploadpath = "e:\\images\\"+ originalfilename;

//       创建要上传的文件
        file uploadfile = new file(fileuploadpath);

        // 判断配置的文件目录是否存在，若不存在则创建一个新的文件目录
        file parentfile = uploadfile.getparentfile();
        if(!parentfile.exists()) {
            parentfile.mkdirs();
        }
        system.out.println(uploadfile);
        
        file.transferto(uploadfile);

    }
}

运行：

四、文件上传——本地存储—第二版

本地存储第一版存在的问题：
- 解决：保证每一个文件的文件名是唯一的（文件名不能重复）
  - 使用uuid工具（通用唯一标识码）——使用生成的uuid码+原始文件名的后缀
- 使用原始文件名进行存储时，如果同时上传了文件名一样的文件，那么后面上传的文件会把前面上传的文件给覆盖。
不管文件路径的报错的写法（和上面文件上传——本地存储—第一版就只有controller的差别）：

package com.knife.controller;

import org.springframework.web.bind.annotation.postmapping;
import org.springframework.web.bind.annotation.restcontroller;
import org.springframework.web.multipart.multipartfile;

import java.io.file;
import java.io.ioexception;
import java.util.uuid;

@restcontroller
public class uploadcontroller {

    @postmapping("/upload")
    public void upload(multipartfile file) throws ioexception {
        system.out.println("file == " + file);
        // 1. 获取源文件的文件名
        string originalfilename = file.getoriginalfilename();

       // 2. 构造唯一的文件名  -- 使用uuid（通用唯一识别码，长度固定的字符串，而且是唯一的）+ 原始文件文件后缀名
//        2.1. 通过字符串的截取，获取文件的后缀名
        int index = originalfilename.lastindexof(".");
        string extname = originalfilename.substring(index);
//        2.2 把uuid和文件后缀名合并
        string newfilename = uuid.randomuuid().tostring() + extname;

        system.out.println("newfilename = " + newfilename);
//        把上传上来的文件存储到磁盘上：（指定一个路径）
        file.transferto(new file("e:\\"+ newfilename));


    }
}

解决文件路径的报错的写法（和上面文件上传——本地存储—第一版就只有controller的差别）：

package com.knife.controller;

import org.springframework.web.bind.annotation.postmapping;
import org.springframework.web.bind.annotation.restcontroller;
import org.springframework.web.multipart.multipartfile;

import java.io.file;
import java.io.ioexception;
import java.util.uuid;

@restcontroller
public class uploadcontroller {

    @postmapping("/upload")
    public void upload(multipartfile file) throws ioexception {
        system.out.println("file == " + file);
        // 1. 获取源文件的文件名
        string originalfilename = file.getoriginalfilename();

       // 2. 构造唯一的文件名  -- 使用uuid（通用唯一识别码，长度固定的字符串，而且是唯一的）+ 原始文件文件后缀名
//        2.1. 通过字符串的截取，获取文件的后缀名
        int index = originalfilename.lastindexof(".");
        string extname = originalfilename.substring(index);
//        2.2 把uuid和文件后缀名合并
        string newfilename = uuid.randomuuid().tostring() + extname;
        //        定义要上传的路径
        string  fileuploadpath = "e:\\images\\"+ newfilename;
        //       创建要上传的文件
        file uploadfile = new file(fileuploadpath);

    // 判断配置的文件目录是否存在，若不存在则创建一个新的文件目录
        file parentfile = uploadfile.getparentfile();
        if(!parentfile.exists()) {
            parentfile.mkdirs();
        }
        system.out.println(uploadfile);
//        把上传上来的文件存储到磁盘上：（指定一个路径）
        file.transferto(uploadfile);

    }
}

运行：

文件上传大小限制的问题：在配置文件里面进行配置

如果是application.properties则如上图一样配置就行，如果是application.yml，则如下配置即可

application.yml：

server:
  port: 8088   # 配置访问服务器的端口

spring:
  servlet:
    multipart:
      max-file-size: 10mb  # 配置单个文件最大上传大小
      max-request-size: 100mb   # 配置单个请求最大上传文件的大小（一次可以上传多个文件，即多个文件的总和也算）

本地存储存在的问题：

五、文件上传——对象存储——阿里云oos

1、参照官方sdk编写入门程序

第一步：在maven工程中使用oss java sdk，只需在pom.xml中加入相应依赖即可。在<dependencies>中加入如下内容（参考官方文档的说明）：

<dependency>
    <groupid>com.aliyun.oss</groupid>
    <artifactid>aliyun-sdk-oss</artifactid>
    <version>3.15.1</version>
</dependency>

如果使用的是java 9及以上的版本，则需要添加jaxb相关依赖。添加jaxb相关依赖示例代码如下：

<dependency>
    <groupid>javax.xml.bind</groupid>
    <artifactid>jaxb-api</artifactid>
    <version>2.3.1</version>
</dependency>
<dependency>
    <groupid>javax.activation</groupid>
    <artifactid>activation</artifactid>
    <version>1.1.1</version>
</dependency>
<!-- no more than 2.3.3-->
<dependency>
    <groupid>org.glassfish.jaxb</groupid>
    <artifactid>jaxb-runtime</artifactid>
    <version>2.3.3</version>
</dependency>

第二步：复制上传文件入门代码（官方文档）官方文档入门程序例子：然后再根据自己的实际情况改写

import com.aliyun.oss.clientexception;
import com.aliyun.oss.oss;
import com.aliyun.oss.common.auth.*;
import com.aliyun.oss.ossclientbuilder;
import com.aliyun.oss.ossexception;
import com.aliyun.oss.model.putobjectrequest;
import com.aliyun.oss.model.putobjectresult;
import java.io.fileinputstream;
import java.io.inputstream;

public class demo {

    public static void main(string[] args) throws exception {
        // endpoint以华东1（杭州）为例，其它region请按实际情况填写。
        string endpoint = "https://oss-cn-hangzhou.aliyuncs.com";
        // 从环境变量中获取访问凭证。运行本代码示例之前，请确保已设置环境变量oss_access_key_id和oss_access_key_secret。
        environmentvariablecredentialsprovider credentialsprovider = credentialsproviderfactory.newenvironmentvariablecredentialsprovider();
        // 填写bucket名称，例如examplebucket。
        string bucketname = "examplebucket";
        // 填写object完整路径，完整路径中不能包含bucket名称，例如exampledir/exampleobject.txt。
        string objectname = "exampledir/exampleobject.txt";
        // 填写本地文件的完整路径，例如d:\\localpath\\examplefile.txt。
        // 如果未指定本地路径，则默认从示例程序所属项目对应本地路径中上传文件流。
        string filepath= "d:\\localpath\\examplefile.txt";

        // 创建ossclient实例。
        oss ossclient = new ossclientbuilder().build(endpoint, credentialsprovider);

        try {
            inputstream inputstream = new fileinputstream(filepath);
            // 创建putobjectrequest对象。
            putobjectrequest putobjectrequest = new putobjectrequest(bucketname, objectname, inputstream);
            // 创建putobject请求。
            putobjectresult result = ossclient.putobject(putobjectrequest);
        } catch (ossexception oe) {
            system.out.println("caught an ossexception, which means your request made it to oss, "
                    + "but was rejected with an error response for some reason.");
            system.out.println("error message:" + oe.geterrormessage());
            system.out.println("error code:" + oe.geterrorcode());
            system.out.println("request id:" + oe.getrequestid());
            system.out.println("host id:" + oe.gethostid());
        } catch (clientexception ce) {
            system.out.println("caught an clientexception, which means the client encountered "
                    + "a serious internal problem while trying to communicate with oss, "
                    + "such as not being able to access the network.");
            system.out.println("error message:" + ce.getmessage());
        } finally {
            if (ossclient != null) {
                ossclient.shutdown();
            }
        }
    }
}

改写后的入门程序：主要修改自己的endpoint、accesskeyid、bucketname、objectname、filepath

package com.knife;

import com.aliyun.oss.clientexception;
import com.aliyun.oss.oss;
import com.aliyun.oss.common.auth.*;
import com.aliyun.oss.ossclientbuilder;
import com.aliyun.oss.ossexception;
import com.aliyun.oss.model.putobjectrequest;
import com.aliyun.oss.model.putobjectresult;
import java.io.fileinputstream;
import java.io.inputstream;

public class uploadoss{

    public static void main(string[] args) throws exception {
        // endpoint：（华北2（北京））请按实际情况填写。
        string endpoint = "oss-cn-beijing.aliyuncs.com"; // 根据自己的实际情况填写

        // 从环境变量中获取访问凭证。运行本代码示例之前，请确保已设置环境变量oss_access_key_id和oss_access_key_secret。
//        environmentvariablecredentialsprovider credentialsprovider = credentialsproviderfactory.newenvironmentvariablecredentialsprovider();
//        使用accesskeyid、accesskeyidsecret替代。
        string accesskeyid = "你自己的密钥id"; // 根据自己的实际情况填写
        string accesskeyidsecret ="你自己的密钥";// 根据自己的实际情况填写

        // 填写bucket名称，例如examplebucket。
        string bucketname = "你自己的bucketname";// 根据自己的实际情况填写

        // 填写object完整路径，完整路径中不能包含bucket名称，例如exampledir/exampleobject.txt。
        string objectname = "1.jpg";  //设置我们上传的文件，最终在阿里云上面是什么名字

        // 填写本地文件的完整路径，例如d:\\localpath\\examplefile.txt。
        // 如果未指定本地路径，则默认从示例程序所属项目对应本地路径中上传文件流。
        string filepath= "c:\\users\\qq351\\pictures\\saved pictures\\1.jpg";

        // 创建ossclient实例。
//        oss ossclient = new ossclientbuilder().build(endpoint, credentialsprovider);
        oss ossclient = new ossclientbuilder().build(endpoint, accesskeyid,accesskeyidsecret);

        try {
            inputstream inputstream = new fileinputstream(filepath);
            // 创建putobjectrequest对象。
            putobjectrequest putobjectrequest = new putobjectrequest(bucketname, objectname, inputstream);
            // 创建putobject请求。
            putobjectresult result = ossclient.putobject(putobjectrequest);
        } catch (ossexception oe) {
            system.out.println("caught an ossexception, which means your request made it to oss, "
                    + "but was rejected with an error response for some reason.");
            system.out.println("error message:" + oe.geterrormessage());
            system.out.println("error code:" + oe.geterrorcode());
            system.out.println("request id:" + oe.getrequestid());
            system.out.println("host id:" + oe.gethostid());
        } catch (clientexception ce) {
            system.out.println("caught an clientexception, which means the client encountered "
                    + "a serious internal problem while trying to communicate with oss, "
                    + "such as not being able to access the network.");
            system.out.println("error message:" + ce.getmessage());
        } finally {
            if (ossclient != null) {
                ossclient.shutdown();
            }
        }
    }
}

路径获取：

运行就可以传进去了

通过浏览器访问该图片的路径时，会直接下载该图片，但是在页面显示出来挺简单的，就是使用一个imag标签，然后把路径放在src下即可

<image src="https://cangqiongwaimaiknife.oss-cn-beijing.aliyuncs.com/1.jpg">

六、在项目中使用oos文件上传

在项目中，一般会把文件上传的方法封装成一个工具类然后再使用。

在配置文件里面对oss的参数进行配置

#阿里云oss
aliyun:
  oss:
    endpoint: https://oss-cn-hangzhou.aliyuncs.com
    accesskeyid: ltai4gch1vx6dkqjwxd6neuw
    accesskeysecret: ybshywehopqduhcarrvhwiibkpyqsl
    bucketname: web-tlias

属性配置类：（读取配置文件里面的属性）

import lombok.data;
import org.springframework.boot.context.properties.configurationproperties;
import org.springframework.stereotype.component;

@data
@component
@configurationproperties(prefix = "aliyun.oss")
public class aliossproperties {
    private string endpoint;
    private string accesskeyid;
    private string accesskeysecret;
    private string bucketname;
}

封装工具类：

import com.aliyun.oss.oss;
import com.aliyun.oss.ossclientbuilder;
import org.springframework.beans.factory.annotation.autowired;
import org.springframework.beans.factory.annotation.value;
import org.springframework.stereotype.component;
import org.springframework.web.multipart.multipartfile;
import java.io.*;
import java.util.uuid;

/**
 * 阿里云 oss 工具类
 */
@component
public class aliossutils {
    @autowired
    private aliossproperties aliossproperties;

    /**
     * 实现上传图片到oss
     */
    public string upload(multipartfile file) throws ioexception {
        //获取阿里云oss参数
        string endpoint = aliossproperties.getendpoint();
        string accesskeyid = aliossproperties.getaccesskeyid();
        string accesskeysecret = aliossproperties.getaccesskeysecret();
        string bucketname = aliossproperties.getbucketname();

        // 获取上传的文件的输入流
        inputstream inputstream = file.getinputstream();

        // 避免文件覆盖
        string originalfilename = file.getoriginalfilename();
        string filename = uuid.randomuuid().tostring() + originalfilename.substring(originalfilename.lastindexof("."));

        //上传文件到 oss
        oss ossclient = new ossclientbuilder().build(endpoint, accesskeyid, accesskeysecret);
        ossclient.putobject(bucketname, filename, inputstream);

        //文件访问路径
        string url = endpoint.split("//")[0] + "//" + bucketname + "." + endpoint.split("//")[1] + "/" + filename;
        // 关闭ossclient
        ossclient.shutdown();
        return url;// 把上传到oss的路径返回
    }
}

controller类上使用

import com.itheima.pojo.result;
import com.itheima.utils.aliossutils;
import lombok.extern.slf4j.slf4j;
import org.springframework.beans.factory.annotation.autowired;
import org.springframework.web.bind.annotation.postmapping;
import org.springframework.web.bind.annotation.restcontroller;
import org.springframework.web.multipart.multipartfile;

import java.io.file;
import java.io.ioexception;
import java.util.uuid;

@restcontroller
public class uploadcontroller {

    @autowired
    private aliossutils aliossutils;

    @postmapping("/upload")
    public result upload(multipartfile image) throws ioexception {
        log.info("文件上传, 文件名: {}", image.getoriginalfilename());

        //调用阿里云oss工具类进行文件上传
        string url = aliossutils.upload(image);
        log.info("文件上传完成,文件访问的url: {}", url);

        return result.success(url);
    }

}