[java] Java Jersey에서 멀티스레딩과 동시성을 처리하는 방법은?

29 Nov 2023

java

Java Jersey는 RESTful 웹 서비스를 개발할 때 많이 사용되는 프레임워크입니다. 멀티스레딩과 동시성을 처리하는 방법을 살펴보도록 하겠습니다.

1. 스레드 풀 설정

Java Jersey에서 멀티스레딩을 처리하기 위해 스레드 풀을 설정할 수 있습니다. 아래는 스레드 풀을 설정하는 예제 코드입니다.

import org.glassfish.jersey.server.ResourceConfig;
import java.util.concurrent.Executors;

public class MyApplication extends ResourceConfig {
    public MyApplication() {
        property("jersey.config.server.provider.threadpool.executorservice.type", "cached");
        property("jersey.config.server.provider.threadpool.executorservice.max-pool-size", "10");
        property("jersey.config.server.provider.threadpool.executorservice.min-pool-size", "5");
        property("jersey.config.server.provider.threadpool.executorservice.queue-size", "100");
        property("jersey.config.server.provider.threadpool.executorservice.keep-alive-seconds", "60");
        property("jersey.config.server.provider.threadpool.executorservice.priority", "5");
    }
}

위 코드에서는 스레드 풀의 속성을 설정하는데, jersey.config.server.provider.threadpool.executorservice.type은 스레드 풀의 유형을 지정하고, jersey.config.server.provider.threadpool.executorservice.max-pool-size와 jersey.config.server.provider.threadpool.executorservice.min-pool-size는 스레드 풀의 최대 및 최소 스레드 수를 설정합니다. 그 외에도 여러 다양한 속성을 설정할 수 있습니다.

2. 동시성 제어

Java Jersey에서 동시성을 제어하기 위해 @Synchronized 애노테이션을 사용할 수 있습니다. 해당 애노테이션을 메소드나 클래스에 적용하면 해당 메소드나 클래스에는 오직 한 스레드만이 접근할 수 있게 됩니다. 아래는 @Synchronized 애노테이션을 사용한 예제입니다.

import javax.ws.rs.GET;
import javax.ws.rs.Path;
import javax.ws.rs.Produces;
import javax.ws.rs.core.MediaType;

@Path("/example")
public class ExampleResource {

    @GET
    @Produces(MediaType.TEXT_PLAIN)
    @Synchronized
    public String getExample() {
        // 동시에 실행될 수 있는 코드
        return "Example Resource";
    }
}

위의 예제 코드에서는 @Synchronized 애노테이션을 getExample() 메소드에 적용하여 해당 메소드의 동시성을 제어하고 있습니다.

3. 비동기 처리

Java Jersey에서 비동기 처리를 위해 @Suspended 애노테이션을 사용할 수 있습니다. 해당 애노테이션을 사용하면 비동기로 요청을 처리하고 응답을 반환할 수 있습니다. 아래는 @Suspended 애노테이션을 사용한 예제입니다.

import javax.ws.rs.GET;
import javax.ws.rs.Path;
import javax.ws.rs.container.AsyncResponse;
import javax.ws.rs.container.Suspended;
import javax.ws.rs.core.MediaType;
import java.util.concurrent.CompletableFuture;

@Path("/example")
public class ExampleResource {

    @GET
    @Produces(MediaType.APPLICATION_JSON)
    public void getExample(@Suspended AsyncResponse asyncResponse) {
        CompletableFuture.supplyAsync(() -> {
            // 비동기로 실행될 코드
            return "Example Resource";
        }).thenAccept(asyncResponse::resume);
    }
}

위의 예제 코드에서는 getExample() 메소드에 @Suspended 애노테이션을 적용하여 비동기 요청을 처리하고, CompletableFuture를 사용하여 비동기로 실행될 코드를 작성하고 있습니다.

이렇게 Java Jersey에서 멀티스레딩과 동시성을 처리할 수 있는 방법을 살펴보았습니다. 위에서 소개한 방법들은 Java Jersey 프레임워크를 사용하는 프로젝트에서 멀티스레딩과 동시성을 처리하기 위한 기본적인 방법들이므로 참고하시기 바랍니다.

참고 자료: