使用ARMS监控异步任务

方式一：默认支持Spring @Async标签

方式二：添加异步透传扫描包

您可以选择在应用设置中添加异步透传扫描包实现异步任务监控。异步透传扫描包中的Runnable、Callable和Supplier接口在创建新对象时会自动捕获当前线程调用链的上下文，并在异步线程中执行时使用该调用链上下文，完成串联。

1. 登录ARMS控制台。
2. 在左侧导航栏，选择应用监控 > 应用列表。
3. 在顶部菜单栏，选择地域。
4. 在应用列表页面，单击应用名称。
5. 在左侧导航栏，单击应用设置，然后单击自定义配置页签。
6. 在高级设置区域的异步透传扫描包名对话框中，添加异步透传扫描包。
   
7. 在页面底部，单击保存。

package com.alibaba.arms.brightroar.console.service;

@Service
public class NameService {

    private ExecutorService es = Executors.newFixedThreadPool(5);

    public void name() {
        es.submit(new Runnable() {
            @Override
            public void run() {
                System.out.println(System.currentTimeMillis()+ ": my name is john, " + Thread.currentThread().getId());
            }
        });
    }
}

方式三：使用ARMS SDK手动透传

当您的使用方式比较复杂，上述场景无法满足需求时，您还可以选择使用ARMS SDK进行手动透传。通过手动增强Runnable接口、Callable接口和Executor，在异步线程中完成调用链串联，实现异步任务监控。

1. 在Maven项目的pom.xml中添加以下依赖。

   <dependency>
    <groupId>com.alibaba.arms.apm</groupId>
    <version>1.7.5</version>
    <artifactId>arms-sdk</artifactId>
   </dependency>

2. 增强Runnable接口、Callable接口和Executor。您可以按需选择以下任意一种增强方式。

   • 方式一：增强Runnable接口和Callable接口

     使用TraceRunnable.asyncEntry()增强Runnable接口，使用TraceCallable.asyncEntry()增强Callable接口。示例代码如下：

     public class AsyncEntryExample {
     
         private final ExecutorService executor = Executors.newSingleThreadExecutor();
     
         @GetMapping(value = "/sdk-async-plugin/asyncEntry-propagation")
         public String asyncEntryAndExecute() throws Exception {
             CompletableFuture<String> future = new CompletableFuture<>();
             Runnable command = TraceRunnable.asyncEntry(() -> future.complete("asyncEntry-execute"));
             executor.execute(command);
             Thread.sleep(1000);
             return future.get();
         }
     }

   • 方式二：增强Executor

     使用TraceExecutors.wrapExecutorService(executr, true)增强Executor。示例代码如下：

     public class AutoExample {
     
         private final ExecutorService contextPropagationExecutor
                 = TraceExecutors.wrapExecutorService(Executors.newSingleThreadExecutor(), true);
     
         @GetMapping(value = "/sdk-async-plugin/auto-context-propagation")
         public String autoWrapAndExecute() throws Exception {
             CompletableFuture<String> future = new CompletableFuture<>();
             contextPropagationExecutor.execute(() -> future.complete("auto-execute"));
             Thread.sleep(1000);
             return future.get();
         }
     }

   • 方式三：同时增强Runnable接口、Callable接口和Executor
     示例代码如下：

     public class ManualExample {
         private final ExecutorService traceExecutor
                 = TraceExecutors.wrapExecutorService(Executors.newSingleThreadExecutor());
     
         @GetMapping(value = "/sdk-async-plugin/manual-context-propagation")
         public String manualWrapAndExecute() throws Exception {
             CompletableFuture<String> future = new CompletableFuture<>();
             traceExecutor.execute(TraceRunnable.wrap(() -> future.complete("manual-execute")));
             traceExecutor.execute(() -> "Not captured");
             Thread.sleep(1000);
             return future.get();
         }
     }