1주차 회고

//도커 네트워크 구성 docker network create my-network //서버 컨테이너 docker run --name backend -d -p 8080:8080 --network my-network backend //nginx 컨테이너 - 윈도우 docker run -d --name nginx --network my-network -p 8080:80 -v ${pwd}/nginx.conf:/etc/nginx/nginx.conf nginx //nginx 컨테이너 - Mac docker run -d --name nginx --network my-network -p 8080:80 -v ./nginx.conf:/etc/nginx/nginx.conf nginx

./gradlew clean build

package org.example.backendproject.stompwebsocket.config; import org.example.backendproject.stompwebsocket.handler.CustomHandshakeHandler; import org.springframework.context.annotation.Configuration; import org.springframework.messaging.simp.config.MessageBrokerRegistry; import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker; import org.springframework.web.socket.config.annotation.StompEndpointRegistry; import org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer; @Configuration @EnableWebSocketMessageBroker public class WebSocketConfig implements WebSocketMessageBrokerConfigurer { @Override public void configureMessageBroker(MessageBrokerRegistry registry) { /** * 구독중 Prefix * /topic 일반 채팅을 받을 접두어 * /queue 귓속말을 받을 접두어 * 서버가 보내는 메시지를 클라이언트가 구독할 때 사용하는 경로 */ registry.enableSimpleBroker("/topic", "/queue"); // 구독용 경로 /** 전송용 Prefix **/ // 클라이언트가 서버에 메시지를 보낼 때 사용하는 경로 접두어 registry.setApplicationDestinationPrefixes("/app"); // 클라이언트 -> 서버 // 서버가 특정 사용자에게 메시지를 보낼 때, 클라이언트가 구독할 경로 접두어 registry.setUserDestinationPrefix("/user"); // 서버 -> 특정 사용자 } @Override public void registerStompEndpoints(StompEndpointRegistry registry) { registry.addEndpoint("/ws-chat") .setHandshakeHandler(new CustomHandshakeHandler()) .setAllowedOriginPatterns("*"); // gpt 전용 채팅 EndPoint 설정 registry.addEndpoint("/ws-gpt") .setAllowedOriginPatterns("*"); } }

package org.example.backendproject.stompwebsocket.handler; import java.security.Principal; public class StompPrincipal implements Principal { private final String name; public StompPrincipal(String name) { this.name = name; } @Override public String getName() { return name; } }

package org.example.backendproject.stompwebsocket.handler; import java.security.Principal; import java.util.Map; import org.springframework.http.server.ServerHttpRequest; import org.springframework.web.socket.WebSocketHandler; import org.springframework.web.socket.server.support.DefaultHandshakeHandler; public class CustomHandshakeHandler extends DefaultHandshakeHandler { @Override protected Principal determineUser(ServerHttpRequest request, WebSocketHandler wsHandler, Map<String, Object> attributes) { String nickname = getNickName(request.getURI().getQuery()); return new StompPrincipal(nickname); } private String getNickName(String query) { if (query == null || !query.contains("nickname=")) { return "닉네임없음"; } else { return query.split("nickname=")[1]; } } }

package org.example.backendproject.stompwebsocket.redis; import lombok.RequiredArgsConstructor; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Profile; import org.springframework.data.redis.connection.RedisConnectionFactory; import org.springframework.data.redis.listener.PatternTopic; import org.springframework.data.redis.listener.RedisMessageListenerContainer; import org.springframework.data.redis.listener.adapter.MessageListenerAdapter; @Profile("!test") @RequiredArgsConstructor @Configuration public class RedisConfig { private final RedisSubscriber redisSubscriber; @Bean public RedisMessageListenerContainer container(RedisConnectionFactory redisConnectionFactory) { RedisMessageListenerContainer container = new RedisMessageListenerContainer(); container.setConnectionFactory(redisConnectionFactory); container.addMessageListener(new MessageListenerAdapter(redisSubscriber), new PatternTopic("room.*")); container.addMessageListener(new MessageListenerAdapter(redisSubscriber), new PatternTopic("private.*")); // 귓속말 return container; } }

package org.example.backendproject.stompwebsocket.redis; import lombok.RequiredArgsConstructor; import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.stereotype.Component; @RequiredArgsConstructor @Component public class RedisPublisher { private final StringRedisTemplate stringRedisTemplate; /** 메세지를 발행하는 클래스 **/ public void publish(String channel, String msg) { stringRedisTemplate.convertAndSend(channel, msg); } }

package org.example.backendproject.stompwebsocket.redis; import com.fasterxml.jackson.databind.ObjectMapper; import lombok.RequiredArgsConstructor; import org.example.backendproject.stompwebsocket.dto.ChatMessage; import org.springframework.data.redis.connection.Message; import org.springframework.data.redis.connection.MessageListener; import org.springframework.messaging.simp.SimpMessagingTemplate; import org.springframework.stereotype.Service; @Service @RequiredArgsConstructor public class RedisSubscriber implements MessageListener { private final SimpMessagingTemplate simpMessagingTemplate; private ObjectMapper objectMapper = new ObjectMapper(); @Override public void onMessage(Message message, byte[] pattern){ try { String msgBody = new String(message.getBody()); ChatMessage chatMessage = objectMapper.readValue(msgBody, ChatMessage.class); if (chatMessage.getTo() != null && !chatMessage.getTo().isEmpty()) { simpMessagingTemplate.convertAndSendToUser(chatMessage.getTo(), "/queue/private", chatMessage); } else { simpMessagingTemplate.convertAndSend("/topic/room." + chatMessage.getRoomId(), chatMessage); } } catch (Exception e) { } } }

package org.example.backendproject.stompwebsocket.gpt; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.JsonNode; import com.fasterxml.jackson.databind.ObjectMapper; import java.io.IOException; import java.net.URI; import java.net.http.HttpClient; import java.net.http.HttpRequest; import java.net.http.HttpResponse; import java.util.HashMap; import java.util.Map; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; @Service @Slf4j public class GPTService { // json 문자열 <-> 자바객체, json객체 private final ObjectMapper mapper = new ObjectMapper(); @Value("${openai.api.key}") private String apiKey; public String gptMessage(String message) throws Exception { try { Map<String, Object> requestBody = new HashMap<>(); requestBody.put("model", "gpt-4o"); requestBody.put("input", message); // http 요청 작성 HttpRequest request = HttpRequest.newBuilder() .uri(URI.create("https://api.openai.com/v1/responses")) .header("Authorization", "Bearer " + apiKey) .header("Content-Type", "application/json") .POST(HttpRequest.BodyPublishers.ofString(mapper.writeValueAsString(requestBody))) .build(); //요청 전송 및 응답 수신 HttpClient client = HttpClient.newHttpClient(); HttpResponse<String> response = client.send(request,HttpResponse.BodyHandlers.ofString()); if (response.statusCode() != 200) { log.error("GPT API 호출 실패: " + response.statusCode() + " - " + response.body()); return "[GPT 호출 실패] 응답 코드 : " + response.statusCode(); } // 응답을 Json으로 파싱 JsonNode jsonNode = mapper.readTree(response.body()); System.out.println("gpt 응답 : " + jsonNode); log.info("gpt 응답 성공!!"); //메세지 부분만 추출하여 반환 String gptMessageResponse = jsonNode.get("output").get(0).get("content").get(0).get("text").asText(); return gptMessageResponse; } catch (IOException e) { log.error("GPT 응답 JSON 파싱 실패: " + e.getMessage()); return "[GPT 오류] 응답을 처리할 수 없습니다."; } catch (IllegalArgumentException e) { log.error("응답 파싱 오류: " + e.getMessage()); return e.getMessage(); } catch (Exception e) { log.error("예상치 못한 오류 발생: " + e.getMessage()); return "[GPT 오류] 예기치 못한 문제가 발생했습니다."; } } }

{ "model": "gpt-4o", "messages": [ {"role": "system", "content": "You are a helpful assistant."}, {"role": "user", "content": "message"} ] }

package org.example.backendproject.stompwebsocket.controller; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.ObjectMapper; import lombok.RequiredArgsConstructor; import org.example.backendproject.stompwebsocket.dto.ChatMessage; import org.example.backendproject.stompwebsocket.gpt.GPTService; import org.example.backendproject.stompwebsocket.redis.RedisPublisher; import org.springframework.beans.factory.annotation.Value; import org.springframework.messaging.handler.annotation.MessageMapping; import org.springframework.messaging.handler.annotation.SendTo; import org.springframework.messaging.simp.SimpMessagingTemplate; import org.springframework.stereotype.Controller; @Controller @RequiredArgsConstructor public class ChatController { @Value("${PROJECT_NAME:web Server}") private String instanceName; private final RedisPublisher redisPublisher; private final ObjectMapper objectMapper = new ObjectMapper(); // 서버가 클라이언트에게 수동으로 메세지를 보낼 수 있도록 하는 클래스 private final SimpMessagingTemplate template; private final GPTService gptService; // 단일 브로드캐스트 (동적으로 방 생성이 안 됨) @MessageMapping("/gpt") public void sendMessageGPT(ChatMessage message) throws Exception { template.convertAndSend("/topic/gpt", message); // gpt 메세지 반환 String getResponse = gptService.gptMessage(message.getMessage()); ChatMessage chatMessage = new ChatMessage("난 GPT", getResponse); template.convertAndSend("/topic/gpt", chatMessage); } // 동적으로 방 생성 가능 @MessageMapping("/chat.sendMessage") public void sendMessage(ChatMessage message) throws JsonProcessingException { message.setMessage(instanceName + " " + message.getMessage()); String channel = null; String msg = null; if (message.getTo() != null && !message.getTo().isEmpty()) { // 귓속말 // 내 아이디로 귓속말 경로를 활성화 함 channel = "private." + message.getRoomId(); msg = objectMapper.writeValueAsString(message); } else { // 일반 메시지 // message에서 roomId를 추출해서 해당 roomId를 구독하고 있는 클라이언트에게 메세지를 전달 channel = "room." + message.getRoomId(); msg = objectMapper.writeValueAsString(message); } redisPublisher.publish(channel, msg); } }