GitHub/netch
1
0
Fork 0
mirror of https://github.com/netchx/netch.git synced 2026-03-24 18:39:47 +08:00
Code Issues Packages Projects Releases Wiki Activity

Update PAC Http Server

Browse Source
This commit is contained in:
ChsBuffer
2021-03-01 22:30:22 +08:00
parent a5147e147e
commit 046079639e
4 changed files with 78 additions and 109 deletions
Download Patch File Download Diff File Expand all files Collapse all files

88
Netch/Utils/HttpProxyHandler/HttpWebServer.cs
View File

@@ -1,85 +1,67 @@
using System;
using System.Net;
using System.Text;
using System.Threading;
namespace Netch.Utils.HttpProxyHandler
{
public class HttpWebServer
{
private HttpListener? _listener;
private readonly Func<HttpListenerRequest, string>? _responderMethod;
private HttpListener? _listener;
public HttpWebServer(string[] prefixes, Func<HttpListenerRequest, string> method)
{
try
{
_listener = new HttpListener();
_listener = new HttpListener();
if (!HttpListener.IsSupported)
throw new NotSupportedException("Needs Windows XP SP2, Server 2003 or later.");
// URI prefixes are required, for example
// "http://localhost:8080/index/".
if (prefixes == null || prefixes.Length == 0)
throw new ArgumentException("prefixes");
// URI prefixes are required, for example
// "http://localhost:8080/index/".
if (prefixes == null || prefixes.Length == 0)
throw new ArgumentException("prefixes");
// A responder method is required
if (method == null)
throw new ArgumentException("method");
// A responder method is required
if (method == null)
throw new ArgumentException("method");
foreach (var s in prefixes)
_listener.Prefixes.Add(s);
foreach (var s in prefixes)
_listener.Prefixes.Add(s);
_responderMethod = method;
_listener.Start();
}
catch (Exception ex)
{
Logging.Error("HttpWebServer():" + ex.Message);
}
_responderMethod = method;
_listener.Start();
}
public HttpWebServer(Func<HttpListenerRequest, string> method, params string[] prefixes) : this(prefixes, method)
{
}
public void Run()
public void StartWaitingRequest()
{
ThreadPool.QueueUserWorkItem(o =>
Logging.Info("Webserver running...");
while (_listener?.IsListening ?? false)
{
Logging.Info("Webserver running...");
HttpListenerContext ctx;
try
{
while (_listener!.IsListening)
ThreadPool.QueueUserWorkItem(c =>
{
var ctx = (HttpListenerContext) c;
try
{
var rstr = _responderMethod!(ctx.Request);
var buf = Encoding.UTF8.GetBytes(rstr);
ctx.Response.StatusCode = 200;
ctx.Response.ContentType = "application/x-ns-proxy-autoconfig";
ctx.Response.ContentLength64 = buf.Length;
ctx.Response.OutputStream.Write(buf, 0, buf.Length);
}
catch
{
// ignored
}
finally
{
ctx.Response.OutputStream.Close();
}
},
_listener.GetContext());
ctx = _listener.GetContext();
}
catch (Exception ex)
catch
{
Logging.Error(ex.Message);
break;
}
});
try
{
var rstr = _responderMethod!(ctx.Request);
var buf = Encoding.UTF8.GetBytes(rstr);
ctx.Response.StatusCode = 200;
ctx.Response.ContentType = "application/x-ns-proxy-autoconfig";
ctx.Response.ContentLength64 = buf.Length;
ctx.Response.OutputStream.Write(buf, 0, buf.Length);
}
finally
{
ctx.Response.OutputStream.Close();
}
}
}
public void Stop()