[java] JAX-RS에서 동시성과 병렬성 처리

28 Nov 2023

java

JAX-RS는 Java API for RESTful Web Services의 약자로, RESTful 웹 서비스를 개발하기 위한 Java API입니다. 이 API를 사용하면 간편하게 RESTful 웹 서비스를 구축할 수 있습니다. 이번 글에서는 JAX-RS에서 동시성과 병렬성 처리에 대해 알아보겠습니다.

동시성과 병렬성

동시성은 여러 작업을 동시에 실행하는 것을 의미합니다. 즉, 여러 작업이 번갈아가며 실행되어 마치 동시에 실행되는 것처럼 보이게 할 수 있습니다. 여러 작업이 동시에 실행되지만 실제로는 작업을 번갈아 가며 실행하기 때문에 실제적인 동시 실행이 아닙니다.

병렬성은 여러 작업을 동시에 실행하는 것을 의미합니다. 즉, 하나의 작업이 실행되는 동안 다른 작업이 실행될 수 있습니다. 여러 개의 쓰레드 또는 프로세스를 사용하여 작업을 동시에 실행함으로써 병렬성을 구현할 수 있습니다. 실제로 여러 작업이 동시에 실행되기 때문에 실제적인 병렬 실행입니다.

JAX-RS에서의 동시성 처리

JAX-RS는 동시성을 처리하기 위해 다음과 같은 방법을 제공합니다.

1. 비동기 요청 처리

JAX-RS에서 비동기 요청 처리는 @Suspend 어노테이션을 사용하여 구현할 수 있습니다. 이 어노테이션을 사용하면 요청이 동기적으로 처리되는 것이 아니라 비동기적으로 처리됩니다. 이를 통해 동시에 여러 요청을 처리할 수 있습니다.

@GET
@Path("/users")
@Suspend
public void getUsers(@Suspended final AsyncResponse asyncResponse) {
    // 비동기적으로 사용자 정보를 조회하고 응답 생성
    // ...
}

2. 쓰레드 풀 사용

JAX-RS는 쓰레드 풀을 사용하여 요청 처리를 병렬적으로 실행할 수 있습니다. @Asynchronous 어노테이션을 사용하여 쓰레드 풀에 작업을 할당할 수 있습니다.

@GET
@Path("/users")
@Asynchronous
public void getUsers(@Suspended final AsyncResponse asyncResponse) {
    // 쓰레드 풀에서 작업 처리
    // ...
}

JAX-RS에서의 병렬성 처리

JAX-RS에서 병렬성을 처리하기 위해서는 다음과 같은 방법을 활용할 수 있습니다.

1. Executor 사용

JAX-RS는 Executor 인터페이스를 사용하여 작업을 병렬적으로 실행할 수 있습니다. @ManagedExecutorService 어노테이션을 사용하여 Executor 인스턴스를 주입받고, 해당 인스턴스를 사용하여 작업을 병렬로 처리할 수 있습니다.

@Path("/users")
public class UserResource {

    @Inject
    @ManagedExecutorService
    private Executor executor;

    @GET
    @Produces(MediaType.APPLICATION_JSON)
    public Response getUsers() {
        List<User> users = // 사용자 정보 조회

        // Executor를 사용하여 작업 병렬 처리
        List<CompletableFuture<User>> futures = users.stream()
                .map(user -> CompletableFuture.supplyAsync(() -> processUser(user), executor))
                .collect(Collectors.toList());

        List<User> processedUsers = futures.stream()
                .map(CompletableFuture::join)
                .collect(Collectors.toList());

        return Response.ok(processedUsers).build();
    }

    private User processUser(User user) {
        // 사용자 정보 가공 및 추가 로직 수행
        // ...

        return user;
    }
}

2. RxJava 사용

JAX-RS에서는 RxJava와 같은 리액티브 프레임워크를 사용하여 병렬성을 처리할 수도 있습니다. 이를 통해 비동기적으로 작업을 처리하고, 병렬 실행을 구현할 수 있습니다.

@Path("/users")
public class UserResource {

    @GET
    @Produces(MediaType.APPLICATION_JSON)
    public Single<Response> getUsers() {
        return Single.fromCallable(() -> {
            List<User> users = // 사용자 정보 조회

            return users.parallelStream()
                    .map(user -> processUser(user))
                    .collect(Collectors.toList());
        }).map(processedUsers -> Response.ok(processedUsers).build());
    }

    private User processUser(User user) {
        // 사용자 정보 가공 및 추가 로직 수행
        // ...

        return user;
    }
}

결론

JAX-RS를 사용하여 동시성과 병렬성을 처리할 수 있습니다. 비동기 요청 처리를 통해 동시에 여러 요청을 처리하고, 쓰레드 풀 또는 Executor를 사용하여 작업을 병렬로 실행할 수 있습니다. 또한, RxJava와 같은 리액티브 프레임워크를 활용하여 비동기적인 처리와 병렬 실행을 구현할 수도 있습니다.