Hallo zusammen,
vielen Dank für Eure Antworten! Nochmal zum Projekt: Wir entwickeln zur Zeit eine mobile Applikation, welche über ein Back-End Daten vom FirstSpirit-Server abruft und visualisiert. Bei jedem Aufruf, baut das Back-End eine Verbindung zum FirstSpirit-Server auf und übergibt die angeforderten Daten an das Front-End.
Das Problem wurde jetzt so gelöst, dass die Anfragen an den FirstSpirit-Server als Callable in einem ExecutorService gestellt werden. Den ExecutorService haben wir in einem Singleton initialisiert und die Menge der Threads begrenzt. Unter Last wird diese Lösung früher oder später zu hohen Ladezeiten führen, weshalb wir zeitnah über ein Caching nachdenken werden. Im Folgenden findet Ihr den Code, welchen wir verwenden.
ExecutorService-Singleton:
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class ConnectionExecutorService {
private static ConnectionExecutorService instance;
private final int NUMTHREAD = 5;
ExecutorService executorService;
public static ConnectionExecutorService getInstance() {
if (instance == null){
instance = new ConnectionExecutorService();
}
return instance;
}
private ConnectionExecutorService() {
executorService = Executors.newFixedThreadPool(NUMTHREAD);
}
public ExecutorService getExecutorService() {
return executorService;
}
}
Verwendung eines Callable:
import java.util.concurrent.Callable;
...
Callable<AnyTypeYouWant > callable = new Callable<AnyTypeYouWant >() {
public AnyTypeYouWant call() throws Exception {
// Enable Connection to FS-Server
// Execute Query
// Disconnect
return result;
}
}
(AnyTypeYouWant) ConnectionExecutorService.getInstance().getExecutorService().submit(callable).get();
Danke nochmal und viele Grüße,
Ronny
