尚医通day11-Java中阿里云对象存储OSS

页面预览

用户认证

• 用户登录成功后都要进行身份认证，认证通过后才可以预约挂号。
  
• 认证过程：用户填写基本信息（姓名、证件类型、证件号码和证件照片），提交平台审核
  
• 用户认证相关接口：
  

（1）上传证件图片
（2）提交认证
（3）获取认证信息
提交认证


获取认证信息


第01章-阿里云OSS

1、对象存储OSS

用户认证需要上传证件图片，因此我们要做文件服务，为了解决海量数据存储与弹性扩容，项目中我们采用云存储的解决方案：阿里云OSS。
1.1、开通“对象存储OSS”服务

（1）申请阿里云账号
（2）实名认证
（3）开通“对象存储OSS”服务
（4）进入管理控制台
1.2、创建Bucket

为Bucket起一个名字，其余选项默认即可。
注意：项目中涉及身份证照片，读写权限选择默认的“私有”

得到endpoint：创建Bucket后，在概览页面可以获取当前Bucket的endpoint值，这个值后面编程的时候会用到

1.3、上传测试文件

创建一个文件夹，上传一个文件

2、使用RAM子用户

2.1、进入子用户管理页面



2.2、添加用户


2.3、获取子用户Id和key

AccessKeyId, AccessKeySecret
2.4、设置用户权限

添加权限：AliyunOSSFullAccess

3、使用SDK

在对象存储首页的右侧，可以找到帮助文档的入口


第02章-用户认证

1、新建云服务模块

1.1、创建模块

在service模块下创建子模块service-yun

1.2、添加依赖

在service-yun中引入依赖

1. <dependencies>
2.    
3.     <dependency>
4.         <groupId>com.aliyun.oss</groupId>
5.         <artifactId>aliyun-sdk-oss</artifactId>
6.         <version>3.15.1</version>
7.     </dependency>
9.    
10.     <dependency>
11.         <groupId>com.atguigu</groupId>
12.         <artifactId>model</artifactId>
13.         <version>1.0</version>
14.     </dependency>
16.    
17.     <dependency>
18.         <groupId>com.atguigu</groupId>
19.         <artifactId>service-util</artifactId>
20.         <version>1.0</version>
21.     </dependency>
22.    
23.    
24.     <dependency>
25.         <groupId>joda-time</groupId>
26.         <artifactId>joda-time</artifactId>
27.     </dependency>
28.    
29.    
30.     <dependency>
31.         <groupId>com.atguigu</groupId>
32.         <artifactId>spring-security</artifactId>
33.         <version>1.0</version>
34.     </dependency>
35.    
36.    
37.     <dependency>
38.         <groupId>org.springframework.boot</groupId>
39.         <artifactId>spring-boot-starter-test</artifactId>
40.         <scope>test</scope>
41.     </dependency>
44. </dependencies>

复制代码

1.3、创建配置文件

在server-yun模块中resources目录下创建文件
application.yml：

1. spring:
2.   application:
3.     name: service-yun
4.   profiles:
5.     active: dev,redis

复制代码

application-dev.yml：

1. server:
2.   port: 8204
3. spring:
4.   cloud:
5.     nacos:
6.       discovery:
7.         server-addr: 127.0.0.1:8848
8.   servlet:
9.     multipart:
10.       max-file-size: 10MB
11.       max-request-size: 10MB
13. logging:
14.   level:
15.     root: info
16.   file:
17.     path: yun
18.   
19. aliyun:
20.   oss: #阿里云 OSS
21.     endpoint: your endpoint
22.     key-id: your accessKeyId
23.     key-secret: your accessKeySecret
24.     bucket-name: your bucketname

复制代码

1.4、创建启动类

创建ServiceYunApplication

1. package com.atguigu.syt.yun;
3. @SpringBootApplication(exclude = DataSourceAutoConfiguration.class)//取消数据源配置自动读取
4. @ComponentScan(basePackages = {"com.atguigu"})
5. public class ServiceYunApplication {
6.     public static void main(String[] args) {
7.         SpringApplication.run(ServiceYunApplication.class, args);
8.     }
9. }

复制代码

1.5、配置网关

在网关中配置如下内容：

1.         - id: service-yun
2.           predicates: Path=/*/yun/**
3.           uri: lb://service-yun

复制代码

2、文件上传

2.1、从配置文件读取常量

创建常量读取工具类：OssConstantProperties.java

1. package com.atguigu.syt.yun.utils;
2. @Configuration
3. @ConfigurationProperties(prefix="aliyun.oss") //读取节点
4. @Data
5. public class OssConstantProperties {
6.    
7.     private String endpoint;
8.     private String keyId;
9.     private String keySecret;
10.     private String bucketName;
11. }

复制代码

2.2、Controller

创建controller.front包，创建FrontFileController类

1. package com.atguigu.syt.yun.controller.front;
3. @Api(tags = "阿里云文件管理")
4. @RestController
5. @RequestMapping("/front/yun/file")
6. public class FrontFileController {
8.     @Resource
9.     private FileService fileService;
10.     /**
11.      * 文件上传
12.      */
13.     @ApiOperation("文件上传")
14.     @ApiImplicitParam(name = "file",value = "上传文件", required = true)
15.     @PostMapping("/auth/upload")
16.     public Result<Map<String, String>> upload(MultipartFile file) {
17.         Map<String, String> map = fileService.upload(file);
18.         return Result.ok(map);
19.     }
20. }

复制代码

2.3、Service

接口：FileService

1. package com.atguigu.syt.oss.service;
3. public interface FileService {
5.     /**
6.      * 文件上传
7.      * @param file
8.      * @return
9.      */
10.     Map<String, String> upload(MultipartFile file);
11. }

复制代码

实现：FileServiceImpl
参考SDK中的：Java->上传文件->简单上传->流式上传->上传文件流

1. package com.atguigu.syt.oss.service.impl;
3. @Service
4. @Slf4j
5. public class FileServiceImpl implements FileService {
7.     @Resource
8.     private OssConstantProperties ossConstantProperties;
10.     /**
11.      * 参考SDK中的：Java->上传文件->简单上传->流式上传->上传文件流
12.      * @param file
13.      * @return
14.      */
15.     @Override
16.     public Map<String, String> upload(MultipartFile file) {
18.         // Endpoint以华东1（杭州）为例，其它Region请按实际情况填写。
19.         String endpoint = ossConstantProperties.getEndpoint();
20.         // 阿里云账号AccessKey拥有所有API的访问权限，风险很高。强烈建议您创建并使用RAM用户进行API访问或日常运维，请登录RAM控制台创建RAM用户。
21.         String accessKeyId = ossConstantProperties.getKeyId();
22.         String accessKeySecret = ossConstantProperties.getKeySecret();
23.         // 填写Bucket名称，例如examplebucket。
24.         String bucketName = ossConstantProperties.getBucketName();
26.         // 文件名称
27.         String originalFilename = file.getOriginalFilename();
28.         String dateString = new DateTime().toString("yyyyMMdd");
29.         // 填写Object完整路径，完整路径中不能包含Bucket名称，例如exampledir/exampleobject.txt。
30.         String objectName =
31.                 dateString
32.                         + "/" + UUID.randomUUID().toString().replace("-", "")
33.                         + originalFilename.substring(originalFilename.lastIndexOf("."));
35.         // 创建OSSClient实例。
36.         OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
38.         try {
39.             InputStream inputStream = file.getInputStream();
40.             // 创建PutObjectRequest对象。
41.             PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, objectName, inputStream);
42.             // 设置该属性可以返回response。如果不设置，则返回的response为空。
43.             putObjectRequest.setProcess("true");
44.             // 创建PutObject请求。
45.             PutObjectResult result = ossClient.putObject(putObjectRequest);
47.             // 如果上传成功，则返回200。
48.             log.info(Integer.toString(result.getResponse().getStatusCode()));
49.             if(result.getResponse().getStatusCode() != 200){
50.                 throw new GuiguException(ResultCodeEnum.FAIL);
51.             }
53.             //返回图片路径
54.             //参考SDK中的：Java-> Java授权访问-> 生成以GET方法访问的签名URL
55.             // 设置URL过期时间为1小时，单位：毫秒
56.             Date expiration = new Date(new Date().getTime() + 60 * 60 * 1000);
57.             URL url = ossClient.generatePresignedUrl(bucketName, objectName, expiration);
59.             Map<String, String> map = new HashMap<>();
60.             map.put("previewUrl", url.toString()); //页面中授权预览图片
61.             map.put("url", objectName); //数据库存储
63.             return map;
65.         } catch (OSSException oe) {
66.             System.out.println("Caught an OSSException, which means your request made it to OSS, "
67.                     + "but was rejected with an error response for some reason.");
68.             System.out.println("Error Message:" + oe.getErrorMessage());
69.             System.out.println("Error Code:" + oe.getErrorCode());
70.             System.out.println("Request ID:" + oe.getRequestId());
71.             System.out.println("Host ID:" + oe.getHostId());
73.             throw new GuiguException(ResultCodeEnum.FAIL, oe);
75.         } catch (GuiguException ce) {
76.             System.out.println("Caught an ClientException, which means the client encountered "
77.                     + "a serious internal problem while trying to communicate with OSS, "
78.                     + "such as not being able to access the network.");
79.             System.out.println("Error Message:" + ce.getMessage());
81.             throw new GuiguException(ResultCodeEnum.FAIL, ce);
83.         } catch (IOException e) {
85.             throw new GuiguException(ResultCodeEnum.FAIL, e);
87.         } finally {
88.             if (ossClient != null) {
89.                 ossClient.shutdown();
90.             }
91.         }
92.     }
93. }

复制代码

3、授权校验

3.1、辅助类

在service-util模块中添加AuthContextHolder.java

1. package com.atguigu.common.service.utils;
3. /**
4. * 授权校验
5. */
6. @Component
7. public class AuthContextHolder {
9.     @Resource
10.     private RedisTemplate redisTemplate;
12.     /**
13.      * 校验token是否存在并返回UserId
14.      * @param request
15.      */
16.     public Long checkAuth(HttpServletRequest request){
17.         //从http请求头中获取token
18.         String token = request.getHeader("token");
19.         if(StringUtils.isEmpty(token)) {
20.             throw new GuiguException(ResultCodeEnum.LOGIN_AUTH);
21.         }
23.         Object userIdObj = redisTemplate.opsForValue().get("user:token:" + token);
25.         //数据存入redis时，按照实际的大小分配空间，取出时int能存下，默认使用int类型，int存不下再用long
26.         //我们无法判断redis中存储的是什么类型的id，因此在此做一个转换
27.         Long userId = null;
28.         if(userIdObj instanceof Integer){
29.             userId = ((Integer)userIdObj).longValue();
30.         }else if(userIdObj instanceof Long){
31.             userId = (Long)userIdObj;
32.         }else if(userIdObj instanceof String){
33.             userId = Long.parseLong(userIdObj.toString());
34.         }
36.         if(StringUtils.isEmpty(userId)) {
37.             throw new GuiguException(ResultCodeEnum.LOGIN_AUTH);
38.         }
40.         return userId;
41.     }
42. }

复制代码

3.2、修改文件上传controller

添加校验代码

1. ...
2. public class FrontFileController {
4.     ...
5.     @Resource
6.     private AuthContextHolder authContextHolder;
7.    
8.     ...
9.     public Result<Map<String, String>> upload(MultipartFile file, HttpServletRequest request) {
11.         authContextHolder.checkAuth(request);
12.         ...
13.     }
14. }

复制代码

3.3、测试文件上传

首先添加全局参数token，然后再进行测试

4、提交认证

4.1、Controller

创建FrontUserInfoController中添加如下方法

1. package com.atguigu.syt.user.controller.front;
3. @Api(tags = "用户管理")
4. @RestController
5. @RequestMapping("/front/user/userInfo")
6. public class FrontUserInfoController {
8.     @Resource
9.     private UserInfoService userInfoService;
11.     @Resource
12.     private AuthContextHolder authContextHolder;
14.     @ApiOperation(value = "用户认证")
15.     @ApiImplicitParam(name = "userAuthVo",value = "用户实名认证对象", required = true)
16.     @PostMapping("/auth/userAuth")
17.     public Result userAuth(@RequestBody UserAuthVo userAuthVo, HttpServletRequest request) {
19.         Long userId = authContextHolder.checkAuth(request);
20.         userInfoService.userAuth(userId, userAuthVo);
21.         return Result.ok();
22.     }
23. }

复制代码

4.2、Service

接口：UserInfoService

1. /**
2.      * 保存实名认证信息
3.      * @param userId
4.      * @param userAuthVo
5.      */
6. void userAuth(Long userId, UserAuthVo userAuthVo);

复制代码

实现：UserInfoServiceImpl

1. @Override
2. public void userAuth(Long userId, UserAuthVo userAuthVo) {
3.     //设置认证信息
4.     UserInfo userInfo = new UserInfo();
5.     userInfo.setId(userId);
6.     userInfo.setName(userAuthVo.getName());
7.     userInfo.setCertificatesType(userAuthVo.getCertificatesType());
8.     userInfo.setCertificatesNo(userAuthVo.getCertificatesNo());
9.     userInfo.setCertificatesUrl(userAuthVo.getCertificatesUrl());
10.     userInfo.setAuthStatus(AuthStatusEnum.AUTH_RUN.getStatus());
11.     //信息更新
12.     baseMapper.updateById(userInfo);
13. }

复制代码

5、获取认证信息

5.1、Controller

在service-user模块的FrontUserInfoController中添加如下方法

1. @ApiOperation(value = "获取认证信息")
2. @GetMapping("/auth/getUserInfo")
3. public Result<UserInfo> getUserInfo(HttpServletRequest request) {
5.     Long userId = authContextHolder.checkAuth(request);
6.     UserInfo userInfo = userInfoService.getUserInfoById(userId);
7.     return Result.ok(userInfo);
8. }

复制代码

5.2、Service

主类添加

1. @EnableFeignClients("com.atguigu.syt")

复制代码

接口：UserInfoService

1. /**
2.      * 根据用户id获取用户信息
3.      * @param userId
4.      * @return
5.      */
6. UserInfo getUserInfoById(Long userId);

复制代码

实现：UserInfoServiceImpl

1. @Override
2. public UserInfo getUserInfoById(Long userId) {
3.     UserInfo userInfo = baseMapper.selectById(userId);
4.     return this.packUserInfo(userInfo);
5. }

复制代码

辅助方法：UserInfoServiceImpl

1. @Resource
2. private DictFeignClient dictFeignClient;
4. /**
5.      * 封装用户状态、认证状态、证件类型信息
6.      * @param userInfo
7.      * @return
8.      */
9. private UserInfo packUserInfo(UserInfo userInfo) {
10.     String certificatesTypeString = dictFeignClient.getName(
11.         DictTypeEnum.CERTIFICATES_TYPE.getDictTypeId(),
12.         userInfo.getCertificatesType()
13.     );
15.     userInfo.getParam().put("certificatesTypeString", certificatesTypeString);
16.     userInfo.getParam().put(
17.         "authStatusString", AuthStatusEnum.getStatusNameByStatus(userInfo.getAuthStatus())
18.     );
19.     userInfo.getParam().put(
20.         "statusString", UserStatusEnum.getStatusNameByStatus(userInfo.getStatus())
21.     );
22.     return userInfo;
23. }

复制代码

6、显示图片

6.1、Controller

InnerFileController类

1. package com.atguigu.syt.yun.controller.inner;
3. @Api(tags = "阿里云文件管理")
4. @RestController
5. @RequestMapping("/inner/yun/file")
6. public class InnerFileController {
8.     @Resource
9.     private FileService fileService;
10.    
11.     @ApiOperation(value = "获取图片预览Url")
12.     @ApiImplicitParam(name = "objectName",value = "文件名", required = true)
13.     @GetMapping("/getPreviewUrl")
14.     public String getPreviewUrl(@RequestParam String objectName) {
16.         return fileService.getPreviewUrl(objectName);
17.     }
18. }

复制代码

6.2、Service

接口：FileService

1. /**
2.      * 获取图片url地址
3.      * @param objectName
4.      * @return
5.      */
6. String getPreviewUrl(String objectName);

复制代码

实现：FileServiceImpl

1. @Override
2. public String getPreviewUrl(String objectName) {
3.     // Endpoint以华东1（杭州）为例，其它Region请按实际情况填写。
4.     String endpoint = ossConstantProperties.getEndpoint();
5.     // 阿里云账号AccessKey拥有所有API的访问权限，风险很高。强烈建议您创建并使用RAM用户进行API访问或日常运维，请登录RAM控制台创建RAM用户。
6.     String accessKeyId = ossConstantProperties.getKeyId();
7.     String accessKeySecret = ossConstantProperties.getKeySecret();
8.     // 填写Bucket名称，例如examplebucket。
9.     String bucketName = ossConstantProperties.getBucketName();
11.     OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
12.     // 设置URL过期时间为1小时，单位：毫秒
13.     Date expiration = new Date(new Date().getTime() + 60 * 60 * 1000);
14.     URL url = ossClient.generatePresignedUrl(bucketName, objectName, expiration);
15.     System.out.println(url.toString());
16.     return url.toString();
17. }

复制代码

6.3、创建service-yun-client


6.4、定义FeignClient

接口：

1. package com.atguigu.syt.yun.client;
2. @FeignClient(
3.         value = "service-yun",
4.         contextId = "fileFeignClient",
5.         fallback = FileDegradeFeignClient.class
6. )
7. public interface FileFeignClient {
9.     @GetMapping("inner/yun/file/getPreviewUrl")
10.     String getPreviewUrl(@RequestParam String objectName);
11. }

复制代码

降级：

1. package com.atguigu.syt.yun.client.impl;
3. @Component
4. public class FileDegradeFeignClient implements FileFeignClient {
5.     @Override
6.     public String getPreviewUrl(String objectName) {
7.         return "图片显示失败";
8.     }
9. }

复制代码

6.5、service中添加依赖

1. <dependency>
2.     <groupId>com.atguigu</groupId>
3.     <artifactId>service-yun-client</artifactId>
4.     <version>1.0</version>
5. </dependency>

复制代码

6.6、远程调用

UserInfoServiceImpl：

1. @Resource
2. private FileFeignClient fileFeignClient;

复制代码

UserInfoServiceImpl：packUserInfo方法中添加如下代码

1. String previewUrl = fileFeignClient.getPreviewUrl(userInfo.getCertificatesUrl());
2. userInfo.getParam().put("previewUrl", previewUrl);

复制代码

注意：由于是远程调用阿里云服务器，因此配置文件中feignClient的远程超时时间可以设置的稍微长一些，避免个别情况下由于网络原因出现的图片无法加载的情况
7、用户认证前端

7.1、api

创建api/userInfo.js

1. import request from '@/utils/request'
3. //引入js-cookie
4. import cookie from 'js-cookie'
6. export default {
8.   saveUserAuth(userAuth) {
9.     return request({
10.       url: `/front/user/userInfo/auth/userAuth`,
11.       method: 'post',
12.       data: userAuth,
13.       headers:{token: cookie.get('token')}
14.     })
15.   },
17.   getUserInfo() {
18.     return request({
19.       url: `/front/user/userInfo/auth/getUserInfo`,
20.       method: `get`,
21.       headers:{token: cookie.get('token')}
22.     })
23.   }
24. }

复制代码

7.2、页面渲染

pages/user/index.vue文件
资料：资料>实名认证>user
7.3、统一发送请求头

也可以统一发送请求头：删除api/user.js 中对请求头的设置，修改utils/request.js文件如下

1. //引入js-cookie
2. import cookie from 'js-cookie'

复制代码

修改请求拦截器

1. // http request 拦截器
2. service.interceptors.request.use(
3.         config => {
4.                 //从cookie中取出token，并且在请求头中携带token
5.                 if (cookie.get('token')) {
6.                         config.headers['token'] = cookie.get('token')
7.                 }
8.                 return config
9.         },
10.         err => {
11.                 return Promise.reject(err)
12.         })

复制代码

源码：https://gitee.com/dengyaojava/guigu-syt-parent

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！