Skip to content

[MERGE] dev->main 병합 #449

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
Hyun0828 merged 2 commits into from
Aug 27, 2025
Merged

[MERGE] dev->main 병합 #449

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
96e643d
[Bug/#433] SSE 에러 로그 + 30초마다 하트비트
Hyun0828 Aug 27, 2025
f977357
Merge pull request #448 from STACKPOT/bug/#433-sse
Hyun0828 Aug 27, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
17 changes: 17 additions & 0 deletions src/main/java/stackpot/stackpot/event/SseService.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.http.MediaType;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;
import org.springframework.transaction.event.TransactionPhase;
import org.springframework.transaction.event.TransactionalEventListener;
Expand All @@ -19,6 +20,7 @@
import stackpot.stackpot.pot.dto.UserMemberIdDto;
import stackpot.stackpot.pot.service.potMember.PotMemberQueryService;

import java.io.IOException;
import java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.Collections;
Expand Down Expand Up @@ -49,11 +51,26 @@ public SseEmitter connect() {
try {
emitter.send(SseEmitter.event().name("connect").data("연결 완료!"));
} catch (Exception e) {
log.error("SSE 연결 중 에러 발생: {}", e.getMessage());
emitters.remove(userId);
}
return emitter;
}

@Scheduled(fixedRate = 30000) // 30초마다 실행
public void sendHeartbeat() {
emitters.forEach((userId, emitter) -> {
try {
emitter.send(SseEmitter.event()
.name("heartbeat")
.data("keep-alive at " + System.currentTimeMillis()));
} catch (IOException e) {
log.warn("Failed to send heartbeat to user {}, removing emitter.", userId);
emitters.remove(userId);
}
});
}

public void sendChatRoomList(Long chatRoomId) {
Long potId = chatRoomQueryService.selectPotIdByChatRoomId(chatRoomId);
List<Long> allUserIds = potMemberQueryService.selectUserIdsAboutPotMembersByPotId(potId); // 채팅방에 있는 모든 사용자 userId
Expand Down