Stomp::getReadTimeout 관련 질문

• CI/CD장인 2일 전 2025.06.03 14:46
• 2
  1

목록

댓글 1

댓글목록



나우호스팅 　2일 전



Stomp 프레임워크의 getReadTimeout() 메서드는 메시지 브로커와의 연결에서 읽기 타임아웃을 설정하는 메서드입니다.

이 메서드는 연결이 끊어질 때까지 기다리는 시간을 설정하는 데 사용됩니다.

기본값은 0으로, 즉 타임아웃이 설정되지 않은 상태입니다.

getReadTimeout() 메서드를 사용하여 예제 코드를 작성해 보겠습니다.



#hostingforum.kr
java

import org.springframework.messaging.Message;

import org.springframework.messaging.MessageHeaders;

import org.springframework.messaging.converter.MessageConverter;

import org.springframework.messaging.converter.MappingJackson2MessageConverter;

import org.springframework.messaging.simp.stomp.StompFrame;

import org.springframework.messaging.simp.stomp.StompHeaders;

import org.springframework.messaging.simp.stomp.StompSession;

import org.springframework.messaging.simp.stomp.StompSessionHandlerAdapter;

import org.springframework.messaging.support.MessageBuilder;

import org.springframework.web.socket.client.standard.StandardWebSocketClient;

import org.springframework.web.socket.messaging.WebSocketStompClient;

import org.springframework.web.socket.sockjs.client.SockJsClient;

import org.springframework.web.socket.sockjs.client.Transport;

import org.springframework.web.socket.sockjs.client.WebSocketTransport;



import java.util.Collections;

import java.util.List;



public class StompClient {



    public static void main(String[] args) {

        WebSocketStompClient stompClient = new WebSocketStompClient(new SockJsClient(Collections.singleton(new WebSocketTransport(new StandardWebSocketClient()))));

        stompClient.setMessageConverter(new MappingJackson2MessageConverter());



        StompHeaders headers = new StompHeaders();

        headers.setDestination("/topic/greeting");



        StompSession session = stompClient.connect("ws://localhost:8080/greeting", new StompSessionHandlerAdapter() {

            @Override

            public void afterConnected(StompSession session, StompHeaders connectedHeaders) {

                session.send(MessageBuilder.createMessage("Hello, World!", headers).build());

            }

        }).get();



        // getReadTimeout() 메서드를 사용하여 읽기 타임아웃을 설정합니다.

        session.getReadTimeout().setTimeout(1000); // 1초의 타임아웃을 설정합니다.



        // 메시지를 받을 때까지 기다립니다.

        try {

            Message<?> message = session.receive();

            System.out.println(message.getPayload());

        } catch (Exception e) {

            System.out.println("타임아웃 발생");

        }

    }

}



이 예제 코드에서는 getReadTimeout() 메서드를 사용하여 읽기 타임아웃을 1초로 설정한 후 메시지를 받을 때까지 기다립니다. 만약 타임아웃이 발생하면 "타임아웃 발생"이 출력됩니다.

2025-06-03 14:47

<br /> <br /> Stomp 프레임워크의 getReadTimeout() 메서드는 메시지 브로커와의 연결에서 읽기 타임아웃을 설정하는 메서드입니다. <br /> <br /> 이 메서드는 연결이 끊어질 때까지 기다리는 시간을 설정하는 데 사용됩니다. <br /> <br /> 기본값은 0으로, 즉 타임아웃이 설정되지 않은 상태입니다. <br /> <br /> getReadTimeout() 메서드를 사용하여 예제 코드를 작성해 보겠습니다.<br /> <br /> [code]#hostingforum.kr<br>java<br /> import org.springframework.messaging.Message;<br /> import org.springframework.messaging.MessageHeaders;<br /> import org.springframework.messaging.converter.MessageConverter;<br /> import org.springframework.messaging.converter.MappingJackson2MessageConverter;<br /> import org.springframework.messaging.simp.stomp.StompFrame;<br /> import org.springframework.messaging.simp.stomp.StompHeaders;<br /> import org.springframework.messaging.simp.stomp.StompSession;<br /> import org.springframework.messaging.simp.stomp.StompSessionHandlerAdapter;<br /> import org.springframework.messaging.support.MessageBuilder;<br /> import org.springframework.web.socket.client.standard.StandardWebSocketClient;<br /> import org.springframework.web.socket.messaging.WebSocketStompClient;<br /> import org.springframework.web.socket.sockjs.client.SockJsClient;<br /> import org.springframework.web.socket.sockjs.client.Transport;<br /> import org.springframework.web.socket.sockjs.client.WebSocketTransport;<br /> <br /> import java.util.Collections;<br /> import java.util.List;<br /> <br /> public class StompClient {<br /> <br /> public static void main(String[] args) {<br /> WebSocketStompClient stompClient = new WebSocketStompClient(new SockJsClient(Collections.singleton(new WebSocketTransport(new StandardWebSocketClient()))));<br /> stompClient.setMessageConverter(new MappingJackson2MessageConverter());<br /> <br /> StompHeaders headers = new StompHeaders();<br /> headers.setDestination("/topic/greeting");<br /> <br /> StompSession session = stompClient.connect("ws://localhost:8080/greeting", new StompSessionHandlerAdapter() {<br /> @Override<br /> public void afterConnected(StompSession session, StompHeaders connectedHeaders) {<br /> session.send(MessageBuilder.createMessage("Hello, World!", headers).build());<br /> }<br /> }).get();<br /> <br /> // getReadTimeout() 메서드를 사용하여 읽기 타임아웃을 설정합니다.<br /> session.getReadTimeout().setTimeout(1000); // 1초의 타임아웃을 설정합니다.<br /> <br /> // 메시지를 받을 때까지 기다립니다.<br /> try {<br /> Message<?> message = session.receive();<br /> System.out.println(message.getPayload());<br /> } catch (Exception e) {<br /> System.out.println("타임아웃 발생");<br /> }<br /> }<br /> }<br /> [/code]<br /> <br /> 이 예제 코드에서는 getReadTimeout() 메서드를 사용하여 읽기 타임아웃을 1초로 설정한 후 메시지를 받을 때까지 기다립니다. 만약 타임아웃이 발생하면 "타임아웃 발생"이 출력됩니다.