[스프링 핵심원리 - 고급편] #1. 예제 만들기(2) #647

Pracrobo · 2025-02-28T02:17:11Z

Pracrobo
Feb 28, 2025

로그추적기 V1 - 프로토타입개발

애플리케이션의 모든 로직에 로그를 남겨도 됨
그것보다는 효율적인 방법이 필요함
깊이를 표현하는 방법을 기존 정보에 이어 받아야하기 때문에 단순히 로그만 남긴다고 해결할 수 있는건 아니다.
요구사항에 맞추어 애플리케이션에 효과적으로 로그를 남기기 위한 로그 추적기를 개발해보자
- 먼저 프로토타입 버전을 개발해보자, 아마 코드를 모두 작성하고 테스트 코드까지 실행해보아야 어떤것을 하는지 감이 올 것이다.
먼저 로그 추적기를 위한 기반 데이터를 가지고 있는 ‘TraceId’, ‘TraceStatus’ 클래스를 만들어 보자.

TraceId 클래스

로그 추적기는 트랜잭션 ID와 깊이를 표현하는 방법이 필요하다

여기서는 트랜잭션ID 와 깊이를 표현하는 level을 묶어서 ‘TraceId’라는 개념을 만들었다.

‘TraceId’는 단순히 ‘id’(트랜잭션ID)와 ‘level’정보를 함께 가지고 있다.

package hello.advanced.trace;

import java.util.UUID;

public class TraceId {
    private String id; //트랜잭션Id
    private int level;

    public TraceId() {
        this.id = createId();
        this.level = 0;
    }

    private TraceId(String id, int level) {
        this.id = id;
        this.level = level;
    }

    // UUID
    // ab99e16f-3cde-4d24-8241-256108c203a2 //생성된 UUID
    // ab99e16f //앞 8자리만 사용
    private String createId() {
        return UUID.randomUUID().toString().substring(0, 8);
    }

    public TraceId createNextId() {  //  id는 같고 레벨만 증가해서 표현
        return new TraceId(id, level + 1);
    }

    public TraceId createPreviousId() {
        return new TraceId(id, level - 1);
    }

    public boolean isFirstLevel() {
        return level == 0;
    }

    public String getId() {
        return id;
    }

    public int getLevel() {
        return level;
    }
}

1. createNextId()

다음 TranceId 를 만든다. 예제 로그를 보면 깊이가 증가해도 트랜잭션 ID 는 같다. 대신에 깊이가 하나 증가한다

new TraceId(jd, level + 1)

따라서 createNextId()를 사용해서 현재 TraceId 를 기반으로 다음 TraceId를 만들면 ‘id’는 기존과 같고 ‘level은 하나 증가한다.

2. createPreviousId()

createNextId()의 반대 역할을 한다.

id는 기존과 같고, level은 하나 감소한다.

3. isFirstLevel()

첫번째 레벨 여부를 편리하게 확인할 수 있는 메서드

TraceStatus클래스

로그의 상태 정보를 만드는것

package hello.advanced.trace;

public class TraceStatus {
    private TraceId traceId;
    private Long startTimeMs;
    private String message;

    public TraceStatus(TraceId traceId, Long startTimeMs, String message) {
        this.traceId = traceId;
        this.startTimeMs = startTimeMs;
        this.message = message;
    }

    public TraceId getTraceId() {
        return traceId;
    }

    public Long getStartTimeMs() {
        return startTimeMs;
    }

    public String getMessage() {
        return message;
    }
}

로그를 시작하면 끝이 있어야 한다.

TraceStatus 는 로그를 시작할때의 상태 정보를 가지고 있다. 이 상태 정보는 로그를 종료할때 사용된다.

traceId : 내부에 트랜잭션 ID와 level을 가지고 있다.
startTimeMs : 로그 시작 시간이다. 로그 종료시 이 시작 시간을 기준으로 시작~종료까지 전체 수행 구간을 구할 수 있다.
message : 시작시 사용한 메세지이다. 이후 로그 종료시에도 이 메세지를 사용해서 출력한다.

TraceId, TraceStatus 를 사용해서 실제 로그를 생성하고 처리하는 기능을 개발해보자.

package hello.advanced.trace.hellotrace;

import hello.advanced.trace.TraceId;
import hello.advanced.trace.TraceStatus;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

@Slf4j
@Component
public class HelloTraceV0 {

    private static final String START_PREFIX = "-->";
    private static final String COMPLETE_PREFIX = "<--";
    private static final String EX_PREFIX = "<X-";

    public TraceStatus begin(String message) {
        TraceId traceId = new TraceId();
        Long startTimeMs = System.currentTimeMillis();
        log.info("[{}] {}{}", traceId.getId(), addSpace(START_PREFIX,
                traceId.getLevel()), message); //addSpace ->
        // 로그 출력
        return new TraceStatus(traceId, startTimeMs, message);
    }

    public void end(TraceStatus status) {
        complete(status, null);
    }

    public void exception(TraceStatus status, Exception e) {
        complete(status, e);
    }

    private void complete(TraceStatus status, Exception e) {
        Long stopTimeMs = System.currentTimeMillis();
        long resultTimeMs = stopTimeMs - status.getStartTimeMs();
        TraceId traceId = status.getTraceId();
        if (e == null) {
            log.info("[{}] {}{} time={}ms", traceId.getId(),
                    addSpace(COMPLETE_PREFIX, traceId.getLevel()), status.getMessage(),
                    resultTimeMs);
        } else {
            log.info("[{}] {}{} time={}ms ex={}", traceId.getId(),
                    addSpace(EX_PREFIX, traceId.getLevel()), status.getMessage(), resultTimeMs,
                    e.toString());
        }
    }
    // level = 0
    // level=1 |-->
    // level=2 |   |-->
    // level=2 ex |    |<X-
    // level=1 ex |<X-
    private static String addSpace(String prefix, int level) {
        StringBuilder sb = new StringBuilder();
        for (int i = 0; i < level; i++) {
            sb.append((i == level - 1) ? "|" + prefix : "|   ");
        }
        return sb.toString();

    }
}

HelloTraceV1 을 사용해서 실제 로그를 시작하고 종료할 수 있다. 그리고 로그를 출력하고 실행시간도 측정할 수 있다.
@Component : 싱글톤으로 사용하기 위해 스프링 빈으로 등록한다. 컴포넌트 스캔의 대상이 된다.

공개 메서드

로그 추적기에서 사용되는 공개 메서드는 다음 3가지이다.

begin(..)
end(..)
exception(..)

하나씩 알아보자

TraceStatus begin(String message)

로그를 시작한다.
로그 메시지를 파라미터로 받아서 시작 로그를 출력한다.
응답 결과롤 현재 로그의 상태인 TraceStatus 를 반환한다.

void end(TraceStatus status)

로그를 정상 종료한다.
파라미터로 시작 로그의 상태(TraceStatus)를 전달받는다. 이 값을 활용해서 실행시간을 계산하고 종료시에도 시작할때와 동일한 로그 메시지를 출력할 수 있다.
정상 흐름에서 호출한다.

void exception(TraceStatus status, Exception e)

로그를 예외 상황으로 종료한다.
TraceStatus, Exception 정보를 함께 전달받아서 실행시간, 예외정보를 포함한 결과 로그를 출력한다.
예외가 발생했을때 호출한다.

비공개 메서드

complete(TraceStatus status, Exception e)
- ‘end()’ , ‘exception()’ 의 요청 흐름을 한곳에서 편리하게 처리한다. 실행 시간을 측정하고 로그를 남긴다.
String addSpace(String prefix, int level) : 다음과 같은 결과를 출력한다.
- prefix : -->
  - level 0 : ‘ ’
  - level 1: ‘ |—>‘
  - level 2: ‘ | |—>’
- prefix: ‘←-’
  - level 0 : ‘ ‘
  - level 1: ‘|←-’
  - level 2: ‘| |←-’
- prefix: ‘<X—’
  - level 0: ‘ ‘
  - level 1: ‘|<X-’
  - level 2: ‘| |<X-’

참고로 HelloTraceV1 는 아직 모든 요구사항을 만족하지는 못한다. 이후에 기능을 하나씩 추가할 예정이다.

테스트 작성

package hello.advanced.trace.hellotrace;

import hello.advanced.trace.TraceStatus;
import org.junit.jupiter.api.Test;

class HelloTraceV1Test {

    @Test
    void begin_end() {
        HelloTraceV1 trace = new HelloTraceV1();
        TraceStatus status = trace.begin("hello");
        trace.end(status);
    }

    @Test
    void begin_exception() {
        HelloTraceV1 trace = new HelloTraceV1();
        TraceStatus status = trace.begin("hello");
        trace.exception(status, new IllegalStateException());
    }
}

이제 다음시간에 실제 애플리케이션에 적용해볼 것임

참고: 이것은 온전한 테스트 코드가 아니다. 일반적으로 테스트라고 하면 자동으로 검증하는 과정이 필요하다. 이 테스트는 검증하는 과정이 없고 결과를 콘솔로 직접 확인해야 한다. 이렇게 응답값이 없는 경우를 자동으로 검증하려면 여러가지 테스트 기법이 필요하다. 이번 강의에서는 예제를 최대한 단순화하기 위해 검증 테스트를 생략했다.

로그추적기V1 - 적용

v0 폴더를 v1으로 변경

controller 부분 /v1/request

package hello.advanced.v1;

import lombok.RequiredArgsConstructor;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController // @Controller + @ResponseBody
@RequiredArgsConstructor
public class OrderControllerV1 {
    private final OrderServiceV1 orderService;

    @GetMapping("/v1/request")
    public String request(String itemId) {
        orderService.orderItem(itemId);
        return "OK"; // @RestController 이기 때문에 문자
    }

}

Controller 변경

package hello.advanced.v1;

import hello.advanced.trace.TraceStatus;
import hello.advanced.trace.hellotrace.HelloTraceV1;
import lombok.RequiredArgsConstructor;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController // @Controller + @ResponseBody
@RequiredArgsConstructor
public class OrderControllerV1 {
    private final OrderServiceV1 orderService;
    private final HelloTraceV1 trace; //추가

    @GetMapping("/v1/request")
    public String request(String itemId) {
        TraceStatus status = trace.begin("OrderController.request()"); //추가
        orderService.orderItem(itemId);
        trace.end(status);  //추가
        return "OK"; 
    }

}

package hello.advanced.v1;

import hello.advanced.trace.TraceStatus;
import hello.advanced.trace.hellotrace.HelloTraceV1;
import lombok.RequiredArgsConstructor;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController // @Controller + @ResponseBody
@RequiredArgsConstructor
public class OrderControllerV1 {
    private final OrderServiceV1 orderService;
    private final HelloTraceV1 trace;

    @GetMapping("/v1/request")
    public String request(String itemId) {
        TraceStatus status = null;
        try {
            status = trace.begin("OrderController.request()");
            orderService.orderItem(itemId);
            trace.end(status); //예외터졌을때 이 부분 안나옴
            return "OK"; // @RestController 이기 때문에 문자
        } catch (Exception e) {
            trace.exception(status, e); // 예외를 가지고 있음
            throw e;//예외를 다시 던져줘야 한다.
        }
    }

}

HelloTraceV1 trace : HelloTraceV1을 주입받는다. 참고로 HelloTraceV1 은 @Component 애노테이션을 가지고 있기 때문에 컴포넌트 스캔의 대상이 된다. 따라서 자동으로 스프링 빈으로 등록된다.
trace.begin("OrderController.request()") : 로그를 시작할 때 메세지 이름으로 컨트롤러 이름 + 메서드 이름을 주었다. 이렇게 하면 어떤 컨트롤러와 메서드가 호출되었는지 로그로 편리하게 확인할 수 있다. 물론 수작업이다.
단순하게 trace.begin() , trace.end() 코드 두줄만 적용하면 될 줄 알았지만 실상은 그렇지 않다. trace.exception() 으로 예외까지ㅏ 처리해야 하므로 지저분한 try, catch 코드가 추가된다.
begin()의 결과값으로 받은 TraceStatus status 값을 end() , exception() 에 넘겨야 한다. 결국 try~ catch 블록 모두에 이 값을 넘겨야한다. 따라서 try 상위에 TraceStatus status 코드를 선언해야 한다. 만약 try, 안에서 TraceSatus staus 를 선언하면 try 블록안에서만 해당 변수가 유효기 때문에 catch 블록에 넘길 수 없다.
- 따라서 컴파일 오류가 발생한다.
throw e : 예외를 꼭 다시 던져주어야 한다. 그렇지 않으면 여기서 예외를 막아버리고 이후에 정상흐름으로 동작한다. 로그는 애플리케이션의 흐름에 영향을 주면 안된다. 로그 때문에 예외가 사라지면 안된다.

실행

정상 : http://localhost:8080/v1/request?itemId=hello
예외 : http://localhost:8080/v1/request?itemId=ex
실행해보면 정상흐름과 예외 모두 로그로 잘 출력된다.

OrderServiceV1

package hello.advanced.v1;

import hello.advanced.trace.TraceStatus;
import hello.advanced.trace.hellotrace.HelloTraceV1;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;

@Service
@RequiredArgsConstructor
public class OrderServiceV1 {
    private final OrderRepositoryV1 orderRepository;
    private final HelloTraceV1 trace;

    public void orderItem(String itemId) {
        TraceStatus status = null;
        try {
            status = trace.begin("OrderService.orderItem()");
            orderRepository.save(itemId);
            trace.end(status); //예외터졌을때 이 부분 안나옴
        } catch (Exception e) {
            trace.exception(status, e); // 예외를 가지고 있음
            throw e;//예외를 다시 던져줘야 한다.
        }

    }
}

OrderRepositoryV1

package hello.advanced.v1;

import hello.advanced.trace.TraceStatus;
import hello.advanced.trace.hellotrace.HelloTraceV1;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Repository;

@Repository
@RequiredArgsConstructor
public class OrderRepositoryV1 {
    private final HelloTraceV1 trace;

    public void save(String itemId) {
        TraceStatus status = null;
        try {
            status = trace.begin("OrderRepository.save()");
            // 저장로직
            if (itemId.equals("ex")) {
                throw new IllegalArgumentException("예외발생! ");
            }
            sleep(1000);
            trace.end(status); //예외터졌을때 이 부분 안나옴
        } catch (Exception e) {
            trace.exception(status, e); // 예외를 가지고 있음
            throw e;//예외를 다시 던져줘야 한다.
        }

    }

    private void sleep(int millis) {
        try {
            Thread.sleep(millis);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

흐름: id 가 생성, level=0 → OrderService로 가서 begin()을 실행 level=0 → OrderRepository로 가서 status =33333으로 찍히고 → begin() 22222 → 111111

HelloTraceV1 덕분에 직접 로그하나하나 남기는 것보다는 편리하게 여러가지 로그를 남길 수 있었다. 하지만 로그를 남기기 위한 코드가 생각보다 너무 복잡하다. 지금은 우선 요구사항과 동작하는 것에만 집중하자.

남은 문제

요구사항

메서드 호출의 깊이 표현
HTTP 요청을 구분
- HTTP 요청 단위로 특정 ID 를 남겨서 어떤 HTTP 요청에서 시작된 것인지 명확하게 구분이 가능해야 한다.
- 트랜잭션 ID(DB 트랜잭션 X)

→ 결국 현재 로그의 상태 정보인 “트랜잭션 ID와 level”이 다음으로 전달되어야 한다.

“정리하면 로그에 대한 문맥(Context) 정보가 필요하다”

로그 추적기 V2 - 파라미터로 동기화 개발

트랜잭션 ID와 메서드 호출의 깊이를 표현하는 가장 단순한 방법은 첫 로그에서 사용한 트랜잭션 ID와 level 을 다음 로그에 넘겨주면된다.
현재 로그의 상태 정보인 트랜잭션 ID와 level은 TraceId에 포함되어 있다. 따라서 TraceId를 다음 로그에 넘겨주면 된다. 이 기능을 추가한 HelloTraceV2를 개발해보자.

    //V2 에서 추가
    public TraceStatus beginSync(TraceId beforeTraceId, String message) {
        TraceId nextId = beforeTraceId.createNextId();
        Long startTimeMs = System.currentTimeMillis();
        log.info("[{}] {}{}", nextId.getId(), addSpace(START_PREFIX,
                nextId.getLevel()), message); //addSpace ->
        // 로그 출력
        return new TraceStatus(nextId, startTimeMs, message);
    }

이부분 추가해서 V2 완성

기존 TraceId에서 createdNextId()를 통해 다음 ID를 구한다.
createNextId()의 TraceId생성 로직은 다음과 같다.
- 트랜잭션 ID는 기존과 같이 유지한다.
- 깊이를 표현하는 Level은 하나 증가한다 (0 → 1)

package hello.advanced.trace.hellotrace;

import hello.advanced.trace.TraceId;
import hello.advanced.trace.TraceStatus;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

@Slf4j
@Component
public class HelloTraceV2 {

    private static final String START_PREFIX = "-->";
    private static final String COMPLETE_PREFIX = "<--";
    private static final String EX_PREFIX = "<X-";

    public TraceStatus begin(String message) {
        TraceId traceId = new TraceId();
        Long startTimeMs = System.currentTimeMillis();
        log.info("[{}] {}{}", traceId.getId(), addSpace(START_PREFIX,
                traceId.getLevel()), message); //addSpace ->
        // 로그 출력
        return new TraceStatus(traceId, startTimeMs, message);
    }

    //V2 에서 추가
    public TraceStatus beginSync(TraceId beforeTraceId, String message) {
        TraceId nextId = beforeTraceId.createNextId();
        Long startTimeMs = System.currentTimeMillis();
        log.info("[{}] {}{}", nextId.getId(), addSpace(START_PREFIX,
                nextId.getLevel()), message); //addSpace ->
        // 로그 출력
        return new TraceStatus(nextId, startTimeMs, message);
    }

    public void end(TraceStatus status) {
        complete(status, null);
    }

    public void exception(TraceStatus status, Exception e) {
        complete(status, e);
    }

    private void complete(TraceStatus status, Exception e) {
        Long stopTimeMs = System.currentTimeMillis();
        long resultTimeMs = stopTimeMs - status.getStartTimeMs();
        TraceId traceId = status.getTraceId();
        if (e == null) {
            log.info("[{}] {}{} time={}ms", traceId.getId(),
                    addSpace(COMPLETE_PREFIX, traceId.getLevel()), status.getMessage(),
                    resultTimeMs);
        } else {
            log.info("[{}] {}{} time={}ms ex={}", traceId.getId(),
                    addSpace(EX_PREFIX, traceId.getLevel()), status.getMessage(), resultTimeMs,
                    e.toString());
        }
    }

    // level = 0
    // level=1 |-->
    // level=2 |   |-->
    // level=2 ex |    |<X-
    // level=1 ex |<X-
    private static String addSpace(String prefix, int level) {
        StringBuilder sb = new StringBuilder();
        for (int i = 0; i < level; i++) {
            sb.append((i == level - 1) ? "|" + prefix : "|   ");
        }
        return sb.toString();

    }
}

HelloTraceV2Test

    @Test
    void begin_end() {
        HelloTraceV2 trace = new HelloTraceV2();
        TraceStatus status1 = trace.begin("hello");
        TraceStatus status2 = trace.beginSync(status1.getTraceId(), "hello2");
        trace.end(status2); // 순서를 변경
        trace.end(status1);
    }

결과

    @Test
    void begin_exception() {
        HelloTraceV2 trace = new HelloTraceV2();
        TraceStatus status1 = trace.begin("hello1");
        TraceStatus status2 = trace.beginSync(status1.getTraceId(), "hello2");
        trace.exception(status2, new IllegalStateException());
        trace.exception(status1, new IllegalStateException());

    }

결과

처음에는 begin() 을 사용하고, 이후에는 beginSync()를 사용하면 된다. beginSync 를 호출할때 직전 로그의 traceId 정보를 넘겨주어야 한다.
실행로그를 보면 같은 트랜잭션ID를 유지하고 level을 통해 메서드 호출 깊이를 표현하는 것을 확인할 수 있다.

로그 추적기 V2 - 적용

이제 로그 추적기를 애플리케이션에 적용해보자.

메소드 호출의 깊이를 표현하고 HTTP 요청도 구분해보자.
이렇게 하려면 처음 로그를 남기는 OrderController.request() 에서 로그를 남길때 어떤 깊이와 어떤 트랜잭션ID 를 사용했는지 다음 차례인 OrderService.orderItem() 에서 로그를 남기는 시점에 알아야 한다.
결국 현재 로그의 상태정보인 트랜잭션ID 와 level 이 다음으로 전달되어야 한다.
이 정보는 TraceStatus.traceId 에 담겨있다. 따라서 traceId 를 컨트롤러에서 서비스를 호출할때 넘겨주면 된다.

traceId를 넘기도록 V2 전체코드를 수정한다.
refactoring : alt + enter

OrderControllerV2

package hello.advanced.v2;

import hello.advanced.trace.TraceStatus;
import hello.advanced.trace.hellotrace.HelloTraceV2;
import lombok.RequiredArgsConstructor;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController // @Controller + @ResponseBody
@RequiredArgsConstructor
public class OrderControllerV2 {
    private final OrderServiceV2 orderService;
    private final HelloTraceV2 trace; //변경

    @GetMapping("/v2/request") //변경
    public String request(String itemId) {
        TraceStatus status = null;
        try {
            status = trace.begin("OrderController.request()");
            orderService.orderItem(status.getTraceId(), itemId);
            trace.end(status); //예외터졌을때 이 부분 안나옴
            return "OK"; // @RestController 이기 때문에 문자
        } catch (Exception e) {
            trace.exception(status, e); // 예외를 가지고 있음
            throw e;//예외를 다시 던져줘야 한다.
        }
    }

}

TraceStatus status = trace.begin() 에서 반환 받은 TraceStatus 에는 트랜잭션 ID와 level 정보가 있는 TraceId가 있다.
orderService.orderItem()을 호출할때 TraceId를 파라미터로 전다라한다.
TraceId 를 파라미터로 전달하기 위해 OrderServiceV2.orderItem() 의 파라미터에 TraceId를 추가해야 한다.

OrderServiceV2

package hello.advanced.v2;

import hello.advanced.trace.TraceId;
import hello.advanced.trace.TraceStatus;
import hello.advanced.trace.hellotrace.HelloTraceV2;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;

@Service
@RequiredArgsConstructor
public class OrderServiceV2 {
    private final OrderRepositoryV2 orderRepository;
    private final HelloTraceV2 trace; //변경

    public void orderItem(TraceId traceId, String itemId) {
        TraceStatus status = null;
        try {
            status = trace.beginSync(traceId, "OrderService.orderItem()"); //beginSync
            orderRepository.save(status.getTraceId(), itemId);
            trace.end(status); //예외터졌을때 이 부분 안나옴
        } catch (Exception e) {
            trace.exception(status, e); // 예외를 가지고 있음
            throw e;//예외를 다시 던져줘야 한다.
        }

    }
}

orderItem()은 파라미터로 전달 받은 traceId를 사용해서 trace.beginSync()를 실행한다.
beginSync()는 내부에서 다음 traceId 를 생성하면서 트랜잭션ID를 유지하고 level은 하나 증가시킨다.
beginSync() 가 반환한 새로운 TraceStatus를 orderRepository.save()를 호출하면서 파라미터로 전달한다
TraceId를 파라미터로 전달하기 위해 orderRepository.save()의 파라미터에 TraceId를 추가해야한다.

OrderRepositoryV2

package hello.advanced.v2;

import hello.advanced.trace.TraceId;
import hello.advanced.trace.TraceStatus;
import hello.advanced.trace.hellotrace.HelloTraceV2;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Repository;

@Repository
@RequiredArgsConstructor
public class OrderRepositoryV2 {
    private final HelloTraceV2 trace; //변경

    public void save(TraceId traceId, String itemId) {
        TraceStatus status = null;
        try {
            status = trace.beginSync(traceId, "OrderRepository.save()"); //beginSync로 변경
            // 저장로직
            if (itemId.equals("ex")) {
                throw new IllegalArgumentException("예외발생! ");
            }
            sleep(1000);
            trace.end(status); //예외터졌을때 이 부분 안나옴
        } catch (Exception e) {
            trace.exception(status, e); // 예외를 가지고 있음
            throw e;//예외를 다시 던져줘야 한다.
        }

    }

    private void sleep(int millis) {
        try {
            Thread.sleep(millis);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

save() 는 파라미터로 전달받은 traceId 를 사용해서 trace.beginSync()를 실행한다.
begin.Sync() 는 내부에서 다음 traceId를 생성하면서 트랜잭션ID는 유지하고 level은 하나 증가시킨다.
begin.Sync() 는 이렇게 갱신된 traceId 로 새로운 TraceStatus 를 반환한다.
trace.end(status) 를 호출하면서 반환된 TraceStatus 를 전달한다.

정상실행

http://localhost:8082/v2/request?itemId=hello

예외실행

http://localhost:8082/v2/request?itemId=ex

정리

요구사항

모든 PUBLIC 메서드의 호출과 응답정보를 로그로 출력
애플리케이션의 흐름을 변경하면 안됨
- 로그를 남긴다고 해서 비즈니스 로직의 동작에 영향을 주면 안됨
메서드 호출에 걸린 시간
정상 흐름과 예외 흐름 구분
- 예외 발생시 예외 정보가 남아야 함
메서드 호출의 깊이 표현
HTTP 요청을 구분
- HTTP 요청 단위로 특정 ID를 남겨서 어떤 HTTP 요청에서 시작된 것인지 명확하게 구분이 가능해야 함
- 트랜잭션 ID(DB 트랜잭션 X)
이 모든 요구사항을 만족했다.

남은문제

HTTP 요청을 구분하고 깊이를 표현하기 위해서 TraceId 동기화가 필요하다.
TraceId 의 동기화를 위해서 관련 메서드의 모든 파라미터를 수정해야한다.
- 만약 인터페이스가 있다면 인터페이스까지 모두 고쳐야 하는 상환ㅇ이다.
로그를 처음 시작할때는 begin() 을 호출하고 처음이 아닐때는 beginSync()를 호출해야 한다.
- 만약에 컨트롤러를 통해서 서비스를 호출하는 것이 아니라 다른 곳에서 서비스를 처음으로 호출하는 상황이라면 파라미터로 넘길 TraceId 가 없다.
HTTP 요청을 구분하고 깊이를 포현하기 위해서 TraceId를 파라미터로 넘기는 것 말고 다른 대안은 없을까???

Navigation Menu

Uh oh!

[스프링 핵심원리 - 고급편] #1. 예제 만들기(2) #647

Uh oh!

{{title}}

Uh oh!

Uh oh!

{{editor}}'s edit

{{editor}}'s edit

Uh oh!

Replies: 0 comments

Select a reply

Uh oh!

Uh oh!

[스프링 핵심원리 - 고급편] #1. 예제 만들기(2) #647

Uh oh!

Uh oh!

Pracrobo Feb 28, 2025

로그추적기 V1 - 프로토타입개발

TraceId 클래스

1. createNextId()

2. createPreviousId()

3. isFirstLevel()

TraceStatus클래스

공개 메서드

비공개 메서드

테스트 작성

로그추적기V1 - 적용

실행

남은 문제

요구사항

로그 추적기 V2 - 파라미터로 동기화 개발

결과

결과

로그 추적기 V2 - 적용

정상실행

예외실행

정리

요구사항

남은문제

Replies: 0 comments

Pracrobo
Feb 28, 2025