java 비동기 처리 하기

데이터 처리 이후 웹에는 결과를 보내고 background  에서 몇초 간격으로 계속 조회를 시도 해야하는 경우

 

serviceImpl.java 에 @Async 를 추가 하고 작업

 

 

@Override
    @Async
    public void chkGetOrderStatusAsync(String orderSubNum, String transactionId, String userId) throws Exception{
        
        //비동기 실행
        //get Order Status 호출하여 accepted 혹은 FAILED 가 뜰때까지 15초 간격으로 실행 최대 20번
        boolean flag = true;
        int cnt = 0;
        try{
            while(flag){
                
                JSONParser jsonParser = new JSONParser();
                String getOrderStausRes = APIUtil.getOrderStatus(transactionId);
                System.out.println("==== get Order Status API Async " + orderSubNum + " : " + transactionId + " (" + cnt + ") ====");
                System.out.println(getOrderStausRes);
                JSONObject getOrderStatusObj = (JSONObject) jsonParser.parse(getOrderStausRes);
                String status = UxisStringUtil.nullConvert(getOrderStatusObj.get("status"));
                String message = UxisStringUtil.nullConvert(getOrderStatusObj.get("message"));
 
                if(("Order is processing.".equals(message) || "Order is created.".equals(message) ) && cnt < 20){
                    //processing 일 경우 15초 대기 후 재실행
                    flag = true;
                    cnt++;
                    Thread.sleep(15000); //15초 대기
                }else{
                    PwsApiLogVO logVo = new PwsApiLogVO();
                    logVo.setOrderSubNum(orderSubNum);
                    logVo.setTransactionId(transactionId);
                    logVo.setStatus(status);
                    //logVo.setCode(code);
                    logVo.setMessage(message);
                    logVo.setRegistUserId(userId);
                    dao.insertData(logVo);
                    flag = false;
                }
                
            }
        }catch(Exception e){
            System.out.println("++++++ " + orderSubNum + " : " + transactionId + " (" + cnt + ") 실패 ++++++ ");
            e.printStackTrace();
        }
        
        
    }