Java使用OSS实现上传文件

Java使用OSS实现上传文件

阿里云OSS使用

1.准备OSS

  1. 访问阿里云官网,注册并登录账户(支付宝方便一些,顺便冲点钱)
  2. 在产品分类中,找到阿里云oss
  3. 然后创建一个bucket

<span>Java使用OSS实现上传文件</span>

2.使用OSS(上传文件)

2.1在阿里云网站导出阿里云颁发的 id 和 秘钥

2.2导入maven坐标

<dependency>
    <groupId>com.aliyun.oss</groupId>
    <artifactId>aliyun-sdk-oss</artifactId>
    <version>3.1.0</version>
</dependency>

2.3进入阿里云oss的学习路径,找到对应java操作的代码

2.3.1首先创建配置文件,将秘钥等信息进行配置

#服务端口
server.port=8002
#服务名
spring.application.name=service-oss

#环境设置:dev、test、prod
spring.profiles.active=dev

#阿里云 OSS
#不同的服务器,地址不同
aliyun.oss.file.endpoint=oss-cn-beijing.aliyuncs.com
aliyun.oss.file.keyid=自己的keyid
aliyun.oss.file.keysecret=自己的keysecret
#bucket可以在控制台创建,也可以使用java代码创建
aliyun.oss.file.bucketname=自己创建的bucket名字

2.3.2创建一个工具类,将配置的属性注入到容器中

<span>Java使用OSS实现上传文件</span>

package com.gyb.eduoss.utils;

import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;

/**
 * @Author: 郜宇博
 * @Date: 2021/9/30 14:54
 */
@Component
@ConfigurationProperties(prefix = "aliyun.oss.file")
@Data
public class AliyunOSSProUtil {
    private String endpoint;
    private String keyid;
    private String keysecret;
    private String bucketname;


}

2.3.3编写java实现类代码(文件上传)

package com.gyb.eduoss.service.impl;

import com.aliyun.oss.OSS;
import com.aliyun.oss.OSSClientBuilder;
import com.gyb.eduoss.service.OssService;
import com.gyb.eduoss.utils.AliyunOSSProUtil;
import org.joda.time.DateTime;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;

import java.io.IOException;
import java.io.InputStream;

/**
 * @Author: 郜宇博
 * @Date: 2021/9/30 15:53
 */
@Service
public class OssServiceImpl implements OssService {
    @Autowired
    AliyunOSSProUtil aliyunOSSProUtil;

    @Override
    public String uploadFileAvatar(MultipartFile multipartFile) {
        //从工具类获取配置文件中的oss值
        String endpoint = aliyunOSSProUtil.getEndpoint();
        String accessKeyId = aliyunOSSProUtil.getKeyid();
        String accessKeySecret = aliyunOSSProUtil.getKeysecret();
        String bucketName = aliyunOSSProUtil.getBucketname();
        System.out.println("endponit:"+endpoint);
        // 创建OSSClient实例。
        OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);

        // 填写本地文件的完整路径。
        // 如果未指定本地路径,则默认从示例程序所属项目对应本地路径中上传文件流。
        InputStream inputStream;
        try {
            inputStream = multipartFile.getInputStream();

            //参数一:依次填写Bucket名称
            // 参数二:文件名称,或Object完整路径(例如exampledir/exampleobject.txt)。Object完整路径中不能包含Bucket名称。
            // 参数三:输入流
            String currentTime = String.valueOf(System.currentTimeMillis());
            String currentDate = new DateTime().toString("yyyy/MM/dd");
            String  originalFileName = multipartFile.getOriginalFilename();
            String fileName = currentDate+"/"+currentTime+originalFileName;
            ossClient.putObject(bucketName,fileName, inputStream);
            String url = "https://"+bucketName+"."+endpoint+"/"+fileName;
            return url;

        } catch (IOException e) {
            e.printStackTrace();
        }finally {
            // 关闭OSSClient。
            ossClient.shutdown();
        }
        return null;
    }
}

2.3.4创建config类,防止传入文件为null

package com.gyb.eduoss.config;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.multipart.MultipartResolver;
import org.springframework.web.multipart.commons.CommonsMultipartResolver;

/**
 * @Author: 郜宇博
 * @Date: 2021/10/2 00:21
 */
@Configuration
public class UploadConfig {
    @Bean(name = "multipartResolver")
    public MultipartResolver multipartResolver() {
        CommonsMultipartResolver resolver = new CommonsMultipartResolver();
        resolver.setDefaultEncoding("UTF-8");
        //resolveLazily属性启用是为了推迟文件解析,以在在UploadAction中捕获文件大小异常
        resolver.setResolveLazily(true);
        resolver.setMaxInMemorySize(40960);
        //上传文件大小 5M 5*1024*1024
        resolver.setMaxUploadSize(5 * 1024 * 1024);
        return resolver;
    }
}

3.配置Nginx反向代理(可以不配)

下载Nginx

实现将对应访问地址进行正则匹配转发

<span>Java使用OSS实现上传文件</span>

3.1将监听端口改为81(防止冲突)

<span>Java使用OSS实现上传文件</span>

3.2配置转发列表

<span>Java使用OSS实现上传文件</span>

server {
        listen       9001;
		server_name  localhost;
#代表带有eduservice路径的请求都走http://localhost:8001
        location ~ /eduservice/ {
            proxy_pass http://localhost:8001;
        }
#代表带有eduoss的请求都走http://localhost:8002		
		location ~ /eduoss/ {
            proxy_pass http://localhost:8002;
        }
    }

4.结果

此时将前端的访问接口改为9001,即可实现下图功能

从而实现功能不同的请求访问不同的服务器

<span>Java使用OSS实现上传文件</span>

<span>Java使用OSS实现上传文件</span>

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请联系我们举报,一经查实,本站将立刻删除。

发布者:全栈程序员-站长,转载请注明出处:https://javaforall.net/115163.html原文链接:https://javaforall.net

(0)
上一篇 2021年11月12日 下午7:00
下一篇 2021年11月12日 下午8:00


相关推荐

  • AE图床-图床聚合源码

    AE图床-图床聚合源码介绍:一个图床聚合程序,自带鉴黄功能,违规图片智能拦截可以直接复制上传以后的链接以及预览支持5个接口上传,图片都支持https永久免费图床,无需注册,批量上传,即时预览,无限流量,无限外链,永久保存,微博服务器,全网CDN,高速稳定,网页上传,无需插件。支持JPG,GIF,PNG等文件格式。支持远程图片上传。微博图床,围脖是个好图床。网盘下载地址:https://zijiewangpan.com/cH4upvpuqQw图片:…

    2022年5月8日
    46
  • Redis学习笔记—-Redis5.0.5配置文件详解「建议收藏」

    Redis学习笔记—-Redis5.0.5配置文件详解「建议收藏」4、解析配置文件(redis5.0.5)配置文件在${PATH}/redis.conf4.1、存储#当你需要为某个配置项指定内存大小的时候,必须要带上单位,通常的格式就是1k5gb4m等:#1k=>1000bytes#1kb=>1024bytes#1m=>1000000bytes#1mb=>10241024bytes#1g…

    2022年6月5日
    33
  • 业界流行的图形数据库(Graph Database)理解(一)

    业界流行的图形数据库(Graph Database)理解(一)关于图形数据库的见解最近在网上阅读了相关图形数据库的知识 深有体会 此外本人想把所理解的知识分享给大家 有错误点请指出 共同进步 图形数据库 Graghdatabas 起源于欧拉的七桥问题 基于图论所设计的 属于 NoSQL 类型的一种 想必都知道 NoSQL 有哪几种吧 键值 Key value 文档 Document 列存储 Column Family 图 Gragh 图形数据库的数据模型主要是以节点 Nodes 和边 Edges 来体现 对于复杂的数据都能快速解决 简单地举个例子

    2025年7月29日
    5
  • TVS二极管SM8S36A,花落谁家?

    TVS二极管SM8S36A,花落谁家?汽车的广泛应用,加速了汽车行业高速发展的同时,也促进了汽车电子行业快速发展。在这个注重智能化和用户体验的时代,汽车所面临的电路保护,诸如汽车总线、USB、CAN总线等,其防护等级越来越高,越来越复杂,同时也越来越严格了。对于汽车电子所需要运用的电路保护器件提出了更高的要求,其中使用最广泛的电路保护元器件之一SM8S系列TVS管,就是最有力的证明,汽车专用型电路防护瞬态电压抑制二极管。采购SM8…

    2026年2月25日
    6
  • 迭代器Python_python迭代器使用

    迭代器Python_python迭代器使用迭代器迭代是访问集合元素的一种方式。迭代器是一个可以记住遍历的位置的对象。迭代器对象从集合的第一个元素开始访问,直到所有的元素被访问完结束。迭代器只能往前不会后退。可迭代对象我们已经知道可以对l

    2022年8月6日
    11
  • 手机APP抓包过程

    手机APP抓包过程0.手机连接WiFi,运行Fiddler的PC连接同一WiFi;假设手机IP为192.168.100.10,PC的IP地址为192.168.100.131.PC端打开Fiddler软件,Tools–Options,选择HTTPS标签页,勾选“CaptureHTTPSCONNECTs”,勾选“DecryptHTTPStraffic”,勾选“Ignoreservercertificateerrors(unsafe)”;选择Connections标签,勾选“Allowremotecompu

    2022年6月28日
    54

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

关注全栈程序员社区公众号