diff --git a/.github/pull_request_template.md b/.github/pull_request_template.md
new file mode 100644
index 0000000..6562b6c
--- /dev/null
+++ b/.github/pull_request_template.md
@@ -0,0 +1,19 @@
+# 📄 Work Description
+- 설명
+
+
+# ⚙️ ISSUE
+- closed #이슈번호
+
+
+# 📷 Screenshot
+ - 동영상, 사진, 로그 등등
+ - ex) 큐알 성공 이미지, 스웨거, 포스트맨 등
+
+
+# 💬 To Reviewers
+리뷰어들에게 하고 싶은 말
+
+
+# 🔗 Reference
+문제를 해결하면서 도움이 되었거나, 참고했던 사이트(코드링크)
diff --git a/build.gradle b/build.gradle
index 7dc7416..4e1b530 100644
--- a/build.gradle
+++ b/build.gradle
@@ -31,6 +31,7 @@ dependencies {
 	implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
 	implementation 'org.springframework.boot:spring-boot-starter-security'
 	implementation 'org.springframework.boot:spring-boot-starter-web'
+	implementation 'org.springframework.boot:spring-boot-starter-websocket'
 	compileOnly 'org.projectlombok:lombok'
 	implementation 'org.springframework.boot:spring-boot-starter-validation'
 	developmentOnly 'org.springframework.boot:spring-boot-devtools'
@@ -60,6 +61,11 @@ dependencies {
 	implementation 'com.google.cloud:google-cloud-storage:2.20.1'
 	implementation 'org.springframework.cloud:spring-cloud-gcp-starter-storage:1.2.8.RELEASE'
 	implementation 'net.coobird:thumbnailator:0.4.14'
+
+	// STOMP
+	implementation 'org.webjars:webjars-locator-core'
+	implementation 'org.webjars:sockjs-client:1.5.1'
+	implementation 'org.webjars:stomp-websocket:2.3.4'
 }
 
 tasks.named('bootBuildImage') {
diff --git a/src/main/java/com/favoriteplace/app/controller/PilgrimageSocketController.java b/src/main/java/com/favoriteplace/app/controller/PilgrimageSocketController.java
new file mode 100644
index 0000000..b482e66
--- /dev/null
+++ b/src/main/java/com/favoriteplace/app/controller/PilgrimageSocketController.java
@@ -0,0 +1,74 @@
+package com.favoriteplace.app.controller;
+
+import com.favoriteplace.app.domain.travel.Pilgrimage;
+import com.favoriteplace.app.dto.travel.PilgrimageDto;
+import com.favoriteplace.app.repository.PilgrimageRepository;
+import com.favoriteplace.app.service.PilgrimageCommandService;
+import com.favoriteplace.global.exception.ErrorCode;
+import com.favoriteplace.global.exception.RestApiException;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.messaging.handler.annotation.DestinationVariable;
+import org.springframework.messaging.handler.annotation.MessageMapping;
+import org.springframework.messaging.handler.annotation.SendTo;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.RestController;
+
+@Controller
+@Slf4j
+@RequiredArgsConstructor
+public class PilgrimageSocketController {
+    private final PilgrimageCommandService pilgrimageService;
+    private final PilgrimageRepository pilgrimageRepository;
+
+    /**
+     * 테스트 컨트롤러
+     * 요청 /app/test
+     * 응답 /pub/pilgrimage
+     * @param testMsg
+     * @return
+     */
+    @MessageMapping("/test")
+    @SendTo("/pub/pilgrimage")
+    public String pilgrimageCertify(String testMsg){
+        log.info("socket message: " + testMsg);
+        return testMsg;
+    }
+
+    /**
+     * 위도/경도 전달 시 상태 변경 알리는 컨트롤러
+     * 요청 컨트롤러 /app/location/{pilgrimageId}
+     * 응답 컨트롤러  /pub/statusUpdate/{pilgrimageId}
+     * @param pilgrimageId 성지순례 ID
+     * @param userLocation 위도/경도
+     * @return
+     */
+    @MessageMapping("/location/{pilgrimageId}")
+    @SendTo("/pub/statusUpdate/{pilgrimageId}")
+    public Boolean checkUserLocation(@DestinationVariable Long pilgrimageId, PilgrimageDto.PilgrimageCertifyRequestDto userLocation) {
+        Pilgrimage pilgrimage = pilgrimageRepository.findById(pilgrimageId)
+                .orElseThrow(()->new RestApiException(ErrorCode.PILGRIMAGE_NOT_FOUND));
+
+        boolean isUserAtPilgrimage = pilgrimageService.isUserAtPilgrimage(pilgrimage, userLocation.getLatitude(), userLocation.getLongitude());
+
+        if (!isUserAtPilgrimage) {
+            // 여기에 이벤트 동작 추가
+            return false;
+        }
+        return true;
+    }
+
+    /**
+     * 최초 접근 시 버튼 상태 전달하는 컨트롤러
+     * 요청 컨트롤러 /app/connect/{pilgrimageId}
+     * 응답 컨트롤러 /pub/statusUpdate/{pilgrimageId}
+     * @param pilgrimageId 성지순례 ID
+     * @return
+     */
+    @MessageMapping("/connect/{pilgrimageId}")
+    @SendTo("/pub/statusUpdate/{pilgrimageId}")
+    public Boolean sendInitialStatus(@DestinationVariable Long pilgrimageId) {
+        log.info("User connected to pilgrimage: " + pilgrimageId);
+        return true; // 초기 버튼 상태
+    }
+}
diff --git a/src/main/java/com/favoriteplace/app/dto/travel/PilgrimageSocketDto.java b/src/main/java/com/favoriteplace/app/dto/travel/PilgrimageSocketDto.java
new file mode 100644
index 0000000..dea6820
--- /dev/null
+++ b/src/main/java/com/favoriteplace/app/dto/travel/PilgrimageSocketDto.java
@@ -0,0 +1,16 @@
+package com.favoriteplace.app.dto.travel;
+
+import lombok.*;
+
+public class PilgrimageSocketDto {
+    @Data
+    @Builder
+    @Getter
+    @NoArgsConstructor
+    @AllArgsConstructor
+    public static class ButtonState {
+        private Boolean certifyButtonEnabled;
+        private Boolean guestbookButtonEnabled;
+        private Boolean multiGuestbookButtonEnabled;
+    }
+}
diff --git a/src/main/java/com/favoriteplace/app/service/PilgrimageCommandService.java b/src/main/java/com/favoriteplace/app/service/PilgrimageCommandService.java
index be006a7..3388491 100644
--- a/src/main/java/com/favoriteplace/app/service/PilgrimageCommandService.java
+++ b/src/main/java/com/favoriteplace/app/service/PilgrimageCommandService.java
@@ -10,9 +10,11 @@
 import com.favoriteplace.app.domain.travel.*;
 import com.favoriteplace.app.dto.CommonResponseDto;
 import com.favoriteplace.app.dto.travel.PilgrimageDto;
+import com.favoriteplace.app.dto.travel.PilgrimageSocketDto;
 import com.favoriteplace.app.repository.*;
 import com.favoriteplace.global.exception.ErrorCode;
 import com.favoriteplace.global.exception.RestApiException;
+import com.favoriteplace.global.websocket.RedisService;
 import jakarta.persistence.EntityManager;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -31,6 +33,7 @@
 @Transactional
 @RequiredArgsConstructor
 public class PilgrimageCommandService {
+    private final MemberRepository memberRepository;
     private final RallyRepository rallyRepository;
     private final PilgrimageRepository pilgrimageRepository;
     private final LikedRallyRepository likedRallyRepository;
@@ -38,7 +41,7 @@ public class PilgrimageCommandService {
     private final PointHistoryRepository pointHistoryRepository;
     private final CompleteRallyRepository completeRallyRepository;
     private final AcquiredItemRepository acquiredItemRepository;
-    private final EntityManager em;
+    private final RedisService redisService;
 
     /***
      * 랠리 찜하기
@@ -127,8 +130,8 @@ private boolean checkCompleteRally(Member member, Pilgrimage pilgrimage, Long co
     }
 
     private boolean checkCoordinate(PilgrimageDto.PilgrimageCertifyRequestDto form, Pilgrimage pilgrimage) {
-        return pilgrimage.getLatitude() + 0.00135 < form.getLatitude() || pilgrimage.getLatitude() - 0.00135 > form.getLatitude()
-                || pilgrimage.getLongitude() + 0.00135 < form.getLongitude() || pilgrimage.getLongitude() - 0.00135 > form.getLongitude();
+        return pilgrimage.getLatitude() + 0.00135 >= form.getLatitude() && pilgrimage.getLatitude() - 0.00135 <= form.getLatitude()
+                && pilgrimage.getLongitude() + 0.00135 >= form.getLongitude() && pilgrimage.getLongitude() - 0.00135 <= form.getLongitude();
     }
 
     private void successVisitedAndPointProcess(Member member, Pilgrimage pilgrimage) {
@@ -139,4 +142,74 @@ private void successVisitedAndPointProcess(Member member, Pilgrimage pilgrimage)
         member.updatePoint(15L);
         log.info("clear");
     }
+
+    public boolean isUserAtPilgrimage(Pilgrimage pilgrimage, Double latitude, Double longitude) {
+        return (pilgrimage.getLatitude() + 0.00135 >= latitude && pilgrimage.getLatitude() - 0.00135 <= latitude) &&
+                (pilgrimage.getLongitude() + 0.00135 >= longitude && pilgrimage.getLongitude() - 0.00135 <= longitude);
+    }
+
+    /**
+     * 웹소켓 버튼 상태 이벤트
+     * @param memberId
+     * @param pilgrimageId
+     * @param latitude
+     * @param longitude
+     * @return
+     */
+    public PilgrimageSocketDto.ButtonState determineButtonState(Long memberId,
+                                                                Long pilgrimageId,
+                                                                double latitude, double longitude) {
+        Pilgrimage pilgrimage = pilgrimageRepository.findById(pilgrimageId)
+                .orElseThrow(() -> new RestApiException(ErrorCode.PILGRIMAGE_NOT_FOUND));
+
+        Member member = memberRepository.findById(memberId)
+                .orElseThrow(()->new RestApiException(ErrorCode.USER_NOT_FOUND));
+
+        // 사용자가 인증 장소에 있는지 확인
+        boolean nearPilgrimage = isUserAtPilgrimage(pilgrimage, latitude, longitude);
+        // redis에 사용자의 인증 기록이 남아있는지 확인 (24시간 이후 만료됨)
+        boolean isCertificationExpired = redisService.isCertificationExpired(member, pilgrimage);
+        // 사용자가 지난 24시간 내에 인증 버튼 눌렀는지 확인
+        boolean certifiedInLast24Hours = checkIfCertifiedInLast24Hours(member, pilgrimage);
+        // 사용자가 이번 인증하기에 이미 방명록을 작성했는지 확인
+        boolean hasWrittenGuestbook = checkIfGuestbookWritten(member, pilgrimage);
+        // 사용자가 24시간 전에 작성한 방명록이 1개 이상인지 확인
+        boolean hasMultiWrittenGuestbook = checkIfMultiGuestbookWritten(member, pilgrimage);
+
+        PilgrimageSocketDto.ButtonState newState = new PilgrimageSocketDto.ButtonState();
+        if (nearPilgrimage && !certifiedInLast24Hours) {
+            newState.setCertifyButtonEnabled(true);  // 인증하기 버튼 활성화
+            newState.setGuestbookButtonEnabled(false); // 방명록 쓰기 버튼 비활성화
+        }
+        else if (certifiedInLast24Hours && !hasWrittenGuestbook) {
+            newState.setCertifyButtonEnabled(false);  // 인증하기 버튼 비활성화
+            newState.setGuestbookButtonEnabled(true); // 방명록 쓰기 버튼 활성화
+        }
+        else {
+            newState.setCertifyButtonEnabled(false);  // 인증하기 버튼 비활성화
+            newState.setGuestbookButtonEnabled(false); // 방명록 쓰기 버튼 비활성화
+        }
+        return newState;
+    }
+
+    private boolean checkIfCertifiedInLast24Hours(Member member, Pilgrimage pilgrimage) {
+        // 인증 버튼을 누른 시간 확인
+        List<VisitedPilgrimage> visitedPilgrimages = visitedPilgrimageRepository
+                .findByPilgrimageAndMemberOrderByCreatedAtDesc(pilgrimage, member);
+
+        ZoneId serverZoneId = ZoneId.of("Asia/Seoul");
+        ZonedDateTime nowInServerTimeZone = ZonedDateTime.now(serverZoneId);
+
+        return false;
+    }
+
+    private boolean checkIfGuestbookWritten(Member member, Pilgrimage pilgrimage) {
+        // 방명록 작성 여부 확인
+        return false;
+    }
+
+    private boolean checkIfMultiGuestbookWritten(Member member, Pilgrimage pilgrimage) {
+        // 방명록 다회 작성 여부 확인
+        return false;
+    }
 }
diff --git a/src/main/java/com/favoriteplace/app/service/WebSocketService.java b/src/main/java/com/favoriteplace/app/service/WebSocketService.java
new file mode 100644
index 0000000..bd07008
--- /dev/null
+++ b/src/main/java/com/favoriteplace/app/service/WebSocketService.java
@@ -0,0 +1,37 @@
+package com.favoriteplace.app.service;
+
+import com.favoriteplace.app.domain.travel.Pilgrimage;
+import com.favoriteplace.app.dto.travel.PilgrimageSocketDto;
+import com.favoriteplace.app.repository.PilgrimageRepository;
+import com.favoriteplace.global.exception.ErrorCode;
+import com.favoriteplace.global.exception.RestApiException;
+import com.google.api.gax.rpc.ApiException;
+import lombok.RequiredArgsConstructor;
+import org.springframework.messaging.simp.SimpMessagingTemplate;
+import org.springframework.stereotype.Service;
+
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+@Service
+@RequiredArgsConstructor
+public class WebSocketService {
+    private final SimpMessagingTemplate messagingTemplate;
+    private final PilgrimageCommandService pilgrimageService;
+    private final PilgrimageRepository pilgrimageRepository;
+    private Map<Long, PilgrimageSocketDto.ButtonState> lastButtonStateCache = new ConcurrentHashMap<>();
+
+    public void handleLocationUpdate(Long userId, Long pilgrimageId, double latitude, double longitude) {
+        Pilgrimage pilgrimage = pilgrimageRepository.findById(pilgrimageId)
+                .orElseThrow(()->new RestApiException(ErrorCode.PILGRIMAGE_NOT_FOUND));
+
+        PilgrimageSocketDto.ButtonState newState = pilgrimageService.determineButtonState(userId, pilgrimage.getId(), latitude, longitude);
+
+        PilgrimageSocketDto.ButtonState lastState = lastButtonStateCache.get(userId);
+
+        if (lastState == null || !newState.equals(lastState)) {
+            lastButtonStateCache.put(userId, newState);
+            messagingTemplate.convertAndSend("/pub/statusUpdate/" + pilgrimageId, newState);
+        }
+    }
+}
diff --git a/src/main/java/com/favoriteplace/global/security/Filter/JwtAuthenticationFilter.java b/src/main/java/com/favoriteplace/global/security/Filter/JwtAuthenticationFilter.java
index 46656cc..38a64c3 100644
--- a/src/main/java/com/favoriteplace/global/security/Filter/JwtAuthenticationFilter.java
+++ b/src/main/java/com/favoriteplace/global/security/Filter/JwtAuthenticationFilter.java
@@ -74,6 +74,12 @@ protected void doFilterInternal(HttpServletRequest request, HttpServletResponse
 
         // 1. Request Header 에서 JWT 토큰 추출
         String token = resolveToken((HttpServletRequest) request);
+
+        if ("websocket".equalsIgnoreCase(request.getHeader("Upgrade"))) {
+            chain.doFilter(request, response);
+            return;
+        }
+
         String requestURI = httpServletRequest.getRequestURI();
 
         // 2. validateToken 으로 토큰 유효성 검사
diff --git a/src/main/java/com/favoriteplace/global/security/config/RedisConfig.java b/src/main/java/com/favoriteplace/global/security/config/RedisConfig.java
new file mode 100644
index 0000000..3ccf7f8
--- /dev/null
+++ b/src/main/java/com/favoriteplace/global/security/config/RedisConfig.java
@@ -0,0 +1,26 @@
+package com.favoriteplace.global.security.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
+import org.springframework.data.redis.serializer.StringRedisSerializer;
+
+@Configuration
+public class RedisConfig {
+
+    @Bean
+    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory connectionFactory) {
+        RedisTemplate<String, Object> template = new RedisTemplate<>();
+        template.setConnectionFactory(connectionFactory);
+
+        // Key serializer
+        template.setKeySerializer(new StringRedisSerializer());
+
+        // Value serializer
+        template.setValueSerializer(new GenericJackson2JsonRedisSerializer());
+
+        return template;
+    }
+}
diff --git a/src/main/java/com/favoriteplace/global/security/provider/JwtTokenProvider.java b/src/main/java/com/favoriteplace/global/security/provider/JwtTokenProvider.java
index d799e6b..09fa932 100644
--- a/src/main/java/com/favoriteplace/global/security/provider/JwtTokenProvider.java
+++ b/src/main/java/com/favoriteplace/global/security/provider/JwtTokenProvider.java
@@ -1,6 +1,7 @@
 package com.favoriteplace.global.security.provider;
 
 import com.favoriteplace.app.dto.member.MemberDto.TokenInfo;
+import com.favoriteplace.global.security.CustomUserDetails;
 import io.jsonwebtoken.Claims;
 import io.jsonwebtoken.ExpiredJwtException;
 import io.jsonwebtoken.Jwts;
@@ -10,6 +11,8 @@
 import io.jsonwebtoken.io.Decoders;
 import io.jsonwebtoken.security.Keys;
 import java.util.Date;
+import java.util.List;
+
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Value;
diff --git a/src/main/java/com/favoriteplace/global/websocket/JwtChannelInterceptor.java b/src/main/java/com/favoriteplace/global/websocket/JwtChannelInterceptor.java
new file mode 100644
index 0000000..1928db6
--- /dev/null
+++ b/src/main/java/com/favoriteplace/global/websocket/JwtChannelInterceptor.java
@@ -0,0 +1,77 @@
+package com.favoriteplace.global.websocket;
+
+import com.favoriteplace.app.domain.Member;
+import com.favoriteplace.app.repository.MemberRepository;
+import com.favoriteplace.global.exception.ErrorCode;
+import com.favoriteplace.global.exception.ErrorResponse;
+import com.favoriteplace.global.exception.RestApiException;
+import com.favoriteplace.global.security.CustomUserDetails;
+import com.favoriteplace.global.security.provider.JwtTokenProvider;
+import com.google.api.gax.rpc.ApiException;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.messaging.Message;
+import org.springframework.messaging.MessageChannel;
+import org.springframework.messaging.simp.stomp.StompCommand;
+import org.springframework.messaging.simp.stomp.StompHeaderAccessor;
+import org.springframework.messaging.support.ChannelInterceptor;
+import org.springframework.security.authentication.UsernamePasswordAuthenticationToken;
+import org.springframework.security.core.Authentication;
+import org.springframework.security.core.context.SecurityContextHolder;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+@Component
+@RequiredArgsConstructor
+@Slf4j
+public class JwtChannelInterceptor implements ChannelInterceptor {
+    private final MemberRepository userUtilityService;
+    private final JwtTokenProvider jwtProvider;
+
+    /**
+     * WebSocket 연결 전 JWT 검사하는 인터셉터 메서드
+     * @param message
+     * @param channel
+     * @return
+     */
+    @Override
+    public Message<?> preSend(Message<?> message, MessageChannel channel) {
+        StompHeaderAccessor accessor = StompHeaderAccessor.wrap(message);
+
+        if (StompCommand.CONNECT.equals(accessor.getCommand())) {
+
+            List<String> authorization = accessor.getNativeHeader("Authorization");
+
+            if (authorization != null && !authorization.isEmpty()) {
+                String bearerToken = authorization.get(0);
+                String jwt = bearerToken.startsWith("Bearer ") ? bearerToken.substring(7) : bearerToken;
+
+                try {
+                    // JWT 토큰 검증
+                    if (!jwtProvider.validateToken(jwt)) {
+                        throw new RestApiException(ErrorCode.USER_NOT_AUTHOR);
+                    }
+
+                    Authentication authentication = jwtProvider.getAuthentication(jwt);
+
+                    Member member = userUtilityService.findByEmail(authentication.getName())
+                            .orElseThrow(()-> new RestApiException(ErrorCode.USER_NOT_FOUND));
+
+                    CustomUserDetails userDetails = new CustomUserDetails(member);
+                    UsernamePasswordAuthenticationToken userInfo =
+                            new UsernamePasswordAuthenticationToken(
+                                    userDetails, null, userDetails.getAuthorities());
+                    SecurityContextHolder.getContext().setAuthentication(userInfo);
+                } catch (Exception e) {
+                    log.error("JWT Verification Failed: " + e.getMessage());
+                    return null;
+                }
+            } else {
+                log.error("Authorization header is not found");
+                return null;
+            }
+        }
+        return message;
+    }
+}
diff --git a/src/main/java/com/favoriteplace/global/websocket/RedisService.java b/src/main/java/com/favoriteplace/global/websocket/RedisService.java
new file mode 100644
index 0000000..cfcdfb7
--- /dev/null
+++ b/src/main/java/com/favoriteplace/global/websocket/RedisService.java
@@ -0,0 +1,39 @@
+package com.favoriteplace.global.websocket;
+
+import com.favoriteplace.app.domain.Member;
+import com.favoriteplace.app.domain.travel.Pilgrimage;
+import lombok.RequiredArgsConstructor;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.stereotype.Service;
+
+import java.time.Duration;
+import java.time.Instant;
+
+@Service
+@RequiredArgsConstructor
+public class RedisService {
+    private final RedisTemplate<String, Object> redisTemplate;
+
+    private static final String CERTIFICATION_KEY_PREFIX = "certification:";
+    private static final Duration CERTIFICATION_EXPIRATION = Duration.ofHours(24);
+
+    // 사용자가 인증 장소에 접속한 시점을 저장
+    public void saveCertificationTime(Long userId, Long pilgrimageId) {
+        String key = CERTIFICATION_KEY_PREFIX + userId + ":" + pilgrimageId;
+        Instant now = Instant.now();
+        redisTemplate.opsForValue().set(key, now);
+        redisTemplate.expire(key, CERTIFICATION_EXPIRATION);
+    }
+
+    // 인증 시점에서 24시간이 지났는지 확인
+    public boolean isCertificationExpired(Member member, Pilgrimage pilgrimage) {
+        String key = CERTIFICATION_KEY_PREFIX + member.getId() + ":" + pilgrimage.getId();
+        Instant savedTime = (Instant) redisTemplate.opsForValue().get(key);
+        return savedTime == null || savedTime.isBefore(Instant.now().minus(CERTIFICATION_EXPIRATION));
+    }
+
+    public void deleteCertificationTime(Long userId, Long pilgrimageId) {
+        String key = CERTIFICATION_KEY_PREFIX + userId + ":" + pilgrimageId;
+        redisTemplate.delete(key);
+    }
+}
diff --git a/src/main/java/com/favoriteplace/global/websocket/WebSocketConfig.java b/src/main/java/com/favoriteplace/global/websocket/WebSocketConfig.java
new file mode 100644
index 0000000..9c6755a
--- /dev/null
+++ b/src/main/java/com/favoriteplace/global/websocket/WebSocketConfig.java
@@ -0,0 +1,34 @@
+package com.favoriteplace.global.websocket;
+
+import lombok.RequiredArgsConstructor;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.messaging.simp.config.ChannelRegistration;
+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
+@RequiredArgsConstructor
+@EnableWebSocketMessageBroker
+public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {
+    private final JwtChannelInterceptor jwtChannelInterceptor;
+
+    @Override
+    public void configureMessageBroker(MessageBrokerRegistry registry) {
+        registry.setApplicationDestinationPrefixes("/app")
+                .enableSimpleBroker("/pub");
+    }
+
+    @Override
+    public void registerStompEndpoints(StompEndpointRegistry registry) {
+        registry.addEndpoint("/ws")
+                .setAllowedOriginPatterns("*")
+                .withSockJS();
+    }
+
+    @Override
+    public void configureClientInboundChannel(ChannelRegistration registration) {
+        registration.interceptors(jwtChannelInterceptor);
+    }
+}