Application Real-Time Monitoring Service:非同期タスクを監視するためにARMSを使用する

監視

非同期パススルーのスキャンパッケージを追加する

非同期タスクを監視するために、アプリケーションの構成に非同期パススルーのスキャンパッケージを追加できます。 Runnable オブジェクト、Callable オブジェクト、または Supplier オブジェクトが作成されると、非同期パススルーのスキャンパッケージ内の対応するメソッドが現在のスレッドのトレースコンテキストを自動的にキャプチャします。次に、スレッドが非同期モードで使用されると、メソッドはキャプチャされたトレースコンテキストをスレッドに渡します。

1. ARMS console にログインします。左側のナビゲーションペインで、[アプリケーション監視] > [アプリケーションリスト] を選択します。

2. [アプリケーションリスト] ページで、上部のナビゲーションバーでリージョンを選択し、管理するアプリケーションの名前をクリックします。

   説明

   [言語] 列に表示されるアイコンは、アプリケーションが記述されている言語を示します。

   : Java アプリケーション

   : Go アプリケーション

   : Python アプリケーション

   ハイフン (-): Managed Service for OpenTelemetry で監視されるアプリケーション。

3. 左側のナビゲーションペインで、[アプリケーション設定] をクリックします。表示されるページで、[カスタム構成] タブをクリックします。

4. タブの [詳細設定] セクションで、[非同期透過伝送スキャンパッケージ名] フィールドに非同期パススルーのスキャンパッケージの名前を入力します。

   

5. [保存] をクリックします。

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() {
                // 現在の時刻とスレッドIDを出力します。
                System.out.println(System.currentTimeMillis()+ ": my name is john, " + Thread.currentThread().getId());
            }
        });
    }
}

ARMS SDK を使用して手動パススルーを実装する

上記のメソッドが複雑な監視シナリオでの要件を満たせない場合は、ARMS SDK を使用して手動パススルーを実装できます。 Runnable メソッドと Callable メソッド、およびエグゼキューターを拡張して、非同期スレッドのトレースを連結し、非同期タスクを監視できます。

1. Maven プロジェクトの pom.xml ファイルに次の依存関係を追加します。

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

2. 必要に応じて、Runnable メソッドと Callable メソッド、およびエグゼキューターを拡張します。必要に応じて、次の拡張メソッドのいずれかを使用できます。

   メソッド 1: Runnable メソッドと Callable メソッドを拡張する

   TraceRunnable.asyncEntry() メソッドを呼び出して、Runnable メソッドを強化します。TraceCallable.asyncEntry() メソッドを呼び出して、Callable メソッドを強化します。次のコードは、Runnable メソッドと 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();
       }
   }

   メソッド 2: エグゼキューターを拡張する

   TraceExecutors.wrapExecutorService(executor, true) メソッドを呼び出して、executor を強化します。次のコードは、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();
       }
   }

   メソッド 3: Runnable メソッドと Callable メソッド、およびエグゼキューターを拡張する

   次のコードは、Runnable メソッドと Callable メソッド、およびエグゼキューターを拡張する方法の例を示しています。

   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();
       }
   }