TCP/IP协议学习(五) 基于C# Socket的Web服务器---动态通讯实现

   //前端ajax实现主体，其中obj为用户提交的相关参数
　　ajax:function(obj){　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　
            var HttpReq = $.GetAjaxReq();                      //获得XmlHttpRequest对象
            $.mix(obj, $.ajaxSettings, false);                 //非覆写模式下多对象合并，用于发送对象初始化
            var ele = $.GetElement(obj.object);        

            HttpReq.open(obj.type, obj.url, obj.async);        //创建一个新的HTTP请求
            HttpReq.setRequestHeader(‘If-Modified-Since‘, ‘0‘);//添加http头 If-Modified-Since：0
            if(!obj.async)                                     //判断是否为异步模式，同步模式是timeout赋值会出错
                HttpReq.timeout = obj.timeout;
            HttpReq.onreadystatechange =  function(){          //Ajax执行后回调函数
                $.ajaxCallback(ele, obj, HttpReq);
            };

            //因为IE中将数组直接发送会不识别(火狐会将数组直接转成字符串发送)，考虑到兼容性, 如果是数组，就转成字符串发送
            if({}.toString.apply(obj.data) === ‘[object Array]‘){         
                HttpReq.send(obj.data.join(‘ ‘));
            }else{
                HttpReq.send(obj.data);
            　　}
           }, 

     private static void dynamic_process(HTTPServer.HttpProcess HttpProcess, string str)
     {
            string send_str = "";
            if (HttpProcess.updata_status == false)
            {
                //解析ajax_methon处理方法 example: /html/AspGet.asp -> /html/aspget.asp -> aspget
                int PEnd = HttpProcess.hpr.url.IndexOf(".");
                int pStart = HttpProcess.hpr.url.LastIndexOf("/");
                HttpProcess.hpr.dynamic_method = HttpProcess.hpr.url.Substring(pStart + 1, PEnd - pStart - 1);
　　　　　　　　　 //......
            }
　　　　　　　//......
　　　　　　　　
　　　　　　　//get模式为false，直接执行
            if (HttpProcess.updata_status == false)
            {
                switch (HttpProcess.hpr.dynamic_method)
                {
                    case "aspapply":
                        send_str = create_correct_head(HttpProcess, System.Text.Encoding.UTF8.GetBytes(str).Length);
                        send_str += str;
                        break;
                    case "aspget":
                        send_str = create_correct_head(HttpProcess, HTTPServer.setup.Length);
                        send_str += HTTPServer.setup;
                        break;
                    default:
                        break;
                }
　　　　　　　　　　
　　　　　　　　　//处理后数据返回
                byte[] send_byte = new byte[send_str.Length];
                send_byte = Encoding.UTF8.GetBytes(send_str);
                HttpProcess.bs = send_byte;
            }
        }

  //考虑到Post提交时长度较长时tcp层分片发送，需要等待所有包发送完在处理
  do
  {
     //获得当前Socket连接传输的数据，并转换为utf-8格式
     length = CurrentSocket.Receive(recvBytes, recvBytes.Length, 0);
     recvStr = Encoding.UTF8.GetString(recvBytes, 0, length);

     Console.WriteLine(recvStr);

     //http引擎处理，返回获得数据
     http_engine(recvStr, length, hpc);
  }while(hpc.updata_status);

       //ajax动态数据处理
        private static void dynamic_process(HTTPServer.HttpProcess HttpProcess, string str)
        {
            string send_str = "";
            if (HttpProcess.updata_status == false)
            {
                //解析ajax_methon处理方法
                int PEnd = HttpProcess.hpr.url.IndexOf(".");
                int pStart = HttpProcess.hpr.url.LastIndexOf("/");
                HttpProcess.hpr.dynamic_method = HttpProcess.hpr.url.Substring(pStart + 1, PEnd - pStart - 1);

                if (HttpProcess.hpr.http_method == "post")
                {
                    //解析Content-Length 获得接收数据正文总长度
                    PEnd = str.IndexOf("Content-Length:");
                    str = str.Substring(PEnd);
                    PEnd = str.IndexOf("\r\n");
                    string str_len = str.Substring(16, PEnd - 16);  //获得接收数据总长度！
                    HttpProcess.total_len = int.Parse(str_len);
                    PEnd = str.IndexOf("\r\n\r\n");
                    HttpProcess.updata_status = true;

                    //右移4位，获得正文首字符位置 \r\n\r\n
                    str = str.Substring(PEnd + 4);
　　　　　　　　
　　　　　　　　　　　 //统计接收数据长度
                    //对于可能的中文输入，直接用str.length获得的长度与Content-Length不符合
                    //因此取长度用System.Text.Encoding.UTF8.GetBytes(str).Length;中英文获得的长度都正确
                    HttpProcess.recv_len += System.Text.Encoding.UTF8.GetBytes(str).Length;
                }
            }
            else
            {
                HttpProcess.recv_len += System.Text.Encoding.UTF8.GetBytes(str).Length;
            }
           
　　　　　　　//接收数据长度和实际长度相同时，表示接收完毕，可以处理
            if (HttpProcess.recv_len == HttpProcess.total_len)
            {
                HttpProcess.updata_status = false;
            }

            if (HttpProcess.updata_status == false)
            {
                switch (HttpProcess.hpr.dynamic_method)
                {
                    case "aspapply":

　　　　　　　　　　　　　　//Post方法，将获得数据返回给客户端
                        send_str = create_correct_head(HttpProcess, System.Text.Encoding.UTF8.GetBytes(str).Length);　　
                        send_str += str;
                        break;
                    case "aspget":
                        send_str = create_correct_head(HttpProcess, HTTPServer.setup.Length);　　//get方法，将服务器内部数据提交返回
                        send_str += HTTPServer.setup;
                        break;
                    default:
                        break;
                }
                byte[] send_byte = new byte[send_str.Length];
                send_byte = Encoding.UTF8.GetBytes(send_str);

                Console.WriteLine(send_str);
                HttpProcess.bs = send_byte;
            }
        }