스프링부트에서 실시간으로 변경된 데이터를 조회하지 않는 문제

Question

안녕하세요 스프링부트로 간단한 웹 서비스를 만들고 있는 중입니다.다름이 아니라 Notify라는 엔터티를 만들어서 조회하여 사용자에게 보여주고 있습니다.우선은 게시판에서 댓글을 작성하면 Async Annotation을 사용해서 Notify에 데이터를 정상적으로 insert하고 있습니다.그러면 사용자에게 변경된 데이터를 포함한 결과를 보여줘야할 것인데 계속 과거에 조회했던 데이터만을 조회합니다.우선 조회하는 API는 화면 전체에서 공통으로 사용하는 Header.html/js 내에 정의 되어서 활용 중입니다.캐시 문제인가 싶어서, 기존에 어플리케이션 전체에서는 캐시를 적용하지 않았지만, 의도적으로 적용하여조회부에 cachable, 데이터 insert 부분에 cacheEvict 각각 적용하여 확인해봤으나 캐시 문제도 아닌 것 같습니다 ....다른 엔터티에서는 이러한 문제가 없는데 어떻게하면 확인할 수 있을까요? /1. 댓글 작성/ @NeedNotify@Transactional public Comment insertPostComment(CommentApiRequest commentRequestDTO) { Long postId = commentRequestDTO.getPostId(); Customer writer = customerRepository.findById(commentRequestDTO.getCustomerId()) .orElseThrow(() -> new IllegalArgumentException("Could not found Customer id : " + commentRequestDTO.getCustomerId())); Comment comment = commentRequestDTO.toEntity(writer); //작성자 셋팅 comment.setWriter(writer); /.........중략............/ System.out.println(comment.toString()); Comment newComment = commentRepository.save(comment); //return Header.OK(newComment.getId()); return newComment; } /2. @NeedNotify 부분/ @Async @AfterReturning(pointcut = "annotationPointcut()", returning = "result") public void checkValue(JoinPoint joinPoint, Object result) throws Throwable { if (result instanceof NotifyInfo) { //알림이 댓글인 경우 if(result instanceof Comment) { NotifyInfo notifyProxy = (NotifyInfo) result; Comment comment = (Comment) result; // if(notifyProxy.getReceiver() == comment.getSalePostWriter()) return; //댓글 작성자와 게시물 작성자가 동일하면 알림 보내지 않음 //댓글의 parent가 없는 경우와 있는 경우로 나누는 것이 좋을듯 //1. 기본적으로 게시물의 작성자에게 알림이 가도록함 notifyService.send( notifyProxy.getReceiver(), notifyProxy.getSender(), notifyProxy.getNotificationType(), makeNotifyMessageByNewComment(comment), //NotifyMessage.YATA_NEW_REQUEST.getMessage(), "/" + comment.getSimpleSalePost().getPostDvs() + "/" + (notifyProxy.getGoUrlId()) ); //2. 추가로 댓글의 답글인 경우 parent 댓글 작성자에게도 알림이 가도록함 if(comment.getParentComment()!= null) notifyService.send( comment.getParentComment().getWriter(), notifyProxy.getSender(), notifyProxy.getNotificationType(), makeNotifyMessageByReplyComment(comment), //NotifyMessage.YATA_NEW_REQUEST.getMessage(), "/" + comment.getSimpleSalePost().getPostDvs() + "/" + (notifyProxy.getGoUrlId()) ); log.info("result = {}", result); } } else { // Handle the case where the conversion is not successful log.error("Type conversion to NotifyInfo failed. result = {}", result); // You may throw an exception or handle it based on your requirements } } /*3. Notifty에 데이터 insert 부분**/ //@Override // beforeInvocation 속성으로 메서드 실행 이후(기본값)나 이전에 제거를 해야하는지 지정할 수 있다. // true이면 메서드 실행 이전에 캐시 비움@CacheEvict(value = "notifyList", key = "#receiver.id", beforeInvocation = true)@Transactional public void send(Customer receiver, Customer sender, Notify.NotificationType notificationType, String content, String url) { System.out.println("@CacheEvict 실행 전"); cacheService.printAllCacheEntries(); Notify notification = notifyRepository.save(createNotification(receiver, sender, notificationType, content, url)); String receiverEmail = receiver.getEmail(); String eventId = receiverEmail + "_" + System.currentTimeMillis(); Map emitters = emitterRepository.findAllEmitterStartWithByMemberId(receiverEmail); emitters.forEach( (key, emitter) -> { emitterRepository.saveEventCache(key, notification); sendNotification(emitter, eventId, key, NotifyApiResponse.Response.createResponse(notification)); } ); } /* 4. Notify를 조회하는 서비스 */ @Cacheable(value = "notifyList", key="#customerId") public Header> getOneMonthNotifyByCustomerId(Long customerId){ cacheService.printAllCacheEntries(); //고객 객체 찾기 Customer receiverCustomer = customerService.getCustomerById(customerId); //한달간 알림 찾기 List notifyList = notifyRepository.getOneMonthNotifyByCustomer(receiverCustomer); //객체를 데이터로 변환 List notifyApiResponseList= notifyList.stream().map(notification ->NotifyApiResponse.Response.createResponse(notification)).collect(Collectors.toList()); return Header.OK(notifyApiResponseList); } /* 5. 실제 데이터 조회하는 부분 */ public List getOneMonthNotifyByCustomer(Customer receiverCustomer){ System.out.println("getOneMonthNotifyByCustomer 쿼리 수행 전"); List notifyList = queryFactory.selectFrom(qNotify) .where(qNotify.receiverCustomer.eq(receiverCustomer), //일치하는 고객 qNotify.regDate.between(oneMonthAgo, currentDate) //한달전 알림 조회 ) .orderBy(qNotify.regDate.desc()) .limit(MAX_FETCH_COUNT) .fetch(); return notifyList; }

Clickin · Answer

Async가 중요한 게 아니라 insert 로직, 조회 로직 및 사용기술을 알려주셔야 답변이 나올 것 같습니다.mybatis인지 jpa인지에 따라 큰 차이가 있습니다.

스프링부트에서 실시간으로 변경된 데이터를 조회하지 않는 문제

1개의 답변

기술 목록