package cn.itxs;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import java.util.UUID;
import java.util.concurrent.TimeUnit;
@SpringBootApplication
public class App 
{
    public static void main(String[] args) {
        SpringApplication.run(App.class,args);
        new Thread( () -> {
            while (true) {
                String str = UUID.randomUUID().toString().replaceAll("-", "");
            }
        },"cpu demo thread").start();
                try {
                    TimeUnit.MILLISECONDS.sleep(10);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
        },"cpu with sleep thread").start();
    }
}

# 下載`arthas-boot.jar`這種也是官方推薦的方式
curl -O https://arthas.aliyun.com/arthas-boot.jar
# 啟動(dòng)arthas-boot.jar，必須啟動(dòng)至少一個(gè) java程序，否則會(huì)自動(dòng)退出。運(yùn)行此命令會(huì)自動(dòng)發(fā)現(xiàn) java進(jìn)程，輸入需要 attach 進(jìn)程對(duì)應(yīng)的序列號(hào)，例如，輸入1按回車(chē)則會(huì)監(jiān)聽(tīng)該進(jìn)程。
java -jar arthas-boot.jar
# 比如輸入JVM （jvm實(shí)時(shí)運(yùn)行狀態(tài)，內(nèi)存使用情況等）

package cn.itxs.controller;

import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;
import java.util.concurrent.TimeUnit;
@RestController
@RequestMapping("/thread")
public class ThreadController {
    private Object obj1 = new Object();
    private Object obj2 = new Object();
    @RequestMapping("/test")
    @ResponseBody
    public String test(){
        new Thread(() -> {
            synchronized (obj1){
                try {
                    TimeUnit.SECONDS.sleep(10);
                } catch (InterruptedException e) {
                    synchronized (obj2){
                        System.out.printf("thread 1執(zhí)行到此");
                    }
                }
            }
        },"thread 1").start();
            synchronized (obj2) {
                synchronized (obj1){
                    System.out.printf("thread 2執(zhí)行到此");
        },"thread 2").start();
        return "thread test";
    }
}

package cn.itxs;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class App 
{
    public static void main(String[] args) {
        SpringApplication.run(App.class,args);
    }
}

# 當(dāng)前最忙的前N個(gè)線程 thread -b, ##找出當(dāng)前阻塞其他線程的線程 thread -n 5 -i 1000 #間隔一定時(shí)間后展示，本例中可以看到最忙CPU線程為id=45，代碼行數(shù)為19
thread -n 5 
# jad查看反編譯的代碼
jad cn.itxs.controller.CpuController

package cn.itxs.controller;

import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;
import java.util.concurrent.TimeUnit;
@RestController
@RequestMapping("/thread")
public class ThreadController {
    private Object obj1 = new Object();
    private Object obj2 = new Object();
    @RequestMapping("/test")
    @ResponseBody
    public String test(){
        new Thread(() -> {
            synchronized (obj1){
                try {
                    TimeUnit.SECONDS.sleep(10);
                } catch (InterruptedException e) {
                }
                synchronized (obj2){
                    System.out.println("thread 1執(zhí)行到此");
            }
        },"thread 1").start();
        try {
            TimeUnit.SECONDS.sleep(2);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
            synchronized (obj2) {
                synchronized (obj1){
                    System.out.println("thread 2執(zhí)行到此");
        },"thread 2").start();
        return "thread test";
    }
}

# 啟動(dòng)SpringBoot演示程序，訪問(wèn)頁(yè)面http://192.168.50.100:8080/thread/test
# 運(yùn)行arthas，查看線程
thread

# 查看阻塞線程
thread -b
# jad反編譯查看代碼
jad --source-only cn.itxs.controller.ThreadController

package cn.itxs.controller;

import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;
import java.util.UUID;
import java.util.concurrent.TimeUnit;
@RestController
@RequestMapping("/hot")
public class HotController {
    @RequestMapping("/test")
    @ResponseBody
    public String test(){
        boolean flag = true;
        if (flag) {
            System.out.println("開(kāi)始處理邏輯");
            throw new RuntimeException("出異常了");
        }
        System.out.println("結(jié)束流程");
        return "hot test";
    }
}

# 第一步：`jad命令` 將需要更改的文件先進(jìn)行反編譯，保存下來(lái) ，編譯器修改,-c 指定這個(gè)類(lèi)的classloader的哈希值，–source-only只顯示源碼，最后是文件反編譯之后的存放路徑
jad --source-only cn.itxs.controller.HotController > /home/commons/arthas/data/HotController.java
# 我們將HotController.java中的throw new RuntimeException("出異常了")代碼刪掉，修改完后需要將類(lèi)重新加載到JVM
# 第二步：`SC命令` 查找當(dāng)前類(lèi)是哪個(gè)classLoader加載的，首先，使用sc命令找到要修改的類(lèi).sc全稱-search class， -d表示detail,主要是為了獲取classLoader的hash值
sc -d *HotController | grep classLoader
classLoaderHash   6267c3bb #類(lèi)加載器  編號(hào)    
# 第三步：`MC命令` 用指定的classloader重新將類(lèi)在內(nèi)存中編譯
mc -c 6267c3bb /home/commons/arthas/data/HotController.java -d /home/commons/arthas/class
# 第四步：`redefine命令` 將編譯后的類(lèi)加載到JVM，參數(shù)是編譯后的.class文件地址
redefine /home/commons/arthas/class/cn/itxs/controller/HotController.class  

package cn.itxs.controller;

import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;
import java.util.ArrayList;
import java.util.List;
import java.util.Random;
@RestController
@RequestMapping("/watch")
public class WatchController {
    private static Random random = new Random();
    private int illegalArgumentCount = 0;
    @RequestMapping("/test")
    @ResponseBody
    public String test(){
        String res = null;
        try {
            int number = random.nextInt() / 10000;
            List<Integer> idStrs = this.getIdStr(number);
            res = printList(number, idStrs);
        }
        catch (Exception e) {
            System.out.println(String.format("illegalArgumentCount:%3d, ", this.illegalArgumentCount) + e.getMessage());
        return res;
    }
    private List<Integer> getIdStr(int number) {
        if (number < 5) {
            ++this.illegalArgumentCount;
            throw new IllegalArgumentException("number is: " + number + ", need >= 5");
        ArrayList<Integer> result = new ArrayList<Integer>();
        int count = 2;
        while (count <= number) {
            if (number % count == 0) {
                result.add(count);
                number /= count;
                count = 2;
                continue;
            }
            ++count;
        return result;
    private String printList(int number, List<Integer> primeFactors) {
        StringBuffer sb = new StringBuffer(number + "=");
        for (int factor : primeFactors) {
            sb.append(factor).append('*');
        if (sb.charAt(sb.length() - 1) == '*') {
            sb.deleteCharAt(sb.length() - 1);
        System.out.println(sb);
        return sb.toString();
}

# Arthas中的**watch**命令可以讓我們能方便的觀察到指定方法的調(diào)用情況，可以觀察到返回值，入?yún)?，以及變量等?
# watch 全路徑類(lèi)名 方法名 觀察表達(dá)式 -x 3  ，觀察表達(dá)式匹配ognl表達(dá)式，觀察的維度也比較多。
# 比如：watch cn.itxs.controller.WatchController printList "{params,returnObj}" -x 3
# 查看printList方法的入?yún)⒑统鰠ⅲ?x表示的是遍歷結(jié)果深度默認(rèn)1，只會(huì)打印對(duì)象的堆地址，看不到具體的屬性值,-x 2會(huì)打印結(jié)果的屬性值的信息 -x 3會(huì)輸出入?yún)傩灾岛徒Y(jié)果屬性值
# -n 1只抓緊一次，由于我們這里是模擬一直請(qǐng)求的
watch cn.itxs.controller.WatchController printList '{params}' -n 1
# -x 表示的是遍歷結(jié)果深度默認(rèn)3
watch cn.itxs.controller.WatchController printList '{params}' -n 1 -x 3
# params[0]代表第一個(gè)參數(shù)
watch cn.itxs.controller.WatchController printList '{params[0]}' -n 1 -x 3

# 方法的返回值
watch cn.itxs.controller.WatchController getIdStr '{returnObj}' -n 1 -x 3
# 方法參數(shù)和返回值
watch cn.itxs.controller.WatchController getIdStr '{params,returnObj}' -n 1 -x 3

# 觀察方法執(zhí)行前后當(dāng)前對(duì)象屬性值
watch cn.itxs.controller.WatchController getIdStr 'target.illegalArgumentCount'

# 在觀察表達(dá)式后面，我們可以增加條件表達(dá)式，例如按時(shí)間過(guò)濾：#cost>0.5,單位是毫秒，那么控制臺(tái)輸出來(lái)的都是耗時(shí)在0.5毫秒以上的方法調(diào)用
watch cn.itxs.controller.WatchController getIdStr '{params}' '#cost>0.5'

# 按條件過(guò)濾觀察params[1].size>4:這里支持ognl表達(dá)式。下面例子的意思是：第二個(gè)參數(shù)（也就是List primeFactors），的size大于4的時(shí)候才觀察入?yún)?。watch cn.itxs.controller.WatchController printList '{params}' 'params[1].size>4' -x 3

# -c ：統(tǒng)計(jì)周期，默認(rèn)值為10秒
monitor -c 10 cn.itxs.controller.WatchController getIdStr
# 在方法調(diào)用之前計(jì)算condition-express,方法后可帶表達(dá)式
monitor -b -c 10 cn.itxs.controller.WatchController getIdStr

# trace:方法內(nèi)部調(diào)用路徑，并輸出方法路徑上的每個(gè)節(jié)點(diǎn)上耗時(shí)
trace cn.itxs.controller.WatchController test -n 2
#包含jdk的函數(shù)--skipJDKMethod <value>  skip jdk method trace, default value true.默認(rèn)情況下，trace不會(huì)包含jdk里的函數(shù)調(diào)用，如果希望trace jdk里的函數(shù)，需要顯式設(shè)置--skipJDKMethod false。
trace --skipJDKMethod false cn.itxs.controller.WatchController test -n 2
# 調(diào)用耗時(shí)過(guò)濾，只會(huì)展示耗時(shí)大于10ms的調(diào)用路徑，有助于在排查問(wèn)題的時(shí)候，只關(guān)注異常情況
trace cn.itxs.controller.WatchController test '#cost > 1'

# 輸出當(dāng)前方法被調(diào)用的調(diào)用路徑，getIdStr是從test方法調(diào)用進(jìn)來(lái)的
stack cn.itxs.controller.WatchController getIdStr -n 1
# 輸出當(dāng)前方法被調(diào)用的調(diào)用路徑，條件表達(dá)過(guò)濾，第0個(gè)參數(shù)小于0，也可以根據(jù)執(zhí)行時(shí)間來(lái)過(guò)濾，'#cost>1'
stack cn.itxs.controller.WatchController getIdStr 'params[0]<0' -n 1

# 記錄指定方法的每次調(diào)用環(huán)境現(xiàn)場(chǎng)
tt -t cn.itxs.controller.WatchController getIdStr 
# 列出所有調(diào)用記錄
tt -l cn.itxs.controller.WatchController getIdStr

# 篩選調(diào)用記錄
tt -s 'method.name=="getIdStr"'
# 查看調(diào)用信息
tt -i 1001

# 重新發(fā)起一次調(diào)用
tt -i 1001 -p

# 啟動(dòng)時(shí)指定Linux的ip
java -jar arthas-boot.jar --target-ip 192.168.50.94

# 啟動(dòng)profiler 默認(rèn)情況下，生成的是cpu的火焰圖，即event為cpu。可以用--event參數(shù)來(lái)指定
profiler start
# 獲取已采集的sample的數(shù)量
profiler getSamples
# 查看profiler狀態(tài)
profiler status
# 停止profiler 生成html格式結(jié)果，默認(rèn)情況下，結(jié)果文件是html格式，也可以用--format參數(shù)指定；或者在--file參數(shù)里用文件名指名格式。比如--file /tmp/result.html
profiler stop --format html

# profiler支持的events
profiler list

# 可以用--event參數(shù)指定要采樣的事件，比如對(duì)alloc事件進(jìn)入采樣：
profiler start --event alloc
# 使用execute來(lái)執(zhí)行復(fù)雜的命令
profiler execute 'start,framebuf=5000000'
# 生成 jfr格式結(jié)果；注意，jfr只支持在 start時(shí)配置。如果是在stop時(shí)指定，則不會(huì)生效。
profiler start --file /tmp/test.jfr
# 配置 include/exclude 來(lái)過(guò)濾數(shù)據(jù)
profiler start --include 'java/*' --include 'demo/*' --exclude '*Unsafe.park*'
# profiler執(zhí)行 300 秒自動(dòng)結(jié)束，可以用 -d/--duration 參數(shù)指定
profiler start --duration 300

{
  "action": "exec",
  "requestId": "req112",
  "sessionId": "94766d3c-8b39-42d3-8596-98aee3ccbefb",
  "consumerId": "955dbd1325334a84972b0f3ac19de4f7_2",
  "command": "version",
  "execTimeout": "10000"
}

# 選擇需要監(jiān)控應(yīng)用的進(jìn)程編號(hào)，回車(chē)后Arthas會(huì)attach到目標(biāo)進(jìn)程上，并輸出日志：
docker exec -it arthas-demo /bin/sh -c "java -jar /opt/arthas/arthas-boot.jar"
# 甚至我們可以直接把a(bǔ)rthas放到容器鏡像文件中：

  <dependency>
            <groupId>com.taobao.arthas</groupId>
            <artifactId>arthas-spring-boot-starter</artifactId>
            <version>${arthas.version}</version>
        </dependency>

 <dependency>
            <groupId>com.taobao.arthas</groupId>
            <artifactId>arthas-agent-attach</artifactId>
            <version>${arthas.version}</version>
        </dependency>
        <dependency>
            <groupId>com.taobao.arthas</groupId>
            <artifactId>arthas-packaging</artifactId>
            <version>${arthas.version}</version>
        </dependency>

import com.taobao.arthas.agent.attach.ArthasAgent;
 
public class ArthasAttachExample {
	
	public static void main(String[] args) {
		ArthasAgent.attach();
	}
}