Dieser Artikel ist ein Spiegelartikel der maschinellen Übersetzung, bitte klicken Sie hier, um zum Originalartikel zu springen.

Architect_Programmer_Code Landwirtschaftsnetzwerk»Architekt › Programmieren › .Net/C # › .net verwendet HttpListener, um die Inhalte anzuhören, und nutzt Threads, um auf den Nutzer zu reagieren und so zu verhindern, dass ...
Ansehen: 19293|Antwort: 0

[Quelle] .net nutzt HttpListener, um Inhalte anzuhören, und nutzt Threads, um auf Nutzer zu reagieren, um Blockierungen zu verhindern

[Link kopieren]
Veröffentlicht am 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.         }
Code kopieren






Vorhergehend:HttpListener erhält die Beitragsanfrage
Nächster:Wenn es eine Rückkehr gibt, versuchen Sie abschließend, die Ausführungsreihenfolge zu fangen

Verwandte Beiträge
Verzichtserklärung:
Alle von Code Farmer Network veröffentlichten Software, Programmiermaterialien oder Artikel dienen ausschließlich Lern- und Forschungszwecken; Die oben genannten Inhalte dürfen nicht für kommerzielle oder illegale Zwecke verwendet werden, andernfalls tragen die Nutzer alle Konsequenzen. Die Informationen auf dieser Seite stammen aus dem Internet, und Urheberrechtsstreitigkeiten haben nichts mit dieser Seite zu tun. Sie müssen die oben genannten Inhalte innerhalb von 24 Stunden nach dem Download vollständig von Ihrem Computer löschen. Wenn Ihnen das Programm gefällt, unterstützen Sie bitte echte Software, kaufen Sie die Registrierung und erhalten Sie bessere echte Dienstleistungen. Falls es eine Verletzung gibt, kontaktieren Sie uns bitte per E-Mail.
Mail To:help@itsvse.com