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 Jun 01 17:47:45 2013 +0000
Revision:
7:cb7fec1265b5
Parent:
5:dc88012caef1
Child:
9:c2a1462b9b71
Fixed a Problem with incorrect HttpBody size when returning GET Request data.
; Fixed incorrect variable size for returned data, which led to a Problem when returned data length exceeds 65535 Bytes.

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 5:dc88012caef1 4
leihen 5:dc88012caef1 5
leihen 5:dc88012caef1 6 #define _DEBUG 1
leihen 5:dc88012caef1 7
leihen 5:dc88012caef1 8 #if (_DEBUG && !defined(TARGET_LPC11U24))
leihen 5:dc88012caef1 9 #define INFO(x, ...) std::printf("[HTTPFsRequestHandler : DBG]"x"\r\n", ##__VA_ARGS__);
leihen 5:dc88012caef1 10 #define WARN(x, ...) std::printf("[HTTPFsRequestHandler : DBG]"x"\r\n", ##__VA_ARGS__);
leihen 5:dc88012caef1 11 #define ERR(x, ...) std::printf("[HTTPFsRequestHandler : DBG]"x"\r\n", ##__VA_ARGS__);
leihen 5:dc88012caef1 12 #else
leihen 5:dc88012caef1 13 #define INFO(x, ...)
leihen 5:dc88012caef1 14 #define WARN(x, ...)
leihen 5:dc88012caef1 15 #define ERR(x, ...)
leihen 5:dc88012caef1 16 #endif
leihen 5:dc88012caef1 17
leihen 5:dc88012caef1 18
leihen 7:cb7fec1265b5 19 #define MAX_BUFFERSIZE 512
leihen 5:dc88012caef1 20 static char buffer[MAX_BUFFERSIZE];
leihen 5:dc88012caef1 21
leihen 5:dc88012caef1 22
leihen 5:dc88012caef1 23 std::map<const char*, const char*> HTTPFsRequestHandler::m_fsMap;
leihen 5:dc88012caef1 24
leihen 5:dc88012caef1 25 HTTPFsRequestHandler::HTTPFsRequestHandler(const char* rootPath, const char* localPath, HTTPConnection::HTTPMessage& Msg, TCPSocketConnection& Tcp)
leihen 5:dc88012caef1 26 : HTTPRequestHandler(Msg, Tcp)
leihen 5:dc88012caef1 27 {
leihen 5:dc88012caef1 28 m_rootPath = rootPath;
leihen 5:dc88012caef1 29 m_localPath = localPath;
leihen 5:dc88012caef1 30
leihen 5:dc88012caef1 31 // Now replace the virtual root path with a mounted device path
leihen 5:dc88012caef1 32 std::map<const char*, const char*>::iterator it;
leihen 5:dc88012caef1 33 for (it = m_fsMap.begin() ; it != m_fsMap.end() ; it++) {
leihen 5:dc88012caef1 34 // find best match (if the given logical path is containted in the root
leihen 5:dc88012caef1 35 if (m_rootPath.find( it->second ) == 0) {
leihen 5:dc88012caef1 36 m_rootPath = it->first;
leihen 5:dc88012caef1 37 break;
leihen 5:dc88012caef1 38 }
leihen 5:dc88012caef1 39 }
leihen 5:dc88012caef1 40
leihen 5:dc88012caef1 41 handleRequest();
leihen 5:dc88012caef1 42 }
leihen 5:dc88012caef1 43
leihen 5:dc88012caef1 44 HTTPFsRequestHandler::~HTTPFsRequestHandler()
leihen 5:dc88012caef1 45 {
leihen 5:dc88012caef1 46 }
leihen 5:dc88012caef1 47
leihen 5:dc88012caef1 48 int HTTPFsRequestHandler::handleGetRequest()
leihen 5:dc88012caef1 49 {
leihen 5:dc88012caef1 50 INFO("Handling Get Request.");
leihen 5:dc88012caef1 51 int retval = 0; //success
leihen 5:dc88012caef1 52 std::string reqPath;
leihen 5:dc88012caef1 53
leihen 5:dc88012caef1 54 // Check if we received a directory with the local bath
leihen 5:dc88012caef1 55 if ((m_localPath.length() == 0) || (m_localPath.substr( m_localPath.length()-1, 1) == "/")) {
leihen 5:dc88012caef1 56 // yes, we shall append the default page name
leihen 5:dc88012caef1 57 m_localPath += "index.html";
leihen 5:dc88012caef1 58 }
leihen 5:dc88012caef1 59
leihen 5:dc88012caef1 60 reqPath = m_rootPath + m_localPath;
leihen 5:dc88012caef1 61
leihen 5:dc88012caef1 62 INFO("Mapping \"%s\" to \"%s\"", msg.uri.c_str(), reqPath.c_str());
leihen 5:dc88012caef1 63
leihen 5:dc88012caef1 64 FILE *fp = fopen(reqPath.c_str(), "r");
leihen 5:dc88012caef1 65 if (fp != NULL) {
leihen 5:dc88012caef1 66 // File was found and can be returned
leihen 5:dc88012caef1 67
leihen 5:dc88012caef1 68 // first determine the size
leihen 5:dc88012caef1 69 fseek(fp, 0, SEEK_END);
leihen 5:dc88012caef1 70 long size = ftell(fp);
leihen 5:dc88012caef1 71 fseek(fp, 0, SEEK_SET);
leihen 5:dc88012caef1 72
leihen 5:dc88012caef1 73 startResponse(200, size);
leihen 5:dc88012caef1 74 while(!feof(fp) && !ferror(fp)) {
leihen 5:dc88012caef1 75 int cnt = fread(buffer, 1, MAX_BUFFERSIZE , fp);
leihen 7:cb7fec1265b5 76 if (cnt < 0)
leihen 7:cb7fec1265b5 77 cnt = 0;
leihen 5:dc88012caef1 78 processResponse(cnt, buffer);
leihen 5:dc88012caef1 79 }
leihen 5:dc88012caef1 80 endResponse();
leihen 5:dc88012caef1 81 fclose(fp);
leihen 5:dc88012caef1 82 }
leihen 5:dc88012caef1 83 else {
leihen 5:dc88012caef1 84 retval = 404;
leihen 5:dc88012caef1 85 ERR("Requested file was not found !");
leihen 5:dc88012caef1 86 }
leihen 5:dc88012caef1 87
leihen 5:dc88012caef1 88 return retval;
leihen 5:dc88012caef1 89 }
leihen 5:dc88012caef1 90
leihen 5:dc88012caef1 91 int HTTPFsRequestHandler::handlePostRequest()
leihen 5:dc88012caef1 92 {
leihen 5:dc88012caef1 93 return 404;
leihen 5:dc88012caef1 94 }
leihen 5:dc88012caef1 95
leihen 5:dc88012caef1 96 int HTTPFsRequestHandler::handlePutRequest()
leihen 5:dc88012caef1 97 {
leihen 5:dc88012caef1 98 return 404;
leihen 5:dc88012caef1 99 }