1.尚医通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中引入依赖
<dependencies><!-- 阿里云oss依赖 --><dependency><groupId>com.aliyun.oss</groupId><artifactId>aliyun-sdk-oss</artifactId><version>3.15.1</version></dependency><!--实体--><dependency><groupId>com.atguigu</groupId><artifactId>model</artifactId><version>1.0</version></dependency><!--服务通用配置--><dependency><groupId>com.atguigu</groupId><artifactId>service-util</artifactId><version>1.0</version></dependency><!--时间日期工具--><dependency><groupId>joda-time</groupId><artifactId>joda-time</artifactId></dependency><!--自定义安全模块--><dependency><groupId>com.atguigu</groupId><artifactId>spring-security</artifactId><version>1.0</version></dependency><!-- 单元测试 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency></dependencies><dependencies> <!-- 阿里云oss依赖 --> <dependency> <groupId>com.aliyun.oss</groupId> <artifactId>aliyun-sdk-oss</artifactId> <version>3.15.1</version> </dependency> <!--实体--> <dependency> <groupId>com.atguigu</groupId> <artifactId>model</artifactId> <version>1.0</version> </dependency> <!--服务通用配置--> <dependency> <groupId>com.atguigu</groupId> <artifactId>service-util</artifactId> <version>1.0</version> </dependency> <!--时间日期工具--> <dependency> <groupId>joda-time</groupId> <artifactId>joda-time</artifactId> </dependency> <!--自定义安全模块--> <dependency> <groupId>com.atguigu</groupId> <artifactId>spring-security</artifactId> <version>1.0</version> </dependency> <!-- 单元测试 --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> </dependencies><dependencies> <!-- 阿里云oss依赖 --> <dependency> <groupId>com.aliyun.oss</groupId> <artifactId>aliyun-sdk-oss</artifactId> <version>3.15.1</version> </dependency> <!--实体--> <dependency> <groupId>com.atguigu</groupId> <artifactId>model</artifactId> <version>1.0</version> </dependency> <!--服务通用配置--> <dependency> <groupId>com.atguigu</groupId> <artifactId>service-util</artifactId> <version>1.0</version> </dependency> <!--时间日期工具--> <dependency> <groupId>joda-time</groupId> <artifactId>joda-time</artifactId> </dependency> <!--自定义安全模块--> <dependency> <groupId>com.atguigu</groupId> <artifactId>spring-security</artifactId> <version>1.0</version> </dependency> <!-- 单元测试 --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> </dependencies>
1.3、创建配置文件#
在server-yun模块中resources目录下创建文件
application.yml：
spring:application:name: service-yunprofiles:active: dev,redisspring: application: name: service-yun profiles: active: dev,redisspring: application: name: service-yun profiles: active: dev,redis
application-dev.yml：
server:port: 8204spring:cloud:nacos:discovery:server-addr: 127.0.0.1:8848servlet:multipart:max-file-size: 10MBmax-request-size: 10MBlogging:level:root: infofile:path: yunaliyun:oss: #阿里云 OSSendpoint: your endpointkey-id: your accessKeyIdkey-secret: your accessKeySecretbucket-name: your bucketnameserver: port: 8204 spring: cloud: nacos: discovery: server-addr: 127.0.0.1:8848 servlet: multipart: max-file-size: 10MB max-request-size: 10MB logging: level: root: info file: path: yun aliyun: oss: #阿里云 OSS endpoint: your endpoint key-id: your accessKeyId key-secret: your accessKeySecret bucket-name: your bucketnameserver: port: 8204 spring: cloud: nacos: discovery: server-addr: 127.0.0.1:8848 servlet: multipart: max-file-size: 10MB max-request-size: 10MB logging: level: root: info file: path: yun aliyun: oss: #阿里云 OSS endpoint: your endpoint key-id: your accessKeyId key-secret: your accessKeySecret bucket-name: your bucketname
1.4、创建启动类#
创建ServiceYunApplication
package com.atguigu.syt.yun;@SpringBootApplication(exclude = DataSourceAutoConfiguration.class)//取消数据源配置自动读取@ComponentScan(basePackages = {"com.atguigu"})public class ServiceYunApplication {public static void main(String[] args) {SpringApplication.run(ServiceYunApplication.class, args);}}package com.atguigu.syt.yun; @SpringBootApplication(exclude = DataSourceAutoConfiguration.class)//取消数据源配置自动读取 @ComponentScan(basePackages = {"com.atguigu"}) public class ServiceYunApplication { public static void main(String[] args) { SpringApplication.run(ServiceYunApplication.class, args); } }package com.atguigu.syt.yun; @SpringBootApplication(exclude = DataSourceAutoConfiguration.class)//取消数据源配置自动读取 @ComponentScan(basePackages = {"com.atguigu"}) public class ServiceYunApplication { public static void main(String[] args) { SpringApplication.run(ServiceYunApplication.class, args); } }
1.5、配置网关#
在网关中配置如下内容：
- id: service-yunpredicates: Path=/*/yun/**uri: lb://service-yun- id: service-yun predicates: Path=/*/yun/** uri: lb://service-yun- id: service-yun predicates: Path=/*/yun/** uri: lb://service-yun
2、文件上传#
2.1、从配置文件读取常量#
创建常量读取工具类：OssConstantProperties.java
package com.atguigu.syt.yun.utils;@Configuration@ConfigurationProperties(prefix="aliyun.oss") //读取节点@Datapublic class OssConstantProperties {private String endpoint;private String keyId;private String keySecret;private String bucketName;}package com.atguigu.syt.yun.utils; @Configuration @ConfigurationProperties(prefix="aliyun.oss") //读取节点 @Data public class OssConstantProperties { private String endpoint; private String keyId; private String keySecret; private String bucketName; }package com.atguigu.syt.yun.utils; @Configuration @ConfigurationProperties(prefix="aliyun.oss") //读取节点 @Data public class OssConstantProperties { private String endpoint; private String keyId; private String keySecret; private String bucketName; }
2.2、Controller#
创建controller.front包，创建FrontFileController类
package com.atguigu.syt.yun.controller.front;@Api(tags = "阿里云文件管理")@RestController@RequestMapping("/front/yun/file")public class FrontFileController {@Resourceprivate FileService fileService;/*** 文件上传*/@ApiOperation("文件上传")@ApiImplicitParam(name = "file",value = "上传文件", required = true)@PostMapping("/auth/upload")public Result<Map<String, String>> upload(MultipartFile file) {Map<String, String> map = fileService.upload(file);return Result.ok(map);}}package com.atguigu.syt.yun.controller.front; @Api(tags = "阿里云文件管理") @RestController @RequestMapping("/front/yun/file") public class FrontFileController { @Resource private FileService fileService; /** * 文件上传 */ @ApiOperation("文件上传") @ApiImplicitParam(name = "file",value = "上传文件", required = true) @PostMapping("/auth/upload") public Result<Map<String, String>> upload(MultipartFile file) { Map<String, String> map = fileService.upload(file); return Result.ok(map); } }package com.atguigu.syt.yun.controller.front; @Api(tags = "阿里云文件管理") @RestController @RequestMapping("/front/yun/file") public class FrontFileController { @Resource private FileService fileService; /** * 文件上传 */ @ApiOperation("文件上传") @ApiImplicitParam(name = "file",value = "上传文件", required = true) @PostMapping("/auth/upload") public Result<Map<String, String>> upload(MultipartFile file) { Map<String, String> map = fileService.upload(file); return Result.ok(map); } }
2.3、Service#
接口：FileService
package com.atguigu.syt.oss.service;public interface FileService {/*** 文件上传* @param file* @return*/Map<String, String> upload(MultipartFile file);}package com.atguigu.syt.oss.service; public interface FileService { /** * 文件上传 * @param file * @return */ Map<String, String> upload(MultipartFile file); }package com.atguigu.syt.oss.service; public interface FileService { /** * 文件上传 * @param file * @return */ Map<String, String> upload(MultipartFile file); }
实现：FileServiceImpl
参考SDK中的：Java->上传文件->简单上传->流式上传->上传文件流
package com.atguigu.syt.oss.service.impl;@Service@Slf4jpublic class FileServiceImpl implements FileService {@Resourceprivate OssConstantProperties ossConstantProperties;/*** 参考SDK中的：Java->上传文件->简单上传->流式上传->上传文件流* @param file* @return*/@Overridepublic Map<String, String> upload(MultipartFile file) {// Endpoint以华东1（杭州）为例，其它Region请按实际情况填写。String endpoint = ossConstantProperties.getEndpoint();// 阿里云账号AccessKey拥有所有API的访问权限，风险很高。强烈建议您创建并使用RAM用户进行API访问或日常运维，请登录RAM控制台创建RAM用户。String accessKeyId = ossConstantProperties.getKeyId();String accessKeySecret = ossConstantProperties.getKeySecret();// 填写Bucket名称，例如examplebucket。String bucketName = ossConstantProperties.getBucketName();// 文件名称String originalFilename = file.getOriginalFilename();String dateString = new DateTime().toString("yyyyMMdd");// 填写Object完整路径，完整路径中不能包含Bucket名称，例如exampledir/exampleobject.txt。String objectName =dateString+ "/" + UUID.randomUUID().toString().replace("-", "")+ originalFilename.substring(originalFilename.lastIndexOf("."));// 创建OSSClient实例。OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);try {InputStream inputStream = file.getInputStream();// 创建PutObjectRequest对象。PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, objectName, inputStream);// 设置该属性可以返回response。如果不设置，则返回的response为空。putObjectRequest.setProcess("true");// 创建PutObject请求。PutObjectResult result = ossClient.putObject(putObjectRequest);// 如果上传成功，则返回200。log.info(Integer.toString(result.getResponse().getStatusCode()));if(result.getResponse().getStatusCode() != 200){throw new GuiguException(ResultCodeEnum.FAIL);}//返回图片路径//参考SDK中的：Java-> Java授权访问-> 生成以GET方法访问的签名URL// 设置URL过期时间为1小时，单位：毫秒Date expiration = new Date(new Date().getTime() + 60 * 60 * 1000);URL url = ossClient.generatePresignedUrl(bucketName, objectName, expiration);Map<String, String> map = new HashMap<>();map.put("previewUrl", url.toString()); //页面中授权预览图片map.put("url", objectName); //数据库存储return map;} 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());throw new GuiguException(ResultCodeEnum.FAIL, oe);} catch (GuiguException 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());throw new GuiguException(ResultCodeEnum.FAIL, ce);} catch (IOException e) {throw new GuiguException(ResultCodeEnum.FAIL, e);} finally {if (ossClient != null) {ossClient.shutdown();}}}}package com.atguigu.syt.oss.service.impl; @Service @Slf4j public class FileServiceImpl implements FileService { @Resource private OssConstantProperties ossConstantProperties; /** * 参考SDK中的：Java->上传文件->简单上传->流式上传->上传文件流 * @param file * @return */ @Override public Map<String, String> upload(MultipartFile file) { // Endpoint以华东1（杭州）为例，其它Region请按实际情况填写。 String endpoint = ossConstantProperties.getEndpoint(); // 阿里云账号AccessKey拥有所有API的访问权限，风险很高。强烈建议您创建并使用RAM用户进行API访问或日常运维，请登录RAM控制台创建RAM用户。 String accessKeyId = ossConstantProperties.getKeyId(); String accessKeySecret = ossConstantProperties.getKeySecret(); // 填写Bucket名称，例如examplebucket。 String bucketName = ossConstantProperties.getBucketName(); // 文件名称 String originalFilename = file.getOriginalFilename(); String dateString = new DateTime().toString("yyyyMMdd"); // 填写Object完整路径，完整路径中不能包含Bucket名称，例如exampledir/exampleobject.txt。 String objectName = dateString + "/" + UUID.randomUUID().toString().replace("-", "") + originalFilename.substring(originalFilename.lastIndexOf(".")); // 创建OSSClient实例。 OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret); try { InputStream inputStream = file.getInputStream(); // 创建PutObjectRequest对象。 PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, objectName, inputStream); // 设置该属性可以返回response。如果不设置，则返回的response为空。 putObjectRequest.setProcess("true"); // 创建PutObject请求。 PutObjectResult result = ossClient.putObject(putObjectRequest); // 如果上传成功，则返回200。 log.info(Integer.toString(result.getResponse().getStatusCode())); if(result.getResponse().getStatusCode() != 200){ throw new GuiguException(ResultCodeEnum.FAIL); } //返回图片路径 //参考SDK中的：Java-> Java授权访问-> 生成以GET方法访问的签名URL // 设置URL过期时间为1小时，单位：毫秒 Date expiration = new Date(new Date().getTime() + 60 * 60 * 1000); URL url = ossClient.generatePresignedUrl(bucketName, objectName, expiration); Map<String, String> map = new HashMap<>(); map.put("previewUrl", url.toString()); //页面中授权预览图片 map.put("url", objectName); //数据库存储 return map; } 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()); throw new GuiguException(ResultCodeEnum.FAIL, oe); } catch (GuiguException 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()); throw new GuiguException(ResultCodeEnum.FAIL, ce); } catch (IOException e) { throw new GuiguException(ResultCodeEnum.FAIL, e); } finally { if (ossClient != null) { ossClient.shutdown(); } } } }package com.atguigu.syt.oss.service.impl; @Service @Slf4j public class FileServiceImpl implements FileService { @Resource private OssConstantProperties ossConstantProperties; /** * 参考SDK中的：Java->上传文件->简单上传->流式上传->上传文件流 * @param file * @return */ @Override public Map<String, String> upload(MultipartFile file) { // Endpoint以华东1（杭州）为例，其它Region请按实际情况填写。 String endpoint = ossConstantProperties.getEndpoint(); // 阿里云账号AccessKey拥有所有API的访问权限，风险很高。强烈建议您创建并使用RAM用户进行API访问或日常运维，请登录RAM控制台创建RAM用户。 String accessKeyId = ossConstantProperties.getKeyId(); String accessKeySecret = ossConstantProperties.getKeySecret(); // 填写Bucket名称，例如examplebucket。 String bucketName = ossConstantProperties.getBucketName(); // 文件名称 String originalFilename = file.getOriginalFilename(); String dateString = new DateTime().toString("yyyyMMdd"); // 填写Object完整路径，完整路径中不能包含Bucket名称，例如exampledir/exampleobject.txt。 String objectName = dateString + "/" + UUID.randomUUID().toString().replace("-", "") + originalFilename.substring(originalFilename.lastIndexOf(".")); // 创建OSSClient实例。 OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret); try { InputStream inputStream = file.getInputStream(); // 创建PutObjectRequest对象。 PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, objectName, inputStream); // 设置该属性可以返回response。如果不设置，则返回的response为空。 putObjectRequest.setProcess("true"); // 创建PutObject请求。 PutObjectResult result = ossClient.putObject(putObjectRequest); // 如果上传成功，则返回200。 log.info(Integer.toString(result.getResponse().getStatusCode())); if(result.getResponse().getStatusCode() != 200){ throw new GuiguException(ResultCodeEnum.FAIL); } //返回图片路径 //参考SDK中的：Java-> Java授权访问-> 生成以GET方法访问的签名URL // 设置URL过期时间为1小时，单位：毫秒 Date expiration = new Date(new Date().getTime() + 60 * 60 * 1000); URL url = ossClient.generatePresignedUrl(bucketName, objectName, expiration); Map<String, String> map = new HashMap<>(); map.put("previewUrl", url.toString()); //页面中授权预览图片 map.put("url", objectName); //数据库存储 return map; } 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()); throw new GuiguException(ResultCodeEnum.FAIL, oe); } catch (GuiguException 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()); throw new GuiguException(ResultCodeEnum.FAIL, ce); } catch (IOException e) { throw new GuiguException(ResultCodeEnum.FAIL, e); } finally { if (ossClient != null) { ossClient.shutdown(); } } } }
3、授权校验#
3.1、辅助类#
在service-util模块中添加AuthContextHolder.java
package com.atguigu.common.service.utils;/*** 授权校验*/@Componentpublic class AuthContextHolder {@Resourceprivate RedisTemplate redisTemplate;/*** 校验token是否存在并返回UserId* @param request*/public Long checkAuth(HttpServletRequest request){//从http请求头中获取tokenString token = request.getHeader("token");if(StringUtils.isEmpty(token)) {throw new GuiguException(ResultCodeEnum.LOGIN_AUTH);}Object userIdObj = redisTemplate.opsForValue().get("user:token:" + token);//数据存入redis时，按照实际的大小分配空间，取出时int能存下，默认使用int类型，int存不下再用long//我们无法判断redis中存储的是什么类型的id，因此在此做一个转换Long userId = null;if(userIdObj instanceof Integer){userId = ((Integer)userIdObj).longValue();}else if(userIdObj instanceof Long){userId = (Long)userIdObj;}else if(userIdObj instanceof String){userId = Long.parseLong(userIdObj.toString());}if(StringUtils.isEmpty(userId)) {throw new GuiguException(ResultCodeEnum.LOGIN_AUTH);}return userId;}}package com.atguigu.common.service.utils; /** * 授权校验 */ @Component public class AuthContextHolder { @Resource private RedisTemplate redisTemplate; /** * 校验token是否存在并返回UserId * @param request */ public Long checkAuth(HttpServletRequest request){ //从http请求头中获取token String token = request.getHeader("token"); if(StringUtils.isEmpty(token)) { throw new GuiguException(ResultCodeEnum.LOGIN_AUTH); } Object userIdObj = redisTemplate.opsForValue().get("user:token:" + token); //数据存入redis时，按照实际的大小分配空间，取出时int能存下，默认使用int类型，int存不下再用long //我们无法判断redis中存储的是什么类型的id，因此在此做一个转换 Long userId = null; if(userIdObj instanceof Integer){ userId = ((Integer)userIdObj).longValue(); }else if(userIdObj instanceof Long){ userId = (Long)userIdObj; }else if(userIdObj instanceof String){ userId = Long.parseLong(userIdObj.toString()); } if(StringUtils.isEmpty(userId)) { throw new GuiguException(ResultCodeEnum.LOGIN_AUTH); } return userId; } }package com.atguigu.common.service.utils; /** * 授权校验 */ @Component public class AuthContextHolder { @Resource private RedisTemplate redisTemplate; /** * 校验token是否存在并返回UserId * @param request */ public Long checkAuth(HttpServletRequest request){ //从http请求头中获取token String token = request.getHeader("token"); if(StringUtils.isEmpty(token)) { throw new GuiguException(ResultCodeEnum.LOGIN_AUTH); } Object userIdObj = redisTemplate.opsForValue().get("user:token:" + token); //数据存入redis时，按照实际的大小分配空间，取出时int能存下，默认使用int类型，int存不下再用long //我们无法判断redis中存储的是什么类型的id，因此在此做一个转换 Long userId = null; if(userIdObj instanceof Integer){ userId = ((Integer)userIdObj).longValue(); }else if(userIdObj instanceof Long){ userId = (Long)userIdObj; }else if(userIdObj instanceof String){ userId = Long.parseLong(userIdObj.toString()); } if(StringUtils.isEmpty(userId)) { throw new GuiguException(ResultCodeEnum.LOGIN_AUTH); } return userId; } }
3.2、修改文件上传controller#
添加校验代码
...public class FrontFileController {...@Resourceprivate AuthContextHolder authContextHolder;...public Result<Map<String, String>> upload(MultipartFile file, HttpServletRequest request) {authContextHolder.checkAuth(request);...}}... public class FrontFileController { ... @Resource private AuthContextHolder authContextHolder; ... public Result<Map<String, String>> upload(MultipartFile file, HttpServletRequest request) { authContextHolder.checkAuth(request); ... } }... public class FrontFileController { ... @Resource private AuthContextHolder authContextHolder; ... public Result<Map<String, String>> upload(MultipartFile file, HttpServletRequest request) { authContextHolder.checkAuth(request); ... } }
3.3、测试文件上传#
首先添加全局参数token，然后再进行测试
4、提交认证#
4.1、Controller#
创建FrontUserInfoController中添加如下方法
package com.atguigu.syt.user.controller.front;@Api(tags = "用户管理")@RestController@RequestMapping("/front/user/userInfo")public class FrontUserInfoController {@Resourceprivate UserInfoService userInfoService;@Resourceprivate AuthContextHolder authContextHolder;@ApiOperation(value = "用户认证")@ApiImplicitParam(name = "userAuthVo",value = "用户实名认证对象", required = true)@PostMapping("/auth/userAuth")public Result userAuth(@RequestBody UserAuthVo userAuthVo, HttpServletRequest request) {Long userId = authContextHolder.checkAuth(request);userInfoService.userAuth(userId, userAuthVo);return Result.ok();}}package com.atguigu.syt.user.controller.front; @Api(tags = "用户管理") @RestController @RequestMapping("/front/user/userInfo") public class FrontUserInfoController { @Resource private UserInfoService userInfoService; @Resource private AuthContextHolder authContextHolder; @ApiOperation(value = "用户认证") @ApiImplicitParam(name = "userAuthVo",value = "用户实名认证对象", required = true) @PostMapping("/auth/userAuth") public Result userAuth(@RequestBody UserAuthVo userAuthVo, HttpServletRequest request) { Long userId = authContextHolder.checkAuth(request); userInfoService.userAuth(userId, userAuthVo); return Result.ok(); } }package com.atguigu.syt.user.controller.front; @Api(tags = "用户管理") @RestController @RequestMapping("/front/user/userInfo") public class FrontUserInfoController { @Resource private UserInfoService userInfoService; @Resource private AuthContextHolder authContextHolder; @ApiOperation(value = "用户认证") @ApiImplicitParam(name = "userAuthVo",value = "用户实名认证对象", required = true) @PostMapping("/auth/userAuth") public Result userAuth(@RequestBody UserAuthVo userAuthVo, HttpServletRequest request) { Long userId = authContextHolder.checkAuth(request); userInfoService.userAuth(userId, userAuthVo); return Result.ok(); } }
4.2、Service#
接口：UserInfoService
/*** 保存实名认证信息* @param userId* @param userAuthVo*/void userAuth(Long userId, UserAuthVo userAuthVo);/** * 保存实名认证信息 * @param userId * @param userAuthVo */ void userAuth(Long userId, UserAuthVo userAuthVo);/** * 保存实名认证信息 * @param userId * @param userAuthVo */ void userAuth(Long userId, UserAuthVo userAuthVo);
实现：UserInfoServiceImpl
@Overridepublic void userAuth(Long userId, UserAuthVo userAuthVo) {//设置认证信息UserInfo userInfo = new UserInfo();userInfo.setId(userId);userInfo.setName(userAuthVo.getName());userInfo.setCertificatesType(userAuthVo.getCertificatesType());userInfo.setCertificatesNo(userAuthVo.getCertificatesNo());userInfo.setCertificatesUrl(userAuthVo.getCertificatesUrl());userInfo.setAuthStatus(AuthStatusEnum.AUTH_RUN.getStatus());//信息更新baseMapper.updateById(userInfo);}@Override public void userAuth(Long userId, UserAuthVo userAuthVo) { //设置认证信息 UserInfo userInfo = new UserInfo(); userInfo.setId(userId); userInfo.setName(userAuthVo.getName()); userInfo.setCertificatesType(userAuthVo.getCertificatesType()); userInfo.setCertificatesNo(userAuthVo.getCertificatesNo()); userInfo.setCertificatesUrl(userAuthVo.getCertificatesUrl()); userInfo.setAuthStatus(AuthStatusEnum.AUTH_RUN.getStatus()); //信息更新 baseMapper.updateById(userInfo); }@Override public void userAuth(Long userId, UserAuthVo userAuthVo) { //设置认证信息 UserInfo userInfo = new UserInfo(); userInfo.setId(userId); userInfo.setName(userAuthVo.getName()); userInfo.setCertificatesType(userAuthVo.getCertificatesType()); userInfo.setCertificatesNo(userAuthVo.getCertificatesNo()); userInfo.setCertificatesUrl(userAuthVo.getCertificatesUrl()); userInfo.setAuthStatus(AuthStatusEnum.AUTH_RUN.getStatus()); //信息更新 baseMapper.updateById(userInfo); }
5、获取认证信息#
5.1、Controller#
在service-user模块的FrontUserInfoController中添加如下方法
@ApiOperation(value = "获取认证信息")@GetMapping("/auth/getUserInfo")public Result<UserInfo> getUserInfo(HttpServletRequest request) {Long userId = authContextHolder.checkAuth(request);UserInfo userInfo = userInfoService.getUserInfoById(userId);return Result.ok(userInfo);}@ApiOperation(value = "获取认证信息") @GetMapping("/auth/getUserInfo") public Result<UserInfo> getUserInfo(HttpServletRequest request) { Long userId = authContextHolder.checkAuth(request); UserInfo userInfo = userInfoService.getUserInfoById(userId); return Result.ok(userInfo); }@ApiOperation(value = "获取认证信息") @GetMapping("/auth/getUserInfo") public Result<UserInfo> getUserInfo(HttpServletRequest request) { Long userId = authContextHolder.checkAuth(request); UserInfo userInfo = userInfoService.getUserInfoById(userId); return Result.ok(userInfo); }
5.2、Service#
主类添加
@EnableFeignClients("com.atguigu.syt")@EnableFeignClients("com.atguigu.syt")@EnableFeignClients("com.atguigu.syt")
接口：UserInfoService
/*** 根据用户id获取用户信息* @param userId* @return*/UserInfo getUserInfoById(Long userId);/** * 根据用户id获取用户信息 * @param userId * @return */ UserInfo getUserInfoById(Long userId);/** * 根据用户id获取用户信息 * @param userId * @return */ UserInfo getUserInfoById(Long userId);
实现：UserInfoServiceImpl
@Overridepublic UserInfo getUserInfoById(Long userId) {UserInfo userInfo = baseMapper.selectById(userId);return this.packUserInfo(userInfo);}@Override public UserInfo getUserInfoById(Long userId) { UserInfo userInfo = baseMapper.selectById(userId); return this.packUserInfo(userInfo); }@Override public UserInfo getUserInfoById(Long userId) { UserInfo userInfo = baseMapper.selectById(userId); return this.packUserInfo(userInfo); }
辅助方法：UserInfoServiceImpl
@Resourceprivate DictFeignClient dictFeignClient;/*** 封装用户状态、认证状态、证件类型信息* @param userInfo* @return*/private UserInfo packUserInfo(UserInfo userInfo) {String certificatesTypeString = dictFeignClient.getName(DictTypeEnum.CERTIFICATES_TYPE.getDictTypeId(),userInfo.getCertificatesType());userInfo.getParam().put("certificatesTypeString", certificatesTypeString);userInfo.getParam().put("authStatusString", AuthStatusEnum.getStatusNameByStatus(userInfo.getAuthStatus()));userInfo.getParam().put("statusString", UserStatusEnum.getStatusNameByStatus(userInfo.getStatus()));return userInfo;}@Resource private DictFeignClient dictFeignClient; /** * 封装用户状态、认证状态、证件类型信息 * @param userInfo * @return */ private UserInfo packUserInfo(UserInfo userInfo) { String certificatesTypeString = dictFeignClient.getName( DictTypeEnum.CERTIFICATES_TYPE.getDictTypeId(), userInfo.getCertificatesType() ); userInfo.getParam().put("certificatesTypeString", certificatesTypeString); userInfo.getParam().put( "authStatusString", AuthStatusEnum.getStatusNameByStatus(userInfo.getAuthStatus()) ); userInfo.getParam().put( "statusString", UserStatusEnum.getStatusNameByStatus(userInfo.getStatus()) ); return userInfo; }@Resource private DictFeignClient dictFeignClient; /** * 封装用户状态、认证状态、证件类型信息 * @param userInfo * @return */ private UserInfo packUserInfo(UserInfo userInfo) { String certificatesTypeString = dictFeignClient.getName( DictTypeEnum.CERTIFICATES_TYPE.getDictTypeId(), userInfo.getCertificatesType() ); userInfo.getParam().put("certificatesTypeString", certificatesTypeString); userInfo.getParam().put( "authStatusString", AuthStatusEnum.getStatusNameByStatus(userInfo.getAuthStatus()) ); userInfo.getParam().put( "statusString", UserStatusEnum.getStatusNameByStatus(userInfo.getStatus()) ); return userInfo; }
6、显示图片#
6.1、Controller#
InnerFileController类
package com.atguigu.syt.yun.controller.inner;@Api(tags = "阿里云文件管理")@RestController@RequestMapping("/inner/yun/file")public class InnerFileController {@Resourceprivate FileService fileService;@ApiOperation(value = "获取图片预览Url")@ApiImplicitParam(name = "objectName",value = "文件名", required = true)@GetMapping("/getPreviewUrl")public String getPreviewUrl(@RequestParam String objectName) {return fileService.getPreviewUrl(objectName);}}package com.atguigu.syt.yun.controller.inner; @Api(tags = "阿里云文件管理") @RestController @RequestMapping("/inner/yun/file") public class InnerFileController { @Resource private FileService fileService; @ApiOperation(value = "获取图片预览Url") @ApiImplicitParam(name = "objectName",value = "文件名", required = true) @GetMapping("/getPreviewUrl") public String getPreviewUrl(@RequestParam String objectName) { return fileService.getPreviewUrl(objectName); } }package com.atguigu.syt.yun.controller.inner; @Api(tags = "阿里云文件管理") @RestController @RequestMapping("/inner/yun/file") public class InnerFileController { @Resource private FileService fileService; @ApiOperation(value = "获取图片预览Url") @ApiImplicitParam(name = "objectName",value = "文件名", required = true) @GetMapping("/getPreviewUrl") public String getPreviewUrl(@RequestParam String objectName) { return fileService.getPreviewUrl(objectName); } }
6.2、Service#
接口：FileService
/*** 获取图片url地址* @param objectName* @return*/String getPreviewUrl(String objectName);/** * 获取图片url地址 * @param objectName * @return */ String getPreviewUrl(String objectName);/** * 获取图片url地址 * @param objectName * @return */ String getPreviewUrl(String objectName);
实现：FileServiceImpl
@Overridepublic String getPreviewUrl(String objectName) {// Endpoint以华东1（杭州）为例，其它Region请按实际情况填写。String endpoint = ossConstantProperties.getEndpoint();// 阿里云账号AccessKey拥有所有API的访问权限，风险很高。强烈建议您创建并使用RAM用户进行API访问或日常运维，请登录RAM控制台创建RAM用户。String accessKeyId = ossConstantProperties.getKeyId();String accessKeySecret = ossConstantProperties.getKeySecret();// 填写Bucket名称，例如examplebucket。String bucketName = ossConstantProperties.getBucketName();OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);// 设置URL过期时间为1小时，单位：毫秒Date expiration = new Date(new Date().getTime() + 60 * 60 * 1000);URL url = ossClient.generatePresignedUrl(bucketName, objectName, expiration);System.out.println(url.toString());return url.toString();}@Override public String getPreviewUrl(String objectName) { // Endpoint以华东1（杭州）为例，其它Region请按实际情况填写。 String endpoint = ossConstantProperties.getEndpoint(); // 阿里云账号AccessKey拥有所有API的访问权限，风险很高。强烈建议您创建并使用RAM用户进行API访问或日常运维，请登录RAM控制台创建RAM用户。 String accessKeyId = ossConstantProperties.getKeyId(); String accessKeySecret = ossConstantProperties.getKeySecret(); // 填写Bucket名称，例如examplebucket。 String bucketName = ossConstantProperties.getBucketName(); OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret); // 设置URL过期时间为1小时，单位：毫秒 Date expiration = new Date(new Date().getTime() + 60 * 60 * 1000); URL url = ossClient.generatePresignedUrl(bucketName, objectName, expiration); System.out.println(url.toString()); return url.toString(); }@Override public String getPreviewUrl(String objectName) { // Endpoint以华东1（杭州）为例，其它Region请按实际情况填写。 String endpoint = ossConstantProperties.getEndpoint(); // 阿里云账号AccessKey拥有所有API的访问权限，风险很高。强烈建议您创建并使用RAM用户进行API访问或日常运维，请登录RAM控制台创建RAM用户。 String accessKeyId = ossConstantProperties.getKeyId(); String accessKeySecret = ossConstantProperties.getKeySecret(); // 填写Bucket名称，例如examplebucket。 String bucketName = ossConstantProperties.getBucketName(); OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret); // 设置URL过期时间为1小时，单位：毫秒 Date expiration = new Date(new Date().getTime() + 60 * 60 * 1000); URL url = ossClient.generatePresignedUrl(bucketName, objectName, expiration); System.out.println(url.toString()); return url.toString(); }
6.3、创建service-yun-client#
6.4、定义FeignClient#
接口：
package com.atguigu.syt.yun.client;@FeignClient(value = "service-yun",contextId = "fileFeignClient",fallback = FileDegradeFeignClient.class)public interface FileFeignClient {@GetMapping("inner/yun/file/getPreviewUrl")String getPreviewUrl(@RequestParam String objectName);}package com.atguigu.syt.yun.client; @FeignClient( value = "service-yun", contextId = "fileFeignClient", fallback = FileDegradeFeignClient.class ) public interface FileFeignClient { @GetMapping("inner/yun/file/getPreviewUrl") String getPreviewUrl(@RequestParam String objectName); }package com.atguigu.syt.yun.client; @FeignClient( value = "service-yun", contextId = "fileFeignClient", fallback = FileDegradeFeignClient.class ) public interface FileFeignClient { @GetMapping("inner/yun/file/getPreviewUrl") String getPreviewUrl(@RequestParam String objectName); }
降级：
package com.atguigu.syt.yun.client.impl;@Componentpublic class FileDegradeFeignClient implements FileFeignClient {@Overridepublic String getPreviewUrl(String objectName) {return "图片显示失败";}}package com.atguigu.syt.yun.client.impl; @Component public class FileDegradeFeignClient implements FileFeignClient { @Override public String getPreviewUrl(String objectName) { return "图片显示失败"; } }package com.atguigu.syt.yun.client.impl; @Component public class FileDegradeFeignClient implements FileFeignClient { @Override public String getPreviewUrl(String objectName) { return "图片显示失败"; } }
6.5、service中添加依赖#
<dependency><groupId>com.atguigu</groupId><artifactId>service-yun-client</artifactId><version>1.0</version></dependency><dependency> <groupId>com.atguigu</groupId> <artifactId>service-yun-client</artifactId> <version>1.0</version> </dependency><dependency> <groupId>com.atguigu</groupId> <artifactId>service-yun-client</artifactId> <version>1.0</version> </dependency>
6.6、远程调用#
UserInfoServiceImpl：
@Resourceprivate FileFeignClient fileFeignClient;@Resource private FileFeignClient fileFeignClient;@Resource private FileFeignClient fileFeignClient;
UserInfoServiceImpl：packUserInfo方法中添加如下代码
String previewUrl = fileFeignClient.getPreviewUrl(userInfo.getCertificatesUrl());userInfo.getParam().put("previewUrl", previewUrl);String previewUrl = fileFeignClient.getPreviewUrl(userInfo.getCertificatesUrl()); userInfo.getParam().put("previewUrl", previewUrl);String previewUrl = fileFeignClient.getPreviewUrl(userInfo.getCertificatesUrl()); userInfo.getParam().put("previewUrl", previewUrl);
注意：由于是远程调用阿里云服务器，因此配置文件中feignClient的远程超时时间可以设置的稍微长一些，避免个别情况下由于网络原因出现的图片无法加载的情况
7、用户认证前端#
7.1、api#
创建api/userInfo.js
import request from '@/utils/request'//引入js-cookieimport cookie from 'js-cookie'export default {saveUserAuth(userAuth) {return request({url: `/front/user/userInfo/auth/userAuth`,method: 'post',data: userAuth,headers:{token: cookie.get('token')}})},getUserInfo() {return request({url: `/front/user/userInfo/auth/getUserInfo`,method: `get`,headers:{token: cookie.get('token')}})}}import request from '@/utils/request' //引入js-cookie import cookie from 'js-cookie' export default { saveUserAuth(userAuth) { return request({ url: `/front/user/userInfo/auth/userAuth`, method: 'post', data: userAuth, headers:{token: cookie.get('token')} }) }, getUserInfo() { return request({ url: `/front/user/userInfo/auth/getUserInfo`, method: `get`, headers:{token: cookie.get('token')} }) } }import request from '@/utils/request' //引入js-cookie import cookie from 'js-cookie' export default { saveUserAuth(userAuth) { return request({ url: `/front/user/userInfo/auth/userAuth`, method: 'post', data: userAuth, headers:{token: cookie.get('token')} }) }, getUserInfo() { return request({ url: `/front/user/userInfo/auth/getUserInfo`, method: `get`, headers:{token: cookie.get('token')} }) } }
7.2、页面渲染#
pages/user/index.vue文件
资料：资料>实名认证>user
7.3、统一发送请求头#
也可以统一发送请求头：删除api/user.js 中对请求头的设置，修改utils/request.js文件如下
//引入js-cookieimport cookie from 'js-cookie'//引入js-cookie import cookie from 'js-cookie'//引入js-cookie import cookie from 'js-cookie'
修改请求拦截器
// http request 拦截器service.interceptors.request.use(config => {//从cookie中取出token，并且在请求头中携带tokenif (cookie.get('token')) {config.headers['token'] = cookie.get('token')}return config},err => {return Promise.reject(err)})// http request 拦截器 service.interceptors.request.use( config => { //从cookie中取出token，并且在请求头中携带token if (cookie.get('token')) { config.headers['token'] = cookie.get('token') } return config }, err => { return Promise.reject(err) })// http request 拦截器 service.interceptors.request.use( config => { //从cookie中取出token，并且在请求头中携带token if (cookie.get('token')) { config.headers['token'] = cookie.get('token') } return config }, err => { return Promise.reject(err) })
© 版权声明
文章版权归作者所有，未经允许请勿转载，侵权请联系 admin@trc20.tw 删除。
THE END
