1
public void processuserrequest(string userid, string requestid) {
2
    try {
3
        // mdc 설정
4
        mdc.put("userid", userid);
5
        mdc.put("requestid", requestid);
6

7
        log.info("요청 처리 시작");        // [user123][req-456] 요청 처리 시작
8

9
        // 비즈니스 로직
10
        userservice.validateuser(userid);
11
        orderservice.createorder(userid);
12

13
        log.info("요청 처리 완료");        // [user123][req-456] 요청 처리 완료
14

15
    } finally {
16
        // 반드시 정리 (메모리 누수 방지)
17
        mdc.clear();
18
    }
19
}

1
@component
2
public class mdcfilter implements filter {
3

4
    @override
5
    public void dofilter(servletrequest request, servletresponse response,
6
                        filterchain chain) throws ioexception, servletexception {
7

8
        httpservletrequest httprequest = (httpservletrequest) request;
9

10
        try {
11
            // 요청 id 생성 또는 헤더에서 추출
12
            string requestid = extractorgeneraterequestid(httprequest);
13
            string useragent = httprequest.getheader("user-agent");
14
            string clientip = getclientipaddress(httprequest);
15

16
            // mdc 설정
17
            mdc.put("requestid", requestid);
18
            mdc.put("useragent", useragent);
19
            mdc.put("clientip", clientip);
20

21
            // 다음 필터 체인 실행
22
            chain.dofilter(request, response);
23

24
        } finally {
25
            // 요청 처리 완료 후 정리
26
            mdc.clear();
27
        }
28
    }
29

30
    private string extractorgeneraterequestid(httpservletrequest request) {
31
        string requestid = request.getheader("x-request-id");
32
        return requestid != null ? requestid : uuid.randomuuid().tostring();
33
    }
34
}

1
@component
2
public class usercontextinterceptor implements handlerinterceptor {
3

4
    @override
5
    public boolean prehandle(httpservletrequest request,
6
                           httpservletresponse response,
7
                           object handler) throws exception {
8

9
        // 인증된 사용자 정보 추출
10
        authentication auth = securitycontextholder.getcontext().getauthentication();
11
        if (auth != null && auth.isauthenticated()) {
12
            string username = auth.getname();
13
            string role = auth.getauthorities().tostring();
14

15
            // mdc에 사용자 정보 추가
16
            mdc.put("username", username);
17
            mdc.put("userrole", role);
18
        }
19

20
        return true;
21
    }
22

23
    @override
24
    public void aftercompletion(httpservletrequest request,
25
                              httpservletresponse response,
26
                              object handler, exception ex) throws exception {
27
        // 사용자 정보만 제거 (requestid는 필터에서 관리)
28
        mdc.remove("username");
29
        mdc.remove("userrole");
30
    }
31
}

1
@service
2
public class asyncorderservice {
3

4
    @async
5
    public completablefuture<orderresult> processorderasync(string orderid) {
6

7
        // 현재 스레드의 mdc 컨텍스트 복사
8
        map<string, string> contextmap = mdc.getcopyofcontextmap();
9

10
        return completablefuture.supplyasync(() -> {
11
            try {
12
                // 새로운 스레드에 mdc 컨텍스트 설정
13
                mdc.setcontextmap(contextmap);
14
                mdc.put("orderid", orderid);
15

16
                log.info("비동기 주문 처리 시작");
17

18
                // 실제 처리 로직
19
                return orderprocessor.process(orderid);
20

21
            } finally {
22
                mdc.clear();
23
            }
24
        });
25
    }
26
}