Acest articol este un articol oglindă al traducerii automate, vă rugăm să faceți clic aici pentru a sări la articolul original.

Architect_Programmer_Code Rețeaua Agricolă»Arhitect › Programare › .Net/C # › .net folosește HttpListener pentru a asculta conținutul și folosește firele pentru a răspunde utilizatorului pentru a preveni ...
Vedere: 19293|Răspunde: 0

[Sursă] .net folosește HttpListener pentru a asculta conținutul și folosește fire de discuție pentru a răspunde utilizatorilor și a preveni blocarea

[Copiază linkul]
Postat pe 17.12.2015 12:28:28 | | |
  1. /// <summary>
  2.         /// 开启监听
  3.         /// </summary>
  4.         private void Init()
  5.         {
  6.             try
  7.             {
  8.                 //指定身份验证 Anonymous匿名访问
  9.                 listeren.AuthenticationSchemes = AuthenticationSchemes.Anonymous;
  10.                 //创建IP地址
  11.                 IPAddress address = IPAddress.Parse(Args.RunningArgs[0]);
  12.                 listeren.Prefixes.Add("http://" + address + ":" + Args.RunningArgs[1] + "/");
  13.                 listeren.Start();
  14.                 Thread threadlistener = new Thread(new ThreadStart(ThreadStartListener));
  15.                 threadlistener.IsBackground = true;
  16.                 threadlistener.Start();
  17.                 MessageBox.Show("监听成功");
  18.             }
  19.             catch (Exception ex)
  20.             {
  21.                 cfg.Logs.Add(new LogClass { LogStr = "HttpListener error", ExInfo = ex });
  22.             }
  23.         }
  24.         /// <summary>
  25.         /// 监听连接线程
  26.         /// </summary>
  27.         private void ThreadStartListener()
  28.         {
  29.             while (true)
  30.             {
  31.                 //int i = 0;
  32.                 // 注意: GetContext 方法将阻塞线程，直到请求到达
  33.                 HttpListenerContext context = listeren.GetContext();
  34.                 //接收到请求，用线程去处理，防止阻塞
  35.                 Thread subThread = new Thread(new ParameterizedThreadStart((currContext) =>
  36.                 {
  37.                     int i = 0;
  38.                     var request = (HttpListenerContext)currContext;
  39.                     try
  40.                     {
  41.                         //post请求
  42.                         if (request.Request.HttpMethod.ToLower().Equals("post"))
  43.                         {
  44.                             this.Dispatcher.Invoke(new Action(() =>
  45.                             {
  46.                                 try
  47.                                 {
  48.                                     i = 1;
  49.                                     string QRcode = PostInput(request.Request);
  50.                                     var data = Convert.FromBase64String(QRcode);
  51.                                     BitmapImage bmp = new BitmapImage();
  52.                                     bmp.BeginInit();
  53.                                     bmp.StreamSource = new MemoryStream(data);
  54.                                     bmp.EndInit();
  55.                                     codeimg.Source = bmp;
  56.                                     Writer("success", request);
  57.                                     return;
  58.                                 }
  59.                                 catch (Exception ex)
  60.                                 {
  61.                                     Writer("img_error", request);
  62.                                     cfg.Logs.Add(new LogClass { LogStr = "HttpListener error", ExInfo = ex });
  63.                                     return;
  64.                                 }
  65.                             }));
  66.                         }
  67.                         else if (request.Request.HttpMethod.ToLower().Equals("get"))//get请求
  68.                         {
  69.                             Writer("get", request);
  70.                             return;
  71.                         }
  72.                         if (i.Equals(0))
  73.                         {
  74.                             Writer("no", request);
  75.                             return;
  76.                         }
  77.                     }
  78.                     catch (Exception)
  79.                     {
  80.                         Writer("error", request);
  81.                         return;
  82.                     }
  83.                 }));
  84.                 subThread.Start(context);  

  86.             }
  87.         }
  88.         /// <summary>
  89.         /// HttpListener接收post请求
  90.         /// </summary>
  91.         /// <param name="request"></param>
  92.         /// <returns></returns>
  93.         private string PostInput(HttpListenerRequest request)
  94.         {
  95.             try
  96.             {
  97.                 System.IO.Stream s = request.InputStream;
  98.                 int count = 0;
  99.                 byte[] buffer = new byte[1024];
  100.                 StringBuilder builder = new StringBuilder();
  101.                 while ((count = s.Read(buffer, 0, 1024)) > 0)
  102.                 {
  103.                     builder.Append(Encoding.UTF8.GetString(buffer, 0, count));
  104.                 }
  105.                 s.Flush();
  106.                 s.Close();
  107.                 s.Dispose();
  108.                 return builder.ToString();
  109.             }
  110.             catch (Exception ex)
  111.             { throw ex; }
  112.         }
  113.         /// <summary>
  114.         /// 响应内容
  115.         /// </summary>
  116.         /// <param name="str"></param>
  117.         /// <param name="context"></param>
  118.         public void Writer(string str, HttpListenerContext context)
  119.         {
  120.             HttpListenerRequest request = context.Request;
  121.             HttpListenerResponse response = context.Response;
  122.             // 构造回应内容
  123.             string responseString = str;
  124.             // 设置回应头部内容，长度，编码
  125.             response.ContentLength64
  126.                 = System.Text.Encoding.UTF8.GetByteCount(responseString);
  127.             response.ContentType = "text/html; charset=UTF-8";
  128.             // 输出回应内容
  129.             System.IO.Stream output = response.OutputStream;
  130.             System.IO.StreamWriter writer = new System.IO.StreamWriter(output);
  131.             writer.Write(responseString);
  132.             // 必须关闭输出流
  133.             writer.Close();
  134.         }
Cod de copiere






Precedent:HttpListener primește cererea de postare
Următor:Dacă există întoarcere, încearcă să prinzi în sfârșit ordinea de execuție

Postări conexe
Disclaimer:
Tot software-ul, materialele de programare sau articolele publicate de Code Farmer Network sunt destinate exclusiv scopurilor de învățare și cercetare; Conținutul de mai sus nu va fi folosit în scopuri comerciale sau ilegale, altfel utilizatorii vor suporta toate consecințele. Informațiile de pe acest site provin de pe Internet, iar disputele privind drepturile de autor nu au legătură cu acest site. Trebuie să ștergi complet conținutul de mai sus de pe calculatorul tău în termen de 24 de ore de la descărcare. Dacă îți place programul, te rugăm să susții software-ul autentic, să cumperi înregistrarea și să primești servicii autentice mai bune. Dacă există vreo încălcare, vă rugăm să ne contactați prin e-mail.
Mail To:help@itsvse.com