01 // Hauptschleife von Webserver
02 HTTPServer::serve()
03 {
04     // Threads für die Verbindungen erzeugen
05     for (int i=0; i<NUM_THREADS; i++) {
06         createClientThread();
07     }
08 
09     int s = openTCPSocket(80); // auf Port 80 hören
10     int client;
11     while (true)
12     {
13         // Systemcall accept() wartet auf nächste Clientverbindung
14         client = accept(s);
15         // Filedescriptor in Warteschlange stopfen
16         pushConnection(client);
17     }
18 }
19 
20 
21 // Hauptschleife von Thread
22 ClientConnection::run()
23 {
24     while (!should_terminate)
25     {
26         // nächste Clientverbindung aus Warteschlange holen
27         // (blockiert, solange Warteschlange leer ist)
28         int fd = server->getConnection();
29 
30         // HTTP Header von Socket lesen und parsen
31         HTTPRequest request(fd);
32 
33         // HTML Objekt erzeugen zum Speichern des Ergebnisses
34         HTML html;
35 
36         // Seite von Engine berechnen lassen
37         engine->processRequest(request, html);
38 
39         // Ergebnis an Client zurückschreiben
40         writeHTTPHeader(request, fd);
41         write(fd, html.buffer(), html.length();
42 
43         // Verbindung zum Client schließen
44         close(fd);
45     }
46 }

01 Engine::processRequest(HTTPRequest &request, HTML &html)
02 {
03     // Dafür sorgen, dass nur ein Thread die Engine
04     // betritt (hier mit pthread-Mechanismen gelöst)
05     pthread_mutex_lock(&_mutex);
06 
07     // Kein Verzeichnis -> index.html
08     if (request.numDirs() == 0)
09         pageIndex(request, html);
10 
11     // 1. Pfadkomponente unterscheidet Art der Seite
12     else if (!strcmp(request.dir(0), "art"))
13         pageArticle(request, html); // Artikelseite
14 
15     else if (!strcmp(request.dir(0), "search"))
16         pageSearch(request, html); // Suchabfrage
17 
18     else
19         pageUnknown(request, html); // Unbekannte Seite
20 
21     // Zugang zur Engine wieder freigeben
22     pthread_mutex_unlock(&_mutex);
23 }
24 
25 
26 // Artikelseite, exemplarisch
27 Engine::pageArticle(HTTPRequest &request, HTML &html)
28 {
29     // Artikelnummer ist 2. Pfadkomponente, z.B. /art/1829/
30     int artid = atoi(request.dir(1));
31 
32     // Finde Artikel in Suchindex
33     Article *art = articleById(artid);
34     if (art) {
35         // HTML-Kopf mit Seitentitel erzeugen
36         html.addPageHeader(art->title()); // Titel des Artikels
37 
38         // Inhalt der Seite anhand der Daten aus dem Objekt art
39         html.add("Beschreibung: %s<br>n", art->description());
40         html.add("Anbieter: %s<br>n",     art->owner->fullname());
41 
42         // Seitenfuss und HTML-Abschlusscode
43         html.addPageFooter();
44     }
45     else // Artikel nicht gefunden
46         pageUnknown(request, html);
47 }