[java] Java Jersey에서 클라이언트 측에서 비동기 호출을 수행하는 방법은?

29 Nov 2023

java

Java Jersey는 Java 기반의 웹 애플리케이션 개발을 위한 프레임워크로, 클라이언트와 서버 간의 통신을 간편하게 처리할 수 있습니다. 비동기 호출은 클라이언트 측에서 서버에게 요청을 보내고 응답을 받을 때, 동기적으로 기다리지 않고 다른 작업을 동시에 처리할 수 있는 방식입니다. 이를 통해 애플리케이션의 성능과 응답 속도를 향상시킬 수 있습니다.

Java Jersey에서 클라이언트 측에서 비동기 호출을 수행하는 방법은 다음과 같습니다:

async 메서드 사용: Java 8 이상에서는 CompletableFuture 클래스를 사용하여 비동기 호출을 처리할 수 있습니다. WebTarget 객체의 async 메서드를 호출하고, CompletableFuture의 supplyAsync 메서드로 비동기 작업을 정의합니다. 예를 들어:

import javax.ws.rs.client.Client;
import javax.ws.rs.client.ClientBuilder;
import javax.ws.rs.client.WebTarget;
import java.util.concurrent.CompletableFuture;

public class AsyncClient {
    public static void main(String[] args) {
        Client client = ClientBuilder.newClient();
        WebTarget target = client.target("http://example.com/api");
        
        CompletableFuture<String> future = target.path("resource").request().async().get(String.class).thenApply(response -> {
            // 응답 처리 로직
            return response.readEntity(String.class);
        });
        
        // 비동기 작업이 완료된 후의 처리
        future.whenComplete((result, throwable) -> {
            if (throwable == null) {
                System.out.println("응답: " + result);
            } else {
                System.err.println("오류: " + throwable.getMessage());
            }
        });
        
        // 애플리케이션의 다른 작업 수행
        System.out.println("다른 작업 수행 중...");
    }
}

InvocationCallback 사용: Java 8 미만에서는 InvocationBuilder의 async 메서드에 InvocationCallback 객체를 전달하여 비동기 호출을 처리할 수 있습니다. 예를 들어:

import javax.ws.rs.client.Client;
import javax.ws.rs.client.ClientBuilder;
import javax.ws.rs.client.InvocationCallback;
import javax.ws.rs.client.WebTarget;

public class AsyncClient {
    public static void main(String[] args) {
        Client client = ClientBuilder.newClient();
        WebTarget target = client.target("http://example.com/api");
        
        target.path("resource").request().async().get(new InvocationCallback<String>() {
            @Override
            public void completed(String response) {
                // 응답 처리 로직
                System.out.println("응답: " + response);
            }

            @Override
            public void failed(Throwable throwable) {
                System.err.println("오류: " + throwable.getMessage());
            }
        });
        
        // 애플리케이션의 다른 작업 수행
        System.out.println("다른 작업 수행 중...");
    }
}

비동기 호출을 통해 클라이언트 측에서 서버와의 통신을 효율적으로 처리할 수 있습니다. 하지만 비동기 호출을 사용할 때에는 콜백 함수 또는 CompletableFuture에서 예외 처리를 잊지 않도록 주의해야 합니다.

이외에도 Java Jersey에서는 Reactive Streams와 같은 라이브러리를 활용하여 비동기 호출을 수행할 수도 있으니 참고하시기 바랍니다.

참고 자료