C#中使用Socket实现简单Web服务器
2021-02-01 18:16
YPE HTML>
最近有个web的小项目,但公司的电脑无法安装IIS,所以就想自己来实现个Web server服务器,原本想了下,也就是socket处理http请求,于是就在博客园中搜索了“socket实现web server”,结果还真搜索到一些文章,于是从中找了几个做参考,如下:
C#中使用Socket实现简单Web服务器
C#中使用Socket模拟请求Web服务器过程
C#中自己动手创建一个Web Server(非Socket实现)
其他的这里就不一一列出了,感兴趣的可以自己搜索看看。
所以我根据他们的代码,然后自己在修改符合自己使用的情况,初次版本就出来了,代码如下:
using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Net; using System.Net.Sockets; namespace socket_webServer { class Program { static Socket _socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); //侦听socket static string webRoot = @"C:\Users\jack\Desktop\"; static string defaultPage = "index.html,home.html"; static void Main(string[] args) { webRoot = @"C:\_jack\DevCode"; _socket.Bind(new IPEndPoint(IPAddress.Any, 8080)); _socket.Listen(100); _socket.BeginAccept(new AsyncCallback(OnAccept), _socket); //开始接收来自浏览器的http请求(其实是socket连接请求) writeLog("Socket Web Server 已启动监听!" + Environment.NewLine + " 监听端口:" + ((IPEndPoint)_socket.LocalEndPoint).Port); Console.ReadKey(); } ////// 接受处理http的请求 /// /// static void OnAccept(IAsyncResult ar) { try { Socket socket = ar.AsyncState as Socket; Socket web_client = socket.EndAccept(ar); //接收到来自浏览器的代理socket //NO.1 并行处理http请求 socket.BeginAccept(new AsyncCallback(OnAccept), socket); //开始下一次http请求接收 (此行代码放在NO.2处时,就是串行处理http请求,前一次处理过程会阻塞下一次请求处理) byte[] recv_Buffer = new byte[1024 * 640]; int recv_Count = web_client.Receive(recv_Buffer); //接收浏览器的请求数据 string recv_request = Encoding.UTF8.GetString(recv_Buffer, 0, recv_Count); writeLog("Data Request : " + recv_request); //将请求显示到界面 //Resolve(recv_request, web_client); //解析、路由、处理 byte[] cont = pageHandle(RouteHandle(recv_request)); sendPageContent(cont, web_client); //NO.2 串行处理http请求 } catch (Exception ex) { writeLog("处理http请求时出现异常!" + Environment.NewLine + "\t" + ex.Message); } } static void sendPageContent(byte[] pageContent, Socket response) { string statusline = "HTTP/1.1 200 OK\r\n"; //状态行 byte[] statusline_to_bytes = Encoding.UTF8.GetBytes(statusline); string content = "" + "" + " socket webServer -- Login " + "" + "" + "" + "欢迎您!" + "" + ",今天是 " + DateTime.Now.ToLongDateString() + "" + "" + ""; //内容 byte[] content_to_bytes = pageContent; string header = string.Format("Content-Type:text/html;charset=UTF-8\r\nContent-Length:{0}\r\n", content_to_bytes.Length); byte[] header_to_bytes = Encoding.UTF8.GetBytes(header); //应答头 response.Send(statusline_to_bytes); //发送状态行 response.Send(header_to_bytes); //发送应答头 response.Send(new byte[] { (byte)‘\r‘, (byte)‘\n‘ }); //发送空行 response.Send(content_to_bytes); //发送正文(html) response.Close(); } ////// /// /// /// static string RouteHandle(string request) { string retRoute = ""; string[] strs = request.Split(new string[] { "\r\n" }, StringSplitOptions.None); //以“换行”作为切分标志 if (strs.Length > 0) //解析出请求路径、post传递的参数(get方式传递参数直接从url中解析) { string[] items = strs[0].Split(‘ ‘); //items[1]表示请求url中的路径部分(不含主机部分) string pageName = items[1]; string post_data = strs[strs.Length - 1]; //最后一项 //Dictionary dict = ParameterHandle(strs); retRoute = pageName + (post_data.Length > 0 ? "?" + post_data : ""); } return retRoute; } ////// 按照HTTP协议格式,解析浏览器发送的请求字符串 /// /// /// static Dictionarystring, string> ParameterHandle(string[] strs) { Dictionarystring, string> param = new Dictionarystring, string>(); if (strs.Length > 0) //解析出请求路径、post传递的参数(get方式传递参数直接从url中解析) { if (strs.Contains("")) //包含空行 说明存在post数据 { string post_data = strs[strs.Length - 1]; //最后一项 if (post_data != "") { string[] post_datas = post_data.Split(‘&‘); foreach (string s in post_datas) { param.Add(s.Split(‘=‘)[0], s.Split(‘=‘)[1]); } } } } return param; } static byte[] pageHandle(string pagePath) { byte[] pageContent = null; webRoot = webRoot.TrimEnd(‘/‘, ‘\\‘); pagePath = pagePath.TrimEnd(‘/‘, ‘\\‘); if (pagePath.Length==0) { foreach (string page in defaultPage.Split(‘,‘)) { if (System.IO.File.Exists(webRoot + page)) { pagePath = page; break; } } } if (System.IO.File.Exists(webRoot + pagePath)) pageContent = System.IO.File.ReadAllBytes(webRoot + pagePath); if (pageContent == null) { string content = notExistPage(); pageContent = Encoding.UTF8.GetBytes(content); } return pageContent; } static void writeLog(string msg) { Console.WriteLine(" " + msg); } static string notExistPage() { string cont = @" This page can’t be displayed "; return cont; } } }This page can’t be displayed
- Make sure the web address is correct.
- Look for the page with your search engine.
- Refresh the page in a few minutes.
这个web server的雏形就出来了,以后有需要的功能在慢慢往上添加吧
参考文章:
Socket网络编程--简单Web服务器各章节传送门
Socket网络编程--简单Web服务器(1) http://www.cnblogs.com/wunaozai/p/3926033.html
Socket网络编程--简单Web服务器(2) http://www.cnblogs.com/wunaozai/p/3936295.html
Socket网络编程--简单Web服务器(3) http://www.cnblogs.com/wunaozai/p/3943952.html
Socket网络编程--简单Web服务器(4) http://www.cnblogs.com/wunaozai/p/3945218.html
Socket网络编程--简单Web服务器(5) http://www.cnblogs.com/wunaozai/p/3946486.html
Socket网络编程--简单Web服务器(6) http://www.cnblogs.com/wunaozai/p/3949324.html
源码下载: http://files.cnblogs.com/wunaozai/WebServer.zip
C#中使用Socket实现简单Web服务器
标签:The locale img users 使用 bytes 需要 修改 exce
原文地址:https://www.cnblogs.com/dawenxi0/p/11584133.html
上一篇:C# Winfrom UI 美化
文章标题:C#中使用Socket实现简单Web服务器
文章链接:http://soscw.com/index.php/essay/49610.html