C#通过HttpListener实现HTTP监听

亦凉 2021-05-03 04:09 988阅读 1赞

using NLog;
    using System;
    using System.Diagnostics;
    using System.IO;
    using System.Net;
    using System.ServiceProcess;
    using System.Text;
    using System.Threading;
    using System.Web;
    using System.Xml;
    
    namespace MasterCardService
    {
        public partial class MainService : ServiceBase
        {
            private static Logger logger = LogManager.GetCurrentClassLogger();
            private HttpListener MyListerner;
    
            public MainService()
            {
                InitializeComponent();
            }
    
            public void DebugStart()
            {
                OnStart(null);
            }
    
            protected override void OnStart(string[] args)
            {
                MyListerner = new HttpListener();
                while (true)
                {
                    try
                    {
                        MyListerner.AuthenticationSchemes = AuthenticationSchemes.Anonymous;
                        MyListerner.Prefixes.Add("http://127.0.0.1:7788/Service/");
                        MyListerner.Start();
                    }
                    catch (Exception ex)
                    {
                        logger.Error(ex, "服务器启动失败......");
                        break;
                    }
                    logger.Debug("服务器启动成功......");
    
                    //线程池
                    int minThreadNum;
                    int portThreadNum;
                    int maxThreadNum;
                    ThreadPool.GetMaxThreads(out maxThreadNum, out portThreadNum);
                    ThreadPool.GetMinThreads(out minThreadNum, out portThreadNum);
                    logger.Debug("最大线程数：{0}", maxThreadNum);
                    logger.Debug("最小空闲线程数：{0}", minThreadNum);
                    //ThreadPool.QueueUserWorkItem(new WaitCallback(TaskProc1), x);
    
                    logger.Debug("\n等待客户连接中......");
                    while (true)
                    {
                        //等待请求连接
                        //没有请求则GetContext处于阻塞状态
                        HttpListenerContext ctx = MyListerner.GetContext();
    
                        ThreadPool.QueueUserWorkItem(new WaitCallback(TaskProc), ctx);
                    }
                }
            }
    
            protected override void OnStop()
            {
                MyListerner?.Stop();
            }
    
            void TaskProc(object obj)
            {
                HttpListenerContext ctx = (HttpListenerContext)obj;
    
                ctx.Response.StatusCode = 200;//设置返回给客服端http状态代码
    
                //接收POST参数
                Stream stream = ctx.Request.InputStream;
                System.IO.StreamReader reader = new System.IO.StreamReader(stream, Encoding.UTF8);
                string body = reader.ReadToEnd();
                logger.Debug("收到POST数据：\r\n" + HttpUtility.UrlDecode(body));
    
                var replyMsg = ProcessMessage(body);
    
                //使用Writer输出http响应代码,UTF8格式
                using (StreamWriter writer = new StreamWriter(ctx.Response.OutputStream, Encoding.UTF8))
                {
                    writer.Write(replyMsg);
                    writer.Close();
                    ctx.Response.Close();
                }
            }
    
            private string ProcessMessage(string body)
            {
                XmlDocument recvDoc = new XmlDocument();
                recvDoc.LoadXml(body);
                XmlNode recvRoot = recvDoc.SelectSingleNode("Msg");
                var firstChild = recvRoot.FirstChild;
    
                XmlDocument sendDoc = CreateXmlDocument();
                XmlElement sendRoot = CreateRootElement(sendDoc);
                sendDoc.AppendChild(sendRoot);
    
                switch (firstChild.Name)
                {
                    case "AgentInfoSet":
                        {
                            XmlElement returnNode = CreateReturnElement(sendDoc, firstChild.Name);
                            sendRoot.AppendChild(returnNode);
                            break;
                        }
                    case "GetAgentInfo":
                        {
                            XmlElement returnNode = CreateReturnElement(sendDoc, firstChild.Name);
                            sendRoot.AppendChild(returnNode);
    
                            XmlElement returnInfoNode = sendDoc.CreateElement("ReturnInfo");
                            sendRoot.AppendChild(returnInfoNode);
                            break;
                        }
                    default:
                        Debug.Assert(false);
                        break;
                }
    
                return sendDoc.InnerXml;
            }
    
            #region 生成XML数据
            private XmlElement CreateReturnElement(XmlDocument doc, string name)
            {
                XmlElement node = doc.CreateElement("Return");
                node.SetAttribute("Type", name);
                node.SetAttribute("Value", "0");
                node.SetAttribute("Desc", "成功");
    
                return node;
            }
    
            private XmlElement CreateRootElement(XmlDocument doc)
            {
                XmlElement root = doc.CreateElement("Msg");
                root.SetAttribute("Version", "3.0");
                root.SetAttribute("MsgID", "2");
                root.SetAttribute("Type", "MonUp");
                root.SetAttribute("DateTime", DateTime.Now.ToString());
                root.SetAttribute("SrcCode", "110000D01");
                root.SetAttribute("DstCode", "110000G01");
                root.SetAttribute("ReplyID", "1000_ID");
    
                return root;
            }
    
            private XmlDocument CreateXmlDocument()
            {
                XmlDocument doc = new XmlDocument();
                XmlDeclaration dec = doc.CreateXmlDeclaration("1.0", "GB2312", "yes");
                doc.AppendChild(dec);
    
                return doc;
            }
            #endregion
        }
    }