【169期】面试官问:说说为什么要限流,有哪些解决方案?
点击上方“Java精选”,选择“设为星标”
别问别人为什么,多问自己凭什么!
下方有惊喜留言必回,有问必答!
每天 08:35 更新文章,每天进步一点点...
一、限流操作:
为什么限流
是防止用户恶意刷新接口,因为部署在外部服务器,并且我们采用websocket的接口实现的,公司没有对硬件升级,导致程序时长崩溃,为了解决这个问题,请教公司的大佬,提出一个方案,限流操作。
但是最后找到原因所在,解决了,吞吐量1万6左右,用的测试服务器,进行测试的,我开发的笔记本进行压测,工具是Jmeter,结果我的电脑未响应,卡了,服务器还没有挂。
限流那些方法
常见的限流:
Netflix的hystrix
阿里系开源的sentinel
说白了限流,为了处理高并发接口那些方式:队列,线程,线程池,消息队列、 kafka、中间件、sentinel:直接拒绝、Warm Up、匀速排队等
技术层面:
判断是否有相同的请求,可以通过自身缓存挡住相同请求
用负载均衡,比如nginx
用缓存数据库,把热点数据get到缓存中,redis,ES
善于使用连接池
业务层面:
加入交互,排队等待
二、应用级别限流与限流实现
方法一、使用google的guava,令牌桶算法实现:平滑突发限流 ( SmoothBursty) 、平滑预热限流 ( SmoothWarmingUp) 实现
<!--Java项目广泛依赖 的核心库-->
<dependency><groupId>com.google.guava</groupId><artifactId>guava</artifactId><version>23.0</version>
</dependency>
package com.citydo.dialogue.controller;import com.google.common.util.concurrent.RateLimiter;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;import java.util.Collections;@RestController
public class HomeController {// 这里的1表示每秒允许处理的量为10个private RateLimiter limiter = RateLimiter.create(10.0);//RateLimiter.create(doublepermitsPerSecond, long warmupPeriod, TimeUnit unit);//RateLimiter limiter = RateLimiter.create(5, 1000, TimeUnit.MILLISECONDS);//permitsPerSecond: 表示 每秒新增 的令牌数// warmupPeriod: 表示在从 冷启动速率 过渡到 平均速率 的时间间隔@GetMapping("/test/{name}")public String Test(@PathVariable("name") String name){// 请求RateLimiter, 超过permits会被阻塞final double acquire = limiter.acquire();System.out.println("--------"+acquire);//判断double是否为空或者为0if(acquire>=(-1e-6)&&acquire<=(1e-6)){return name;}else{return "操作太频繁";}}
}
这个有点类似与QPS流量控制:
当 QPS 超过某个阈值的时候,则采取措施进行流量控制。另外推荐面试题资料公众号Java精选,回复Java面试,获取最新面试资料,支持在线随时随地刷题。
直接拒绝:
方式是默认的流量控制方式,当QPS超过任意规则的阈值后,新的请求就会被立即拒绝,拒绝方式为抛出Exception或者返回值404。这种方式适用于对系统处理能力确切已知的情况下,比如通过压测确定了系统的准确水位时。
方法二、请求一次redis增加1,key可以是IP+时间或者一个标识+时间,没有就创建,需要设置过期时间
设置拦截器:
package com.citydo.dialogue.config;import com.citydo.dialogue.service.AccessLimitInterceptor;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
import org.springframework.web.servlet.config.annotation.ViewControllerRegistry;
import org.springframework.web.servlet.config.annotation.WebMvcConfigurationSupport;/*** 拦截器配置* @author nick*/@Configuration
public class InterceptorConfig extends WebMvcConfigurationSupport {@Overridepublic void addInterceptors(InterceptorRegistry registry) {//addPathPatterns 添加拦截规则registry.addInterceptor(new AccessLimitInterceptor())//添加需要拦截请求的路径.addPathPatterns("/**");//swagger2 放行 .excludePathPatterns("/swagger-resources/**", "/webjars/**", "/v2/**", "/swagger-ui.html/**");//.excludePathPatterns("/*")//去除拦截请求的路径}@Overridepublic void addViewControllers(ViewControllerRegistry registry) {registry.addViewController("/");}
}
拦截方法
package com.citydo.dialogue.service;import com.citydo.dialogue.entity.AccessLimit;
import com.citydo.dialogue.utils.IpUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.web.method.HandlerMethod;
import org.springframework.web.servlet.HandlerInterceptor;
import org.springframework.web.servlet.ModelAndView;import javax.servlet.ServletOutputStream;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.lang.reflect.Method;
import java.util.concurrent.TimeUnit;public class AccessLimitInterceptor implements HandlerInterceptor {//使用RedisTemplate操作redis@Autowiredprivate RedisTemplate<String, Integer> redisTemplate;@Overridepublic boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {if (handler instanceof HandlerMethod) {HandlerMethod handlerMethod = (HandlerMethod) handler;Method method = handlerMethod.getMethod();if (!method.isAnnotationPresent(AccessLimit.class)) {return true;}AccessLimit accessLimit = method.getAnnotation(AccessLimit.class);if (accessLimit == null) {return true;}int limit = accessLimit.limit();int sec = accessLimit.sec();String key = IpUtil.getIpAddr(request) + request.getRequestURI();//资源唯一标识String formatDate=new SimpleDateFormat("yyyyMMddHHmm").format(new Date());//String key="request_"+formatDate;Integer maxLimit = redisTemplate.opsForValue().get(key);if (maxLimit == null) {//set时一定要加过期时间redisTemplate.opsForValue().set(key, 1, sec, TimeUnit.SECONDS);} else if (maxLimit < limit) {redisTemplate.opsForValue().set(key, maxLimit + 1, sec, TimeUnit.SECONDS);} else {output(response, "请求太频繁!");return false;}}return true;}public void output(HttpServletResponse response, String msg) throws IOException {response.setContentType("application/json;charset=UTF-8");ServletOutputStream outputStream = null;try {outputStream = response.getOutputStream();outputStream.write(msg.getBytes("UTF-8"));} catch (IOException e) {e.printStackTrace();} finally {outputStream.flush();outputStream.close();}}@Overridepublic void postHandle(HttpServletRequest request, HttpServletResponse response, Object handler, ModelAndView modelAndView) throws Exception {}@Overridepublic void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {}
}
可以设置成注解,当然也可以直接添加参数
package com.citydo.dialogue.entity;import java.lang.annotation.*;@Inherited
@Documented
@Target({ElementType.FIELD,ElementType.TYPE,ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
public @interface AccessLimit {//标识 指定sec时间段内的访问次数限制int limit() default 5;//标识 时间段int sec() default 5;
}
redis编写配置
package com.citydo.dialogue.config;import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;/*** 解决redis乱码问题* 解决配置问题* @author nick*/
@Configuration
public class RedisConfig {/*** 此方法解决存储乱码*/@Beanpublic RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {RedisTemplate<Object, Object> template = new RedisTemplate<Object, Object>();template.setConnectionFactory(redisConnectionFactory);template.setKeySerializer(new StringRedisSerializer());template.setValueSerializer(new GenericJackson2JsonRedisSerializer());template.setHashKeySerializer(new GenericJackson2JsonRedisSerializer());template.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());template.afterPropertiesSet();return template;}
}
方法三、分布式限流,分布式限流最关键的是要将限流服务做成原子化,而解决方案可以使用redis+lua或者nginx+lua技术进行实现。
推荐:Java进阶学习资料
方法四、可以使用池化技术来限制总资源数:连接池、线程池。比如分配给每个应用的数据库连接是 100,那么本应用最多可以使用 100 个资源,超出了可以 等待 或者 抛异常。
方法五、限流总并发/连接/请求数,如果你使用过 Tomcat,其 Connector 其中一种配置有如下几个参数:
maxThreads
: Tomcat 能启动用来处理请求的 最大线程数,如果请求处理量一直远远大于最大线程数,可能会僵死。maxConnections
: 瞬时最大连接数,超出的会 排队等待。acceptCount
: 如果 Tomcat 的线程都忙于响应,新来的连接会进入 队列排队,如果 超出排队大小,则 拒绝连接。
方法六、限流某个接口的总并发/请求数,使用 Java 中的 AtomicLong,示意代码:
try{if(atomic.incrementAndGet() > 限流数) {//拒绝请求} else {//处理请求}
} finally {atomic.decrementAndGet();
}
方法七、 限流某个接口的时间窗请求数使用 Guava 的 Cache,示意代码:
LoadingCache counter = CacheBuilder.newBuilder().expireAfterWrite(2, TimeUnit.SECONDS).build(newCacheLoader() {@Overridepublic AtomicLong load(Long seconds) throws Exception {return newAtomicLong(0);}});
longlimit =1000;
while(true) {// 得到当前秒long currentSeconds = System.currentTimeMillis() /1000;if(counter.get(currentSeconds).incrementAndGet() > limit) {System.out.println("限流了: " + currentSeconds);continue;}// 业务处理
}
不管哪种目的是为了,进行限流操作。
参考:https://blog.csdn.net/fanrenxiang/article/details/80683378
参考:https://mp.weixin.qq.com/s/2_oDGJiI1GhaNYnaeL7Qpg
源码:https://github.com/863473007/springboot_current_limiting
版权声明:本文为CSDN博主「灬点点」的原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接及本声明。
https://blog.csdn.net/qq_32447301/article/details/86659474
公众号“Java精选”所发表内容注明来源的,版权归原出处所有(无法查证版权的或者未注明出处的均来自网络,系转载,转载的目的在于传递更多信息,版权属于原作者。如有侵权,请联系,笔者会第一时间删除处理!
------ THE END ------
精品资料,超赞福利!
>Java精选面试题<
3000+ 道面试题在线刷,最新、最全 Java 面试题!
期往精选 点击标题可跳转
【161期】MySQL 性能优化的 9 种姿势,面试再也不怕了!
【162期】面试官:请说说对 HashMap 及 LinkedHashMap 源码底层的深入理解(八股文)
【163期】MYSQL 中 SQL 语句三种去除重复数据的方法
【164期】面试官问:为什么生产环境中,建议禁用 Redis 的 keys 命令?
【165期】关于 5 道 String 面试题,全答对的面试者不足 10%
【166期】面试官问:为什么不建议使用 @Async 注解?
【167期】Java8 新特性:使用 Stream 流递归实现遍历树形结构
【168期】面试官问:如果 MySQL 的自增 ID 用完了,怎么办?
技术交流群!
最近有很多人问,有没有读者交流群,想知道如何加入。加入方式很简单,有兴趣的同学,只需要点击下方卡片,回复“加群”,即可免费加入我们的高质量技术交流群!
文章有帮助的话,在看,转发吧!
【169期】面试官问:说说为什么要限流,有哪些解决方案?相关推荐
- 后处理程序文件大小的变量_【每日一题】(17题)面试官问:JS中事件流,事件处理程序,事件对象的理解?...
关注「松宝写代码」,精选好文,每日一题 作者:saucxs | songEagle 2020,实「鼠」不易 2021,「牛」转乾坤 风劲潮涌当扬帆,任重道远须奋蹄! 一.前言 2020.12.23 立 ...
- java各层级限流对比,面试官说:来谈谈限流-从概念到实现,一问你就懵逼了?...
后端服务的接口都是有访问上限的,如果外部qps或并发量超过了访问上限会导致应用瘫痪.所以一般都会对接口调用加上限流保护,防止超出预期的请求导致系统故障. 从限流类型来说一般来说分为两种:并发数限流和q ...
- 【059期】面试官问:序列化是什么,为什么要序列化,如何实现?
>>号外:关注"Java精选"公众号,回复"面试资料",免费领取资料!"Java精选面试题"小程序,3000+ 道面试题在线刷, ...
- 【154期】面试官问:请你说说 B 树、B+ 树的原理及区别?
点击上方"Java精选",选择"设为星标" 别问别人为什么,多问自己凭什么! 下方留言必回,有问必答! 每天 08:35 更新文章,每天进步一点点... 之前在 ...
- 【020期】面试官问:Java 遍历 Map 集合有几种方式?效率如何?
>>号外:关注"Java精选"公众号,回复"2021面试题",领取免费资料!"Java精选面试题"小程序,3000+ 道面试题在 ...
- 【146期】面试官问:说一说 RabbitMQ 的几种工作模式和优化建议?
点击上方"Java精选",选择"设为星标" 别问别人为什么,多问自己凭什么! 下方留言必回,有问必答! 每天 08:00 更新文章,每天进步一点点... 1.组 ...
- 【266期】面试官问:为什么 SQL 要尽量避免使用 IN 和 NOT IN?
点击上方"Java精选",选择"设为星标" 别问别人为什么,多问自己凭什么! 下方有惊喜,留言必回,有问必答! 每一天进步一点点,是成功的开始... IN 和 ...
- 【264期】面试官问:Spring Boot 启动时自动执行代码方式有哪几种?解释一二!...
点击上方"Java精选",选择"设为星标" 别问别人为什么,多问自己凭什么! 下方有惊喜,留言必回,有问必答! 每一天进步一点点,是成功的开始... 前言 目前 ...
- 【263期】面试官问:假设有一千万数据,怎么快速查询?
点击上方"Java精选",选择"设为星标" 别问别人为什么,多问自己凭什么! 下方有惊喜,留言必回,有问必答! 每一天进步一点点,是成功的开始... 前言 面试 ...
最新文章
- 逐飞科技对于STC8H1K系列的单片机正交解码的资料以及实验
- ie 不执行回调函时_javascript引擎执行的过程的理解--执行阶段
- 分享一款颜色神器ColorSchemer Studio
- 一款不错的编程字体Source Code Pro
- java 多线程和并行编程_Java 8中的并行和异步编程
- BugkuCTF-WEB题login1
- 服务器可以显示的血量显示,魔兽世界怀旧服怪物如何显示血量
- maven库的查询和配置
- Android Studio 常用快捷键和使用技巧
- 南京林业大学计算机考研资料,2021南京林业大学考研历年真题复习资料
- word转HTML 基本版
- [日推荐]『足球欧洲』.这里有关于足球的一切!
- 一阶线性偏微分方程通解法和特征线法(二)| n个自变量情况 | 偏微分方程(八)
- 奇兔recovery卡刷教程_奇兔刷机小编为你详解recovery界面中的功能
- cesium天气(晴、雨、雪、雾)
- Java 基础篇--字符串
- Linus Torvalds称讨厌被人崇拜
- 3D游戏编程与设计作业六
- ATFX:欧央行利率决议来袭,重点关注拉加德新闻发布会
- 电脑游戏怎么转移新电脑,换新电脑如何迁移游戏