#31 BE : [FEAT] 동시 팝업창 구현

Author: bbabbi

server/build.gradle

@@ -37,7 +37,7 @@ dependencies {
 	implementation("software.amazon.awssdk:s3:2.21.0")
 	//actuator
 	implementation 'org.springframework.boot:spring-boot-starter-actuator'
-	// Spring Security
+	//Spring Security
 	implementation 'org.springframework.boot:spring-boot-starter-security'
 	testImplementation 'org.springframework.security:spring-security-test'
 	//JWT Token
@@ -48,10 +48,13 @@ dependencies {
 	implementation 'org.springdoc:springdoc-openapi-starter-webmvc-ui:2.0.2'
 	//Jsoup
 	implementation 'org.jsoup:jsoup:1.18.1'
-	// JSON 라이브러리
+	//JSON
 	implementation 'org.json:json:20231013'
-	// Apache HttpClient 라이브러리
+	//Apache HttpClient
 	implementation 'org.apache.httpcomponents.client5:httpclient5:5.2.1'
+	//Web Socket
+	implementation 'org.springframework.boot:spring-boot-starter-websocket'
+	implementation 'org.springframework.boot:spring-boot-starter-web'
 }
 
 tasks.named('test') {

server/src/main/java/org/cecd/server/controller/CommandController.java

@@ -4,6 +4,8 @@
 import org.cecd.server.dto.CommandRequest;
 import org.cecd.server.service.CommandService;
 import org.springframework.http.ResponseEntity;
+import org.springframework.messaging.handler.annotation.MessageMapping;
+import org.springframework.messaging.handler.annotation.SendTo;
 import org.springframework.web.bind.annotation.*;
 
 @RestController
@@ -23,4 +25,11 @@ public ResponseEntity<String> sendControlCommand(@RequestBody CommandRequest com
     public ResponseEntity<CommandRequest> echoControlCommand(@RequestBody CommandRequest commandRequest) {
         return ResponseEntity.ok(commandRequest);
     }
+
+    @MessageMapping("/socket/control") // 클라이언트가 이 경로로 메시지를 송신
+    @SendTo("/topic/commands") // 이 경로를 구독 중인 모든 클라이언트에게 메시지 전달
+    public CommandRequest sendCommand (CommandRequest commandRequest) {
+        System.out.println("Received command: " + commandRequest); // 로그 추가
+        return commandRequest; // command는 클라이언트로 전달할 메시지
+    }
 }

server/src/main/java/org/cecd/server/external/SecurityConfig.java

@@ -45,7 +45,8 @@ public SecurityFilterChain securityFilterChain(HttpSecurity httpSecurity) throws
                 .authorizeHttpRequests(authorize -> authorize // 권한 설정
                         .requestMatchers("/jwt-login/info").authenticated()
                         .requestMatchers("/jwt-login/admin/**").hasAuthority(MemberRole.ADMIN.name())
-                        .anyRequest().permitAll()
+                        .requestMatchers("/ws/**").permitAll() // WebSocket 엔드포인트 허용
+                        .anyRequest().permitAll() // 추후 수정 예정
                 )
                 .exceptionHandling(exceptionHandling ->
                         exceptionHandling

server/src/main/java/org/cecd/server/external/WebSocketConfig.java

@@ -0,0 +1,27 @@
+package org.cecd.server.external;
+
+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 config) {
+        config.enableSimpleBroker("/topic");
+        config.setApplicationDestinationPrefixes("/app");
+    }
+
+    @Override
+    public void registerStompEndpoints(StompEndpointRegistry registry) {
+        registry.addEndpoint("/ws")
+                .setAllowedOriginPatterns("http://localhost:3000","https://www.dgu1921.p-e.kr")
+                .withSockJS();
+    }
+}
+
+