当前位置:首页 > 技术分析 > 正文内容

好难~记录一次生产上的OOM解决过程

ruisui883个月前 (02-04)技术分析13

点击上方,轻松关注!及时获取有趣有料的技术文章



记录一次生产上的OOM解决过程


一.项目架构

SpringCloud Dalston.SR1 + SpringBoot 1.5.9 + Mysql +Redis + RabbitMQ

所有的业务模块的应用服务都部署在同一个服务器,且单实例部署,服务器配置4核32G。

二. 原因分析

自己所负责的data模块这两天OOM较多,导致服务重启;

data服务主要业务是报表相关,数仓对接的业务以及多个外部数据相关的小程序的后台,与数据库的交互比较多,业务逻辑相对其他模块较为简单,

第一次:2月25日OOM情况:

由于Redis反序列化失败导致的OOM

第二次:2月26日的OOM情况:

由于GC无法回收对象导致

第一次发生OOM时,觉得可能就是由于Redis序列化器和反序列化器不一致,原有的JVM参数仅设置时-Xmx:512m -Xms:512m, 老年代:年轻代=2:1 ,老年代大概分配有300M内存

时候排查问题时,发现Redis的使用都是用自己用RedisTemplate封装的工具类,按道理说不会出现什么问题,并未过多关注;

第二次发生OOM时,与第一次相距的时间仅为1天,当时就觉得问题不对了,

1.首先使用jmap -histo:live pid 查看 服务内存活的对象,发现 [C 类型的数组和ConcurrentHashMap对象都存活较多;

检查代码后发现并未有显示的使用该两类类型,怀疑时是String字符串过多导致的;

2.其次使用JDK自带的分析工具:jmap -dump:format=b,file=文件名 [pid] 导出OOM时的dump日志;

导出时间非常慢,且占用线上系统的CPU,导致CPU达到100%

3.使用jstat -gc pid /jstat -gcutil pid 查看gc的状况

发现gc和fgc的都非常多,特别是fgc已经达到1000多次;

初步解决方案:(2月26日)

最后仍然是重启服务,-添加参数Xmx1024m -Xms:1024m

然后添加JVM参数(使用jinfo -flag可以在生产环境上直接添加)

jinfo -flag +HeapDumpBeforeFullGC pid

jinfo -flag +HeapDumpAfterFullGC pid

jinfo -flag +HeapDumpOnOutOfMemoryError pid

jinfo -flag +HeapDumpPath=/home/xxx/xxx pid 添加dump日志的目录(需要提前建好)

jinfo -flag -XX:+PrintGCDetails pid 开启gc日志

jinfo -flag -XX:+PrintGCDateStamps -Xloggc:/xxx/xxx 设置gc日志的目录

修改完成后第二天根据fgc产生的dump日志,加载到jvisualVM里面之后发现也是[C占用内存较多

下午 2点左右,监控线上服务时发现Old老年代的内存占用为300M,总大小为700M,经过一次FGC之后占用70M,这就比较正常了;


重点来了

在2月26日添加完成JVM参数后,第二天同样的接口,FGC之前终于拿到了dump文件,大小是1.4G,接下来就是分析dump文件了,这里我选择了两个工具:

MAT与Jvisualvm

在使用体验来说JDK自带的Jvisualvm真的很垃圾,文件打开都要半个小时,果断放弃,转而使用MAT

导入dump文件以后如图

这里主要是看Leak Suspects:其他的几个指标在此也说明一下:

1. Histogram可以列出内存中的对象,对象的个数以及大小。

2. Dominator Tree可以列出那个线程,以及线程下面的那些对象占用的空间。

3.Top consumers通过图形列出最大的object。

4.Leak Suspects通过MA自动分析泄漏的原因。

打开Leak Suspects后可以看到线程堆栈如图

再继续找,找到是否有我们的业务代码。找到如图

这里其实已经定位到具体的业务代码了,但是MAT的强大之处就是可以定位究竟是什么大对象,

如图,这里已经可以看到了6W多个HashMap被Object[]引用,这里是内存占用的主要原因

OK,接下来可以看业务代码了

**

业务代码如下,只展示关键代码,这个接口是报表数据导出的接口,查询mysql后使用HashMap去接收结果集,

Object[]用于是用于写入报表工具类的入参;

查看服务器日志后,发现这条SQL有6W多条数据,而且在一分钟之内有人操作导出了两次,导致数据封装到HashMap里面,发生FGC

三、最终解决方案

1.加大堆内存 原来由512扩大到1024M;

2.HashMap改为JavaBean对象去封装结果集,因为HashMap底层是数组,还有其他的引用成员变量,更加有频繁的扩容,

查资料后发现HashMap在数据量的情况下内存占用比Java对象要大;

3.导出接口添加限流注解,防止在短时间内多次请求;

以下是限流代码:使用Guava的限流组件实现,当然也可以基于Redis的实现,或者自己实现一套

4.由于EasyExcel内存占用少,可以将poi换成阿里的EasyExcel,实现多条数据分页导出;

代码如下图片


代码如下

/**
* @author: Gabriel
* @date: 2020/2/18 12:03
* @description 自定义接口限流注解
*/
@Target({ElementType.TYPE,ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
public @interface RateLimitAnno {
  /** 每秒放入令牌桶中的token */
  double limitNum() default 20;
}
/**
* @author: Gabriel
* @date: 2020/2/18 12:07
* @description
*/
@Slf4j
@Aspect
@Component
public class RateLimitAspect {
  /**
   * 用来存放不同接口的RateLimiter(key为接口名称,value为RateLimiter)
   */
  private ConcurrentHashMap<String, RateLimiter> map = new ConcurrentHashMap<>();
  private RateLimiter rateLimiter;
  @Autowired
  private static ObjectMapper objectMapper = new ObjectMapper();
  @Autowired
  private HttpServletResponse httpServletResponse;
  @Pointcut("@annotation(com.gabriel.stage.annotation.RateLimitAnno)")
  public void rateLimit() {
  }
  /**
   * 环绕通知
   *
   * @param joinPoint
   * @return
   * @throws Exception
   */
  @Around("rateLimit()")
  public Object around(ProceedingJoinPoint joinPoint) throws Throwable {
      Object obj = null;
      //获取拦截的方法签名
      MethodSignature signature = (MethodSignature) joinPoint.getSignature();
      Object target = joinPoint.getTarget();
      //获取注解信息
      Method method = target.getClass().getMethod(signature.getName(), signature.getParameterTypes());
      RateLimitAnno annotation = method.getAnnotation(RateLimitAnno.class);
      double limitNum = annotation.limitNum();
      //获取方法名
      String functionName = signature.getName();
      //获取类名
      String className = signature.getDeclaringTypeName();
      signature.getDeclaringTypeName();
      if (StringUtils.isNotBlank(className)) {
          className = StringUtils.substringAfterLast(className, ".");
      }
      //拼接类名和方法名,保证key唯一
      String joinName = StringUtils.join(functionName, className);
      //获取rateLimiter
      if (map.containsKey(joinName)) {
          rateLimiter = map.get(joinName);
      } else {
          map.put(joinName, RateLimiter.create(limitNum));
          rateLimiter = map.get(joinName);
      }
      if (rateLimiter.tryAcquire()) {
              obj = joinPoint.proceed();
      } else {
          System.err.println("接口限流,请求降级。。。。。。。。。。。。。。。。。");
          throw new BusinessException(ResultCode.SERVER_ERROR);
      }
      return obj;
  }

作者:听风是雨
原文地址:https://www.cnblogs.com/july-sunny/p/12370615.html




上面就是本次文章的全部内容,感谢你的阅读,希望对你有帮助,也欢迎你点赞留言和转发~

关注我,不迷路,及时获取有趣有料内容,See you next good day~

扫描二维码推送至手机访问。

版权声明:本文由ruisui88发布,如需转载请注明出处。

本文链接:http://www.ruisui88.com/post/1657.html

标签: objectmapper
分享给朋友:

“好难~记录一次生产上的OOM解决过程” 的相关文章

前后端分离自动化运维平台开发

运维平台采用前后端分离:前端vue,框架vue-element-admin;后端python,框架django-rest-framework.目前运维平台模块如下:1、 CMDB管理应用管理、环境管理、开发语言管理、产品项目管理、资产管理2、 构建发布持续构建、持续部署、Jar工程依赖构建3、 容器...

K8s里我的容器到底用了多少内存?

作者:frostchen导语 Linux下开发者习惯在物理机或者虚拟机环境下使用top和free等命令查看机器和进程的内存使用量,近年来越来越多的应用服务完成了微服务容器化改造,过去查看、监控和定位内存使用量的方法似乎时常不太奏效。如果你的应用程序刚刚迁移到K8s中,经常被诸如以下问题所困扰:容器的...

K8S NFS 共享存储

NFS 共享存储前面我们学习了 hostPath 与 Local PV 两种本地存储方式,但是平时我们的应用更多的是无状态服务,可能会同时发布在不同的节点上,这个时候本地存储就不适用了,往往就需要使用到共享存储了,比如最简单常用的网络共享存储 NFS,本节课我们就来介绍下如何在 Kubernetes...

雅马哈TMAX 560 TECH MAX 外媒深度测评

应雅马哈(Yamaha)的邀请,在葡萄牙埃斯托里尔对全新的Yamaha TMAX 560 Tech Max踏板车进行了测试,在这里TMAX 560 Tech Max售价为11649英镑。雅马哈TMAX长期以来一直站在踏板车的顶端,就声誉和知名度而言,它是当之无愧的大踏板界NO.1。2020 TMAX...

Vue实现动态路由

通常我们在vue项目中都是前端配置好路由的,但在一些项目中我们可能会遇到权限控制,这样我们就涉及到动态路由的设置了。动态路由设置一般有两种:(1)、简单的角色路由设置: 比如只涉及到管理员和普通用户的权限。通常直接在前端进行简单的角色权限设置(2)、复杂的路由权限设置: 比如OA系统、多种角色的权限...

vue开发微信小程序 - 登录组件

移动端登录功能抽象为通用组件,满足:不同移动端应用中一键登录功能复用支持多种登录:微信登录、H5、QQ登录登录组件使用//引用登录组件 import login from "../components/user/login.vue" export default { compone...