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:
Sun May 26 22:49:42 2013 +0000
Revision:
1:6b7472d5e9ee
Parent:
0:7a2421e63e74
Child:
2:8653bbcf7e58
Basic functionality demonstrated. One issue exists with error pages, which does not work 100%
;

Who changed what in which revision?

UserRevisionLine numberNew contents of line
leihen 0:7a2421e63e74 1 #include "mbed.h"
leihen 0:7a2421e63e74 2 #include "HTTPServer.h"
leihen 0:7a2421e63e74 3
leihen 0:7a2421e63e74 4 DigitalOut led1(LED1);
leihen 0:7a2421e63e74 5 DigitalOut led2(LED2);
leihen 0:7a2421e63e74 6 DigitalOut led3(LED3);
leihen 0:7a2421e63e74 7 DigitalOut led4(LED4);
leihen 0:7a2421e63e74 8
leihen 1:6b7472d5e9ee 9 #if (0 && !defined(TARGET_LPC11U24))
leihen 0:7a2421e63e74 10 #define INFO(x, ...) if (m_pDbg) m_pDbg->printf("[HttpServer : DBG]"x"\r\n", ##__VA_ARGS__); else printf("[HttpServer : DBG]"x"\r\n", ##__VA_ARGS__);
leihen 0:7a2421e63e74 11 #define WARN(x, ...) if (m_pDbg) m_pDbg->printf("[HttpServer : WARN]"x"\r\n", ##__VA_ARGS__); else printf("[HttpServer : DBG]"x"\r\n", ##__VA_ARGS__);
leihen 0:7a2421e63e74 12 #define ERR(x, ...) if (m_pDbg) m_pDbg->printf("[HttpServer : ERR]"x"\r\n", ##__VA_ARGS__); else printf("[HttpServer : DBG]"x"\r\n", ##__VA_ARGS__);
leihen 0:7a2421e63e74 13 #else
leihen 0:7a2421e63e74 14 #define INFO(x, ...)
leihen 0:7a2421e63e74 15 #define WARN(x, ...)
leihen 0:7a2421e63e74 16 #define ERR(x, ...)
leihen 0:7a2421e63e74 17 #endif
leihen 0:7a2421e63e74 18
leihen 1:6b7472d5e9ee 19 static const char* szMsgs = "No such file or folder.";
leihen 0:7a2421e63e74 20
leihen 0:7a2421e63e74 21 HTTPServer::HTTPServer(Serial* pDbg)
leihen 0:7a2421e63e74 22 {
leihen 0:7a2421e63e74 23 m_pDbg = pDbg;
leihen 0:7a2421e63e74 24 m_pSvr = NULL;
leihen 0:7a2421e63e74 25 m_bServerListening = false;
leihen 0:7a2421e63e74 26 }
leihen 0:7a2421e63e74 27
leihen 0:7a2421e63e74 28 HTTPServer::~HTTPServer()
leihen 0:7a2421e63e74 29 {
leihen 0:7a2421e63e74 30 if (m_pSvr) {
leihen 0:7a2421e63e74 31 delete m_pSvr;
leihen 0:7a2421e63e74 32 m_pSvr = NULL;
leihen 0:7a2421e63e74 33 m_bServerListening = false;
leihen 0:7a2421e63e74 34 }
leihen 0:7a2421e63e74 35 }
leihen 0:7a2421e63e74 36
leihen 0:7a2421e63e74 37 int HTTPServer::start(int port)
leihen 0:7a2421e63e74 38 {
leihen 0:7a2421e63e74 39 // check if the start member was called already once
leihen 0:7a2421e63e74 40 if (m_pSvr != NULL) {
leihen 0:7a2421e63e74 41 ERR("start function was already called, server is already in listening state.");
leihen 0:7a2421e63e74 42 return -1;
leihen 0:7a2421e63e74 43 }
leihen 0:7a2421e63e74 44
leihen 0:7a2421e63e74 45 m_bServerListening = false;
leihen 0:7a2421e63e74 46
leihen 0:7a2421e63e74 47 // Create a new server object
leihen 0:7a2421e63e74 48 m_pSvr = new TCPSocketServer();
leihen 0:7a2421e63e74 49
leihen 0:7a2421e63e74 50 // Bind the local server to the given port
leihen 0:7a2421e63e74 51 if (m_pSvr->bind(port) < 0) {
leihen 0:7a2421e63e74 52 ERR("Failed to bind to port %d\n", port);
leihen 0:7a2421e63e74 53 return -1;
leihen 0:7a2421e63e74 54 }
leihen 0:7a2421e63e74 55 else {
leihen 0:7a2421e63e74 56 INFO("Binding succeeded !\n");
leihen 0:7a2421e63e74 57 }
leihen 0:7a2421e63e74 58
leihen 0:7a2421e63e74 59 // Listen to a maximum of 10 concurrent connections
leihen 0:7a2421e63e74 60 if (m_pSvr->listen(1) < 0) {
leihen 0:7a2421e63e74 61 ERR("Faild to listen !\n");
leihen 0:7a2421e63e74 62 delete m_pSvr;
leihen 0:7a2421e63e74 63 m_pSvr = NULL;
leihen 0:7a2421e63e74 64 return -1;
leihen 0:7a2421e63e74 65 }
leihen 0:7a2421e63e74 66 else {
leihen 0:7a2421e63e74 67 INFO("Listening\n");
leihen 0:7a2421e63e74 68 m_bServerListening = true;
leihen 0:7a2421e63e74 69 }
leihen 0:7a2421e63e74 70
leihen 0:7a2421e63e74 71 // set into non blocking operation
leihen 0:7a2421e63e74 72 m_pSvr->set_blocking(false, 100);
leihen 0:7a2421e63e74 73
leihen 0:7a2421e63e74 74 return 0;
leihen 0:7a2421e63e74 75 }
leihen 0:7a2421e63e74 76
leihen 0:7a2421e63e74 77
leihen 0:7a2421e63e74 78 int HTTPServer::poll()
leihen 0:7a2421e63e74 79 {
leihen 0:7a2421e63e74 80 INFO("Listening for new connection requests.");
leihen 0:7a2421e63e74 81
leihen 0:7a2421e63e74 82 // This thread basically checks if there is a new incoming connection.
leihen 0:7a2421e63e74 83 // If so , a new HTTPConnection is created and the connection thread is started.
leihen 0:7a2421e63e74 84 TCPSocketConnection Clnt;
leihen 0:7a2421e63e74 85
leihen 0:7a2421e63e74 86 led4 = 1; // Indicate we are waiting for a new connection
leihen 0:7a2421e63e74 87 if (m_pSvr->accept(Clnt) < 0) {
leihen 0:7a2421e63e74 88 // an error occured
leihen 0:7a2421e63e74 89 ERR("There was an error, Accept returned with an error. Probably the connection to the router was lost. Shutting down server");
leihen 0:7a2421e63e74 90 led2 = 0;
leihen 0:7a2421e63e74 91 m_bServerListening = false;
leihen 0:7a2421e63e74 92 m_pSvr->close();
leihen 0:7a2421e63e74 93 delete m_pSvr;
leihen 0:7a2421e63e74 94 m_pSvr = NULL;
leihen 0:7a2421e63e74 95 led4 = 0;
leihen 0:7a2421e63e74 96 led3 = 1; // ERROR
leihen 0:7a2421e63e74 97 led2 = 0;
leihen 0:7a2421e63e74 98 led1 = 0;
leihen 0:7a2421e63e74 99 return -1;
leihen 0:7a2421e63e74 100 }
leihen 0:7a2421e63e74 101 else {
leihen 0:7a2421e63e74 102 led4 = 0;
leihen 0:7a2421e63e74 103 // a new connection was received
leihen 0:7a2421e63e74 104 INFO("Client (IP=%s) is connected !\n", Clnt.get_address());
leihen 0:7a2421e63e74 105 // Start the main connection thread
leihen 0:7a2421e63e74 106 led3 = 1;
leihen 0:7a2421e63e74 107 led2 = 1;
leihen 0:7a2421e63e74 108 HTTPConnection con;
leihen 0:7a2421e63e74 109 int c = con.poll();
leihen 0:7a2421e63e74 110 if (c == 0) {
leihen 1:6b7472d5e9ee 111 // Handle the request
leihen 1:6b7472d5e9ee 112 HandleRequest(con.m_Msg, Clnt);
leihen 0:7a2421e63e74 113 }
leihen 0:7a2421e63e74 114 led2 = 0;
leihen 0:7a2421e63e74 115 led3 = 0;
leihen 0:7a2421e63e74 116 }
leihen 0:7a2421e63e74 117
leihen 0:7a2421e63e74 118 INFO("Leaving polling thread");
leihen 0:7a2421e63e74 119 return 0;
leihen 1:6b7472d5e9ee 120 }
leihen 1:6b7472d5e9ee 121
leihen 1:6b7472d5e9ee 122 void HTTPServer::HandleRequest(HTTPMessage& msg, TCPSocketConnection& tcp)
leihen 1:6b7472d5e9ee 123 {
leihen 1:6b7472d5e9ee 124 static char echoHeader[256] = {};
leihen 1:6b7472d5e9ee 125 static const char* szPage = {
leihen 1:6b7472d5e9ee 126 "<HTML>\r\n"
leihen 1:6b7472d5e9ee 127 "<HEAD>\r\n"
leihen 1:6b7472d5e9ee 128 "<META content=\"text/html\" http-equiv=Content-Type>\r\n"
leihen 1:6b7472d5e9ee 129 "</HEAD>\r\n"
leihen 1:6b7472d5e9ee 130 "<BODY>\r\n"
leihen 1:6b7472d5e9ee 131 "<h1>ERROR 404</h1>\r\n"
leihen 1:6b7472d5e9ee 132 "<P>File not found<P>\r\n"
leihen 1:6b7472d5e9ee 133 "</BODY>\r\n"
leihen 1:6b7472d5e9ee 134 "</HTML>\r\n\r\n"};
leihen 1:6b7472d5e9ee 135
leihen 1:6b7472d5e9ee 136 map<string, HTTPRequestHandlerFunction>::iterator it;
leihen 1:6b7472d5e9ee 137
leihen 1:6b7472d5e9ee 138 it = m_pHandlers.find(msg.uri);
leihen 1:6b7472d5e9ee 139
leihen 1:6b7472d5e9ee 140 if (it == m_pHandlers.end()) {
leihen 1:6b7472d5e9ee 141 // There is no such handler, so return invalid
leihen 1:6b7472d5e9ee 142
leihen 1:6b7472d5e9ee 143 tcp.set_blocking(true, 1500);
leihen 1:6b7472d5e9ee 144 sprintf(echoHeader,"HTTP/1.1 404 Fail\r\nContent-Length: %d\r\nContent-Type: text/html\r\nServer: mbed embedded\r\nConnection: Close\r\n\r\n",strlen(szPage));
leihen 1:6b7472d5e9ee 145 tcp.send(echoHeader,strlen(echoHeader));
leihen 1:6b7472d5e9ee 146 tcp.send((char*)szPage,strlen(szMsgs));
leihen 1:6b7472d5e9ee 147 INFO("Webrequest left unhandled.");
leihen 1:6b7472d5e9ee 148 }
leihen 1:6b7472d5e9ee 149 else {
leihen 1:6b7472d5e9ee 150 // Handler was found so pass action to handler
leihen 1:6b7472d5e9ee 151 INFO("Routing webrequest !");
leihen 1:6b7472d5e9ee 152 (it->second)(msg, tcp);
leihen 1:6b7472d5e9ee 153 }
leihen 0:7a2421e63e74 154 }