阿里云OSS使用Java上传文件

一、准备工作

1.1登录阿里云点击对象存储OSS

1.2 先点击Bucket 列表，在点击创建Bucket 。

1.3 根据自己需求勾选，然后点击确定。

1.4 新建好之后，点击bucket名称。

1.5 点击文件管理

1.6 在这个页面就可以实现文件的上传和下载。

二、基于java实现OSS上传

2.1 将鼠标放在头像上，点击AccessKey管理。

2.2 点击使用子账户

2.3填写登录名称和显示名称，勾选open api。

2.4 创建好后将AccessKey ID和 AccessKey Secret 保存好。

注意： 创建后系统会给你提供如下:记得复制粘贴保存下来,后面会用到;当你你退出这个页面后,系统不会帮你记录下来。要想使用就只能重新创建配置。

2.5 点击添加权限。进去后选择AliyunOSSFullAccess 点击确定。

2.6 在项目pom.xml添加依赖。

<dependency>
   <groupId>com.aliyun.oss</groupId>
   <artifactId>aliyun-sdk-oss</artifactId>
   <version>3.10.2</version>
</dependency>
<dependency>
   <groupId>com.alibaba.cloud</groupId>
   <artifactId>spring-cloud-starter-alicloud-oss</artifactId>
</dependency>

2.7 使用test测试类测试

 @Test
    public void testUp() throws FileNotFoundException {
        // Endpoint外网访问域名，以杭州为例。
        String endpoint = "oss-cn-hangzhou.aliyuncs.com";
        // accessKeyId 和 accessKeySecret 是先前创建用户生成的
        String accessKeyId = "accessKeyId ";
        String accessKeySecret = "accessKeySecret ";

        // 创建OSSClient实例。
        OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);

        // 上传文件流。
        InputStream inputStream = new FileInputStream("D:\\图片\\img3.jpg");
        ossClient.putObject("tx-ecps", "img3.jpg", inputStream);

        // 关闭OSSClient。
        ossClient.shutdown();
    }

上传成功后，可以在文件管理看见对应的图片。

三、服务端签名直传

3.1 设置好跨域访问

点击【bucket列表】=>【点击bucket名称】=>【侧边栏选择概览】=>【基础设置下跨域访问点击设置】

3.2 创建签名方式

我是采用配置文件读取信息方式，在application.yml添加配置。

spring:
  cloud:
    alicloud:
      access-key: 在创建用户时保存的AccessKey ID
      secret-key: 在创建用户时保存的AccessKey Secret 
      bucket: bucket名称
      oss:
        endpoint: OSS外网访问的地域节点endpoint

创建签名工具类

@RestController
@RequestMapping("third")
public class OssController {

    @Autowired
    OSS ossClient;

    @Value("${spring.cloud.alicloud.oss.endpoint}")
    private String endpoint;
    @Value("${spring.cloud.alicloud.bucket}")
    private String bucket;

    @Value("${spring.cloud.alicloud.access-key}")
    private String accessId;


    @RequestMapping("/oss/policy")
    public R policy() {

        String host = "https://" + bucket + "." + endpoint; // host的格式为 bucketname.endpoint
        // callbackUrl为 上传回调服务器的URL，请将下面的IP和Port配置为您自己的真实信息。
//        String callbackUrl = "http://88.88.88.88:8888";
        String format = new SimpleDateFormat("yyyy-MM-dd").format(new Date());
        String dir = format + "/"; // 用户上传文件时指定的前缀。

        Map<String, String> respMap = null;
        try {
            long expireTime = 30;
            long expireEndTime = System.currentTimeMillis() + expireTime * 1000;
            Date expiration = new Date(expireEndTime);
            PolicyConditions policyConds = new PolicyConditions();
            policyConds.addConditionItem(PolicyConditions.COND_CONTENT_LENGTH_RANGE, 0, 1048576000);
            policyConds.addConditionItem(MatchMode.StartWith, PolicyConditions.COND_KEY, dir);

            String postPolicy = ossClient.generatePostPolicy(expiration, policyConds);
            byte[] binaryData = postPolicy.getBytes("utf-8");
            String encodedPolicy = BinaryUtil.toBase64String(binaryData);
            String postSignature = ossClient.calculatePostSignature(postPolicy);

            respMap = new LinkedHashMap<String, String>();
            respMap.put("accessid", accessId);
            respMap.put("policy", encodedPolicy);
            respMap.put("signature", postSignature);
            respMap.put("dir", dir);
            respMap.put("host", host);
            respMap.put("expire", String.valueOf(expireEndTime / 1000));
            // respMap.put("expire", formatISO8601Date(expiration));
        } catch (Exception e) {
            // Assert.fail(e.getMessage());
            System.out.println(e.getMessage());
        }

        return R.ok().put("data",respMap);
    }
}

启动访问成果页面，访问接口返回签名信息就表示成功。前端文件上传就直接调用即可。