스프링-플라스크 서버간의 비동기 처리

Question

안녕하세요 ai 웹서비스를 개발하고 있습니다. 구조는 클라-스프링-플라스크 구조이고, 스프링은 클라이언트의 요청을 처리합니다. 플라스크 서버는 이미지를 생성하기 때문에 시간이 소요되는 작업입니다.이때 스프링에서 플라스크로 이미지 생성요청을 하게 되면 동기방식을 사용하기 때문에 둘 사이에 커넥션이 계속 연결되어야 하고, 스프링의 스레드가 비효율적으로 할당되는 것을 확인할 수 있었습니다.따라서 비동기 방식을 도입하기로 했습니다. 그 결과 스프링은 플라스크 서버의 결과에 상관없이 정해진 서비스 로직을 다 실행하고 응답을 반환합니다. 이때 저는 플라스크 서버가 작업이 완료되면 스프링 서버에서 콜백이 동작했으면 좋겠어서 아래와 같이 콜백을 설정했습니다.여기서 제가 궁금한건 스프링 서버는 분명 비동기 통신을 하고 커넥션을 끊었을텐데 플라스크 서버의 작업 완료여부를 어떻게 알고 콜백을 실행하는지 궁금합니다..try{ ListenableFuture> ganerate = ganerate(uploadUrl, originalFileName, uploadFileName, createDataSize, dataProduct.getId()); try { ganerate.addCallback( r -> { log.info("callback"); log.info(r.toString()); notificationService.notify(user.getId(), r); }, ex -> { log.info("callback"); log.error(ex.getMessage()); notificationService.notify(user.getId(), ex.getMessage()); } ); }catch (Exception e){ e.printStackTrace(); throw new CustomException(Result.FAIL_ALRET); } } catch (RestClientException e) { throw new CustomException(Result.FAIL_CREATE_DATA); }

kkang01 · Answer

쓰레드가 종료되면 그냥 콜백 함수 실행하는거 아닌가요?

Clickin · Answer

Spring 측에서 플라스크 서버를 호출 -> 플라스크 작업완료 후 Spring 호출 방식으로 하시면 됩니다.보통 이런 개념을 웹훅이라고 부르는 경우가 많습니다.

톰소여 · Answer

Rabbitmq 같은 메시지큐서버에 넣어두고 완료여부는 요청한 클라에서 확인하게끔 하면 안되려나요?

스프링-플라스크 서버간의 비동기 처리

3개의 답변

#async 목록