Jak uruchamiać asynchroniczne/nie blokujące zapytania MySQL w strukturze Play?

Question

Po prostu zaczyna się w Play. Dokumentacja mówi o tym, jak Play może być uruchamiana asynchronicznie.

Ale jak uruchomić kwerendy MySQL podczas uruchamiania Asynchronicznie? Normalne zapytania MySQL są blokowane, prawda? To by nie działało.

Node.js ma własnych, nie blokujących klientów MySQL, tylko do tego celu, ale nie mogę znaleźć niczego podobnego do Play.

Jak uruchomić kwerendy MySQL w asynchronicznej aplikacji Play?

Answer 1

spójrz na ten link Asynchronous jobs w ramce gry.

Answer 2

Odtwórz Zadania są wykonywane w osobnym wątku i zwalniają główny wątek http. Główny wątek http jest następnie uruchamiany tam, gdzie został przerwany, gdy zadanie (zawinięte w obiekt obietnicy) powróci po zakończeniu.

Główny wątek protokołu HTTP nie jest więc wstrzymywany i można go udostępnić do obsługi innych przychodzących żądań http.

Answer 3

Generalnie wykonywanie wywołań SQL do DB jest zwykle blokowane i wykonywane sekwencyjnie. Play ma doskonałą obsługę asynchronicznego wykonywania, co poprawia wydajność Twojej aplikacji.

kod przykładowy Praca Zagraj 2,0

public static Result slow() { 
    Logger.debug("slow started"); 

    // Start execution 
    Promise<DataObject> userObject1 = SlowQuery.getUser(440); 
    Promise<DataObject> userObject2 = SlowQuery.getCategory(420); 
    // ... here execution is already in progress ... 

    // Map to Promise Objects 
    Promise<DataObject> res1 = userObject1.map(new Function<DataObject, DataObject>() { 
     public DataObject apply(DataObject res) { 
      Logger.debug("Got result (userObject1): " + res.toString()); 
      return res; 
     } 
    }); 

    Promise<DataObject> res2 = userObject2.map(new Function<DataObject, DataObject>() { 
     public DataObject apply(DataObject res) { 
      Logger.debug("Got result (userObject2): " + res.toString()); 
      return res; 
     } 
    }); 

    // here we wait for completion - this blocks 
    userObject1.getWrappedPromise().await(); 
    userObject2.getWrappedPromise().await(); 

    // the result is available 
    Logger.debug(res1.get().toString()); 
    Logger.debug(res2.get().toString()); 

    Logger.debug("slow finished"); 
    return ok("done"); 
} 

krępuj się poprawić za pomocą funkcji wiki społeczności - Jestem pewien, że niektóre części mogą ulec skróceniu.

Answer 4

Należy rozważyć użycie nieblokującego się złącza MySQL. Na przykład. https://code.google.com/p/async-mysql-connector/