文档章节

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

 木宛城主
发布于 2015/03/02 19:41
字数 1401
阅读 3
收藏 0

有了以下的知识:

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);


        }

  总结

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

© 著作权归作者所有

共有 人打赏支持
粉丝 2
博文 222
码字总数 199010
作品 0
黄浦
私信 提问
[本周] 就来说说Asp.net 身份验证、授权

[本周]如约而至;时间是争取来的,这回的[本周]是把若干零碎的时间利用起来成文的,完成对Asp.net身份验证、访问授权等内容的梳理,可能漏掉的东西会比较多,漏掉的还是希望大家来补充。顺便说...

唐玄奘
2017/12/03
0
0
ASP.NET MVC 随笔汇总

ASP.NET MVC 随笔汇总 为了方便大家浏览所以整理一下,有的系列篇幅中不是很全面以后会慢慢的补全的。 学前篇之: ASP.NET MVC学前篇之扩展方法、链式编程 ASP.NET MVC学前篇之Lambda表达式、...

jinyuan0829
2014/08/03
0
0
session共享那点事

二、如何实现session的共享? 首先我们应该明白,为什么要实现共享,如果你的网站是存放在一个机器上,那么是不存在这个问题的,因为会话数据就在这台机器,但是如果你使用了负载均衡把请求分...

yagujj
2015/09/16
29
0
学习ASP.NET Core Razor 编程系列十七——分组

学习ASP.NET Core Razor 编程系列目录 学习ASP.NET Core Razor 编程系列一 学习ASP.NET Core Razor 编程系列二——添加一个实体 学习ASP.NET Core Razor 编程系列三——创建数据表及创建项目...

DotNet菜园
08/22
0
0
学习ASP.NET Core Razor 编程系列十六——排序

学习ASP.NET Core Razor 编程系列目录 学习ASP.NET Core Razor 编程系列一 学习ASP.NET Core Razor 编程系列二——添加一个实体 学习ASP.NET Core Razor 编程系列三——创建数据表及创建项目...

DotNet菜园
08/03
0
0

没有更多内容

加载失败,请刷新页面

加载更多

PHP生成CSV之内部换行

当我们使用PHP将采集到的文件内容保存到csv文件时,往往需要将采集内容进行二次过滤处理才能得到需要的内容。比如网页中的换行符,空格符等等。 对于空格等处理起来都比较简单,这里我们单独...

豆花饭烧土豆
34分钟前
1
0
使用 mjml 生成 thymeleaf 邮件框架模板

发邮件算是系统开发的一个基本需求了,不过搞邮件模板实在是件恶心事,估计搞过的同仁都有体会。 得支持多种客户端 支持响应式 疼彻心扉的 outlook 多数客户端只支持 inline 形式的 css 布局...

郁也风
37分钟前
4
0
让哲学照亮我们的人生——读《医务工作者需要学点哲学》有感2600字

让哲学照亮我们的人生——读《医务工作者需要学点哲学》有感2600字: 作者:孙冬梅;以前读韩国前总统朴槿惠的著作《绝望锻炼了我》时,里面有一句话令我印象深刻,她说“在我最困难的时期,...

原创小博客
今天
3
0
JAVA-四元数类

public class Quaternion { private final double x0, x1, x2, x3; // 四元数构造函数 public Quaternion(double x0, double x1, double x2, double x3) { this.x0 = ......

Pulsar-V
今天
17
0
Xshell利用Xftp传输文件,使用pure-ftpd搭建ftp服务

Xftp传输文件 如果已经通过Xshell登录到服务器,此时可以使用快捷键ctrl+alt+f 打开Xftp并展示Xshell当前的目录,之后直接拖拽传输文件即可。 pure-ftpd搭建ftp服务 pure-ftpd要比vsftp简单,...

野雪球
今天
2
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部