ASP.NET一个简易的WebServer,用控制台程序模拟IIS 托起web服务

Posted 2020-09-18

     ProcessRequestHandler( page,  query, TextWriter writer);      WebServer : MarshalByRefObject, IRegisteredObject
    {          ProcessRequest( page,  query, TextWriter writer)
        {
            SimpleWorkerRequest worker =  SimpleWorkerRequest(page, query, writer);

            HttpRuntime.ProcessRequest(worker);
        }          Stop( immediate)
        {
            HostingEnvironment.UnregisterObject();
        }
    }      SimpleHttpListener
    {
        ProcessRequestHandler ProcessRequest;          SetProcessRequest(ProcessRequestHandler handler)
        {            .ProcessRequest = handler;
        }          PhysicRoot = .Empty;
         public void Run()
        {
            if (!HttpListener.IsSupported)
                throw new InvalidOperationException("使用 HttpListener 必须为 Windows XP SP2 或 Server 2003 以上系统！");
            string[] prefixes = new string[] { "http://localhost:49152/" };
            HttpListener listener = new HttpListener();
            foreach (string item in prefixes)
            {
                listener.Prefixes.Add(item);
            }
            listener.Start();
            Console.WriteLine("开始监听.....");
            while (true)
            {
                HttpListenerContext context = listener.GetContext();
                HttpListenerRequest request = context.Request;
                Console.WriteLine("{0} {1} HTTP/1.1", request.HttpMethod, request.RawUrl);
                HttpListenerResponse response = context.Response;
                using (StreamWriter writer = new StreamWriter(response.OutputStream))
                {
                    StringWriter sw = new StringWriter();
                    string content = string.Empty;
                    string filename = request.Url.LocalPath.ToLower();
                    Regex reg = new Regex("(.aspx|.ashx|.svc|.asmx)");
                    Match m = reg.Match(filename);
                    if (m.Success)
                    {
                        string path = request.Url.AbsolutePath;
                        string query = request.Url.Query.Replace("?", string.Empty);
                        string prefx = m.Groups[0].Value;
                        if (!filename.EndsWith(prefx))
                        {
                            int index = path.IndexOf(prefx);
                            index = index + prefx.Length;
                            query = path.Substring(index);
                            path = path.Substring(0, index);

                        }
                        path = Path.GetFileName(path);
                        this.ProcessRequest(path, query, sw);
                        content = sw.ToString();
                        sw.Close();

                        response.ContentLength64 = Encoding.UTF8.GetByteCount(content);
                        response.ContentType = "text/html; charset=UTF-8";
                        writer.Write(content);
                    }

                    else
                    {
                        string filePath = Path.Combine(PhysicRoot, request.Url.AbsolutePath.Substring(1));
                        lock (this)
                        {
                            byte[] buffer = new byte[4096];
                            if (File.Exists(filePath))
                            {
                                using (StreamReader sr = new StreamReader(filePath))
                                {
                                    response.ContentLength64 = sr.BaseStream.Length;
                                    int readLength = sr.BaseStream.Read(buffer, 0, buffer.Length);
                                    while (readLength > 0)
                                    {
                                        writer.BaseStream.Write(buffer, 0, readLength);
                                        readLength = sr.BaseStream.Read(buffer, 0, buffer.Length);
                                    }
                                }
                            }
                            else
                            {
                                string msg = "not found:" + filePath;
                                byte[] data = Encoding.UTF8.GetBytes(msg);
                                writer.BaseStream.Write(data, 0, data.Length);
                            }
                        }

                    }
                    Console.WriteLine("\r\nProcess Ok.\r\n");
                }
                if (Console.KeyAvailable)
                    break;
            }
            listener.Stop();

        }           Start()
        {
            PhysicRoot = ;
            WebServer server = CreateWorkerAppDomainWithHost((WebServer), , PhysicRoot)  WebServer;            
            SimpleHttpListener listener =  SimpleHttpListener();
            listener.SetProcessRequest(server.ProcessRequest);
            listener.Run();
        }          CreateWorkerAppDomainWithHost(Type hostType,  virtualPath,  physicalPath)
        {             uniqueAppString = .Concat(virtualPath, physicalPath).ToLowerInvariant();             appid = (uniqueAppString.GetHashCode()).ToString(, CultureInfo.InvariantCulture);             appmanager = ApplicationManager.GetApplicationManager();             buildManagerHostType = (HttpRuntime).Assembly.GetType();             buildManagerHost = appmanager.CreateObject(appid, buildManagerHostType, virtualPath, physicalPath, );
            buildManagerHostType.InvokeMember(, BindingFlags.Instance | BindingFlags.InvokeMethod | BindingFlags.NonPublic, , buildManagerHost,  [] { hostType.Assembly.FullName, hostType.Assembly.Location });             appmanager.CreateObject(appid, hostType, virtualPath, physicalPath, );
        }
    }