spring multi thread timer

Question

이 커머스에서 회원이 상품구매를 위해 결제 전 장바구니에 담긴 상품을 30분 동안만 유지하고 결제하지 않으면 삭제하는 기능입니다. 여기에 장바구니 상품을 유지하는 동안 타이머를 비동기로 처리해야 해서 여러 방법을 적용해 봤는데 잘 안됩니다. for문을 실행해서 테스트 하니 7번 까지는 정상 실행되는데 그 이후에는 web 서버가 pending 상태가 되어버려 마우스로 메뉴를 클릭해도 동작을 하지 않습니다. multi thread timer를 어떻게 여러 회원들이 동시에 사용하는지 한 수 부탁 드립니다. 코드는 아래와 같습니다. spring project에 있는 것을 간단히 정리한 것입니다. StartTimer()에 있는 주석 처리되어 있는 여러 기능들을 시험해 봤는데 거의 비슷한 상황이 발생합니다. public class CommonController { private DemoService demoService; @Autowired public CommonController(DemoService demoService) { this.demoService = demoService; } @RequestMapping(value = {"/requestAjax.do"}, method = {RequestMethod.GET, RequestMethod.POST}) public void requestAjax(HttpServletRequest request) { for(int i=0; i<10; i++) { demoService.doCheckTime(); TimeUnit.SECONDS.sleep(3); } }}@Servicepublic class serviceImpl { @Async public void doCheckTime() throws InterruptedException, ExecutionException { int delay = 10; // 10분 MultiThreadTimer multiThreadTimer = new MultiThreadTimer(); String result = multiThreadTimer.StartTimer(delay); if(result.equals("0000")) System.out.println("special working run."); }}@Servicepublic class MultiThreadTimer { @Async public String StartTimer(int delay) { // private ExecutorService executorService = Executors.newSingleThreadExecutor(); // private ExecutorService executorService = Executors.newFixedThreadPool(64); // private ExecutorService executorService = Executors.newWorkStealingPool(64); final CompletableFuture future = new CompletableFuture<>(); // future 변수를 final로 선언 try { CompletableFuture.runAsync(() -> { ScheduledExecutorService timerExecutor = Executors.newSingleThreadScheduledExecutor(); ScheduledFuture scheduledFuture = timerExecutor.schedule(() -> { System.out.println("end of timer!"); timerExecutor.shutdown(); // 타이머 Executor 종료 future.complete(null); // 외부 변수 변경 }, delay, TimeUnit.MINUTES); // 타이머 Executor 종료 timerExecutor.shutdown(); }); // CompletableFuture가 완료될 때까지 대기 future.get(); } catch (InterruptedException | ExecutionException e) { e.printStackTrace(); } String result = "0000"; return result; }}

kenu,전독시 · Answer

30분 정도의 시간이면 1분마다 cron으로 배치 돌리는 게 낫지 않을까요?저는 스프링 이전이라 따로 프로세스 돌렸던 기억이 있습니다.

톰소여 · Answer

스프링에 있는 스케줄러 쓰면 됩니다.저걸로 많이 처리합니다.부하가 많아질 것 같으면 별도로 분리해도 됩니다.https://spring.io/guides/gs/scheduling-tasks/package com.example.schedulingtasks; import java.text.SimpleDateFormat; import java.util.Date; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; @Component public class ScheduledTasks { private static final Logger log = LoggerFactory.getLogger(ScheduledTasks.class); private static final SimpleDateFormat dateFormat = new SimpleDateFormat("HH:mm:ss"); @Scheduled(fixedRate = 5000) public void reportCurrentTime() { log.info("The time is now {}", dateFormat.format(new Date())); } }

yeori · Answer

결제할때 걸러내면 될거같은데요...

spring multi thread timer

3개의 답변

Q&A 목록