ini复制代码jps -v 查看java进程
jinfo -flags pid 查看运行参数
jstat -gc 8544 5000 100，将每隔5s采样一次pid为8544的gc，输出100次

jmap -dump:live,format=b,file=dump.hprof 29170 
#生成虚拟机的内存转储快照 注意线上可能会触发线上gc
jmap -heap 29170
jmap -histo:live 29170 | more
jmap -permstat 29170

jstack -l 29170 |more 显示虚拟机的线程快照

df -h # 磁盘 
free -m / -h # 内存
top cpu  # cpu

perl复制代码方法1：原生工具，慢
top -c #显示完整信息  P：cpu使用排序 M：内存使用排序
top -Hp 10765 ，#显示一个进程的线程运行信息列表  -H 显示线程信息，-p指定pid & P
printf "%x\n" 10804    转16进制   2f71
jstack 12084 | grep '0x2f71' -C5 --color 查看堆栈，找到线程在干嘛

方法2：
使用提前准备好的sh脚本，可以一条命名查看当前出事的线程代码，快，推荐
sh show-busy-java-threads.sh > a.txt #查询java耗时线程前5个
sh show-busy-java-threads.sh -p > a.txt #查询指定进程

方法3：
使用arthas，工具内置很多功能，比如可以查看源码，判断是否发布成功，可以用来排查疑难问题
curl -O https://alibaba.github.io/arthas/arthas-boot.jar
java -jar arthas-boot.jar
dashboard
thread -8
jad com.xx.xx.xx.xxximp 查看线上类代码
watch com.xx.xx.xx.xxximp doTask '{params}' '#cost>100' -x 2 
#观察会慢在什么入参上，监控耗时超过100毫秒的 doTask方法的入参，并且输出入参，展开2层入参参数
ognl #查询某静态字段的值

定位到堆栈就可以定位到出问题代码的行号，然后找对应的发布分支代码该行号即可

bash复制代码某Java服务（假设PID=12084）出现了OOM，最常见的原因为：
1. 有可能是内存分配确实过小，而正常业务使用了大量内存
2. 某一个对象被频繁申请，却没有释放，内存不断泄漏，导致内存耗尽未调用close()，dispose()释放资源，例如：文件io，网络io
3. 某一个资源被频繁申请，系统资源耗尽，例如：不断创建线程（没有用线程池），不断发起网络连接等
总结：本身资源不够，申请资源太多，资源耗尽

分析工具：
jvisualvm（直方图），MAT（优先，直方图，跟踪内存使用的引用关系），JProfiler

线下分析：
服务挂掉之后有保留文件：直接下载dump文件导入mat分析
java -jar -XX:+HeapDumpOnOutOfMemoryError -XX:HeapDumpPath=

线上分析：
1. 确认是不是内存本身就分配过小
jmap -heap 12084

2. 找到最耗内存的对象
jmap -histo:live 12084 | head -n 10  #该命令会强制执行一次fgc

jmap -dump:format=b,file=/opt/dump.hprof {pid} #以二进制输出档当前内存的堆情况，
然后可以导入MAT等工具进行
tar –czf dump.tar.gz dump.hprof

3. 确认进程创建的线程数，以及网络连接数，如果资源耗尽，也可能出现OOM
ll /proc/17306/fd | wc -l
ll /proc/17306/task | wc -l

typescript复制代码import com.github.pagehelper.Page;
import com.github.pagehelper.PageHelper; 
import org.apache.commons.io.IOUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.io.ByteArrayOutputStream;
import java.util.List;
import java.util.Map;
import java.util.zip.ZipOutputStream;

/**
 * 代码生成器
 */
@Service
public class SysGeneratorService {
   @Autowired
   private GeneratorDao generatorDao;

   /**
    * 通过表名称去生成代码，支持多表一起
    * @param tableNames 表明集合
    * @return
    */
   public byte[] generatorCode(String[] tableNames) {
      ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
      ZipOutputStream zip = new ZipOutputStream(outputStream);
      for(String tableName : tableNames){
         //查询表信息
         Map<String, String> table = queryTable(tableName);
         //查询列信息
         List<Map<String, String>> columns = queryColumns(tableName);
         //生成代码
         GenUtils.generatorCode(table, columns, zip);
      }
      IOUtils.closeQuietly(zip);
      return outputStream.toByteArray();
   }
   /**
    * 根据表名查询表相关信息
    * @param tableName
    * @return
    */
   public Map<String, String> queryTable(String tableName) {
      return generatorDao.queryTable(tableName);
   }

   /**
    * 通过表名获取表的字段信息
    * @param tableName
    * @return
    */
   public List<Map<String, String>> queryColumns(String tableName) {
      return generatorDao.queryColumns(tableName);
   }
}

ini复制代码private static final String COLUMN_NAME = "columnName";
private static final String TABLE_NAME = "tableName";
private static final String TABLE_COMMENT = "tableComment";
private static final String TABLE_PREFIX = "tablePrefix";
private static final String DATA_TYPE = "dataType";
private static final String COLUMN_COMMENT = "columnComment";
private static final String EXTRA = "extra";
private static final String UNKNOW_TYPE = "unknowType";
private static final String BIGDECIMAL = "BigDecimal";
private static final String COLUMN_KEY = "columnKey";
private static final String PRI = "PRI";
/**
 * 生成代码
 */
public static void generatorCode(Map<String, String> table,
      List<Map<String, String>> columns, ZipOutputStream zip){
   //配置信息
   Configuration config = getConfig();
   boolean hasBigDecimal = false;
   //表信息
   TableEntity tableEntity = new TableEntity();
   tableEntity.setTableName(table.get(TABLE_NAME));
   tableEntity.setComments(table.get(TABLE_COMMENT));
   //表名转换成Java类名
   String className = tableToJava(tableEntity.getTableName(), config.getString(TABLE_PREFIX));
   tableEntity.setClassName(className);
   tableEntity.setClassname(StringUtils.uncapitalize(className));
   
   //列信息
   List<ColumnEntity> columsList = new ArrayList<>();
   for(Map<String, String> column : columns){
      ColumnEntity entity = new ColumnEntity();
      entity.setColumnName(column.get(COLUMN_NAME));
      entity.setDataType(column.get(DATA_TYPE));
      entity.setComments(column.get(COLUMN_COMMENT));
      entity.setExtra(column.get(EXTRA));
      String attrName = columnToJava(entity.getColumnName());
      entity.setAttrName(attrName);
      entity.setAttrname(StringUtils.uncapitalize(attrName));
      String attrType = config.getString(entity.getDataType(), UNKNOW_TYPE);
      entity.setAttrType(attrType);
      if (!hasBigDecimal && attrType.equals(BIGDECIMAL)) {
         hasBigDecimal = true;
      }
      //是否主键
      if(PRI.equalsIgnoreCase(column.get(COLUMN_KEY)) && tableEntity.getPk() == null){
         tableEntity.setPk(entity);
      }
      columsList.add(entity);
   }
   tableEntity.setColumns(columsList);
   
   //没主键，则第一个字段为主键
   if(tableEntity.getPk() == null){
      tableEntity.setPk(tableEntity.getColumns().get(0));
   }

xml复制代码<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="${package}.${moduleName}.dao.${className}Dao">
    <resultMap type="${package}.${moduleName}.entity.${className}Entity" id="${classname}Map">
#foreach($column in $columns)
        <result property="${column.attrname}" column="${column.columnName}"/>
#end
    </resultMap>
</mapper>

java复制代码package ${package}.${moduleName}.dao;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
import ${package}.${moduleName}.entity.${className}Entity;

/**
 * ${comments}
 * @author ${author}
 * @date ${datetime}
 */
@Mapper
public interface ${className}Dao extends BaseMapper<${className}Entity> {
   
}

java复制代码package ${package}.${moduleName}.entity;

import lombok.Data;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
#if(${hasBigDecimal})
import java.math.BigDecimal;
#end
import java.io.Serializable;
import java.util.Date;

/**
 * 对象说明：${comments}
 * @author ${author}
 * @date ${datetime}
 */
@TableName("${tableName}")
@Data
public class ${className}Entity implements Serializable {
   private static final long serialVersionUID = 1L;
#foreach ($column in $columns)
   /**
    * $column.comments
    */
   #if($column.columnName == $pk.columnName)
   @TableId
   #end
   private $column.attrType $column.attrname;
#end
}

java复制代码package ${package}.${moduleName}.service;

import com.baomidou.mybatisplus.extension.service.IService;
import ${mainPath}.common.utils.PageUtils;
import ${package}.${moduleName}.entity.${className}Entity;
import java.util.Map;

/**
 * 接口描述：${comments}
 * @author ${author}
 * @date ${datetime}
 */
public interface ${className}Service extends IService<${className}Entity> {
    /**
    * 分页查询
    * @param params
    * @return 
    */
    PageUtils queryPage(Map<String, Object> params);
}

java复制代码package ${package}.${moduleName}.service.impl;

import org.springframework.stereotype.Service;
import java.util.Map;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import ${mainPath}.common.utils.PageUtils;
import ${mainPath}.common.utils.Query;
import ${package}.${moduleName}.dao.${className}Dao;
import ${package}.${moduleName}.entity.${className}Entity;
import ${package}.${moduleName}.service.${className}Service;
/**
 * 描述：${comments}
 * @author ${author}
 * @date ${datetime}
 */
public class ${className}ServiceImpl extends ServiceImpl<${className}Dao, ${className}Entity> implements ${className}Service {
    /**
    * 分页查询
    * @param params
    * @return 
    */
    @Override
    public PageUtils queryPage(Map<String, Object> params) {
        IPage<${className}Entity> page = this.page(
                new Query<${className}Entity>().getPage(params),
                new QueryWrapper<${className}Entity>()
        );
        return new PageUtils(page);
    }

}

kotlin复制代码package ${package}.${moduleName}.controller;

import java.util.Arrays;
import java.util.Map;
import io.renren.common.validator.ValidatorUtils;
import org.apache.shiro.authz.annotation.RequiresPermissions;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import ${package}.${moduleName}.entity.${className}Entity;
import ${package}.${moduleName}.service.${className}Service;
import ${mainPath}.common.utils.PageUtils;
import ${mainPath}.common.utils.R;

/**
 * 描述：${comments}
 * @author ${author}
 * @date ${datetime}
 */
@RestController
@RequestMapping("${moduleName}/${pathName}")
public class ${className}Controller {
    @Autowired
    private ${className}Service ${classname}Service;

    /**
     * 分页查询列表
     */
    @RequestMapping("/list")
    @RequiresPermissions("${moduleName}:${pathName}:list")
    public R list(@RequestParam Map<String, Object> params){
        PageUtils page = ${classname}Service.queryPage(params);
        return R.ok().put("page", page);
    }

    /**
     * 获取单个对象信息
     */
    @RequestMapping("/info/{${pk.attrname}}")
    @RequiresPermissions("${moduleName}:${pathName}:info")
    public R info(@PathVariable("${pk.attrname}") ${pk.attrType} ${pk.attrname}){
        ${className}Entity ${classname} = ${classname}Service.getById(${pk.attrname});
        return R.ok().put("${classname}", ${classname});
    }

    /**
     * 新增
     */
    @RequestMapping("/save")
    @RequiresPermissions("${moduleName}:${pathName}:save")
    public R save(@RequestBody ${className}Entity ${classname}){
        ${classname}Service.save(${classname});
        return R.ok();
    }

    /**
     * 编辑修改
     */
    @RequestMapping("/update")
    @RequiresPermissions("${moduleName}:${pathName}:update")
    public R update(@RequestBody ${className}Entity ${classname}){
        ValidatorUtils.validateEntity(${classname});
        ${classname}Service.updateById(${classname});
        return R.ok();
    }

    /**
     * 删除（物理删除）
     */
    @RequestMapping("/delete")
    @RequiresPermissions("${moduleName}:${pathName}:delete")
    public R delete(@RequestBody ${pk.attrType}[] ${pk.attrname}s){
        ${classname}Service.removeByIds(Arrays.asList(${pk.attrname}s));
        return R.ok();
    }

}

nginx复制代码input {
    # 从文件读取日志信息
    file{
        path => "日志文件路径"
        codec => plain {
          charset => "UTF-8"
        }
    }
}

output {
	# 输出到es
	elasticsearch {
        hosts => ["127.0.0.1:9200"]
        index => "logstash"
    }
}

erlang复制代码input {
    # 从数据库中读取数据
    jdbc {
        # 数据库驱动地址
        jdbc_driver_library => "./repository/mysql-connector-java-5.1.47.jar"
        # 驱动包名称
        jdbc_driver_class => "com.mysql.jdbc.Driver"
        # 连接地址
        jdbc_connection_string => "jdbc:mysql://127.0.0.1:3306/logstash"
        # 数据库用户名
        jdbc_user => "root"
        # 数据库密码
        jdbc_password => "tianxin"
        # 获取数据SQL
        statement => "select * from logstash where id > :sql_last_value"
        # 可以将SQL定义到文件中
        #statement_filepath => "./config/jdbc.sql"
        # 同步频率(分 时 天 月 年)，默认一分钟执行一次
        schedule => "*/1 * * * *"
        # 记录上次执行结果，将会保存到last_run_metadata_path配置文件中，不建议配置
        # 如果配置为true将会导致磁盘受到两倍IO压力
        #record_last_run => false
        # 数据库自增字段，用来增量记录，通常是主键
        use_column_value => true
        # 查询字段类型，此处为数值，时间戳为timestamp
        tracking_column_type => "numeric"
        # 查询条件的字段
        tracking_column => "id"
        # 记录最后一次查询的id，初始数值默认0，时间戳为1970后的时间戳
        last_run_metadata_path => "./repository/last_run_metadata.txt"
        # 是否清除last_run_metadata_path值，如果为true，表示每次都做全量同步
        clean_rum => false
    }
}

output {
    # 输出到es
    elasticsearch {
        hosts => ["127.0.0.1:9200"]
        index => "logstash"
        # 文档id与数据库id字段关联
        document_id => "%{id}"
        # 使用模板，可以提升效率
        template_overwrite => true
    }
}

nginx复制代码input {
    # 监听TCP端口信息
    tcp {
        port => 4560
        codec => json_lines
    }
}

output {
    # 输出到es
    elasticsearch {
        hosts => ["127.0.0.1:9200"]
        index => "logstash"
    }
}

复制代码java -jar xxx.jar

java复制代码@Component
public class MyRabbitmqConfig {
//创建队列（my_ttl_queue），投递到该队列的消息如果没有消费都将在6秒之后被删除
    @Bean
    public Queue my_ttl_queue(){
        return QueueBuilder.durable("my_ttl_queue")
                .ttl(5000)
                .build();
    }

}

java复制代码@RunWith(SpringRunner.class)
@SpringBootTest
public class RabbitmqStudy2ApplicationTests {

    @Autowired
    RabbitTemplate rabbitTemplate;
    /**
     * 过期队列消息
     * 投递到该队列的消息如果没有消费都将在6秒之后被删除
     */
    @Test
    public void ttlQueueTest(){
        //路由键与队列同名
        rabbitTemplate.convertAndSend("my_ttl_queue", "发送到过期队列my_ttl_queue，5秒内不消费则不能再被消费。");
    }

}

java复制代码@Component
public class MyRabbitmqConfig {

    @Bean
    public Queue my_ttl_queue(){
        return QueueBuilder.durable("my_ttl_queue")
                .ttl(500000)
                .build();
    }

}

java复制代码     /**
     * 过期消息
     * 该消息投递任何交换机或队列中的时候；如果到了过期时间则将从该队列中删除
     */
    @Test
    public void ttlMessageTest(){
        MessageProperties messageProperties = new MessageProperties();
        //设置消息的过期时间，30秒
        messageProperties.setExpiration("30000");//字符串非负数字
        Message message = new Message("测试过期消息，30秒钟过期".getBytes(), messageProperties);
        //路由键与队列同名
        rabbitTemplate.convertAndSend("my_ttl_queue", message);
    }

java复制代码    //定义定向交换机中的持久化死信队列
    @Bean
    public Queue my_dlx_queue(){
        return QueueBuilder.durable("my_dlx_queue")
                .build();
    }

    //定义广播类型交换机
    @Bean
    public DirectExchange my_dlx_exchange(){
        return ExchangeBuilder.directExchange("my_dlx_exchange").build();
    }

    @Bean
    public Binding dlx_exchange_to_queue(@Qualifier("my_dlx_queue")Queue my_dlx_queue,
                                         @Qualifier("my_dlx_exchange")DirectExchange my_dlx_exchange){
        //绑定路由键my_ttl_dlx，可以将过期的消息转移到my_dlx_queue队列
        return BindingBuilder.bind(my_dlx_queue).to(my_dlx_exchange).with("my_ttl_dlx");
    }

    //定义过期队列及其属性
    @Bean
    public Queue my_ttl_dlx_queue(){
        return QueueBuilder.durable("my_ttl_dlx_queue")
                .ttl(6000)//投递到该队列的消息如果没有消费都将在6秒之后被投递到死信交换机
                .deadLetterExchange("my_dlx_exchange")//设置当消息过期后投递到对应的死信交换机
                .build();
    }

    //定义定向交换机 根据不同的路由key投递消息
    @Bean
    public DirectExchange my_normal_exchange(){
        return ExchangeBuilder.directExchange("my_normal_exchange").build();
    }

    @Bean
    public Binding normal_exchange_to_queue(@Qualifier("my_ttl_dlx_queue")Queue my_ttl_dlx_queue,
                                         @Qualifier("my_normal_exchange")DirectExchange my_normal_exchange){
        //绑定路由键my_ttl_dlx，可以将过期的消息转移到my_dlx_queue队列
        return BindingBuilder.bind(my_ttl_dlx_queue).to(my_normal_exchange).with("my_ttl_dlx");
    }

java复制代码    /**
     * 过期消息投递到死信队列
     * 投递到一个正常的队列，但是该队列有设置过期时间，到过期时间之后消息会被投递到死信交换机（队列）
     */
    @Test
    public void dlxTTLMessageTest(){
        rabbitTemplate.convertAndSend("my_normal_exchange", "my_ttl_dlx", "测试过期消息；6秒过期后会被投递到死信交换机");
    }

c复制代码curl -O https://alibaba.github.io/arthas/arthas-boot.jar

c复制代码curl -O https://arthas.gitee.io/arthas-boot.jar

c复制代码[root@localhost ~]# ll -lrt
-rw-r--r--. 1 root root   138880 Jun 22 02:55 arthas-boot.jar

c复制代码[root@localhost ~]# java -jar arthas-boot.jar 
[INFO] arthas-boot version: 3.3.3
[INFO] Can not find java process. Try to pass <pid> in command line.
Please select an available pid.

c复制代码[root@localhost ~]# java -jar arthas-boot.jar 
[INFO] arthas-boot version: 3.3.3
[INFO] Found existing java process, please choose one and input the serial number of the process, eg : 1\. Then hit ENTER.
* [1]: 2467 jvm-0.0.1-SNAPSHOT.jar

c复制代码[root@localhost arthas]# java -jar arthas-boot.jar 
[INFO] arthas-boot version: 3.3.3
[INFO] Found existing java process, please choose one and input the serial number of the process, eg : 1\. Then hit ENTER.
* [1]: 2467 jvm-0.0.1-SNAPSHOT.jar
1
[INFO] arthas home: /usr/local/arthas
[INFO] Try to attach process 2467
[INFO] Attach process 2467 success.
[INFO] arthas-client connect 127.0.0.1 3658
  ,---.  ,------. ,--------.,--.  ,--.  ,---.   ,---.                           
 /  O  \ |  .--. ''--.  .--'|  '--'  | /  O  \ '   .-'                          
|  .-.  ||  '--'.'   |  |   |  .--.  ||  .-.  |`.  `-.                          
|  | |  ||  |\  \    |  |   |  |  |  ||  | |  |.-'    |                         
`--' `--'`--' '--'   `--'   `--'  `--'`--' `--'`-----'                          

wiki      https://alibaba.github.io/arthas                                      
tutorials https://alibaba.github.io/arthas/arthas-tutorials                     
version   3.3.3                                                                 
pid       2467                                                                  
time      2020-06-22 03:02:31                                                   

[arthas@2467]$

c复制代码[arthas@2467]$ help
 NAME         DESCRIPTION                      
 help         Display Arthas Help                                       
 keymap       Display all the available keymap for the specified connection.  
 sc           Search all the classes loaded by JVM       
 sm           Search the method of classes loaded by JVM      
 classloader  Show classloader info 
 jad          Decompile class 
 getstatic    Show the static field of a class     
 ...

c复制代码[arthas@2467]$ sc --help
 USAGE:                                    
   sc [-c <value>] [-d] [-x <value>] [-f] [-h] [-E] class-pattern                                                                                     
 SUMMARY:                                                                                                                             
   Search all the classes loaded by JVM                                                                                                       
 EXAMPLES:                                   
   sc -d org.apache.commons.lang.StringUtils   
   sc -d org/apache/commons/lang/StringUtils   
   sc -d *StringUtils                          
   sc -d -f org.apache.commons.lang.StringUtils                                        
   sc -E org\\.apache\\.commons\\.lang\\.StringUtils                                                                                  

 WIKI:                                
   https://alibaba.github.io/arthas/sc                                                                                                                             
 OPTIONS:                                                
 -c, --classloader <value>                    The hash code of the special class's classLoader                                        
 -d, --details                                Display the details of class        
 -x, --expand <value>                         Expand level of object (0 by default)
 -f, --field                                  Display all the member variables 
 -h, --help                                   this help                             
 -E, --regex                                  Enable regular expression to match (wildcard matching by default)                       
 <class-pattern>                              Class name pattern, use either '.' or '/' as separator

c复制代码[arthas@2467]$ thread
Threads Total: 28, NEW: 0, RUNNABLE: 11, BLOCKED: 0, WAITING: 14, TIMED_WAITING: 3, TERMINATED: 0                                     
ID         NAME                              GROUP                 PRIORITY   STATE      %CPU        TIME       INTERRUPTE DAEMON     
16         http-nio-8080-exec-2              main                  5          RUNNABLE   99          0:25       false      true       
29         Attach Listener                   system                9          RUNNABLE   0           0:0        false      true       
11         Catalina-utility-1                main                  1          WAITING    0           0:0        false      false      
12         Catalina-utility-2                main                  1          TIMED_WAIT 0           0:0        false      false      
28         DestroyJavaVM                     main                  5          RUNNABLE   0           0:4        false      false      
3          Finalizer                         system                8          WAITING    0           0:0        false      true       
2          Reference Handler                 system                10         WAITING    0           0:0        false      true

c复制代码[arthas@2467]$ thread 16
"http-nio-8080-exec-2" Id=16 RUNNABLE
    at com.spareyaya.jvm.service.EndlessLoopService.service(EndlessLoopService.java:19)
    at com.spareyaya.jvm.controller.JVMController.endlessLoop(JVMController.java:30)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    ...

c复制代码[arthas@2997]$ thread -b
"Thread-3" Id=29 BLOCKED on java.lang.Object@3f20bf9 owned by "Thread-4" Id=30
    at com.spareyaya.jvm.service.DeadLockService.service1(DeadLockService.java:27)
    -  blocked on java.lang.Object@3f20bf9
    -  locked java.lang.Object@2fea801a <---- but blocks 1 other threads!
    at com.spareyaya.jvm.controller.JVMController.lambda$deadLock$0(JVMController.java:37)
    at com.spareyaya.jvm.controller.JVMController$$Lambda$456/748979989.run(Unknown Source)
    at java.lang.Thread.run(Thread.java:748)

c复制代码[arthas@23581]$ heapdump --live /root/jvm.hprof
Dumping heap to /root/jvm.hprof...
Heap dump file created

arduino复制代码import requests
 
import json
 
import os
 
import threading

ruby复制代码class WebSpider(object):
 
def __init__(self):
 
 
 
        self.url = 'https://bbs-api.mihoyo.com/post/wapi/getForumPostList?forum_id=49'
 
        self.headers = {
 
            'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko)'
 
                          ' Chrome/92.0.4515.107 Safari/537.36'
 
        }

ini复制代码  def parse(self):
 
        img_dict_data = {}         
 
 res = requests.get(self.url, headers=self.headers).content.decode('utf-8')  
 
        res = json.loads(res)          
 
res = res['data']['list']  
 
        subject_name = [i['post']['subject'] for i in res]          
 
cover_url = [i['post']['cover'] for i in res]         
 
 # print(cover_url, subject_name)
 
        # 获取对应的标题以及图片地址
 
        for name, url in zip(subject_name, cover_url):
 
            # print(name, url)
 
            img_dict_data[name] = url  
 
        return img_dict_data

scss复制代码def save_img(self, data):
 
        for k, v in data.items():
 
            img_type = v.split('/')[-1].split('.')[-1]            
 
 save_path = os.path.dirname(os.path.join(__file__)) + '/img'  # 当前目录下的图片保存路径
 
            if not os.path.exists(save_path):  
 
                os.mkdir('img')
 
            with open(f'img/{k}.{img_type}', 'wb') as f:
 
                img = requests.get(v, headers=self.headers).content                  f.write(img)  
 
            print(f'{k}.{img_type} ---图保存成功！'

python复制代码"""
爬取地址：https://bbs-api.mihoyo.com/post/wapi/getForumPostList?forum_id=49
getForumPostList：api返回当前最新回复的列表json数据 
forum_id=49：COS栏目ID数据为 49
"""
import requests
import json
import os
import threading
 
class WebSpider(object):
    def __init__(self):
          self.url = 'https://bbs-api.mihoyo.com/post/wapi/getForumPostList?forum_id=49'
        self.headers = {
            'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko)'
                          ' Chrome/92.0.4515.107 Safari/537.36'
        }
 
    def parse(self):
        img_dict_data = {}         
res = requests.get(self.url, headers=self.headers).content.decode('utf-8')          
res = json.loads(res)         
res = res['data']['list']        
subject_name = [i['post']['subject'] for i in res]         
 cover_url = [i['post']['cover'] for i in res]  # 遍历图片的URL地址
        # print(cover_url, subject_name)
        # 获取对应的标题以及图片地址
        for name, url in zip(subject_name, cover_url):
            # print(name, url)
            img_dict_data[name] = url  # 字典增加数据
 
        return img_dict_data  # 返回数据
 
    # 保存图片
    def save_img(self, data):
        for k, v in data.items():
            img_type = v.split('/')[-1].split('.')[-1]  # 获取图片类型
            save_path = os.path.dirname(os.path.join(__file__)) + '/img'  # 当前目录下的图片保存路径
            if not os.path.exists(save_path):  # img文件夹不存在时则创建新文件夹
                os.mkdir('img')
            with open(f'img/{k}.{img_type}', 'wb') as f:
                img = requests.get(v, headers=self.headers).content  # 发送请求获取图片内容
                f.write(img)  # 写入数据
            print(f'{k}.{img_type} ---图保存成功！')
 
    def main(self):
        data = self.parse()
        self.save_img(data)