The developers mind: Serveur HTTP

vendredi 23 décembre 2011

Faire du HTTP server PUSH en PHP

Voici un bout de code utile en PHP qui permet d'envoyer une réponse HTTP 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.

<?
# Used to separate multipart
$boundary = "my_boundary";

# We start with the standard headers. PHP allows us this much
header("Cache-Control: no-cache");
header("Cache-Control: private");
header("Pragma: no-cache");
header("Content-type: multipart/x-mixed-replace; boundary=$boundary");

# From here out, we no longer expect to be able to use the header() function
print "--$boundary\n";

# Set this so PHP doesn't timeout during a long stream
set_time_limit(0);

# Disable Apache and PHP's compression of output to the client
@apache_setenv('no-gzip', 1);
@ini_set('zlib.output_compression', 0);

# Set implicit flush, and flush all current buffers
@ini_set('implicit_flush', 1);
for ($i = 0; $i < ob_get_level(); $i++)
    ob_end_flush();
ob_implicit_flush(1);

$val = 0;

# The loop, producing one jpeg frame per iteration
while ($val < 100) {
    # Per-image header, note the two new-lines
    print "Content-type: text/plain\n\n";

# Your function to get one jpeg image
    print "value:".$val;

# The separator
    print "--$boundary\n";

$val++;

usleep(300000);
}
?>

Le code d'origine provient du blog cité ci-dessous.

Source : http://ben-collins.blogspot.com/2010/06/php-sending-motion-jpeg.html

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" );
  }
}