当前位置： 移动技术网 > IT编程>开发语言>.net > HttpListener 实现小型web服务器

HttpListener 实现小型web服务器

2019年08月12日  | 移动技术网IT编程  | 我要评论

中信金通大阳网,陈雪豹,小球急速穿越

httplistener 实现web服务器

用于小型服务器，简单、方便、不需要部署。

总共代码量不超过50行。

 static void main(string[] args)
        {
            //创建http监听
            using (var httplistener = new httplistener())
            {
                //监听的路径
                httplistener.prefixes.add("http://localhost:8820/");
                //设置匿名访问
                httplistener.authenticationschemes = authenticationschemes.anonymous;
                //开始监听
                httplistener.start();
                console.writeline("监听端口:8820...");
                while (true)
                {
                    //等待传入的请求接受到请求时返回，它将阻塞线程，直到请求到达
                    var context = httplistener.getcontext();
                    //取得请求的对象
                    httplistenerrequest request = context.request;
                    console.writeline("{0} {1} http/1.1", request.httpmethod, request.rawurl);
                    var reader = new streamreader(request.inputstream);
                    var msg = reader.readtoend();//读取传过来的信息

                    //console.writeline("accept: {0}", string.join(",", request.accepttypes));
                    //console.writeline("accept-language: {0}",
                    //    string.join(",", request.userlanguages));
                    console.writeline("user-agent: {0}", request.useragent);
                    console.writeline("accept-encoding: {0}", request.headers["accept-encoding"]);
                    console.writeline("connection: {0}",
                        request.keepalive ? "keep-alive" : "close");
                    console.writeline("host: {0}", request.userhostname);
                    console.writeline("pragma: {0}", request.headers["pragma"]);

                    // 取得回应对象
                    httplistenerresponse response = context.response;

                    // 设置回应头部内容，长度，编码
                    response.contentencoding = encoding.utf8;
                    //response.contenttype = "text/plain;charset=utf-8";
                    
                    //var path = @"c:\users\wyl\desktop\cese\";
                    ////访问的文件名
                    //var filename = request.url.localpath;

                    //读取文件内容
                    //var buff = file.readallbytes(path + filename);
                    //response.contentlength64 = buff.length;

                    //-------------------------
                    //byte[] data = new byte[1] { 1 };
                    //stringwriter sw = new stringwriter();
                    //xmlserializer xm = new xmlserializer(data.gettype());
                    //xm.serialize(sw, data);
                    //var buff = encoding.utf8.getbytes(sw.tostring());
                    //------------------------

                    //-------------------------------
                    //构造soap请求信息
                    //response.contenttype = "text/xml; charset=utf-8";
                    //stringbuilder soap = new stringbuilder();
                    //soap.append("<?xml version=\"1.0\" encoding=\"utf-8\"?>");
                    //soap.append("<soap:envelope xmlns:xsi=\"http://www.w3.org/2001/xmlschema-instance\" xmlns:xsd=\"http://www.w3.org/2001/xmlschema\" xmlns:soap=\"http://schemas.xmlsoap.org/soap/envelope/\">");
                    //soap.append("<soap:body>");
                    //soap.append("<getipcountryandlocal xmlns=\"http://tempuri.org/\">");
                    //soap.append("<requestip>183.39.119.90</requestip>");
                    //soap.append("</getipcountryandlocal>");
                    //soap.append("</soap:body>");
                    //soap.append("</soap:envelope>");
                    //byte[] buff = encoding.utf8.getbytes(soap.tostring());
                    //-----------------------------------

                    response.contenttype = "text/xml; charset=utf-8";
                    string responsestring = string.format("<html><body> {0}</body></html>", datetime.now);
                    byte[] buff = encoding.utf8.getbytes(responsestring);

                    // 输出回应内容
                    system.io.stream output = response.outputstream;
                    output.write(buff, 0, buff.length);
                    // 必须关闭输出流
                    output.close();
                }
            }
        }

 

可通过网页直接访问。

程序访问方法

string httpurl = system.configuration.configurationmanager.appsettings["url"];// http://localhost:8820/
            webrequest webrequest = webrequest.create(httpurl);
            webrequest.contenttype = "text/xml; charset=utf-8";
            webrequest.method = "post";
            string responsestring = string.format("<html><body> {0}</body></html>", datetime.now);
            //byte[] buffer = system.text.encoding.utf8.getbytes(responsestring);
            using (stream requeststream = webrequest.getrequeststream())
            {
                byte[] parambytes = encoding.utf8.getbytes(responsestring);
                requeststream.write(parambytes, 0, parambytes.length);
            }

            //响应
            webresponse webresponse = webrequest.getresponse();
            using (streamreader mystreamreader = new streamreader(webresponse.getresponsestream(), encoding.utf8))
            {
                string result = "";
                result = mystreamreader.readtoend();
            }

json数据传输方法

//data未数据对象
string str = jsonconvert.serializeobject(data);
string res = post(httpurl, str);



 public static string post(string url, string json)
        {
            string st;
            try
            {
                httpwebrequest request = webrequest.create(url) as httpwebrequest; //创建请求
                cookiecontainer cookiecontainer = new cookiecontainer();
                request.cookiecontainer = cookiecontainer;
                request.method = "post"; //请求方式为post
                request.allowautoredirect = true;
                request.maximumresponseheaderslength = 1024;
                request.contenttype = "application/json";
                //request.contenttype = "text/xml; charset=utf-8";
                byte[] jsonbyte = encoding.utf8.getbytes(json);
                stream poststream = request.getrequeststream();
                poststream.write(jsonbyte, 0, jsonbyte.length);
                poststream.close();
                //发送请求并获取相应回应数据    
                httpwebresponse res = (httpwebresponse)request.getresponse();
                streamreader sr = new streamreader(res.getresponsestream(), encoding.utf8);
                st = sr.readtoend();
            }
            catch (webexception ex)
            {
                //log4nethelper.writeerrorlog(url, ex);
                st = null;
            }

            return st;
        }

 

您可能感兴趣的文章:

如对本文有疑问，请在下面进行留言讨论，广大热心网友会与你互动！！ 点击进行留言回复

相关文章:

验证码：
最近更新的文章
大家感兴趣的文章
移动技术网