비동기 애플리케이션을 위한 Java 에이전트 API

아래 코드 스니펫에서 parallelStream() 메서드를 고려하세요. requestItemAsync() 에 대한 일부 호출은 별도의 스레드에서 발생하기 때문에 토큰이 생성되고 해당 비동기 작업을 다시 요청 스레드에 연결하기 위해 전달됩니다.

/**
* Example showing multi-threaded implementation of requesting data using a parallel {@link Stream}.
*/
@RequestMapping("parallel_stream")
@Trace(dispatcher = true) // starts a transaction
public ResponseEntity<String> parallelStream(@RequestParam("ids") List<Long> ids) {
    final Token token = NewRelic.getAgent().getTransaction().getToken();
    List<item> results = ids
            .parallelStream()
            .map(id -> requestItemAsync(id, token)) // requestItemAsync represents an  example of work being passed to another thread. The token is passed along to allow linking the work on the new thread back to the thread that the token was originally created on.
            .filter(item -> item != null)
            .collect(Collectors.toList());
    token.expire();
    return formattedResponse("parallel_stream", results);
}

이 샘플의 에이전트 API 호출은 다음과 같습니다.

• @Trace(dispatcher = true): 에이전트에게 트랜잭션을 시작하도록 지시합니다. 이 방법에 대한 자세한 내용은 Javadoc 을 참조하십시오.
• getToken(): 작업을 함께 연결할 토큰을 만듭니다. 이 방법에 대한 자세한 내용은 Javadoc 을 참조하십시오.
• token.expire(): 토큰이 만료됩니다. 이렇게 하면 트랜잭션이 종료됩니다. 이 방법에 대한 자세한 내용은 Javadoc 을 참조하십시오.

다음 코드 예시는 요청 스레드와 별도의 스레드에서 실행될 수 있는 requestItemAsync 를 보여줍니다. 이러한 이유로 이전 코드 예에서 생성된 토큰은 requestItemAsync 의 트랜잭션에 연결됩니다. requestItemAsync() 에는 기존 트랜잭션에 연결된 경우 이 메서드를 추적하도록 에이전트에 알리는 @Trace(async=true) 주석이 있습니다.

parallelStream() 이 모든 결과를 수집한 후 토큰이 만료됩니다. 이는 parallelStream() 이 완료된 후 트랜잭션이 열린 상태로 유지되지 않도록 하기 때문에 중요합니다.

@Trace(async = true)
private Item requestItemAsync(long id, Token token) {
    token.link();
    return requestItem(id);
}

이 샘플의 에이전트 API 호출은 다음과 같습니다.

• @Trace(async = true): 트랜잭션을 시작합니다. 이 방법에 대한 자세한 내용은 Javadoc 을 참조하십시오.
• token.link(): requestItemAsync() 에서 수행 중인 작업(다른 스레드에서 실행 중임)을 요청 스레드에 연결합니다. 이 방법에 대한 자세한 내용은Javadoc 을 참조하십시오.

프로세서 트레이스 세부정보를 보려면 다음으로 이동하세요. one.newrelic.com APM & services > (select an app) > Transactions > Transaction trace > Trace details.

비동기 활동은 시간 차원에서 수평으로 서로 겹치는 세그먼트로 추적 폭포 보기에 표시됩니다.

같은 스레드에 있는 메서드를 연결할 필요는 없지만 그렇게 해도 부정적인 영향은 없습니다. parallelStream() 예와 같이 단일 토큰을 공유할 수 있는 경우가 많습니다.

아래 메서드는 storeItem() 메서드를 사용하여 외부 서비스(이 경우 데이터베이스)를 호출합니다.

/**
* Example showing single threaded implementation of inserting data into a datasource.
*/
@RequestMapping("insert")
@Trace(dispatcher = true) //starts a transaction
public ResponseEntity insert(@RequestParam("id") Long id) {
    if (id != null) {
        storeItem(id);
        return new ResponseEntity<>("insert", HttpStatus.OK);
    } else {
        return new ResponseEntity<>("insert", HttpStatus.BAD_REQUEST);
    }
}

이 경우 목표는 storeItem() 이 실행되는 시간을 결정하는 것이 아니라 실행하기 전에 Lambda 문의 Callable 이 스레드 풀에서 대기하는 시간을 찾는 것입니다. 이러한 이유로 토큰 대신 세그먼트를 사용하며 토큰의 경우와 같이 @Trace(async = true) 가 필요하지 않습니다.

이 샘플의 에이전트 API 호출은 다음과 같습니다.

• @Trace(dispatcher = true): 트랜잭션을 시작합니다. 이 방법에 대한 자세한 내용은 Javadoc 을 참조하십시오.

다음 코드 예시에서는 Lambda 문이 스레드 풀에서 대기하는 시간을 측정하기 위해 storeItem 메서드에서 시작하는 세그먼트를 보여줍니다. 세그먼트 타이밍을 중지하려면 .end() 또는 .ignore() 호출해야 합니다. don't 세그먼트를 상위 트랜잭션의 일부로 보고하려면 .ignore() 호출하세요. 그렇지 않고 상위 트랜잭션의 일부로 세그먼트를 보고하려면 .end() 호출하세요.

private void storeItem(long id) {
    Segment segment = NewRelic.getAgent().getTransaction().startSegment("storeItem");

    segment.reportAsExternal(DatastoreParameters
           .product("H2")
           .collection(null)
           .operation("insert")
           .instance("localhost", 8080)
           .databaseName("test")
           .build());

    // fire and forget
    DB_POOL.submit(() -> {
        segment.end();
        insertData(id);
    });
}

이 샘플의 에이전트 API 호출은 다음과 같습니다.

• startSegment(...): 코드의 시간을 측정할 세그먼트를 시작합니다. 이 방법에 대한 자세한 내용은 Javadoc 을 참조하십시오.
• reportAsExternal(DatastoreParameters()): 시간을 데이터 저장소 외부 호출과 연결합니다. 이것은 데이터 저장소 데이터 와 함께 APM에 표시됩니다. 자세한 내용은 reportAsExternal API 를 참조하십시오.
• segment.end(): 이 세그먼트의 타이밍을 중지합니다. 이 방법에 대한 자세한 내용은 Javadoc 을 참조하십시오.

메서드가 완료되면 APM은 하나의 외부 호출로 트랜잭션 추적을 표시합니다.