Single instance HTTP Server using new Ethernet Interface.

Dependents:   EthHTTPServer if201410_section5 _PE2E_12-04_EthernetInterfaceServer MGAS_GR_Peach ... more

Fork of WiFlyHTTPServer by Henry Leinen

Desciprtion of the library

Overview

This is an HTTPServer library using the new MBED EthernetInterface library. It allows you to :

  • serve files from any file System
  • use Remote procedure calls
  • extend the HTTPServer functionality according to your needs, using the provided handler classes or writing new classes. The following sections will give you a brief overview of how to use the library.

Usage description

You can use the library as file server, as RPC server or a combination of both. You can even define your own behaviour by deriving from one of the classes provided.

Use as file server

You may want to look at my sample application which allows you to serve files from the internal local storage of the mbed with no modifcation of the code :

Very simple example application

#include "mbed.h"
#include "HTTPServer.h"
#include "FsHandler.h"
#include "LocalFileSystem.h"

//  Use LED1 to indicate that the main loop is still executing
DigitalOut myled(LED1);
//  Use the serial connection 'pc' to dump debug information
Serial pc(USBTX, USBRX, "pc");
//  Instantiate a HTTPServer to handle incoming requests
HTTPServer  svr;
//  Instantiate a local file system handler named 'local' which will be used later to access files on the mbed.
LocalFileSystem local("local");


int main() {

    pc.baud(460800);
    HTTPFsRequestHandler::mount("/local/", "/");
    svr.addHandler<HTTPFsRequestHandler>("/");

    if (!svr.start()) {
       error("Server not starting !");
        exit(0);
    }
    
    while(1) {
        svr.poll();
        myled = 1;
        wait(0.2);
        myled = 0;
        wait(0.2);
    }
}

Another alternative is to provide the EthernetInterface library to the HTTPServer library. This may be useful in case you need to perform other tasks with your internet connection. In this case it is necessary that you initialize the EthernetInterface and perform the connection prior to calling the start() method. Here is the example :

Sample application with re-use of existing EthernetInterface object

#include "mbed.h"
#include "HTTPServer.h"
#include "FsHandler.h"
#include "LocalFileSystem.h"
#include "EthernetInterface.h"


//  Use LED1 to indicate that the main loop is still executing
DigitalOut myled(LED1);
//  Use the serial connection 'pc' to dump debug information
Serial pc(USBTX, USBRX, "pc");
//  Instantiate a HTTPServer to handle incoming requests
HTTPServer  svr;
//  Instantiate a local file system handler named 'local' which will be used later to access files on the mbed.
LocalFileSystem local("local");
//  Create the EthernetInterface. This is optional, please see the documentation of HTTP Server's start method.
EthernetInterface eth;


int main() {

    pc.baud(460800);
    HTTPFsRequestHandler::mount("/local/", "/");
    svr.addHandler<HTTPFsRequestHandler>("/");

    //  Initialize the EthernetInterface and initiate a connection using DHCP.
    eth.init();
    eth.connect();

    // ***
    // TODO: Perform other Tasks using the ethernet connection here.
    // ****
    
    // Now start the server on port 80.
    if (!svr.start(80, &eth)) {
        error("Server not starting !");
        exit(0);
    }
    
    // The whole server activity is performed in this Loop. You can also put it into a separate RTOS Task and let it run there all the time.
    while(1) {
        svr.poll();
        myled = 1;
        wait(0.2);
        myled = 0;
        wait(0.2);
    }
}

Use as remote procedure call (RPC) server

To access objects or resources via HTTP you can make use of the RPC functionality. Each object that shall be accessible via HTTP needs to be registered before use. Here is an example which Registers the DigitalOut class for use over RPC :

RPC usage over HTTPServer

#include "mbed.h"
#include "HTTPServer.h"
#include "RpcHandler.h"
#include "mbed_rpc.h"

//  Use LED1 to indicate that the main loop is still executing
DigitalOut myled(LED1);
//  Use the serial connection 'pc' to dump debug information
Serial pc(USBTX, USBRX, "pc");
//  Instantiate a HTTPServer to handle incoming requests
HTTPServer  svr;


int main() {

    pc.baud(460800);
    RPC::add_rpc_class<RpcDigitalOut>();
    svr.addHandler<HTTPRpcRequestHandler>("/RPC");
    
    if (!svr.start()) {
        error("Server not starting !");
        exit(0);
    }
    
    while(1) {
        svr.poll();
        myled = 1;
        wait(0.2);
        myled = 0;
        wait(0.2);
    }
}

And using the above code, enter the following in the address field of your browser :

http://<your_mbed_ip>/RPC/DigitalOut/new LED4 myled4 - - > to create a new object of type DigitalOut on pin LED4 which can be referred to as 'myled4'.

and

http://<your_mbed_ip>/RPC/myled4/write 1 - - > to switch on the LED4.

Of course it is possible to Register your own objects with the standard MBED RPC functionality.

All the above Scenarios are implemented in a sample application, which will allow you to try out the functionality with basically no changes. If you want to try out the HTTP file Server, it is of course helpful to upload an html file to your MBED local storage.

Here is the sample application :

Import programEthHTTPServer

Working sample implementation for the EthernetInterface HTTPServer.

Future plans

Currently I am not considering to further extend this library. However, if someone needs extensions to this library, I will consider implementing them. Of course I will be taking care of bugfixes.

Known issues

Please note that the current implementation of the EthernetInterface seems to have an issue which results in unresponsive behaviour of the Sockets in some situations. This odd behaviour has not only been reported on my HTTPServer but also on other components using the EthernetInterface library.

Committer:
leihen
Date:
Sat Aug 17 16:17:55 2013 +0000
Revision:
16:cc3f5c53d0d5
Parent:
13:aa5338a5e452
- Removed old Debug message helper macros and replaced them with new hl_debug.h macros.
; - Renamed debug.h file to hl_debug.h to avoid conflict with EthernetInterface.
; - Fixed incorrectly used debug macro where an ERR was used instead of an INFO

Who changed what in which revision?

UserRevisionLine numberNew contents of line
leihen 5:dc88012caef1 1 /* FsHandler.cpp */
leihen 5:dc88012caef1 2 #include "mbed.h"
leihen 5:dc88012caef1 3 #include "FsHandler.h"
leihen 13:aa5338a5e452 4 #define DEBUG
leihen 16:cc3f5c53d0d5 5 #include "hl_debug.h"
leihen 5:dc88012caef1 6
leihen 5:dc88012caef1 7
leihen 5:dc88012caef1 8
leihen 12:ba81cc117fb6 9 static int matchstrings(const char* one, const char* two)
leihen 12:ba81cc117fb6 10 {
leihen 12:ba81cc117fb6 11 int m = 0;
leihen 12:ba81cc117fb6 12
leihen 12:ba81cc117fb6 13 for (m = 0; m < min(strlen(one), strlen(two)) ; m++) {
leihen 12:ba81cc117fb6 14 if (one[m] != two[m])
leihen 12:ba81cc117fb6 15 return m;
leihen 12:ba81cc117fb6 16 }
leihen 12:ba81cc117fb6 17 return m;
leihen 12:ba81cc117fb6 18 }
leihen 5:dc88012caef1 19
leihen 5:dc88012caef1 20 std::map<const char*, const char*> HTTPFsRequestHandler::m_fsMap;
leihen 5:dc88012caef1 21
leihen 5:dc88012caef1 22 HTTPFsRequestHandler::HTTPFsRequestHandler(const char* rootPath, const char* localPath, HTTPConnection::HTTPMessage& Msg, TCPSocketConnection& Tcp)
leihen 5:dc88012caef1 23 : HTTPRequestHandler(Msg, Tcp)
leihen 5:dc88012caef1 24 {
leihen 5:dc88012caef1 25 m_rootPath = rootPath;
leihen 5:dc88012caef1 26 m_localPath = localPath;
leihen 5:dc88012caef1 27
leihen 12:ba81cc117fb6 28 string myPath = m_rootPath + m_localPath;
leihen 12:ba81cc117fb6 29
leihen 5:dc88012caef1 30 // Now replace the virtual root path with a mounted device path
leihen 5:dc88012caef1 31 std::map<const char*, const char*>::iterator it;
leihen 12:ba81cc117fb6 32 const char *bestMatch = NULL;
leihen 12:ba81cc117fb6 33 const char *bestMatchExchange = NULL;
leihen 12:ba81cc117fb6 34 int match_ind = -1;
leihen 5:dc88012caef1 35 for (it = m_fsMap.begin() ; it != m_fsMap.end() ; it++) {
leihen 5:dc88012caef1 36 // find best match (if the given logical path is containted in the root
leihen 12:ba81cc117fb6 37 int s = matchstrings(myPath.c_str(), it->second);
leihen 12:ba81cc117fb6 38 INFO("Matching Root %s with handler %s results in %d identical characters\n", myPath.c_str(), it->second, s);
leihen 12:ba81cc117fb6 39 if ((s == strlen(it->second)) && (s > match_ind)) {
leihen 12:ba81cc117fb6 40 match_ind = s;
leihen 12:ba81cc117fb6 41 bestMatch = it->first;
leihen 12:ba81cc117fb6 42 bestMatchExchange = it->second;
leihen 5:dc88012caef1 43 }
leihen 5:dc88012caef1 44 }
leihen 12:ba81cc117fb6 45
leihen 12:ba81cc117fb6 46 if (bestMatch != NULL) {
leihen 12:ba81cc117fb6 47 m_rootPath = bestMatch;
leihen 12:ba81cc117fb6 48 m_localPath = string(myPath).substr(strlen(bestMatchExchange));
leihen 12:ba81cc117fb6 49 }
leihen 12:ba81cc117fb6 50
leihen 5:dc88012caef1 51 handleRequest();
leihen 5:dc88012caef1 52 }
leihen 5:dc88012caef1 53
leihen 5:dc88012caef1 54 HTTPFsRequestHandler::~HTTPFsRequestHandler()
leihen 5:dc88012caef1 55 {
leihen 5:dc88012caef1 56 }
leihen 5:dc88012caef1 57
leihen 5:dc88012caef1 58 int HTTPFsRequestHandler::handleGetRequest()
leihen 5:dc88012caef1 59 {
leihen 12:ba81cc117fb6 60 HTTPHeaders headers;
leihen 12:ba81cc117fb6 61
leihen 12:ba81cc117fb6 62 if (m_localPath.length() > 4)
leihen 12:ba81cc117fb6 63 getStandardHeaders(headers, m_localPath.substr(m_localPath.length()-4).c_str());
leihen 12:ba81cc117fb6 64 else
leihen 12:ba81cc117fb6 65 getStandardHeaders(headers);
leihen 12:ba81cc117fb6 66
leihen 12:ba81cc117fb6 67 INFO("Handling Get Request (root = %s, local = %s).", m_rootPath.c_str(), m_localPath.c_str());
leihen 5:dc88012caef1 68 int retval = 0; //success
leihen 5:dc88012caef1 69 std::string reqPath;
leihen 5:dc88012caef1 70
leihen 5:dc88012caef1 71 // Check if we received a directory with the local bath
leihen 5:dc88012caef1 72 if ((m_localPath.length() == 0) || (m_localPath.substr( m_localPath.length()-1, 1) == "/")) {
leihen 5:dc88012caef1 73 // yes, we shall append the default page name
leihen 5:dc88012caef1 74 m_localPath += "index.html";
leihen 5:dc88012caef1 75 }
leihen 5:dc88012caef1 76
leihen 5:dc88012caef1 77 reqPath = m_rootPath + m_localPath;
leihen 5:dc88012caef1 78
leihen 5:dc88012caef1 79 INFO("Mapping \"%s\" to \"%s\"", msg.uri.c_str(), reqPath.c_str());
leihen 5:dc88012caef1 80
leihen 5:dc88012caef1 81 FILE *fp = fopen(reqPath.c_str(), "r");
leihen 5:dc88012caef1 82 if (fp != NULL) {
leihen 12:ba81cc117fb6 83 char * pBuffer = NULL;
leihen 12:ba81cc117fb6 84 int sz = 8192;
leihen 12:ba81cc117fb6 85 while( pBuffer == NULL) {
leihen 12:ba81cc117fb6 86 sz /= 2;
leihen 12:ba81cc117fb6 87 pBuffer = (char*)malloc(sz);
leihen 12:ba81cc117fb6 88 if (sz < 128)
leihen 12:ba81cc117fb6 89 error ("OutOfMemory");
leihen 12:ba81cc117fb6 90 }
leihen 12:ba81cc117fb6 91
leihen 5:dc88012caef1 92 // File was found and can be returned
leihen 5:dc88012caef1 93
leihen 5:dc88012caef1 94 // first determine the size
leihen 5:dc88012caef1 95 fseek(fp, 0, SEEK_END);
leihen 5:dc88012caef1 96 long size = ftell(fp);
leihen 5:dc88012caef1 97 fseek(fp, 0, SEEK_SET);
leihen 5:dc88012caef1 98
leihen 5:dc88012caef1 99 startResponse(200, size);
leihen 5:dc88012caef1 100 while(!feof(fp) && !ferror(fp)) {
leihen 12:ba81cc117fb6 101 int cnt = fread(pBuffer, 1, sz , fp);
leihen 7:cb7fec1265b5 102 if (cnt < 0)
leihen 7:cb7fec1265b5 103 cnt = 0;
leihen 12:ba81cc117fb6 104 processResponse(cnt, pBuffer);
leihen 5:dc88012caef1 105 }
leihen 12:ba81cc117fb6 106 delete pBuffer;
leihen 5:dc88012caef1 107 endResponse();
leihen 5:dc88012caef1 108 fclose(fp);
leihen 5:dc88012caef1 109 }
leihen 5:dc88012caef1 110 else {
leihen 5:dc88012caef1 111 retval = 404;
leihen 5:dc88012caef1 112 ERR("Requested file was not found !");
leihen 5:dc88012caef1 113 }
leihen 5:dc88012caef1 114
leihen 5:dc88012caef1 115 return retval;
leihen 5:dc88012caef1 116 }
leihen 5:dc88012caef1 117
leihen 5:dc88012caef1 118 int HTTPFsRequestHandler::handlePostRequest()
leihen 5:dc88012caef1 119 {
leihen 5:dc88012caef1 120 return 404;
leihen 5:dc88012caef1 121 }
leihen 5:dc88012caef1 122
leihen 5:dc88012caef1 123 int HTTPFsRequestHandler::handlePutRequest()
leihen 5:dc88012caef1 124 {
leihen 5:dc88012caef1 125 return 404;
leihen 5:dc88012caef1 126 }