java- come aspettare costantemente che un evento avvenga

Question

Sto creando un'applicazione in cui ci sono più stadi - per ogni fase un messaggio viene inviato alla mia coda in Amazon Simple Work Flow (SWF) ... L'app dovrebbe inizia una nuova discussione per ogni messaggio ricevuto.

Come si implementa la parte in attesa, in modo che l'applicazione esegua costantemente la scansione della coda per i nuovi messaggi e agisca nel momento in cui viene ricevuto un messaggio?

Answer 1

Un modo si può fare è poll il queue fino ad ottenere un nuovo messaggio al while loop mechanism.once si ottiene il nuovo messaggio, si può invocare la propria azione.

Answer 2

Utilizzare un ServerSocket:

serversocket

in particolare, il metodo Accetti() attende che l'utente richiede una connessione. È quindi possibile creare un'istanza di un nuovo thread passando i parametri necessari per mantenere la connessione (indirizzo, porta, ecc.).

Answer 3

ciò che si chiede circa si chiama un modello produttore-consumatore si può leggere su di esso here

L'idea di base: il sito è un produttore e tu sei come un client consumatore.

si attende() fino a quando l'ascoltatore riceve un messaggio e poi notifAll()

class WaitForAmazon{ 
    private boolean available = false; 
    private int contents; 

    public synchronized int consumer() { 
     while (available == false) { 
      try { 
       wait(); 
      } catch (InterruptedException e) { } 
     } 
     available = false; 
     notifyAll(); 
     return contents; 
    } 

    public synchronized void producer(int value) { 
     while (available == true) { 
      try { 
       wait(); 
      } catch (InterruptedException e) { } 
     } 
     contents = value; 
     available = true; 
     notifyAll(); 
    } 
} 

Answer 4

BlockingQueue e la sua attuazione LinkedBlockingQueue può essere utile qui.

Quando Thread vorranno take qualcosa dalla coda chiamando

queue.take() 

e coda sarà vuota, come filo attenderà altro thread metterà qualcosa in coda chiamando

queue.put(something). 

anche se la coda è piena, queue.put() farà mettere il thread in attesa fino a quando non ci sarà spazio in coda per i nuovi elementi.