Faire du HTTP Server Push en Java

Voici un bout de code utile qui permet de créer un serveur HTTP en Java et envoyant une réponse suivant la méthode Push. En résumé, cette méthode permet d'envoyé des réponse HTTP à intervalle régulier au sein de la même requête. Ceci est notamment utilisé par les caméra IP qui possède un serveur HTTP desservant un flux Motion JPEG.

Voici donc un bout de code permettant d'envoyer la valeur d'une variable à un intervalle régulier. La valeur sera donc mis à jour automatiquement dans le navigateur sans émettre une nouvelle requête HTTP.

import java.io.IOException; import java.io.OutputStream; import java.net.InetSocketAddress; import java.util.concurrent.Executors; import com.sun.net.httpserver.Headers; import com.sun.net.httpserver.HttpExchange; import com.sun.net.httpserver.HttpHandler; import com.sun.net.httpserver.HttpServer; class MyHttpHandler implements HttpHandler { public void handle(HttpExchange exchange) throws IOException { System.out.println("Request from : " + exchange.getRemoteAddress()); String requestMethod = exchange.getRequestMethod(); if (requestMethod.equalsIgnoreCase("GET")) { OutputStream responseBody = null; try { // Used to separate multipart String strBoundary = "my_boundary"; // We start with the standard headers Headers responseHeaders = exchange.getResponseHeaders(); responseHeaders.set("Cache-Control", "no-cache"); responseHeaders.set("Cache-Control", "private"); responseHeaders.set("Pragma", "no-cache"); responseHeaders.set("Content-Type", "multipart/x-mixed-replace; boundary=" + strBoundary); exchange.sendResponseHeaders(200, 0); // Define the multipart tag separator String strTagBoundary = String.format("--%s\n", strBoundary); // Start output from here responseBody = exchange.getResponseBody(); responseBody.write(strTagBoundary.getBytes()); responseBody.flush(); int val = 0; // The loop, producing one response per iteration while (val < 100) { // Per-image header, note the two new-lines //print "Content-type: image/jpeg\n\n"; // Set the header, we will send text/plain data responseBody.write("Content-type: text/plain\n\n".getBytes()); // Send the response String strTmp = String.format("value: %s", val); responseBody.write(strTmp.getBytes()); System.out.println("Sending response: " + strTmp); val++; // The separator responseBody.write(strTagBoundary.getBytes()); responseBody.flush(); try { Thread.sleep(300); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } responseBody.close(); System.out.println("Request ended"); } catch (IOException e){ System.out.println("Request aborted"); throw e; } } } public static void main(String[] args) throws IOException { InetSocketAddress addr = new InetSocketAddress(8080); HttpServer server = HttpServer.create(addr, 0); server.createContext("/", new MyHttpHandler()); server.setExecutor(Executors.newCachedThreadPool()); server.start(); System.out.println("Server is listening on port 8080" ); } }