海量数据处理商用短链接生成器平台 - 4

第六章 架构核心技术-池化思想-异步结合 性能优化最佳实践

第1集 RestTemplate里面的存在的问题你知道多少- Broken pipe错误

项目就更新到第六章了，剩下的内容 放百度网盘里面了，需要的来取。
链接：https://pan.baidu.com/s/19LHPw36dsxPB75z_FHS64Q?pwd=8h89
提取码：8h89
在这里插入图片描述

简介： RestTemplate里面的存在的问题你知道多少

  • 还原代码（暂时不用异步）

    • 异步-里面是用线程池-是池化思想的一种应用

  • 同步发送+resttemplate未池化

    • 压测结果 几百吞吐量

    • 错误Caused by: java.io.IOException: Broken pipe

      • 服务端向前端socket连接管道写返回数据时 链接（pipe）却断开了
        • 从应用角度分析，这是因为客户端等待返回超时了，主动断开了与服务端链接
        • 连接数设置太小，并发量增加后，造成大量请求排队等待
        • 网络延迟，是否有丢包
        • 内存是否足够多支持对应的并发量

      在这里插入图片描述

  • 问题分析

    • resttemplate底层是怎样的？
    • 基于之前的认知-池化思想，联想到是否使用了http连接池？

  • 重新认识RestTemplate

    • RestTemplate是Spring提供的用于访问Rest服务的客户端
    • 底层通过使用java.net包下的实现创建HTTP 请求
    • 通过使用ClientHttpRequestFactory指定不同的HTTP请求方式，主要提供了两种实现方式
      • SimpleClientHttpRequestFactory（默认）
        • 底层使用J2SE提供的方式，既java.net包提供的方式，创建底层的Http请求连接
        • 主要createRequest 方法（ 断点调试），每次都会创建一个新的连接，每次都创建连接会造成极大的资源浪费，而且若连接不能及时释放，会因为无法建立新的连接导致后面的请求阻塞
      • HttpComponentsClientHttpRequestFactory
        • 底层使用HttpClient访问远程的Http服务

  • 问题解决

    • 客户端每次请求都要和服务端建立新的连接，即三次握手将会非常耗时
    • 通过http连接池可以减少连接建立与释放的时间，提升http请求的性能
    • Spring的restTemplate是对httpclient进行了封装, 而httpclient是支持池化机制
    • 拓展
      • 对httpclient进行封装的有：Apache的Fluent、es的restHighLevelClient、spring的restTemplate等
第2集 高性能RestTemplate连接池封装配置实战

简介： 高性能RestTemplate封装配置实战

  • 配置RestTemplate连接池实战
  @Beanpublic RestTemplate restTemplate(ClientHttpRequestFactory factory) {return new RestTemplate(factory);}@Beanpublic ClientHttpRequestFactory httpRequestFactory() {return new HttpComponentsClientHttpRequestFactory(httpClient());}/*** @return*/@Beanpublic HttpClient httpClient() {Registry<ConnectionSocketFactory> registry = RegistryBuilder.<ConnectionSocketFactory>create().register("http", PlainConnectionSocketFactory.getSocketFactory()).register("https", SSLConnectionSocketFactory.getSocketFactory()).build();PoolingHttpClientConnectionManager connectionManager = new PoolingHttpClientConnectionManager(registry);//设置整个连接池最大连接数connectionManager.setMaxTotal(500);//MaxPerRoute路由是对maxTotal的细分,每个主机的并发，这里route指的是域名connectionManager.setDefaultMaxPerRoute(200);RequestConfig requestConfig = RequestConfig.custom()//返回数据的超时时间.setSocketTimeout(20000)//连接上服务器的超时时间.setConnectTimeout(10000)//从连接池中获取连接的超时时间.setConnectionRequestTimeout(1000).build();return HttpClientBuilder.create().setDefaultRequestConfig(requestConfig).setConnectionManager(connectionManager).build();}
第3集 【10倍+QPS提升】Jmeter5.x压测 优化后RestTemplate前后性能对比

简介： 【10倍+提升】Jmeter5.x压测 优化后RestTemplate前后性能对比

  • 同步发送+resttemplate未池化

    • 压测结果 几百 吞吐量

  • 同步发送+resttemplate池化

    • 压测结果

    在这里插入图片描述

  • 检查你自己公司的项目，是否存在对应的问题

在这里插入图片描述

第七章 账号微服务-发送短信验证码-池化+异步结合最佳实践

第1集 调用第三方短信验证码组件性能优化实战

简介：调用第三方短信验证码组件性能优化实战

  • 调整代码

  • 采用异步调用方式

  • 采用 resttemplate池化方式

第2集 说说一些薅羊毛的事情+防范解决方案
  • 抢票
  • 稀缺的酒、鞋等

在这里插入图片描述

  • 短信邮箱轰炸机

    • 什么是短信-邮箱轰炸机：
    手机短信轰炸机是批量、循环给手机无限发送各种网站的注册验证码短信的方法。
    • 美好的初衷-发明的由来
    最早发明是用来整治街头广告电话号泛滥的一种手段，采用“手机短信轰炸机”软件可无限发送垃圾短信到牛皮癣小广告的手机号码上，使对方的手机快速消耗电量，变成高频率振动棒，且无法正常使用。“短信轰炸机”可严厉打击城市“牛皮癣”，还城市明净容颜。
    • 灰色产业的目光-也就是部分不法分子利用
    某次大型程序员相亲现场-老王得罪了小王， 小王不爽，就道听途说知道了”短信轰炸机“，1天50元，轰炸了5天还打折300元。一天内接到来自全国各地数千个陌生电话短信的轰炸骚扰，导致个人通讯中断，被工作生活受到严重影响，连刚相亲到的女友没没法联系上了。

  • 原理

    很多人都用手机注册一些网站的验证了，比如手机验证码。先填手机号，然后发一条验证码过去，输入验证码，完成验证，注册成功。* 寻找大量肉鸡网站，寻找发送验证码的请求接口* 如果找不到接口，也可以使用自动化UI工具触发* 编写程序和调度任务，相关脚本录入数据库* 输入目标手机号或者邮箱，触发攻击

  • 公司带来的损失

    • 短信一条5分钱，如果被大量盗刷大家自己计算
    • 邮箱通知不用钱，但被大量盗刷，带宽、连接等都被占用，导致无法正常使用

  • 如何避免自己的网站成为”肉鸡“或者被刷呢

    • 增加图形验证码（开发人员）
    • 单IP请求次数限制（开发人员）
    • 限制号码发送（一般短信提供商会做）

  • 是否可以一劳永逸？？？

    • 没有百分百的安全，验证码是可以破解的，ip也是可以租用代理ip的

    • 攻防永远是有的，只过加大了攻击者的成本，ROI划不过来自然就放弃了

在这里插入图片描述

第3集 图形验证码开发之谷歌kaptcha引入

简介：谷歌开源kaptcha图形验证码开发

  • Kaptcha 框架介绍 谷歌开源的一个可高度配置的实用验证码生成工具

    • 验证码的字体/大小/颜色
    • 验证码内容的范围(数字，字母，中文汉字！)
    • 验证码图片的大小，边框，边框粗细，边框颜色
    • 验证码的干扰线
    • 验证码的样式(鱼眼样式、3D、普通模糊)

  • 聚合工程依赖添加（使用国内baomidou二次封装的springboot整合starter）

            <!--kaptcha依赖包--><dependency><groupId>com.baomidou</groupId><artifactId>kaptcha-spring-boot-starter</artifactId><version>1.1.0</version></dependency>
  • 账号微服务添加
            <dependency><groupId>com.baomidou</groupId><artifactId>kaptcha-spring-boot-starter</artifactId></dependency>
  • 开发配置（任何框架和springboot整合基本都是）
@Configuration
public class CaptchaConfig {/*** 验证码配置* Kaptcha配置类名* * @return*/@Bean@Qualifier("captchaProducer")public DefaultKaptcha kaptcha() {DefaultKaptcha kaptcha = new DefaultKaptcha();Properties properties = new Properties();
//    properties.setProperty(Constants.KAPTCHA_BORDER, "yes");
//    properties.setProperty(Constants.KAPTCHA_BORDER_COLOR, "220,220,220");
//    //properties.setProperty(Constants.KAPTCHA_TEXTPRODUCER_FONT_COLOR, "38,29,12");
//    properties.setProperty(Constants.KAPTCHA_IMAGE_WIDTH, "147");
//    properties.setProperty(Constants.KAPTCHA_IMAGE_HEIGHT, "34");
//    properties.setProperty(Constants.KAPTCHA_TEXTPRODUCER_FONT_SIZE, "25");
//    //properties.setProperty(Constants.KAPTCHA_SESSION_KEY, "code");//验证码个数properties.setProperty(Constants.KAPTCHA_TEXTPRODUCER_CHAR_LENGTH, "4");
//    properties.setProperty(Constants.KAPTCHA_TEXTPRODUCER_FONT_NAMES, "Courier");//字体间隔properties.setProperty(Constants.KAPTCHA_TEXTPRODUCER_CHAR_SPACE,"8");//干扰线颜色
//    properties.setProperty(Constants.KAPTCHA_NOISE_COLOR, "white");//干扰实现类properties.setProperty(Constants.KAPTCHA_NOISE_IMPL, "com.google.code.kaptcha.impl.NoNoise");//图片样式properties.setProperty(Constants.KAPTCHA_OBSCURIFICATOR_IMPL, "com.google.code.kaptcha.impl.WaterRipple");//文字来源properties.setProperty(Constants.KAPTCHA_TEXTPRODUCER_CHAR_STRING, "0123456789");Config config = new Config(properties);kaptcha.setConfig(config);return kaptcha;}
}
  • 开发一个Controller使用测试
第4集 池化思想应用-Redis6.X配置连接池实战

简介：池化思想应用-Redis6.X配置连接池实战

  • 连接池好处

    • 使用连接池不用每次都走三次握手、每次都关闭Jedis
    • 相对于直连，使用相对麻烦，在资源管理上需要很多参数来保证，规划不合理也会出现问题
    • 如果pool已经分配了maxActive个jedis实例，则此时pool的状态就成exhausted了

  • 连接池配置 common项目

     <!--redis客户端--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId><exclusions><exclusion><groupId>io.lettuce</groupId><artifactId>lettuce-core</artifactId></exclusion></exclusions></dependency><dependency><groupId>redis.clients</groupId><artifactId>jedis</artifactId></dependency><dependency><groupId>org.apache.commons</groupId><artifactId>commons-pool2</artifactId></dependency>

  • 配置Redis连接

      redis:client-type: jedishost: 120.79.150.146password: class.netport: 6379jedis:pool:# 连接池最大连接数（使用负值表示没有限制）max-active: 100# 连接池中的最大空闲连接max-idle: 100# 连接池中的最小空闲连接min-idle: 100# 连接池最大阻塞等待时间（使用负值表示没有限制）max-wait: 60000

  • 序列化配置

    @Configuration
public class RedisTemplateConfiguration {/*** @param redisConnectionFactory* @return*/@Beanpublic RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {RedisTemplate<Object, Object> redisTemplate = new RedisTemplate<>();redisTemplate.setConnectionFactory(redisConnectionFactory);// 使用Jackson2JsonRedisSerialize 替换默认序列化Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);ObjectMapper objectMapper = new ObjectMapper();objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);jackson2JsonRedisSerializer.setObjectMapper(objectMapper);// 设置key和value的序列化规则redisTemplate.setKeySerializer(new StringRedisSerializer());redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);// 设置hashKey和hashValue的序列化规则redisTemplate.setHashKeySerializer(new StringRedisSerializer());redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer);return redisTemplate;}
}
第5集 账号微服务开发图形验证码加入缓存+Try-with-resource

简介：账号微服务开发图形验证码接口+Try-with-resource

  • redis做隔离, 多集群：核心集群和非核心集群，高并发集群和非高并发集群

    • 资源隔离
    • 数据保护
    • 提高性能
    • key规范：业务划分，冒号隔离
      • account-service:captcha:xxxx
      • 长度不能过长

  • 验证码接口开发

/***临时使用10分钟有效，方便测试*/private static final long CAPTCHA_CODE_EXPIRED = 60 * 1000 * 10;/*** 获取图形验证码* @param request* @param response*/@GetMapping("captcha")public void getCaptcha(HttpServletRequest request, HttpServletResponse response) {String captchaText = captchaProducer.createText();log.info("图形验证码:{}", captchaText);//存储redisTemplate.opsForValue().set(getCaptchaKey(request),captchaText, CAPTCHA_CODE_EXPIRED, TimeUnit.MILLISECONDS);BufferedImage bufferedImage = captchaProducer.createImage(captchaText);try (ServletOutputStream outputStream = response.getOutputStream()){ImageIO.write(bufferedImage, "jpg", outputStream);outputStream.flush();} catch (IOException e) {log.error("获取图形验证码异常:{}", e);}}
  • 什么是try-with-resources
    • 资源的关闭很多⼈停留在旧的流程上，jdk7新特性就有, 但是很多⼈以为是jdk8的
    • 在try( …)⾥声 明的资源，会在try-catch代码块结束后⾃动关闭掉
    • 注意点
      • 实现了AutoCloseable接⼝的类，在try()⾥声明该类实例的时候，try结束后⾃动调⽤的 close⽅法，这个动作会早于finally⾥调⽤的⽅法
      • 不管是否出现异常，try()⾥的实例都会被调⽤close⽅法
      • try⾥⾯可以声明多个⾃动关闭的对象，越早声明的对象，会越晚被close掉
第6集 账号微服务之注册短信验证码接口开发

简介：注册短信验证码接口开发

  • service层
  @Overridepublic JsonData sendCode(SendCodeEnum sendCodeType, String to) {if(CheckUtil.isEmail(to)){//邮箱验证码}else if(CheckUtil.isPhone(to)){//短信验证码}return JsonData.buildResult(BizCodeEnum.CODE_TO_ERROR);}
  • 邮箱工具类正则
public class CheckUtil {/*** 邮箱正则*/private static final Pattern MAIL_PATTERN = Pattern.compile("^([a-z0-9A-Z]+[-|\\.]?)+[a-z0-9A-Z]@([a-z0-9A-Z]+(-[a-z0-9A-Z]+)?\\.)+[a-zA-Z]{2,}$");/*** 手机号正则*/private static final Pattern PHONE_PATTERN = Pattern.compile("^((13[0-9])|(14[0-9])|(15[0-9])|(17[0-9])|(18[0-9]))\\d{8}$");/*** @param email* @return*/public static  boolean isEmail(String email) {if (null == email || "".equals(email)) {return false;}Matcher m = MAIL_PATTERN.matcher(email);return m.matches();}/*** * @param phone* @return*/public static boolean isPhone(String phone) {if (null == phone || "".equals(phone)) {return false;}Matcher m = PHONE_PATTERN.matcher(phone);boolean result = m.matches();return result;}
}
第7集 关于注册短信验证码防刷设计方案你能想到几个

简介：注册短信验证码防刷方案你能想到几个

在这里插入图片描述

  • 需求：一定时间内禁止重复发送短信,大家想下有哪几种实现方式

    • 两个时间要求
      • 60秒后才可以重新发送短信验证码
      • 发送的短信验证码10分钟内有效

    • 方式一：前端增加校验倒计时，不到60秒按钮不给点击

      • 简单
      • 不安全，存在绕过的情况

    • 方式二：增加Redis存储，发送的时候设置下额外的key，并且60秒后过期

      • 非原子操作，存在不一致性

      • 增加的额外的key - value存储，浪费空间

      • /*** 前置：判断是否重复发送** 1、存储验证码到缓存** 2、发送短信验证码** 后置：存储发送记录**/

    • 方式三：基于原先的key拼装时间戳

      • 好处：满足了当前节点内的原子性，也满足业务需求
第8集 【重要】注册邮箱验证码防刷代码落地+整体测试

简介：注册邮箱验证码防刷落地和整体测试

@Overridepublic JsonData sendCode(SendCodeEnum sendCodeEnum, String to) {String cacheKey = String.format(RedisKey.CHECK_CODE_KEY,sendCodeEnum.name(),to);String cacheValue = redisTemplate.opsForValue().get(cacheKey);//如果不为空，再判断是否是60秒内重复发送 0122_232131321314132if(StringUtils.isNotBlank(cacheValue)){long ttl = Long.parseLong(cacheValue.split("_")[1]);//当前时间戳-验证码发送的时间戳，如果小于60秒，则不给重复发送long leftTime = CommonUtil.getCurrentTimestamp() - ttl;if( leftTime < (1000*60)){log.info("重复发送短信验证码，时间间隔:{}秒",leftTime);return JsonData.buildResult(BizCodeEnum.CODE_LIMITED);}}String code = CommonUtil.getRandomCode(6);//生成拼接好验证码String value = code+"_"+CommonUtil.getCurrentTimestamp();redisTemplate.opsForValue().set(cacheKey,value,CODE_EXPIRED,TimeUnit.MILLISECONDS);if(CheckUtil.isEmail(to)){//发送邮箱验证码  TODO}else if(CheckUtil.isPhone(to)){//发送手机验证码smsComponent.send(to,smsConfig.getTemplateId(),code);}return JsonData.buildSuccess();}

第八章 账号微服务-阿里云OSS接入实战

第1集 分布式文件存储业界常见解决方案介绍

简介：分布式文件存储常见解决方案介绍

  • 目前业界比较多这个解决方案，这边就挑选几个介绍下

    • MinIO
    是在 Apache License v2.0 下发布的对象存储服务器,学习成本低，安装运维简单，主流语言的客户端整合都有, 号称最强的对象存储文件服务器，且可以和容器化技术docker/k8s等结合，社区活跃但不够成熟，业界参考资料较少官网：https://docs.min.io/cn/
    • FastDFS
    一个开源的轻量级分布式文件系统,比较少的客户端可以整合，目前主要是C和java客户端，在一些互联网创业公司中有应用比较多，没有官方文档,社区不怎么活跃.
架构+部署结构复杂，出问题定位比较难定位，可以说是fastdfs零件的组装过程，需要去理解fastDFS的架构设计，才能够正确的安装部署

    • 云厂商

      • 阿里云OSS

      • 七牛云

      • 腾讯云

      • 亚马逊云

      • CDN最强：Akamai https://www.akamai.com/cn

  • 选云厂商理由

    • 优点：开发简单，功能强大，容易维护（不同网络下图片质量、水印、加密策略、扩容、加速）
    • 缺点：要钱, 个性化处理，未来转移比较复杂，不排除有些厂商会提供一键迁移工具

  • 选开源MinIO的理由

    • 优点：功能强大、可以根据业务做二次的定制，新一代分布式文件存储系统，容器化结合强大，更重要的是免费（购买磁盘、内存、带宽）
    • 缺点：自己需要有专门的团队进行维护、扩容等

  • 文件上传流程

    • web控制台
    • 前端->后端程序->阿里云OSS

在这里插入图片描述

第2集 阿里云OSS分布式对象存储介绍开通

简介：阿里云OSS对象存储介绍和开通

  • 阿里云OSS介绍
对象存储OSS（Object Storage Service）是阿里云提供的海量、安全、低成本、高持久的云存储服务。其数据设计持久性不低于99.9999999999%（12个9），服务设计可用性不低于99.995%。OSS具有与平台无关的RESTful API接口，您可以在任何应用、任何时间、任何地点存储和访问任意类型的数据。提供标准、低频访问、归档和冷归档四种存储类型，全面覆盖从热到冷的各种数据存储场景：
标准存储类型高持久、高可用、高性能的对象存储服务，支持频繁的数据访问。是各种社交、分享类的图片、音视频应用、大型网站、大数据分析的合适选择。
低频访问存储类型适合长期保存不经常访问的数据（平均每月访问频率1到2次）。存储单价低于标准类型，适合各类移动应用、智能设备、企业数据的长期备份，支持实时数据访问。
归档存储类型适合需要长期保存（建议半年以上）的归档数据，在存储周期内极少被访问，数据进入到可读取状态需要1分钟的解冻时间。适合需要长期保存的档案数据、医疗影像、科学资料、影视素材。
冷归档存储类型适合需要超长时间存放的极冷数据。例如因合规要求需要长期留存的数据、大数据及人工智能领域长期积累的原始数据、影视行业长期留存的媒体资源、在线教育行业的归档视频等。

  • 开通阿里云OSS

    • 有阿里云账号、实名认证

    • OSS介绍：https://www.aliyun.com/product/oss

    • OSS控制台：https://oss.console.aliyun.com/bucket

    • 学习路径：https://help.aliyun.com/learn/learningpath/oss.html

  • 开通后的操作

    • 创建Bucket
    • 上传文件
    • 访问文件
第3集 权限知识 RBAC-ACL模式应用之阿里云RAM访问控制

简介：权限知识 RBAC-ACL模式应用之阿里云RAM访问控制

  • ACL: Access Control List 访问控制列表

    • 以前盛行的一种权限设计，它的核心在于用户直接和权限挂钩
    • 优点：简单易用，开发便捷
    • 缺点：用户和权限直接挂钩，导致在授予时的复杂性，比较分散，不便于管理
    • 例子：常见的文件系统权限设计, 直接给用户加权限

  • RBAC: Role Based Access Control

    • 基于角色的访问控制系统。权限与角色相关联，用户通过成为适当角色的成员而得到这些角色的权限
    • 优点：简化了用户与权限的管理，通过对用户进行分类，使得角色与权限关联起来
    • 缺点：开发对比ACL相对复杂
    • 例子：基于RBAC模型的权限验证框架与应用 Apache Shiro、spring Security

  • 总结：不能过于复杂，规则过多，维护性和性能会下降， 更多分类 ABAC、PBAC等

  • RAM权限介绍

    • 阿里云用于各个产品的权限，基于RBAC、ACL模型都有，进行简单管理账号、统一分配权限、集中管控资源，从而建立安全、完善的资源控制体系。

    • 众多产品，一般采用子账号进行分配权限，防止越权攻击

      在这里插入图片描述

    • 建立用户，勾选编程访问（保存accessKey和accessSecret，只出现一次）

      • 用户登录名称 dcloud_link@1701673122790560.onaliyun.com AccessKey ID : LTAI5tHVGvYw7twoVFyruB1H AccessKey Secret : r4d0EudzSvPfVMb9Zp0TfmsE32RXmN

    • 为新建用户授权OSS全部权限

第4集 阿里云OSS客户端SDK集成和上传组件功能开发

简介：阿里云OSS对象存储客户端集成和测试服务

  • 添加阿里云OSS的SDK

    • 地址：https://help.aliyun.com/document_detail/32008.html

    • 添加maven依赖

      • 底层聚合工程添加版本
       <!-- OSS各个项目单独加依赖，根据需要进行添加--><dependency><groupId>com.aliyun.oss</groupId><artifactId>aliyun-sdk-oss</artifactId><version>3.10.2</version></dependency>
      • 账号微服务添加
       <!-- OSS各个项目单独加依赖，根据需要进行添加--><dependency><groupId>com.aliyun.oss</groupId><artifactId>aliyun-sdk-oss</artifactId></dependency>

  • 账号微服务配置OSS

#阿里云OSS配置
aliyun:oss:endpoint: oss-cn-guangzhou.aliyuncs.comaccess-key-id: LTAI5tHVGvYw7twoVFyruB1Haccess-key-secret: r4d0EudzSvPfVMb9Zp0TfmsE32RXmNbucketname: dcloud-link
  • 新建配置类 (配置里面的横杠会，自动转驼峰)
@ConfigurationProperties(prefix = "aliyun.oss")
@Configuration
@Data
public class OSSConfig {private String endpoint;private String accessKeyId;private String accessKeySecret;private String bucketname;
}

  • 开发controller

  • 开发service

@Service
@Slf4j
public class FileServiceImpl implements FileService {@Autowiredprivate OSSConfig ossConfig;@Overridepublic String uploadUserImg(MultipartFile file) {//获取相关配置String bucketname = ossConfig.getBucketname();String endpoint = ossConfig.getEndpoint();String accessKeyId = ossConfig.getAccessKeyId();String accessKeySecret = ossConfig.getAccessKeySecret();//创建OSS对象OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);//获取原生文件名  xxx.jpgString originalFileName = file.getOriginalFilename();//JDK8的日期格式LocalDateTime ldt = LocalDateTime.now();DateTimeFormatter dtf = DateTimeFormatter.ofPattern("yyyy/MM/dd");//拼装路径,oss上存储的路径  user/2022/12/1/sdfdsafsdfdsf.jpgString folder = dtf.format(ldt);String fileName = CommonUtil.generateUUID();String extension = originalFileName.substring(originalFileName.lastIndexOf("."));// 在OSS上的bucket下创建 user 这个文件夹String newFileName = "user/"+folder+"/"+fileName+ extension;try {PutObjectResult putObjectResult = ossClient.putObject(bucketname,newFileName,file.getInputStream());//拼装返回路径if(putObjectResult != null){String imgUrl = "https://"+bucketname+"."+endpoint+"/"+newFileName;return imgUrl;}} catch (IOException e) {log.error("文件上传失败:{}",e);} finally {//oss关闭服务，不然会造成OOMossClient.shutdown();}return null;}
}
第5集 账号微服务头像上传阿里云OSS接口和PostMan测试

简介： 账号微服务头像上传阿里云OSS接口和PostMan测试

  • 文件上传流程
    • 先上传文件，返回url地址，再和普通表单一并提交（推荐这种,更加灵活，失败率低）
    • 文件和普通表单一并提交（设计流程比较多，容易超时和失败）
  • 注意：默认SpringBoot最大文件上传是1M,大家测试的时候记得关注下
  • 开发controller
    • @requestPart注解 接收文件以及其他更为复杂的数据类型
   /*** 上传用户头像** 默认文件大小 1M,超过会报错** @param file* @return*/@PostMapping(value = "upload")public JsonData uploadHeaderImg(@RequestPart("file") MultipartFile file){String result = fileService.uploadUserHeadImg(file);return result != null?JsonData.buildSuccess(result):JsonData.buildResult(BizCodeEnum.FILE_UPLOAD_USER_IMG_FAIL);}

 } catch (IOException e) {log.error("文件上传失败:{}",e);} finally {//oss关闭服务，不然会造成OOMossClient.shutdown();}return null;
}

}

#### 第5集 账号微服务头像上传阿里云OSS接口和PostMan测试**简介： 账号微服务头像上传阿里云OSS接口和PostMan测试**- 文件上传流程- 先上传文件，返回url地址，再和普通表单一并提交（推荐这种,更加灵活，失败率低）- 文件和普通表单一并提交（设计流程比较多，容易超时和失败）
- 注意：默认SpringBoot最大文件上传是1M,大家测试的时候记得关注下
- 开发controller- @requestPart注解 接收文件以及其他更为复杂的数据类型```java/*** 上传用户头像** 默认文件大小 1M,超过会报错** @param file* @return*/@PostMapping(value = "upload")public JsonData uploadHeaderImg(@RequestPart("file") MultipartFile file){String result = fileService.uploadUserHeadImg(file);return result != null?JsonData.buildSuccess(result):JsonData.buildResult(BizCodeEnum.FILE_UPLOAD_USER_IMG_FAIL);}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/686051.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

四、JMS规范

四、JMS规范

JMS规范 一、JMS是什么二、MQ中间件对比三、JMS组成1.JMS Provider2.JMS Producer3.JMS Consumer4.JSM Message4.1 消息头4.2 消息体4.2.1 生产者4.2.2 消费者 4.3 消息属性 四、JMS可靠性1.PERSISTENT - 持久化1.1 参数设置1.2 Queue持久化1.3 Topic持久化1.3.1 持久的发布主题…
阅读更多...
Linux文件操作类命令 touch | stat | cp | scp | alias | mv | dd | cat | head | tail

Linux文件操作类命令 touch | stat | cp | scp | alias | mv | dd | cat | head | tail

touch 1.创建空文件&#xff08;只有元数据信息&#xff0c;没有数据段内容&#xff09;touch 1.txt 2.对创建或已经存在的文件改变元数据信息的时间记录值-d 改变创建时间touch -d 20240101 1.txt -a改变访问时间 -m改变修改时间stat 查看元数据信息 Blocks是512字…
阅读更多...
排序算法---桶排序

排序算法---桶排序

原创不易&#xff0c;转载请注明出处。欢迎点赞收藏~ 桶排序&#xff08;Bucket Sort&#xff09;是一种排序算法&#xff0c;它将待排序的数据分到几个有序的桶中&#xff0c;每个桶再分别进行排序&#xff0c;最后将各个桶中的数据按照顺序依次取出&#xff0c;即可得到有序序…
阅读更多...
【机器学习笔记】 9 集成学习

【机器学习笔记】 9 集成学习

集成学习方法概述 Bagging 从训练集中进行子抽样组成每个基模型所需要的子训练集&#xff0c;对所有基模型预测的结果进行综合产生最终的预测结果&#xff1a; 假设一个班级每个人的成绩都不太好&#xff0c;每个人单独做的考卷分数都不高&#xff0c;但每个人都把自己会做的…
阅读更多...
在 Android 上部署自定义 YOLOv8 教程

在 Android 上部署自定义 YOLOv8 教程

在本教程中&#xff0c;我将向您展示如何在 Android 设备上使用自定义数据集部署 YOLOv8。想要了解如何在 Android 设备上使用您自己的数据集部署 YOLOv8&#xff1f;本文将展示如何操作。 Android 上的 自定义 YOLOv8 &#x1f525; ⚡️ 结果显示标题 对从 GoPro 流式传输到移…
阅读更多...
Sora时代，我们的AI应该何去何从?——关于Sora大模型的思考

Sora时代，我们的AI应该何去何从?——关于Sora大模型的思考

Sora时代&#xff0c;我们的AI应该何去何从?——关于Sora大模型的思考 一、Sora大模型&#xff1a;横空出世&#xff0c;让AI生成所有领域瑟瑟发抖二、Sora的出现代表了相关行业的灭亡&#xff1f;三、我们将何去何从&#xff1f; 一、Sora大模型&#xff1a;横空出世&#xf…
阅读更多...
1.8 NLP自然语言处理

1.8 NLP自然语言处理

NLP自然语言处理 更多内容&#xff0c;请关注&#xff1a; github&#xff1a;https://github.com/gotonote/Autopilot-Notes.git 一、简介 seq2seq(Sequence to Sequence)是一种输入不定长序列&#xff0c;产生不定长序列的模型&#xff0c;典型的处理任务是机器翻译&#…
阅读更多...
前端常见的设计模式

前端常见的设计模式

说到设计模式&#xff0c;大家想到的就是六大原则&#xff0c;23种模式。这么多模式&#xff0c;并非都要记住&#xff0c;但作为前端开发&#xff0c;对于前端出现率高的设计模式还是有必要了解并掌握的&#xff0c;浅浅掌握9种模式后&#xff0c;整理了这份文章。 六大原则&…
阅读更多...
Linux第一个小程序－进度条

Linux第一个小程序－进度条

提示&#xff1a;文章写完后&#xff0c;目录可以自动生成&#xff0c;如何生成可参考右边的帮助文档 文章目录 前言 一、回车和换行 二、行缓冲区概念 三、倒计时 四、进度条代码 版本一&#xff1a; ​编辑 版本二&#xff1a; 总结 前言 世上有两种耀眼的光芒&#xff0c;一…
阅读更多...
第七篇【传奇开心果系列】Python微项目技术点案例示例：数据可视化界面图形化经典案例

第七篇【传奇开心果系列】Python微项目技术点案例示例：数据可视化界面图形化经典案例

传奇开心果微博系列 系列微博目录Python微项目技术点案例示例系列 微博目录一、微项目开发背景和项目目标&#xff1a;二、雏形示例代码三、扩展思路介绍四、数据输入示例代码五、数据分析示例代码六、排名统计示例代码七、数据导入导出示例代码八、主题定制示例代码九、数据过…
阅读更多...
蓝桥杯第十四届电子类单片机组程序设计

蓝桥杯第十四届电子类单片机组程序设计

目录 前言 蓝桥杯大赛历届真题&#xff08;点击查看&#xff09; 一、第十四届比赛题目 1.比赛原题 2.题目解读 1&#xff09;任务要求 2&#xff09;注意事项 二、任务实现 1.NE555读取时机的问题 1&#xff09;缩短计数时间 2&#xff09;实时读取 2.温度传感器读…
阅读更多...
＜网络安全＞《35 网络攻防专业课＜第一课 - 网络攻防准备＞》

＜网络安全＞《35 网络攻防专业课＜第一课 - 网络攻防准备＞》

1 主要内容 认识黑客 认识端口 常见术语与命令 网络攻击流程 VMWare虚拟环境靶机搭建 2 认识黑客 2.1 白帽、灰帽和黑帽黑客 白帽黑客是指有能力破坏电脑安全但不具恶意目的黑客。 灰帽黑客是指对于伦理和法律态度不明的黑客。 黑帽黑客经常用于区别于一般&#xff08;正面…
阅读更多...
问题：在额定电压500V以下的电路中,使用的各种用电设备,一般称为（_ _ _)用电设备 #媒体#媒体#媒体

问题：在额定电压500V以下的电路中,使用的各种用电设备,一般称为（_ _ _)用电设备 #媒体#媒体#媒体

问题&#xff1a;在额定电压500V以下的电路中,使用的各种用电设备,一般称为&#xff08;_ _ _)用电设备 参考答案如图所示
阅读更多...
【dofile版本】实证研究Stata代码命令汇总

【dofile版本】实证研究Stata代码命令汇总

一、引言 在现代社会科学研究领域&#xff0c;Stata已成为欧美地区最受欢迎的计量分析软件之一。然而&#xff0c;许多研究人员在使用上仍显生疏 为了帮助研究人员更好地利用Stata&#xff0c;整理了一套Stata实证命令汇总&#xff0c;覆盖了从数据的初步处理到高级统计分析的…
阅读更多...
Mysql第一关之常规用法

Mysql第一关之常规用法

简介 介绍Mysql常规概念&#xff0c;用法。包括DDL、DCL、DML、DQL&#xff0c;关键字、分组、连表、函数、排序、分页等。 一、 SQL DCMQ&#xff0c;分别代表DDL、DCL、DML、DQL。 模糊简记为DCMQ&#xff0c;看起来像一个消息队列。 D&#xff1a;Definition 定义语句 M…
阅读更多...
【Vue前端】vue使用笔记0基础到高手第2篇：Vue知识点介绍（附代码，已分享）

【Vue前端】vue使用笔记0基础到高手第2篇：Vue知识点介绍（附代码，已分享）

本系列文章md笔记&#xff08;已分享&#xff09;主要讨论vue相关知识。Vue.js是前端三大新框架&#xff1a;Angular.js、React.js、Vue.js之一&#xff0c;Vue.js目前的使用和关注程度在三大框架中稍微胜出&#xff0c;并且它的热度还在递增。Vue.js是一个轻巧、高性能、可组件…
阅读更多...
[ai笔记7] google浏览器ai学习提效定制优化+常用插件推荐

[ai笔记7] google浏览器ai学习提效定制优化+常用插件推荐

欢迎来到文思源想的ai空间&#xff0c;这是技术老兵重学ai以及成长思考的第7篇分享&#xff01; 工欲善其事必先利其器&#xff0c;为了ai学习的效能提升&#xff0c;放假期间对google浏览器做了一次系统整改&#xff0c;添加了一些配置和插件&#xff0c;这里既有一些显示、主…
阅读更多...
在Visual Studio中搭建Dynamo Python开发环境，效率飞一般的增长

在Visual Studio中搭建Dynamo Python开发环境，效率飞一般的增长

最近在学习Dynamo中Python Script的用法&#xff0c;发现这个东西用起来太不友好了&#xff0c;不支持自动缩进&#xff0c;不支持自动填充和提示。用过Visual Studio做二开的都知道&#xff0c;在引用了Revit api以后&#xff0c;就可以自动填充和提示了。 本来英语就不好&am…
阅读更多...
Netty中的内置通信模式、Bootstrap和ChannelInitializer

Netty中的内置通信模式、Bootstrap和ChannelInitializer

内置通信传输模式 NIO:io.netty.channel.socket.nio 使用java.nio.channels包作为基础–基于选择器的方式Epoll:io.netty.channel.epoll由JNI驱动的epoll()和非阻塞IO.这个传输支持只有在Linux上可用的多种特性&#xff0c;如果SO_REUSEPORT&#xff0c;比NIO传输更快&#xf…
阅读更多...
代码随想录 Leetcode435. 无重叠区间

代码随想录 Leetcode435. 无重叠区间

题目&#xff1a; 代码(首刷看解析 2024年2月17日&#xff09;&#xff1a; class Solution { private:const static bool cmp(vector<int>& a,vector<int>& b) {return a[0] < b[0];} public:int eraseOverlapIntervals(vector<vector<int>&…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023