当前位置： 首页 > article >正文

文件上传功能（四）——项目集成

article 2025/2/21 23:35:12

总说

过程参考黑马程序员SpringBoot3+Vue3全套视频教程，springboot+vue企业级全栈开发从基础、实战到面试一套通关_哔哩哔哩_bilibili

目录

总说

一、功能实现

1.1 Controller层

1.2 测试接口

一、功能实现

我们要将入门程序改为一个工具类

在utils目录下创建AliOssUtil

将Demo中的代码复制过来

代码如下：

    public static void main(String[] args) throws Exception {
        // 以华东1（杭州）为例，endpoint：是服务器区域节点
        String endpoint = "https://oss-cn-hangzhou.aliyuncs.com";
        // 从环境变量中获取访问凭证。运行本代码示例之前，请确保已设置环境变量OSS_ACCESS_KEY_ID和OSS_ACCESS_KEY_SECRET。
        //EnvironmentVariableCredentialsProvider credentialsProvider = CredentialsProviderFactory.newEnvironmentVariableCredentialsProvider();
        String ACCESS_KEY_ID = "LTAI5tRrhg6TFMC9vRnE8PSa";
        String ACCESS_KEY_SECRET = "d4vDQAycnaNh1oXl6cLgFwXii2uPIV";
        // 填写Bucket名称
        String bucketName = "learn-project-test";
        // 填写Object完整路径，完整路径中不能包含Bucket名称，例如exampledir/exampleobject.txt。
        String objectName = "001.png";
        // 填写Bucket所在地域。以华东1（杭州）为例，Region填写为cn-hangzhou。
        String region = "cn-hangzhou";

        // 使用 DefaultCredentialProvider 或 StaticCredentialsProvider
        CredentialsProvider credentialsProvider = new DefaultCredentialProvider(ACCESS_KEY_ID, ACCESS_KEY_SECRET);

        // 创建OSSClient实例。
        ClientBuilderConfiguration clientBuilderConfiguration = new ClientBuilderConfiguration();
        clientBuilderConfiguration.setSignatureVersion(SignVersion.V4);
        OSS ossClient = OSSClientBuilder.create()
                .endpoint(endpoint)
                .credentialsProvider(credentialsProvider)
                .clientConfiguration(clientBuilderConfiguration)
                .region(region)
                .build();

        try {
            // 填写字符串。
            String content = "Hello OSS，你好世界";

            // 创建PutObjectRequest对象
            //这里我们要上传图片，修改为：new FileInputStream("本地磁盘路径")
            PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, objectName, new FileInputStream("C:\\Users\\86176\\Desktop\\files\\001.png"));

            // 如果需要上传时设置存储类型和访问权限，请参考以下示例代码。
            // ObjectMetadata metadata = new ObjectMetadata();
            // metadata.setHeader(OSSHeaders.OSS_STORAGE_CLASS, StorageClass.Standard.toString());
            // metadata.setObjectAcl(CannedAccessControlList.Private);
            // putObjectRequest.setMetadata(metadata);

            // 上传字符串。
            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、ACCESS_KEY_ID、ACCESS_KEY_SECRET、bucketName的值不会变，我们设置成全局变量，并修改endpoint、bucketName变量名

// 以华东1（杭州）为例，endpoint：是服务器区域节点
    private static final String ENDPOINT = "https://oss-cn-hangzhou.aliyuncs.com";
    // 从环境变量中获取访问凭证。运行本代码示例之前，请确保已设置环境变量OSS_ACCESS_KEY_ID和OSS_ACCESS_KEY_SECRET。
    //EnvironmentVariableCredentialsProvider credentialsProvider = CredentialsProviderFactory.newEnvironmentVariableCredentialsProvider();
    private static final String ACCESS_KEY_ID = "LTAI5tRrhg6TFMC9vRnE8PSa";
    private static final String ACCESS_KEY_SECRET = "d4vDQAycnaNh1oXl6cLgFwXii2uPIV";
    // 填写Bucket名称
    private static final String BUCKET_NAME = "learn-project-test";

对代码进行修改，修改完的完整代码如下：

package com.example.learnproject.utils;

import com.aliyun.oss.*;
import com.aliyun.oss.common.auth.CredentialsProvider;
import com.aliyun.oss.common.auth.DefaultCredentialProvider;
import com.aliyun.oss.common.comm.SignVersion;
import com.aliyun.oss.model.PutObjectRequest;
import com.aliyun.oss.model.PutObjectResult;

import java.io.FileInputStream;
import java.io.InputStream;

public class AliOssUtil {

    // 以华东1（杭州）为例，endpoint：是服务器区域节点
    private static final String ENDPOINT = "https://oss-cn-hangzhou.aliyuncs.com";
    // 从环境变量中获取访问凭证。运行本代码示例之前，请确保已设置环境变量OSS_ACCESS_KEY_ID和OSS_ACCESS_KEY_SECRET。
    //EnvironmentVariableCredentialsProvider credentialsProvider = CredentialsProviderFactory.newEnvironmentVariableCredentialsProvider();
    private static final String ACCESS_KEY_ID = "LTAI5tRrhg6TFMC9vRnE8PSa";
    private static final String ACCESS_KEY_SECRET = "d4vDQAycnaNh1oXl6cLgFwXii2uPIV";
    // 填写Bucket名称
    private static final String BUCKET_NAME = "learn-project-test";
    // 填写Bucket所在地域。以华东1（杭州）为例，Region填写为cn-hangzhou。
    private static final String region = "cn-hangzhou";

    //设置String类型访问地址，返回图片地址
    public static String uploadFile(String objectName, InputStream inputStream) throws Exception {

        // 使用 DefaultCredentialProvider 或 StaticCredentialsProvider
        CredentialsProvider credentialsProvider = new DefaultCredentialProvider(ACCESS_KEY_ID, ACCESS_KEY_SECRET);

        // 创建OSSClient实例。
        ClientBuilderConfiguration clientBuilderConfiguration = new ClientBuilderConfiguration();
        clientBuilderConfiguration.setSignatureVersion(SignVersion.V4);
        OSS ossClient = OSSClientBuilder.create()
                .endpoint(ENDPOINT)
                .credentialsProvider(credentialsProvider)
                .clientConfiguration(clientBuilderConfiguration)
                .region(region)
                .build();

        // 图片地址，用于返回
        String url = "";

        try {
            // 填写字符串。
            String content = "Hello OSS，你好世界";

            // 创建PutObjectRequest对象
            //这里我们要上传图片，修改为：new FileInputStream("本地磁盘路径")
            PutObjectRequest putObjectRequest = new PutObjectRequest(BUCKET_NAME, objectName, inputStream);

            // 如果需要上传时设置存储类型和访问权限，请参考以下示例代码。
            // ObjectMetadata metadata = new ObjectMetadata();
            // metadata.setHeader(OSSHeaders.OSS_STORAGE_CLASS, StorageClass.Standard.toString());
            // metadata.setObjectAcl(CannedAccessControlList.Private);
            // putObjectRequest.setMetadata(metadata);

            // 上传字符串。
            PutObjectResult result = ossClient.putObject(putObjectRequest);
            // url组成：https://bucket名称.区域节点/时间/objectName名称
            url = "https://" + BUCKET_NAME + "." + ENDPOINT.substring(ENDPOINT.lastIndexOf("/") + 1) + "/" + objectName;
        } 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();
            }
        }
    }

}

1.1 Controller层

来到FileUploadController，我们之前写的静态的，修改代码如下：

@RestController
public class FileUploadController {

    @PostMapping("/upload")
    public Result<String> upload(MultipartFile file) throws Exception { //MultipartFile file 用来接收上传的文件
        //把文件的内容存到本地磁盘上
        String originFilename = file.getOriginalFilename();// 获取原始文件名
        //保证文件的名字唯一，防止文件名被覆盖
        //用UUID.randomUUID().toString() 生成一个随机的字符串 + 原始文件名后缀
        String fileName = UUID.randomUUID().toString() + originFilename.substring(originFilename.lastIndexOf("."));

        //file.transferTo(new File("C:\\Users\\86176\\Desktop\\files\\" + fileName));//将接收到的文件内容写入到本地磁盘上
        //第一个参数是String类型的文件路径，第二个参数是File类型的输入流
        String url = AliOssUtil.uploadFile(fileName, file.getInputStream());
        
        return Result.success(url);
    }
}

1.2 测试接口

来到apifox的稳健上传接口，我们再测试一下，上传一个新的图片

成功上传

上传git保存


http://www.kler.cn/a/549674.html

相关文章：

  • Hive之分区表
  • 使用sublime_text中，TAB键无效怎么解决？？？
  • 【第4章：循环神经网络（RNN）与长短时记忆网络（LSTM）——4.2 LSTM的引入与解决长期依赖问题的方法】
  • Qt QOpenGLShaderProgram详解
  • Machine Learning:General Guide
  • 探索深度学习与人类智能交互的共生关系与发展路径
  • 【深度学习】计算机视觉（CV）-目标检测-DETR（DEtection TRansformer）—— 基于 Transformer 的端到端目标检测
  • 【pytorch】weight_norm和spectral_norm
  • 【面试】在Vue3中，beforeCreate和created钩子函数有什么区别？
  • Visonpro 检测是否有缺齿
  • 【第1章：深度学习概览——1.4 深度学习的核心组件与概念解析之激活函数的作用与类型】
  • pytorch cnn 实现猫狗分类
  • 【C++】详解 set multiset map multiset 的使用
  • 网络安全讲座
  • Redis 的常见应用场景
  • 【第9章：计算机视觉实战—9.1 目标检测与识别：YOLO、Faster R-CNN等模型的实现与应用】
  • 案例-06.部门管理-根据ID查询
  • ESP32通过MQTT连接阿里云平台实现消息发布与订阅
  • 9. Docker 当中的复杂安装(MySQL主从复制的安装，Redis 的3主3从的安装配置)的详细说明[附加步骤图]
  • Linux（ubuntu）下载ollama速度慢解决办法