谷粒商城笔记-环境配置（2）——文件上传、java参数验证、递归，分页、事务

2021-08-22 15:57:36

18.阿里云OSS文件上传功能

18.1 创建三方服务

创建微服务gulimall-third-part：

组织名：com.atguigu.gulimall；模块名：gulimall-third-part；包名：com.atguigu.gulimall.thirdpart

Name：gulimall.thirdpart 。之后在下一步的依赖中添加web—>spring web,Spring Cloud Routing—> open Feign

添加公用配置依赖：

a.添加common 公共依赖

View Code

b.nacos注册中心，配置中心

注册中心：添加pom引用（common中包含）,新建配置文件（bootstrap.properties）添加配置，开启注册中心（在启动服务main函数类上）@EnableDiscoveryClient

配置文件：

spring.application.name=gulimall-third-part

spring.cloud.nacos.config.server-addr=127.0.0.1:8848

server.port= 88

18.2 OSS阿里云存储

分布式系统中的文件存储：https://www.jianshu.com/p/1be6bf51566f

阿里云教程：https://help.aliyun.com/learn/learningpath/oss.html?spm=5176.7933691.J_7985555940.3.53e94c59v339me

阿里云使用使用官网：https://help.aliyun.com/document_detail/32009.html

登录阿里云账号，进入对象存储界面（对象存储OSS）
在Bucket 列表创建一个gulimaill-hello2的bucket，创建过程中需要的参数介绍：https://help.aliyun.com/document_detail/31827.html

3.创建访问密钥在鼠标放到用户头像显示的AccessKey 管理——>选择开始使用子用户管理AccessKey——>创建用户名与显示名都为gulimall的用户之后，访问方式Open API 调用访问——为新用户添加权限——>创建新的AccessKey，之后保存id与密码。

AliyunOSSFullAccess

管理对象存储服务(OSS)权限

4.用文件上传方式上传文件：参考地址：https://help.aliyun.com/document_detail/84781.html

本次尝试使用的是上传文件流；

View Code

18.3 Spring Alibaba OSS 封装的组件

Spring Alibaba OSS 封装的组件：https://github.com/alibaba/aliyun-spring-boot/tree/master/aliyun-spring-boot-samples/aliyun-oss-spring-boot-sample

1、添加pom文件的引用

<groupId>com.alibaba.cloud</groupId>

<artifactId>aliyun-oss-spring-boot-starter</artifactId>

</dependency>

2、在配置文件中.直接添加配置

// application.properties

alibaba.cloud.access-key=your-ak

alibaba.cloud.secret-key=your-sk

alibaba.cloud.oss.endpoint=***

3、在微服务中的调用： OSSClient 以服务注册的方式注入。

@Service
 public class YourService {
     @Autowired
     private OSSClient ossClient;

     public void saveFile() {
                 String bucketName = "gulimaill-hello2";
// 填写本地文件的完整路径。如果未指定本地路径，则默认从示例程序所属项目对应本地路径中上传文件流。
        InputStream inputStream = new FileInputStream("/D:\\testa2.txt");
// 依次填写Bucket名称（例如examplebucket）和Object完整路径（例如exampledir/exampleobject.txt）。Object完整路径中不能包含Bucket名称。
        ossClient.putObject(bucketName, "testa2.txt", inputStream);

     }
 }

View Code

4、配置文件配置在nacos配置中心中

根据nacos中的配置，配置成配置文件

spring.cloud.nacos.config.server-addr=127.0.0.1:8848
spring.cloud.nacos.config.namespace=d3791198-6eea-45e8-8e33-8e1a37bc5f34

spring.cloud.nacos.config.ext-config[0].data-id=gulimall-third-part-oss.yml
spring.cloud.nacos.config.ext-config[0].group=DEFAULT_GROUP
spring.cloud.nacos.config.ext-config[0].refresh=true

18.4 分布式系统中的文件上传模型

参考文档：https://help.aliyun.com/document_detail/31926.html

1、服务器模拟policy，微服务中生成一个通用方法

@RestController
public class OSSController {
    @Autowired
    OSS ossClient;
    @Value("${spring.cloud.alicloud.oss.endpoint}")
    private  String endpoint;
    @Value("${spring.cloud.alicloud.oss.bucket}")
    private String bucket;
    @Value("${spring.cloud.alicloud.access-key}")
    private String accessId;
   
    @RequestMapping("/oss/policy")
    public   Map<String, String>  doGet(HttpServletRequest request, HttpServletResponse response)
            throws ServletException, IOException {
       /* String accessId = "<yourAccessKeyId>"; // 请填写您的AccessKeyId。
        String accessKey = "<yourAccessKeySecret>"; // 请填写您的AccessKeySecret。
        String endpoint = "oss-cn-hangzhou.aliyuncs.com"; // 请填写您的 endpoint。*/
        //String bucket = "bucket-name"; // 请填写您的 bucketname 。
        String host = "https://" + bucket + "." + endpoint; // host的格式为 bucketname.endpoint
        // callbackUrl为上传回调服务器的URL，请将下面的IP和Port配置为您自己的真实信息。
        //String callbackUrl = "http://88.88.88.88:8888";
        //修改为按照时间格式的方式
        String dateFormat=new SimpleDateFormat("yyyy-MM-dd").format(new Date());
        String dir =dateFormat+"/"; // 用户上传文件时指定的前缀。
        // 创建OSSClient实例。
        //OSS ossClient = new OSSClientBuilder().build(endpoint, accessId, accessKey);
        Map<String, String> respMap = new LinkedHashMap<String, String>();
        try {
            long expireTime = 30;
            long expireEndTime = System.currentTimeMillis() + expireTime * 1000;
            Date expiration = new Date(expireEndTime);
            // PostObject请求最大可支持的文件大小为5 GB，即CONTENT_LENGTH_RANGE为5*1024*1024*1024。
            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.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());
        } finally {
            ossClient.shutdown();
        }
        return  respMap;
    }
}

View Code

2、测试结果：

调用链接：http://localhost:30000/oss/policy

返回结果：

{"accessid":"LTAI5tEVEUcQMFAYHM1p1Rwe","policy":"etJleHBpcmF0aW9uIjoiMjAyMS0xMC0wNVQwMjoyNDo1Mi4xNThaIiwiY29uZGl0aW9ucyI6W1siY29udGVudC1sZW5ndGgtcmFuZ2UiLDAsMTA0ODU3NjAwMF0sWyJzdGFydHMtd2l0aCIsIiRrZXkiLCIyMDIxLTEwLTA1LyJdXX0=","signature":"/j/0l4ZFpq2MQ4rSGCBsL4tt6N4=","dir":"2021-10-05/","host":"https://gulimaill-hello2.oss-cn-shanghai.aliyuncs.com","expire":"1633400692"}

3、网关配置：

policy的链接访问统一从： http://localhost:88/api/thirdpart/oss/policy

在网关配置中添加：

- id: third_party_route
  uri: lb://gulimall-third-party
  predicates:
    - Path=/api/thirdparty/**
  filters:
    - RewritePath=/api/thirdparty/(?<segment>.*),/$\{segment}

码农公寓

谷粒商城笔记-环境配置（2）——文件上传、java参数验证、递归，分页、事务

18.阿里云OSS文件上传功能

18.1 创建三方服务

18.2 OSS阿里云存储

AliyunOSSFullAccess

管理对象存储服务(OSS)权限

18.3 Spring Alibaba OSS 封装的组件

18.4 分布式系统中的文件上传模型

19.JAVA参数校验（Valid，Validated，自定义检验）

码农公寓

18.阿里云OSS文件上传功能

18.1 创建三方服务

18.2 OSS阿里云存储

AliyunOSSFullAccess

管理对象存储服务(OSS)权限

18.3 Spring Alibaba OSS 封装的组件

18.4 分布式系统中的文件上传模型

19.JAVA参数校验（Valid，Validated，自定义检验）

相关文章