[java] Java Jersey에서 서버 측 이벤트 스트리밍을 구현하는 방법은?

29 Nov 2023

java

Jersey는 Java 기반의 웹 애플리케이션 프레임워크로, RESTful 웹 서비스를 개발할 때 자주 사용됩니다. 이벤트 스트리밍은 서버가 클라이언트에게 실시간으로 데이터를 전달하는 방법 중 하나입니다. Jersey를 사용하여 서버 측 이벤트 스트리밍을 구현하는 방법에 대해 알아보겠습니다.

Maven 종속성 추가하기: Jersey를 사용하기 위해 pom.xml 파일에 다음 종속성을 추가해야 합니다.

<dependencies>
    <dependency>
        <groupId>org.glassfish.jersey.containers</groupId>
        <artifactId>jersey-container-servlet</artifactId>
        <version>2.32</version>
    </dependency>
    <dependency>
        <groupId>org.glassfish.jersey.media</groupId>
        <artifactId>jersey-media-sse</artifactId>
        <version>2.32</version>
    </dependency>
</dependencies>

이벤트 스트리밍 엔드포인트 만들기: 이벤트 스트리밍을 지원하는 엔드포인트를 생성해야 합니다. Jersey에서는 @SseEventSink 어노테이션을 사용하여 이벤트를 클라이언트에게 스트리밍할 수 있습니다. 예를 들어, 다음과 같이 엔드포인트를 작성할 수 있습니다.

import javax.ws.rs.GET;
import javax.ws.rs.Path;
import javax.ws.rs.Produces;
import javax.ws.rs.core.MediaType;
import javax.ws.rs.sse.Sse;
import javax.ws.rs.sse.SseEventSink;

@Path("/stream")
public class EventStreamResource {

    @GET
    @Produces(MediaType.SERVER_SENT_EVENTS)
    public void streamEvents(@Context SseEventSink eventSink, @Context Sse sse) {
        // 이벤트 스트리밍 로직 작성
        // eventSink로 이벤트를 클라이언트에게 스트리밍
    }
}

서버 실행 및 클라이언트에서 이벤트 수신하기: 이제 프로젝트를 빌드하여 서버를 실행할 수 있습니다. 서버가 실행될 때, 클라이언트는 /stream 엔드포인트로 연결하여 이벤트를 수신할 수 있습니다.

import javax.ws.rs.client.Client;
import javax.ws.rs.client.ClientBuilder;
import javax.ws.rs.client.WebTarget;
import javax.ws.rs.sse.SseEventSource;

public class EventStreamClient {

    public static void main(String[] args) {
        Client client = ClientBuilder.newClient();
        WebTarget target = client.target("http://localhost:8080/stream");

        SseEventSource eventSource = SseEventSource.target(target).build();
        eventSource.register(System.out::println); // 이벤트 수신 로직 작성

        eventSource.open();
    }
}

위 코드에서 System.out::println 부분은 이벤트를 수신할 때 수행할 동작을 작성하는 곳입니다. 이 예제에서는 이벤트를 콘솔에 출력하도록 설정되어 있습니다.

이제 Jersey를 사용하여 Java 언어로 서버 측 이벤트 스트리밍을 구현하는 방법을 알아보았습니다. 자세한 내용은 Jersey 공식 문서를 참조하시기 바랍니다.