ASP.NET那点不为人知的事(三)

有了以下的知识: ASP.NET那点不为人知的事(一) ASP.NET那点不为人知的事(二)

想必开发一个小型服务器以不是问题了,功能补复杂,能够响应客户端浏览器的请求,并根据请求文件的类型返回响应的信息,如能处理静态页面、图片、样式、脚本、动态页面等。  

回顾

由于客户端和服务端的通信是通过Socket通信,且它们通信的“语言”是基于Http1.1协议。根据这个线索,我们完全可以自己开发服务器软件,暂且叫他Melodies Server,当然这是一个很简单的样例,和真正的服务器还是有差距的,好,我们进入正题,首先需要了解以下几个知识点:

  • 客户端和服务端是由Socket进行通信,在服务器端需要有监听请求的套接字,他绑定在某个端口号上,如果发现有请求过来,socket.Accept()产生一个套接字和客户端进行通信。
  • 客户端发送的请求(报文)交给服务器软件分析,判断是否为静态页面、图片还是动态aspx文件,若是静态文件能直接返回。
  • 处理动态页面稍稍麻烦,需要反射创建页面类(原因详见ASP.NET那点不为人知的事(二))

 开启服务

 public partial class WebServerForm : Form
    {
        public WebServerForm()
        {
            InitializeComponent();
            TextBox.CheckForIllegalCrossThreadCalls = false;
        }

        private Socket socketWatch;//负责监听浏览器连接请求的套接字
     
        private Thread threadWatch;//负责循环调用Socket.Accept 监听线程   

        private void btnStartServer_Click(object sender, EventArgs e)
        {
            socketWatch=new Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);
            IPAddress address = IPAddress.Parse(txtIPAddress.Text.Trim());
            IPEndPoint endPoint=new IPEndPoint(address,int.Parse(txtPort.Text.Trim()));

            socketWatch.Bind(endPoint);
            socketWatch.Listen(10);

            threadWatch = new Thread(WatchConnect);
            threadWatch.IsBackground = true;
            threadWatch.Start();
        }

        private bool isWatch = true;
        //Dictionary<> 
        void WatchConnect()
        {
            while (isWatch)
            {
                Socket socketConnection=socketWatch.Accept();
                ShowMsg("浏览器:"+socketConnection.RemoteEndPoint.ToString()+",连接成功*********************");
                ConnectionClient connectionClient = new ConnectionClient(socketConnection, ShowMsg);
            }
        }

        void ShowMsg(string msg)
        {
            txtLog.AppendText(msg+"\r\n");
        }
        

    }

分析报文,处理请求 

  • 在异步线程创建的与客户端通信的Socket,它的主要职责就是分析保文:
    /// <summary>
    /// 与客户端连接通信类(包含一个与客户端通信的套接字和通信线程)
    /// </summary>
    public class ConnectionClient
    {
        private Socket socketMsg;//与客户端通信套接字
        private Thread threadMsg;//通信线程

        private DGShowMsg dgShowMsg;//负责向主窗体文本框显示消息的委托
        public ConnectionClient(Socket socket,DGShowMsg dgShowMsg)
        {
            this.socketMsg = socket;
            this.dgShowMsg = dgShowMsg;

            //负责启动一个接受客户端浏览器请求报文的线程
            threadMsg = new Thread(ReceiveMsg);
            threadMsg.IsBackground = true;
            threadMsg.Start();
        }

        private bool isRec = true;
        void ReceiveMsg()
        {
            while (isRec)
            {
                byte[] arrMsg=new byte[1024*1024*3];
                //接受对应客户端发送过来的请求报文
                int length = socketMsg.Receive(arrMsg);

                string strMsg = System.Text.Encoding.UTF8.GetString(arrMsg, 0, length);
                dgShowMsg(strMsg);
                //处理报文
                string[] arrStr = strMsg.Replace("\r\n", "韘").Split('韘');
                string[] firstRow=arrStr[0].Split(' ');
                string requestFile = firstRow[1];
                ExcuteRequest(requestFile);//todo:长连接多少时间
            }
        }
        private void ExcuteRequest(string requestFile)
        {
            //获得被请求页面的后缀名
            string fileExtension = System.IO.Path.GetExtension(requestFile);
            if (!string.IsNullOrEmpty(fileExtension))
            {
                switch (fileExtension.ToLower())
            {
                    case ".html":
                    case ".htm":
                    case ".css":
                    case ".js":
                   
                    ExcuteStaticPage(requestFile,fileExtension);
                    break;
                    case ".jpg":
                    ExcuteImg(requestFile,fileExtension);
                    break;
                    case ".aspx":
                    ExcuteDymPage(requestFile,fileExtension);
                    break;
            }
            }
        }
  • 针对不同的请求执行不同的操作,其中静态页面、css、js、图片处理操作一样,都是属性静态文件,直接返回字节流:
/// <summary>
        /// 处理静态页面,直接输出
        /// </summary>
        private void ExcuteStaticPage(string requestPath,string fileExtension)
        {
            StringBuilder sb=new StringBuilder();
            //获得请求文件的文件夹的物理路径
            string dataDir = AppDomain.CurrentDomain.BaseDirectory;
            if (dataDir.EndsWith(@"\bin\Debug\") || dataDir.EndsWith(@"\bin\Release\"))
            {
                dataDir = System.IO.Directory.GetParent(dataDir).Parent.Parent.FullName;
            }
            string phyPath = dataDir + requestPath;
            //读取静态页面内容
            string fileContent = System.IO.File.ReadAllText(phyPath);
            //获得响应体字节数组
            byte[] fileArr = System.Text.Encoding.UTF8.GetBytes(fileContent);

            //获得响应报文头:
            string responseHeader = GetResponseHeader(fileArr.Length, fileExtension);
            byte[] arrHead = System.Text.Encoding.UTF8.GetBytes(responseHeader);
            //发送响应报文头回浏览器
            socketMsg.Send(arrHead);
            //发送响应报文体回浏览器
            //todo:sleep 1分钟会怎样
            socketMsg.Send(fileArr);
        }
        /// <summary>
        /// 处理图片
        /// </summary>
        /// <param name="requestPath"></param>
        /// <param name="extentionName"></param>
        private void ExcuteImg(string requestPath, string extentionName)
        {
            //获得请求文件的文件夹的物理路径
            string dataDir = AppDomain.CurrentDomain.BaseDirectory;
            if (dataDir.EndsWith(@"\bin\Debug\") || dataDir.EndsWith(@"\bin\Release"))
            {
                dataDir = System.IO.Directory.GetParent(dataDir).Parent.Parent.FullName;
            }
            //获得请求文件的物理路径(绝对路径)
            string phyPath = dataDir + requestPath;
            int imgLength;
            byte[] fileArr;
            //读取图片内容
            using (FileStream fs = new FileStream(phyPath, FileMode.Open))
            {
                fileArr = new byte[fs.Length];
                imgLength = fs.Read(fileArr, 0, fileArr.Length);
                //获得响应报文头
                string responseHeader = GetResponseHeader(imgLength, extentionName);
                byte[] arrHeader = System.Text.Encoding.UTF8.GetBytes(responseHeader);
                socketMsg.Send(arrHeader);
                socketMsg.Send(fileArr, imgLength, SocketFlags.None);
            }
        }
        /// <summary>
        /// 得到响应头信息
        /// </summary>
        /// <param name="contentLength"></param>
        /// <param name="fileExtentionName"></param>
        /// <returns></returns>
        private string GetResponseHeader(int contentLength,string fileExtentionName)
        {
            StringBuilder sbHeader=new StringBuilder();
            sbHeader.Append("HTTP/1.1 200 OK\r\n");
            sbHeader.Append("Content-Length: "+contentLength+"\r\n");
            sbHeader.Append("Content-Type:" + GetResponseHeadContentType(fileExtentionName) + ";charset=utf-8\r\n\r\n");
            return sbHeader.ToString();
        }
        /// <summary>
        /// 根据后缀名获取响应保文中的内容类型
        /// </summary>
        /// <param name="fileExtentionName"></param>
        /// <returns></returns>
        private string GetResponseHeadContentType(string fileExtentionName)
        {
            switch (fileExtentionName.ToLower())
            {
                case ".html":
                case ".htm":
                case ".aspx":
                    return "text/html";
                    break;
                case ".css":
                    return "text/plain";
                    break;
                case ".js":
                    return "text/javascript";
                    break;
                case ".jpg":
                    return "image/JPEG";
                case ".gif":
                    return "image/GIF";
                    break;
                default:
                    return "text/html";
                    break;

            }
        }
  • 同样,针对动态页面反射创建其页面类,注意记得让其实现IHttpHandler接口
  • 创建一个页面类View
 public class View:IHttpHandler
    {
        public string ProcessRequest()
        {
            string dataDir = AppDomain.CurrentDomain.BaseDirectory;
            //获得模板物理路径
            if (dataDir.EndsWith(@"\bin\Debug\") || dataDir.EndsWith(@"\bin\Release"))
            {
                dataDir = System.IO.Directory.GetParent(dataDir).Parent.Parent.FullName;
            }
            string phyPath = dataDir + "/model.htm";
            string modelContent=System.IO.File.ReadAllText(phyPath);
            modelContent = modelContent.Replace("@Title", "动态页面").Replace("@Content", "反射创建页面类");
            return modelContent;
        }
    }
  • 反射View,调用其ProcessRequest方法执行服务端代码
  /// <summary>
        /// 反射创建动态页面对象
        /// </summary>
        /// <param name="requestFile"></param>
        /// <param name="extentionName"></param>
        private void ExcuteDymPage(string requestFile, string extentionName)
        {
            string pageClassName = System.IO.Path.GetFileNameWithoutExtension(requestFile);
            string assemblyName = Assembly.GetExecutingAssembly().GetName().Name;
            //获得页面类全名称
            pageClassName = assemblyName + "." + pageClassName;
            //通过反射创建页面类对象
            object pageObj = Assembly.GetExecutingAssembly().CreateInstance(pageClassName);
            IHttpHandler page = pageObj as IHttpHandler;
            byte[] fileArr=null;
            if (page!=null)
            {
                string strHtml=page.ProcessRequest();
                fileArr= System.Text.Encoding.UTF8.GetBytes(strHtml);
            }
            //获得响应报文头
            string responseHeader = GetResponseHeader(fileArr.Length, extentionName);
            byte[] arrHeader = System.Text.Encoding.UTF8.GetBytes(responseHeader);

            socketMsg.Send(arrHeader);
            socketMsg.Send(fileArr);


        }

  总结

至此,一个小型的服务器软件就构建好了,赶紧测试一下呵呵。

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏小特工作室

基于微软企业库的AOP组件(含源码)

软件开发,离不开对日志的操作。日志可以帮助我们查找和检测问题,比较传统的日志是在方法执行前或后,手动调用日志代码保存。但自从AOP出现后,我们就可以避免这种繁琐...

24270
来自专栏恰童鞋骚年

ASP.Net请求处理机制初步探索之旅 - Part 3 管道

开篇:上一篇我们了解了一个ASP.Net页面请求的核心处理入口,它经历了三个重要的入口,分别是:ISAPIRuntime.ProcessRequest()、Ht...

15920
来自专栏技术小讲堂

ASP.NET AJAX(8)__Microsoft AJAX Library中异步通信层的使用什么是异步通信层Micorsoft AJAX Library异步通信层的组成WebRequestExec

什么是异步通信层 Microsoft AJAX Library的组长部分之一 负责ASP.NET AJAX框架中所有的客户端与服务器端的通信 其默认实现了封装了...

35950
来自专栏技术博客

一步一步学Linq to sql(三):增删查改

  今天主要是来学习一下,通过Linq如何进行数据库的操作,增加、删除、修改。准备工作,先是建立了一个Asp.Net Mvc 3.0的Web项目,

12220
来自专栏.NET开发者社区

一步一步创建ASP.NET MVC5程序[Repository+Autofac+Automapper+SqlSugar](四)

上一篇《一步一步创建ASP.NET MVC5程序[Repository+Autofac+Automapper+SqlSugar](三)》,我们完成了:

22590
来自专栏Golang语言社区

关于JSON.stringify和Unicode编码,需要注意的几点

1JSON.stringify会自动把所要转换内容中的汉字转换为Unicode编码 2浏览器间有差别,个别浏览器会把将要提交表单内容中的Unicode编码自动转...

41240
来自专栏张善友的专栏

使用LogParser分析日志

系统运维,少不了分析系统日志,微软有个工具Log Parser可以帮助你分析日志。它功能强大,使用简单,可以分析基于文本的日志文件、XML 文件、CSV(逗号分...

49270
来自专栏跟着阿笨一起玩NET

ASP.NET用HttpListener实现文件断点续传

本文转载:http://www.cnblogs.com/TianFang/archive/2007/01/03/610739.html

13010
来自专栏ASP.NET MVC5 后台权限管理系统

ASP.NET MVC5+EF6+EasyUI 后台管理系统(63)-Excel导入和导出-自定义表模导入

前言 上一节使用了LinqToExcel和CloseXML对Excel表进行导入和导出的简单操作,大家可以跳转到上一节查看: ASP.NET MVC5+EF...

45850
来自专栏菩提树下的杨过

Sqlite快速上手使用指南

这是网上收集的几篇教程 1. Sqlite简明教程 http://www.sqlite.com.cn/MySqlite/4/32.Html 2. Sqlite入...

25290

扫码关注云+社区

领取腾讯云代金券