C#监听服务

控制台应用程序

class Program
    {
        static void Main(string[] args)
        {
            HttpListenerService hls = new HttpListenerService();
            hls.OnStart(null);
            Console.WriteLine("按任意键退出...");
            Console.ReadLine();       
        }
    }

监听服务

internal class HttpListenerService
    {
        /// <summary>
        /// 构造函数
        /// </summary>
        public HttpListenerService() { }

        public void OnStart(string[] args)
        {
            Console.Title = "HTTP 监听服务！";
            //http listener
            System.Net.HttpListener httplistener = new System.Net.HttpListener();
            httplistener.Prefixes.Add("http://localhost:8855/data/sync/");
            httplistener.Prefixes.Add("http://localhost:8855/data/listen/");
            //httplistener.ExtendedProtectionSelectorDelegate += (o) =>
            //    {
            //        o.Headers["Server"] = "DTK-Server";
            //        return null;
            //    };
            try
            {
                httplistener.Start();
                //Handle(httplistener);
                System.Threading.ThreadPool.SetMinThreads(10, 3);
       
                System.Threading.ThreadPool.SetMaxThreads(1000, 512);

                //System.Threading.ThreadPool.QueueUserWorkItem((state) => { Handle((System.Net.HttpListener)state); }, httplistener);
                System.Threading.ThreadPool.QueueUserWorkItem((start) => { Handle(httplistener); });

                FluentConsole.Green.Line("API监听服务启动成功！");
            }
            catch (Exception ex)
            {
                FluentConsole.Red.Line(ex.Message);
                if (httplistener.IsListening)
                {
                    httplistener.Stop();
                }
            }
        }

        private void Handle(System.Net.HttpListener httpListener)
        {
            while (true)
            {
                System.Net.HttpListenerContext context = httpListener.GetContext();
                System.Net.HttpListenerRequest request = context.Request;
                //context.Response.Headers["Server"] = "DTK-Server";
                if (httpListener.IsListening && request != null)
                {
                    System.Net.HttpListenerResponse response = context.Response;
                    
                    if (request.RawUrl.IndexOf("/data/listen/") > -1)
                    {
                        for (int i = 0; i < 10; i++)
                        {
                            FluentConsole.Green.Line("请求成功>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>");
                            FluentConsole.Green.Line("-------------------------------<>---------------------------");
                        }
                    }
                }
            }
        }
    }