《第四章单系统高并发优化》之《第五节单机限流》

《4.5.1 单机限流(限流算法及隔离策略》

• 四种限流算法&＃xff1a;计数器、滑动窗口、漏桶、令牌桶

  • 计数器、滑动窗口的讲解可参考https://www.cnblogs.com/linjiqin/p/9707713.html
  • 漏桶&＃xff1a;
    
    
  • 34分&＃xff1a;令牌桶&＃xff1a;

此缺点真的存在&＃xff1f;《4.5.3 编写限流框架中的核心模块》118:50&＃43;有解释&＃xff0c;但我认为解释不正确。
Guava RateLimiter原理是令牌桶

• 隔离策略&＃xff1a;线程池、信号量Semaphore

《4.5.2 低入侵限流框架设计与实现》

使用Guava RateLimiter实现限流

7分 DateTimeFormatter与LocalDateTime&＃xff0c;是jdk1.8以后线程安全的时间处理类

《【技术分享】OOM问题解决与优化》

• 

• 29:30&＃xff1a;
  逃逸分析 & 栈上分配 & 标量替换 默认开启>&＃61;1.6u23
  逃逸分析默认开启&＃xff0c;关闭 -XX:-DoEscapeAnalysis
  对象有动态调整大小的集合时&＃xff0c;不会进行栈上分配

• 55:30&＃43; 防止full GC: 运用Btrace的强大定位功能&＃xff0c;发现system.gc被调用
  

• 83分 分步骤分析瓶颈

• 136分- 一些OOM场景&＃xff1a;
  

• 146分 -XX:&＃43;HeapDumpOnOutOfMemoryError -XX:HeapDumpPath&＃61;/temp/202006.hprof
  用MemoryAnalyzer工具分析dump文件&＃xff1a;

• 166:45&＃43;: 对堆内内存溢出的问题&＃xff0c;在测试环境下用gperftools工具&＃xff1a;
  

old《3.2.4 内存爆炸、CPU100%问题分析、定位、解决》

• 垃圾回收器一般用 CMS&＃43;ParNewGC?

• 36:50 监控系统&＃xff1a;大众点评的CAT, Zabbix

• 60:23 禁止显式调用gc方法&＃xff1a;
  

• jcmd
  jmap输出内存快照

• 104:30 没有分页&＃xff08;或者前端参数不严谨&＃xff09;导致10w&＃43;的超长arraylist, OOM

old《3.2.5 网易真实性能调优案例分享》

• 28:15 某案例中&＃xff0c;cpu占用不高但接口访问依然慢&＃xff0c;用jstack输出进程堆栈信息后&＃xff0c;发现一个sleep的线程&＃xff1a;
  
  然后在对应代码中发现了问题&＃xff1a;是调用了sleep命令
  
• 54:35 本机不能直连生产环境的机器&＃xff0c;必须通过中转机&＃xff08;或称堡垒机&＃xff09;
• 87:50 jstack输出信息中的线程的nid,为os中线程pid的16进制形式。通过这种办法来定位那些cpu占用率特别高的线程的代码
  

《4.5.3 编写限流框架中的核心模块》

使用aop的环绕通知来拦截自定义注解&＃xff0c;在切面类中使用Guava的令牌桶限流算法&＃xff1a;
Controller中的方法:

&＃64;GetMapping("sdh")&＃64;SdhRateLimiter(permitsPerSecond &＃61; 1, timeout &＃61; 500, errorMsg &＃61; "有错误")public String sdhLimiter() {return "sdh success";}


自定义注解&＃xff1a;

&＃64;Retention(RetentionPolicy.RUNTIME)
&＃64;Target({ElementType.METHOD})
public &＃64;interface SdhRateLimiter {double permitsPerSecond() default 1;long timeout() default 500;TimeUnit timeUnit() default TimeUnit.MILLISECONDS;String errorMsg();
}


切面类&＃xff1a;

&＃64;Aspect
&＃64;Component
public class SdhRateLimiterAspect {private Map<String, RateLimiter> url_limitMap &＃61; new ConcurrentHashMap<>();&＃64;Around("&＃64;annotation(com.study.current.limiting.aop.SdhRateLimiter)")public Object around(ProceedingJoinPoint joinPoint) throws Throwable {// 获取request,responseHttpServletRequest request &＃61; ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();HttpServletResponse response &＃61; ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getResponse();String url &＃61; request.getRequestURI();// 获取自定义注解SdhRateLimiter limiterAnnotation &＃61; getSdhRateLimiter(joinPoint);if (limiterAnnotation !&＃61; null) {RateLimiter limiter &＃61; null;if (!url_limitMap.containsKey(url)) {// 创建令牌桶limiter &＃61; RateLimiter.create(limiterAnnotation.permitsPerSecond());url_limitMap.put(url, limiter);System.out.println("<<&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61; 请求"&＃43;url&＃43;",创建令牌桶成功!!!");}limiter &＃61; url_limitMap.get(url);// 获取令牌boolean acquire &＃61; limiter.tryAcquire(limiterAnnotation.timeout(), limiterAnnotation.timeUnit());if (!acquire) {return limiterAnnotation.errorMsg();}}return joinPoint.proceed();}/*** 获取注解对象** &＃64;param joinPoint 对象* &＃64;return ten LogAnnotation*/private SdhRateLimiter getSdhRateLimiter(final JoinPoint joinPoint) {Method[] methods &＃61; joinPoint.getTarget().getClass().getDeclaredMethods();String name &＃61; joinPoint.getSignature().getName();if (!StringUtils.isEmpty(name)) {for (Method method : methods) {SdhRateLimiter annotation &＃61; method.getAnnotation(SdhRateLimiter.class);if (annotation!&＃61;null && name.equals(method.getName())) {return annotation;}}}return null;}}


《【技术分享】CPU100%问题解决与优化》

• 伪共享; &＃64;Contended

• 死锁&＃xff1a;用jcmd列出进程号&＃xff0c;用jstack可查看进程中是否有死锁

• 55分-&＃xff1a; cpu 100%(比如while(true)导致的)
  1&＃xff0c;linux命令top,找到进程
  2&＃xff0c;找到线程&＃xff0c;top -H -P javapid
  3&＃xff0c;jstack pid > log.txt

• 64&＃xff1a;14 核心方法的度量工具Metrics

• 78:24 接口响应很慢
  监控工具arthas
  

• 90:47 【面试题】JUC包你使用过哪些类&＃xff1f;在哪些场景使用&＃xff1f;

页面打开太慢&＃xff0c; 请求太多&＃xff0c;浏览器有限制。
优化方案&＃xff1a; 多个请求合并到一起。
后台优化&＃xff1a;后台收到请求之后&＃xff0c;要 执行多个复杂的service、多次数据库查询。多线程异步编程并发查询&＃xff0c;用到futrue相关技术。