Skip to content

Instantly share code, notes, and snippets.

@RickStrahl
Created January 11, 2022 23:35
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save RickStrahl/810de799ac33e8eba011f96f5e611c02 to your computer and use it in GitHub Desktop.
Save RickStrahl/810de799ac33e8eba011f96f5e611c02 to your computer and use it in GitHub Desktop.
A simple .NET HttpListener implementation of a basic static Web Server on Windows
using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.Net.Sockets;
using System.Net;
using System.IO;
using System.Threading;
namespace Westwind.Http.Server
{
/// <summary>
/// A simple self-contained static file Web Server that can be
/// launched in a folder with a port and serve static files
/// from that folder. Very basic features but easy to integrate.
/// </summary>
/// <example>
/// StartHttpServerOnThread(@"c:\temp\http",8080);
/// ...
/// StopHttpServerOnThread();
/// </example>
/// <remarks>
/// Based heavily on this Gist:
/// https://gist.github.com/aksakalli/9191056
///
/// Additions to make it easier to host server inside of an
/// external, non-.NET application.
///</remarks>
public class SimpleHttpServer
{
public string[] DefaultDocuments =
{
"index.html",
"index.htm",
"default.html",
"default.htm"
};
public static SimpleHttpServer Current;
/// <summary>
/// This method can be used externally to start a singleton instance of
/// the Web Server and keep it running without tracking a reference.
///
/// If a server instance is already running it's shut down.
/// </summary>
/// <param name="path"></param>
/// <param name="port"></param>
/// <param name="requestHandler">
/// Optional parameter of an object that has a Process method that gets passed a context
/// and returns true if the request is handled or false if default processing should occur
/// </param>
public static bool StartHttpServerOnThread(string path, int port=8080, object requestHandler = null, bool verbose = false)
{
// make sure we're not already running
if(Current != null)
Current.Stop();
try
{
// see if we can access the port
TcpListener listener = new TcpListener(IPAddress.Loopback,port);
listener.Start();
listener.Stop();
}
catch (Exception ex)
{
return false;
}
var t = new Thread(StartHttpServerThread);
t.SetApartmentState(ApartmentState.STA);
t.Start(new ServerStartParameters {Path = path, Port = port, RequestHandler = requestHandler, Verbose = verbose });
return true;
}
/// <summary>
/// Call this method to stop the Singleton instance of the server.
/// </summary>
public static void StopHttpServerOnThread()
{
Current.Stop();
Current = null;
}
/// <summary>
/// Internal method that instantiates the server instance
/// </summary>
/// <param name="parms"></param>
private static string StartHttpServerThread(object parms)
{
try
{
if (Current != null)
StopHttpServerOnThread();
var httpParms = parms as ServerStartParameters;
Current = new SimpleHttpServer(httpParms.Path, httpParms.Port)
{
Verbose = httpParms.Verbose
};
Current.RequestHandler = httpParms.RequestHandler;
}
catch (Exception ex)
{
return ex.GetBaseException().Message;
}
return null;
}
/// <summary>
/// Registers an HTTP Port so it can be accessed locally. Otherwise you'll get an
/// error when the server tries to launch.
/// </summary>
/// <param name="path">The Web Server relative path</param>
/// <param name="port">The Web Server port</param>
public static bool RegisterHttpPort(int port, string path="/", string username = "Interactive")
{
if (string.IsNullOrEmpty(path))
path = "/";
var si = new ProcessStartInfo()
{
FileName = "netsh.exe",
Arguments = "http add urlacl url=\"http://*:" + port + $"{path}\" user={username}",
WindowStyle = ProcessWindowStyle.Hidden,
Verb = "runas"
};
var process = System.Diagnostics.Process.Start(si);
process.WaitForExit();
return process.ExitCode == 0;
}
/// <summary>
/// Unregister an HTTP port
/// </summary>
/// <param name="port"></param>
/// <param name="path"></param>
/// <returns></returns>
public static bool UnregisterHttpPort(int port, string path ="/")
{
var si = new ProcessStartInfo()
{
FileName = "netsh.exe",
Arguments = "http delete urlacl url=\"http://*:" + port + $"{path}\"",
WindowStyle = ProcessWindowStyle.Hidden,
Verb = "runas"
};
var process = System.Diagnostics.Process.Start(si);
process.WaitForExit();
return process.ExitCode == 0;
}
/// <summary>
/// Mime Type conversion table
/// </summary>
private static IDictionary<string, string> _mimeTypeMappings =
new Dictionary<string, string>(StringComparer.InvariantCultureIgnoreCase)
{
#region extension to MIME type list
{".asf", "video/x-ms-asf"},
{".asx", "video/x-ms-asf"},
{".avi", "video/x-msvideo"},
{".bin", "application/octet-stream"},
{".cco", "application/x-cocoa"},
{".crt", "application/x-x509-ca-cert"},
{".css", "text/css"},
{".deb", "application/octet-stream"},
{".der", "application/x-x509-ca-cert"},
{".dll", "application/octet-stream"},
{".dmg", "application/octet-stream"},
{".ear", "application/java-archive"},
{".eot", "application/octet-stream"},
{".exe", "application/octet-stream"},
{".flv", "video/x-flv"},
{".gif", "image/gif"},
{".hqx", "application/mac-binhex40"},
{".htc", "text/x-component"},
{".htm", "text/html"},
{".html", "text/html"},
{".ico", "image/x-icon"},
{".img", "application/octet-stream"},
{".iso", "application/octet-stream"},
{".jar", "application/java-archive"},
{".jardiff", "application/x-java-archive-diff"},
{".jng", "image/x-jng"},
{".jnlp", "application/x-java-jnlp-file"},
{".jpeg", "image/jpeg"},
{".jpg", "image/jpeg"},
{".js", "application/x-javascript"},
{".mml", "text/mathml"},
{".mng", "video/x-mng"},
{".mov", "video/quicktime"},
{".mp3", "audio/mpeg"},
{".mpeg", "video/mpeg"},
{".mpg", "video/mpeg"},
{".msi", "application/octet-stream"},
{".msm", "application/octet-stream"},
{".msp", "application/octet-stream"},
{".pdb", "application/x-pilot"},
{".pdf", "application/pdf"},
{".pem", "application/x-x509-ca-cert"},
{".pl", "application/x-perl"},
{".pm", "application/x-perl"},
{".png", "image/png"},
{".prc", "application/x-pilot"},
{".ra", "audio/x-realaudio"},
{".rar", "application/x-rar-compressed"},
{".rpm", "application/x-redhat-package-manager"},
{".rss", "text/xml"},
{".run", "application/x-makeself"},
{".sea", "application/x-sea"},
{".shtml", "text/html"},
{".sit", "application/x-stuffit"},
{".svg", "image/svg+xml" },
{".swf", "application/x-shockwave-flash"},
{".tcl", "application/x-tcl"},
{".tk", "application/x-tcl"},
{".txt", "text/plain"},
{".war", "application/java-archive"},
{".wbmp", "image/vnd.wap.wbmp"},
{".wmv", "video/x-ms-wmv"},
{".woff", "application/font-woff"},
{".woff2", "application/font-woff2"},
{".xml", "text/xml"},
{".xpi", "application/x-xpinstall"},
{".zip", "application/zip"}
#endregion
};
private Thread _serverThread;
private string _rootDirectory;
private HttpListener _listener;
private int _port;
public int Port
{
get { return _port; }
}
public bool Verbose { get; set; }
/// <summary>
/// Instance of an object whose Process() method is called on each request.
/// Return true if the reuqest is handled, fase if it's not.
/// </summary>
public object RequestHandler { get; set; }
/// <summary>
/// Construct server with given port.
/// </summary>
/// <param name="path">Directory path to serve.</param>
/// <param name="port">Port of the server.</param>
public SimpleHttpServer(string path, int port = 8080)
{
Initialize(path, port);
}
/// <summary>
/// Construct server with an available port.
/// </summary>
/// <param name="path">Directory path to serve.</param>
public SimpleHttpServer(string path)
{
// Find an open port and bind to it
TcpListener listener = new TcpListener(IPAddress.Loopback, 0);
listener.Start();
int port = ((IPEndPoint) listener.LocalEndpoint).Port;
listener.Stop();
Initialize(path, port);
}
/// <summary>
/// Stop server and dispose all functions.
/// </summary>
public void Stop()
{
_serverThread.Abort();
_listener.Stop();
}
/// <summary>
/// Internal Handler
/// </summary>
private void Listen()
{
try
{
_listener = new HttpListener();
_listener.Prefixes.Add("http://*:" + _port + "/");
_listener.Start();
}
catch (Exception ex)
{
return;
}
while (true)
{
try
{
HttpListenerContext context = _listener.GetContext();
Process(context);
}
catch (Exception ex)
{
}
}
}
/// <summary>
/// Process an individual request. Handles only static file based requests
/// </summary>
/// <param name="context"></param>
private void Process(HttpListenerContext context)
{
string filename = context.Request.Url.LocalPath?.Replace("/","\\");
if (Verbose)
Console.WriteLine(context.Request.HttpMethod + " " + filename);
if (RequestHandler != null)
{
// if true is returned request is handled - exit
if ((bool) ReflectionUtils.CallMethodCom(RequestHandler, "Process", context))
return;
}
filename = filename.Substring(1);
if (string.IsNullOrEmpty(filename))
{
foreach (string indexFile in DefaultDocuments)
{
if (File.Exists(Path.Combine(_rootDirectory, indexFile)))
{
filename = indexFile;
break;
}
}
}
filename = Path.Combine(_rootDirectory, filename);
if (File.Exists(filename))
{
try
{
Stream input = new FileStream(filename, FileMode.Open);
//Adding permanent http response headers
string mime;
context.Response.ContentType = _mimeTypeMappings.TryGetValue(Path.GetExtension(filename), out mime)
? mime
: "application/octet-stream";
context.Response.ContentLength64 = input.Length;
context.Response.AddHeader("Date", DateTime.Now.ToString("r"));
context.Response.AddHeader("Last-Modified", File.GetLastWriteTime(filename).ToString("r"));
byte[] buffer = new byte[1024*32];
int nbytes;
while ((nbytes = input.Read(buffer, 0, buffer.Length)) > 0)
context.Response.OutputStream.Write(buffer, 0, nbytes);
input.Close();
context.Response.OutputStream.Flush();
context.Response.StatusCode = (int) HttpStatusCode.OK;
}
catch (Exception ex)
{
context.Response.StatusCode = (int) HttpStatusCode.InternalServerError;
}
}
else
{
context.Response.StatusCode = (int) HttpStatusCode.NotFound;
}
context.Response.OutputStream.Close();
}
private void Initialize(string path, int port)
{
_rootDirectory = path;
_port = port;
_serverThread = new Thread(Listen);
_serverThread.Start();
}
}
/// <summary>
/// Parameters thatr are passed to the thread method
/// </summary>
public class ServerStartParameters
{
public string Path { get; set; }
public int Port { get; set; }
public bool Verbose { get; set; }
/// <summary>
/// Any object that implements a Process method
/// method should return true (request is handled)
/// or false (to fall through and handle as files)
/// </summary>
public object RequestHandler { get; set; }
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment