자바에서 비동기 프로세스를위한 기술과 디자인

Question

현재 Java로 Restfull 아키텍처하에 애플리케이션을 개발 중입니다. 내 웹 휴식 서비스, 다른 웹 서비스 비누 및 안드로이드 클라이언트 간의 상호 작용 중에 매우 큰 문제가 발생했습니다.

몇 가지 테스트를 거친 후 클라이언트가 처리되는 동안 작업 실패를 반환하고 위에서 언급 한 두 서비스 간의 서비스 소비에 대해 동일한 경우가 발생한다는 것을 깨달았습니다.

이 문제를 해결하려면 다음과 같이 진행하십시오. 클라이언트가 서버에 작업을 보내면 서버는 즉시 요청에 응답한다고 응답합니다. 그런 다음 고객은 사용자에게 알리는 것이 좋을 때까지 매번 자신의 작업 상태를 테스트해야합니다.

이제 내 관심사는 그 스레드 만 만들 것이라는 점입니다. 그러나 나는 그것을 위해 좋은 디자인과 기술을 찾을 수 없습니다 ... 도움을 미리 감사드립니다.

Answer 1

클라이언트의 호출 (서버의 엔드 포인트 중 하나에서)을 폴링하고 클라이언트 메소드가 getStatus 메소드를 구현하도록하고, run 메소드 내부의 상태를 업데이트합니다. 소비자 스레드에 대한, 원유 구현은 같을 것이다 :

public class ConsumerThread implements Runnable{ 
    private int status = 0; 
    private Random rand = new Random(); 
    private final CountDownLatch startSignal; 

    public ConsumerThread(CountDownLatch latch){ 
     this.startSignal = latch; 
    } 

    public int getStatus() { 
     return status; 
    } 

    private void setStatus(int status) { 
     this.status = status; 
    } 

    public void run() { 
     try { 
      this.startSignal.await(); 
      while (true){ 
       this.setStatus(rand.nextInt(10)); 
      } 
     } catch (InterruptedException e1) { 
      e1.printStackTrace(); 
     }  
    } 
} 

그런 다음 간단한 기본 방법을 시도

(나는 같은 시간에 시작하는 내 모든 스레드를 위해 CountDownLatch을 구현, 그렇지 않은 필수입니다) :

public class ThreadMain{ 
    private static List<ConsumerThread> consumers = new ArrayList<ConsumerThread>(); 

    public static void main(String[] args) { 
     int NUM_THREAD = 15; 
     ExecutorService executor = Executors.newFixedThreadPool(NUM_THREAD); 

     CountDownLatch latch = new CountDownLatch(NUM_THREAD); 
     ConsumerThread buffer = new ConsumerThread(latch); 
     for (int i = 0; i < NUM_THREAD; i++){ 
      consumers.add(buffer); 
      executor.execute(buffer); 
      latch.countDown(); 
      buffer = new ConsumerThread(latch); 
     } 

     for (int i = 0; i < 100; i++){ 
      System.out.println("Status for Thread 0: " + getStatusId(0)); 
      System.out.println("Status for Thread 14: " + getStatusId(14)); 
      try { 
       Thread.sleep(1000); 
      } catch (InterruptedException e) { 
       e.printStackTrace(); 
      } 
     } 
    } 

    public static int getStatusId(int index){ 
     return consumers.get(index).getStatus(); 
    } 
} 

샘플 출력 :

Status for Thread 0: 5 
Status for Thread 14: 0 
Status for Thread 0: 7 
Status for Thread 14: 2 
Status for Thread 0: 7 
Status for Thread 14: 4 
Status for Thread 0: 6 
Status for Thread 14: 3