架构师_程序员

 找回密码
 注册[Register]

QQ登录

只需一步,快速开始

查看: 122|回复: 0

[资料] httplistener 监听获取 Post 请求参数

[复制链接]
跳转到指定楼层
楼主
发表于 2019-11-26 15:02:39
zu
使用httplistener监听来自客户端的http请求,对于Get请求的数据可以通过Request.QueryString["参数"]获取

而对于来自客户端的Post请求则不能使用Request[""]获取,需要将获取分析请求流中的数据拿到参数

  1. using System;
  2. using System.Collections.Generic;
  3. using System.IO;
  4. using System.Linq;
  5. using System.Net;
  6. using System.Text;
  7. using System.Threading.Tasks;

  8. namespace HttpListenerPost
  9. {
  10.     /// <summary>
  11.     /// HttpListenner监听Post请求参数值实体
  12.     /// </summary>
  13.     public class HttpListenerPostValue
  14.     {
  15.         /// <summary>
  16.         /// 0=> 参数
  17.         /// 1=> 文件
  18.         /// </summary>
  19.         public int type = 0;
  20.         public string name;
  21.         public byte[] datas;
  22.     }

  23.     /// <summary>
  24.     /// 获取Post请求中的参数和值帮助类
  25.     /// </summary>
  26.     public class HttpListenerPostParaHelper
  27.     {
  28.         private HttpListenerContext request;

  29.         public HttpListenerPostParaHelper(HttpListenerContext request)
  30.         {
  31.             this.request = request;
  32.         }

  33.         private bool CompareBytes(byte[] source, byte[] comparison)
  34.         {
  35.             try
  36.             {
  37.                 int count = source.Length;
  38.                 if (source.Length != comparison.Length)
  39.                     return false;
  40.                 for (int i = 0; i < count; i++)
  41.                     if (source[i] != comparison[i])
  42.                         return false;
  43.                 return true;
  44.             }
  45.             catch
  46.             {
  47.                 return false;
  48.             }
  49.         }

  50.         private byte[] ReadLineAsBytes(Stream SourceStream)
  51.         {
  52.             var resultStream = new MemoryStream();
  53.             while (true)
  54.             {
  55.                 int data = SourceStream.ReadByte();
  56.                 resultStream.WriteByte((byte)data);
  57.                 if (data == 10)
  58.                     break;
  59.             }
  60.             resultStream.Position = 0;
  61.             byte[] dataBytes = new byte[resultStream.Length];
  62.             resultStream.Read(dataBytes, 0, dataBytes.Length);
  63.             return dataBytes;
  64.         }

  65.         /// <summary>
  66.         /// 获取Post过来的参数和数据
  67.         /// </summary>
  68.         /// <returns></returns>
  69.         public List<HttpListenerPostValue> GetHttpListenerPostValue()
  70.         {
  71.             try
  72.             {
  73.                 List<HttpListenerPostValue> HttpListenerPostValueList = new List<HttpListenerPostValue>();
  74.                 if (request.Request.ContentType.Length > 20 && string.Compare(request.Request.ContentType.Substring(0, 20), "multipart/form-data;", true) == 0)
  75.                 {
  76.                     string[] HttpListenerPostValue = request.Request.ContentType.Split(';').Skip(1).ToArray();
  77.                     string boundary = string.Join(";", HttpListenerPostValue).Replace("boundary=", "").Trim();
  78.                     byte[] ChunkBoundary = Encoding.UTF8.GetBytes("--" + boundary + "\r\n");
  79.                     byte[] EndBoundary = Encoding.UTF8.GetBytes("--" + boundary + "--\r\n");
  80.                     Stream SourceStream = request.Request.InputStream;
  81.                     var resultStream = new MemoryStream();
  82.                     bool CanMoveNext = true;
  83.                     HttpListenerPostValue data = null;
  84.                     while (CanMoveNext)
  85.                     {
  86.                         byte[] currentChunk = ReadLineAsBytes(SourceStream);
  87.                         if (!Encoding.UTF8.GetString(currentChunk).Equals("\r\n"))
  88.                             resultStream.Write(currentChunk, 0, currentChunk.Length);
  89.                         if (CompareBytes(ChunkBoundary, currentChunk))
  90.                         {
  91.                             byte[] result = new byte[resultStream.Length - ChunkBoundary.Length];
  92.                             resultStream.Position = 0;
  93.                             resultStream.Read(result, 0, result.Length);
  94.                             CanMoveNext = true;
  95.                             if (result.Length > 0)
  96.                                 data.datas = result;
  97.                             data = new HttpListenerPostValue();
  98.                             HttpListenerPostValueList.Add(data);
  99.                             resultStream.Dispose();
  100.                             resultStream = new MemoryStream();

  101.                         }
  102.                         else if (Encoding.UTF8.GetString(currentChunk).Contains("Content-Disposition"))
  103.                         {
  104.                             byte[] result = new byte[resultStream.Length - 2];
  105.                             resultStream.Position = 0;
  106.                             resultStream.Read(result, 0, result.Length);
  107.                             CanMoveNext = true;
  108.                             data.name = Encoding.UTF8.GetString(result).Replace("Content-Disposition: form-data; name="", "").Replace(""", "").Split(';')[0];
  109.                             resultStream.Dispose();
  110.                             resultStream = new MemoryStream();
  111.                         }
  112.                         else if (Encoding.UTF8.GetString(currentChunk).Contains("Content-Type"))
  113.                         {
  114.                             CanMoveNext = true;
  115.                             data.type = 1;
  116.                             resultStream.Dispose();
  117.                             resultStream = new MemoryStream();
  118.                         }
  119.                         else if (CompareBytes(EndBoundary, currentChunk))
  120.                         {
  121.                             byte[] result = new byte[resultStream.Length - EndBoundary.Length - 2];
  122.                             resultStream.Position = 0;
  123.                             resultStream.Read(result, 0, result.Length);
  124.                             data.datas = result;
  125.                             resultStream.Dispose();
  126.                             CanMoveNext = false;
  127.                         }
  128.                     }
  129.                 }
  130.                 return HttpListenerPostValueList;
  131.             }
  132.             catch (Exception ex)
  133.             {
  134.                 return null;
  135.             }
  136.         }
  137.     }
  138. }
复制代码
开启监听,获取Post请求的参数

  1. class Program
  2.     {
  3.         private static HttpListener httpPostRequest = new HttpListener();

  4.         static void Main(string[] args)
  5.         {
  6.             httpPostRequest.Prefixes.Add("http://10.0.0.217:30000/posttype/");
  7.             httpPostRequest.Start();

  8.             Thread ThrednHttpPostRequest = new Thread(new ThreadStart(httpPostRequestHandle));
  9.             ThrednHttpPostRequest.Start();
  10.         }

  11.         private static void httpPostRequestHandle()
  12.         {
  13.             while (true)
  14.             {
  15.                 HttpListenerContext requestContext = httpPostRequest.GetContext();
  16.                 Thread threadsub = new Thread(new ParameterizedThreadStart((requestcontext) =>
  17.                 {
  18.                     HttpListenerContext request = (HttpListenerContext)requestcontext;

  19.                     //获取Post请求中的参数和值帮助类
  20.                     HttpListenerPostParaHelper httppost=new HttpListenerPostParaHelper (request);
  21.                     //获取Post过来的参数和数据
  22.                     List<HttpListenerPostValue> lst=httppost.GetHttpListenerPostValue();

  23.                     string userName = "";
  24.                     string password = "";
  25.                     string suffix = "";
  26.                     string adType = "";
  27.                     
  28.                     //使用方法
  29.                     foreach (var key in lst)
  30.                     {
  31.                         if (key.type == 0)
  32.                         {
  33.                             string value = Encoding.UTF8.GetString(key.datas).Replace("\r\n", "");
  34.                             if (key.name == "username")
  35.                             {
  36.                                 userName = value;
  37.                                 Console.WriteLine(value);
  38.                             }
  39.                             if (key.name == "password")
  40.                             {
  41.                                 password = value;
  42.                                 Console.WriteLine(value);
  43.                             }
  44.                             if (key.name == "suffix")
  45.                             {
  46.                                 suffix = value;
  47.                                 Console.WriteLine(value);
  48.                             }
  49.                             if (key.name == "adtype")
  50.                             {
  51.                                 adType = value;
  52.                                 Console.WriteLine(value);
  53.                             }   
  54.                         }
  55.                         if (key.type == 1)
  56.                         {
  57.                             string fileName = request.Request.QueryString["FileName"];
  58.                             if (!string.IsNullOrEmpty(fileName))
  59.                             {
  60.                                 string filePath = AppDomain.CurrentDomain.BaseDirectory + DateTime.Now.ToString("yyMMdd_HHmmss_ffff") + Path.GetExtension(fileName).ToLower();
  61.                                 if (key.name == "File")
  62.                                 {
  63.                                     FileStream fs = new FileStream(filePath, FileMode.Create);
  64.                                     fs.Write(key.datas, 0, key.datas.Length);
  65.                                     fs.Close();
  66.                                     fs.Dispose();
  67.                                 }
  68.                             }
  69.                         }
  70.                     }

  71.                     //Response
  72.                     request.Response.StatusCode = 200;
  73.                     request.Response.Headers.Add("Access-Control-Allow-Origin", "*");
  74.                     request.Response.ContentType = "application/json";
  75.                     requestContext.Response.ContentEncoding = Encoding.UTF8;
  76.                     byte[] buffer = System.Text.Encoding.UTF8.GetBytes(Newtonsoft.Json.JsonConvert.SerializeObject(new {success="true",msg="提交成功" }));
  77.                     request.Response.ContentLength64 = buffer.Length;
  78.                     var output = request.Response.OutputStream;
  79.                     output.Write(buffer, 0, buffer.Length);
  80.                     output.Close();
  81.                 }));
  82.                 threadsub.Start(requestContext);
  83.             }
  84.         }
复制代码
使用谷歌请求插件进行post请求,上传了文件,获取到了post参数.







上一篇:节假日·API·离线·自己撸一个方便自己调用(2019年-2020年)
下一篇:ASP.NET用HttpListener实现文件断点续传
帖子永久地址: 

架构师_程序员 - 论坛版权1、本主题所有言论和图片纯属会员个人意见,与本论坛立场无关
2、本站所有主题由该帖子作者发表,该帖子作者与架构师_程序员享有帖子相关版权
3、其他单位或个人使用、转载或引用本文时必须同时征得该帖子作者和架构师_程序员的同意
4、帖子作者须承担一切因本文发表而直接或间接导致的民事或刑事法律责任
5、本帖部分内容转载自其它媒体,但并不代表本站赞同其观点和对其真实性负责
6、如本帖侵犯到任何版权问题,请立即告知本站,本站将及时予与删除并致以最深的歉意
7、架构师_程序员管理员和版主有权不事先通知发贴者而删除本文

码农网,只发表在实践过程中,遇到的技术难题,不误导他人。
您需要登录后才可以回帖 登录 | 注册[Register]

本版积分规则

免责声明:
码农网所发布的一切软件、编程资料或者文章仅限用于学习和研究目的;不得将上述内容用于商业或者非法用途,否则,一切后果请用户自负。本站信息来自网络,版权争议与本站无关。您必须在下载后的24个小时之内,从您的电脑中彻底删除上述内容。如果您喜欢该程序,请支持正版软件,购买注册,得到更好的正版服务。如有侵权请邮件与我们联系处理。

Mail To:help@itsvse.com

QQ|Archiver|手机版|小黑屋|架构师 ( 鲁ICP备14021824号-2 )|网站地图

GMT+8, 2019-12-14 18:08

Powered by Discuz! X3.4

© 2001-2017 Comsenz Inc.

快速回复 返回顶部 返回列表