java-Implementierung : polling-a-web-service

Unten finden Sie meine Anforderung.

Voraussetzung : Umfrage a-web-service. Zwei entscheidende Parameter des polling max_timeout, polling_interval konfiguriert werden in properties-Datei. Hauptziel ist, zu verbringen, für eine Zeit von insgesamt in den Erhalt der Antwort. Wenn wir die Antwort mit in max_timeout, können wir Rückgabe der Antwort an den client. Sonst werden wir werfen eine Fehlermeldung, dass der Vorgang fehlgeschlagen ist.

Unten ist das code-snippet, das ich geschrieben habe.

int maxTimeOut = 10;
int interval   = 2;

int iterations = maxTimeOut/interval;
boolean success = false;

for (int i = 0; i < iterations; i++)
{
    System.out.println("Number of iteration = " + i);
    try
    {
        Thread.sleep(interval * 1000);
        System.out.println("Waited for " + interval + " seconds");

        success =  getWSResponse(i);
        System.out.println("CALL" + ((success) ? "SUCCESSFUL" : "FAIL"));

        if(success) break;

    }catch (InterruptedException ie)
    {
        System.out.println(ie.getMessage());
    }
}

//Send the success flag to client

Konnte Sie korrigieren Sie mich, wenn dies der ordnungsgemäßen Durchführung von polling. Ich bin wenig besorgt, dass dieser code geht davon aus, dass der webservice-Aufruf liefert in kürzester Zeit. Wenn dies dauert 2-3 Sekunden (normalerweise tut ), dann würden wir mehr ausgeben, als max_timeout insgesamt für POLLING allein. Wie könnten wir dieses Problem beheben. Gibt es einen besseren Ansatz als diesen.

  • catch (InterruptedException ie) { System.out.println(ie.getMessage()); } ... tun Sie das nicht. Nur rethrow es { throw new RuntimeException(ie) }
  • Dank artbristol für Ihren Vorschlag. Ich will diesen code ändern zu werfen RTE anstelle von SOP.
InformationsquelleAutor shafi khan | 2012-01-23
  1. 2

    können Sie kombinieren die Verwendung eines ScheduledExecutorService mit der HttpURLConnection-Timeout poll in einer gegebenen Verzögerung und Abbruch der Aufgabe, wenn es dauert länger.

    • Dank Licht. Könnten Sie auf den sample-code/die url, wo dieses Szenario beschrieben ist richtig. BTW,sehen Sie irgendwelche Probleme mit dem code-snippet, das ich angehängt habe (außer das problem habe ich auch angegeben)
    • ein problem des Codes wäre eine Unterbrechung. Da Sie sich nicht ausbreiten der Flagge unterbrochen oder werfen die Ausnahme unterbrochen.
    InformationsquelleAutor light_303
  2. 1

    Wenn polling bedeutet einfach nur, dass das webservice eingerichtet ist und ausgeführt wird, in deinem poll-code können Sie versuchen, die Verbindung zu dem webservice (mit connection timeout) .Wenn Sie erfolgreich eine Verbindung herstellen können, dies bedeutet, dass der webservice ist.

    HttpURLConnection connection = null;
URL url = new URL("URL");
connection = (HttpURLConnection) url.openConnection();
connection .setConnectTimeout(timeout);//specify the timeout and catch the IOexception
connection.connect();

    BEARBEITEN

    Alternativ können Sie rufen Sie den webservice mit einem executor (siehe java.util.gleichzeitige.ExecutorService) in eine Aufgabe mit Zeitlimit und können entsprechend entscheiden. Beispiel : 

    //Make the ws work a time-boxed task
            final Future<Boolean> future= executor.submit(new Callable<Boolean>() {         
                @Override
                public Boolean call() throws Exception {
                    //get ws result
                       return getWSResponse();
                }
            });
try {
                boolean result = future.get(max_wait_time, TimeUnit.SECONDS);
            } catch (TimeoutException te) {
throw e;
}
    • Nrj, wir haben tatsächlich eine Methode aufrufen, die auf web-service gibt große xml -, und das müssen wir analysieren es und dann finden wir heraus, ob die Antwort ist 'Erfolg' oder 'inprogress'. Diese ganze Sache ist abstrahiert in getWSResponse - Aufruf oben. Das Ziel ist nicht nur Kontrolle über die Konnektivität.
    • Danke Nrj für das code-snippet. Lassen Sie mich versuchen, das herauszufinden.
    • ist es in Ordnung, dass die Zukunft von code in einer controller-Klasse und habe es nicht eingesperrt?
    InformationsquelleAutor Nrj
Schreibe einen Kommentar