채팅 서비스 적용기

@Transactional(readOnly = true) public ChatRoomDetailGetRes getDetailChatRoom(Long chatRoomId, User user) { isChatRoomMember(chatRoomId, user.getId()); // 채팅방에 존재하는 사용자 인지 Check ChatRoom chatRoom = findById(chatRoomId); List<ChatRes> chatList = chatRepository.findAllByChatRoom_Id(chatRoomId) // 해당 채팅방 내에 있는 채팅을 모두 가져옴 .orElseThrow(() -> new GlobalException(NOT_FOUND_CHAT)) .stream() .map(ChatRes::to) .toList(); return ChatRoomDetailGetRes.builder() .title(chatRoom.getTitle()) .chatResList(chatList) .build(); }

@Transactional(readOnly = true) public ChatRoomPaginationDetailGetRes getPaginationDetailChatRoom(Long chatRoomId, Long lastChatId, User user) { isChatRoomMember(chatRoomId, user.getId()); // 채팅방에 속한 사람만 조회 가능 ChatRoom chatRoom = findById(chatRoomId); Slice<ChatRes> chatResList = chatRepository.findChatsByChatRoomId(chatRoomId, lastChatId, LIMIT_SIZE); // 10개 return ChatRoomPaginationDetailGetRes.builder() .title(chatRoom.getTitle()) .chatResList(chatResList) .build(); }

private List<ChatRes> queryChats(Long chatRoomId, Long lastChatId, int limitSize) { QChat chat = QChat.chat; QUser user = QUser.user; BooleanExpression queryCondition = createQueryCondition(chat, chatRoomId, lastChatId); List<ChatRes> chats = queryFactory .select(Projections.constructor( ChatRes.class, chat.id, user.id, user.username, user.profileImage, chat.message, chat.isDeleted, chat.createdAt)) .from(chat) .leftJoin(chat.sender, user) .where(queryCondition) .orderBy(chat.id.desc()) .limit(limitSize + 1) .fetch(); Collections.reverse(chats); // <- ( 개선할 부분 ) return chats; }

private List<ChatRes> queryChats(Long chatRoomId, Long lastChatId, int limitSize) { QChat chat = QChat.chat; QUser user = QUser.user; BooleanExpression queryCondition = createQueryCondition(chat, chatRoomId, lastChatId); List<ChatRes> chats = queryFactory .select(Projections.constructor( ChatRes.class, chat.id, user.id, user.username, user.profileImage, chat.message, chat.isDeleted, chat.createdAt)) .from(chat) .leftJoin(chat.sender, user) .where(queryCondition) .orderBy(chat.id.desc()) .limit(limitSize + 1) .fetch(); return chats; }

GET /stomp Host: localhost:8080 Origin: http://localhost:5173 Connection: Upgrade Upgrade: websocket Sec-WebSocket-Key: eZSHFuOwZzTm8h1B1dpY3g== Sec-WebSocket-Version: 13

@EnableWebSocketMessageBroker @Configuration public class StompWebSocketConfig implements WebSocketMessageBrokerConfigurer { @Override public void registerStompEndpoints(StompEndpointRegistry registry) { registry.addEndpoint("/stomp").setAllowedOrigins("*"); } @Override public void configureMessageBroker(MessageBrokerRegistry registry) { registry.setApplicationDestinationPrefixes("/pub"); registry.enableSimpleBroker("/sub"); } }

public class ChatController { private final ChatService chatService; @MessageMapping("chat-rooms/{chatRoomId}") public void sendMessage(@DestinationVariable Long chatRoomId, @Payload ChatCreateReq chatCreateReq) { chatService.sendMessage(chatRoomId, chatCreateReq); } }

@Service @RequiredArgsConstructor public class ChatService { private final SimpMessagingTemplate template; @Transactional public void sendMessage(Long chatRoomId, ChatCreateReq req) { ChatRoomUser chatRoomUser = chatRoomUserRepository.findByChatRoom_IdAndUser_Id(chatRoomId, user.getId()) .orElseThrow(() -> new GlobalException(ACCESS_DENY)); Chat chat = chatRepository.save(Chat.builder() .message(req.getMessage()) .sender(chatRoomUser.getUser()) .chatRoom(chatRoom) .build()); template.convertAndSend("/sub/chat-rooms/" + chatRoomId, chat.getMessage()); } }

@Override public void configureMessageBroker(MessageBrokerRegistry registry) { registry.setPathMatcher(new AntPathMatcher(".")); registry.setApplicationDestinationPrefixes("/pub"); registry.enableStompBrokerRelay("/queue", "/topic", "/exchange", "/amq/queue"); }

@Configuration @EnableRabbit public class RabbitConfig { // Queue 등록 @Bean public Queue queue() { return new Queue(queueName, true); } // Exchange 등록 @Bean public TopicExchange exchange() { return new TopicExchange(exchangeName); } // Exchange와 Queue바인딩 @Bean public Binding binding(Queue queue, TopicExchange exchange) { return BindingBuilder.bind(queue).to(exchange).with(routingKey); } // RabbitMQ와의 메시지 통신을 담당하는 클래스 @Bean public RabbitTemplate rabbitTemplate() { RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory()); rabbitTemplate.setMessageConverter(jackson2JsonMessageConverter()); return rabbitTemplate; } // RabbitMQ와의 연결을 관리하는 클래스 @Bean public ConnectionFactory connectionFactory() { CachingConnectionFactory factory = new CachingConnectionFactory(); factory.setHost(rabbitmqHost); factory.setPort(rabbitmqPort); factory.setUsername(rabbitmqUsername); factory.setPassword(rabbitmqPassword); factory.setVirtualHost("/"); return factory; } }

public class ChatController { @MessageMapping("chat-rooms.{chatRoomId}") public void sendMessage(@DestinationVariable Long chatRoomId, @Payload ChatCreateReq chatCreateReq) { chatService.sendMessage(chatRoomId, chatCreateReq); } }

@Service @RequiredArgsConstructor public class ChatService { private final RabbitTemplate rabbitTemplate; @Transactional public void sendMessage(Long chatRoomId, ChatCreateReq req) { ChatRoomUser chatRoomUser = chatRoomUserRepository.findByChatRoom_IdAndUser_Id(chatRoomId, user.getId()) .orElseThrow(() -> new GlobalException(ACCESS_DENY)); Chat chat = chatRepository.save(Chat.builder() .message(req.getMessage()) .sender(chatRoomUser.getUser()) .chatRoom(chatRoom) .build()); rabbitTemplate.convertAndSend(exchangeName, "chat-rooms." + chatRoomId, ChatRes.to(chat)); } }