c# http用HttpListener监听线程

小渣渣

1. using AndroidPush.Common;
   
2. using System;
   
3. using System.Collections.Generic;
   
4. using System.Linq;
   
5. using System.Net;
   
6. using System.Text;
   
7. using System.Threading;
   
8. 
   
9. namespace AndroidPush.WindowsService
   
10. {
    
11.     public class HttpService
    
12.     {
    
13.         private HttpListener listeren = new HttpListener();
    
14. 
    
15.         /// <summary>
    
16.         /// 初始化
    
17.         /// </summary>
    
18.         public void Init()
    
19.         {
    
20.             try
    
21.             {
    
22.                 //指定身份验证 Anonymous匿名访问
    
23.                 listeren.AuthenticationSchemes = AuthenticationSchemes.Anonymous;
    
24.                 //创建IP地址
    
25.                 IPAddress address = IPAddress.Parse(Config._ip);
    
26.                 listeren.Prefixes.Add("http://" + address + ":" + Config._porthttp + "/");
    
27.                 listeren.Start();
    
28.                 Thread threadlistener = new Thread(new ThreadStart(ThreadStartListener));
    
29.                 threadlistener.IsBackground = true;
    
30.                 threadlistener.Start();
    
31.                 LogHelper.WriteLog("HTTP success ip:" + Config._ip + "_port:" + Config._porthttp);
    
32.             }
    
33.             catch (Exception ex)
    
34.             {
    
35.                 LogHelper.WriteLog(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType.Namespace + "." + this.GetType().Name + "." + System.Reflection.MethodInfo.GetCurrentMethod().Name, ex);
    
36.             }
    
37.         }
    
38.         /// <summary>
    
39.         /// 监听连接线程
    
40.         /// </summary>
    
41.         private void ThreadStartListener()
    
42.         {
    
43.             while (true)
    
44.             {
    
45.                 //int i = 0;
    
46.                 // 注意: GetContext 方法将阻塞线程，直到请求到达
    
47.                 HttpListenerContext context = listeren.GetContext();
    
48.                 //接收到请求，用线程去处理，防止阻塞
    
49.                 Thread subThread = new Thread(new ParameterizedThreadStart((currContext) =>
    
50.                 {
    
51.                     var request = (HttpListenerContext)currContext;
    
52.                     try
    
53.                     {
    
54.                         //post请求
    
55.                         if (request.Request.HttpMethod.ToLower().Equals("post"))
    
56.                         {
    
57.                             string json = PostInput(request.Request);
    
58.                             Writer("success", request);
    
59.                         }
    
60.                         else {
    
61.                             Writer("error", request);
    
62.                         }
    
63.                     }
    
64.                     catch (Exception ex)
    
65.                     {
    
66.                         LogHelper.WriteLog(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType.Namespace + "." + this.GetType().Name + "." + System.Reflection.MethodInfo.GetCurrentMethod().Name, ex);
    
67.                         Writer("error", request);
    
68.                     }
    
69.                 }));
    
70.                 subThread.Start(context);
    
71.             }
    
72.         }
    
73. 
    
74.         /// <summary>
    
75.         /// HttpListener接收post请求
    
76.         /// </summary>
    
77.         /// <param name="request"></param>
    
78.         /// <returns></returns>
    
79.         private string PostInput(HttpListenerRequest request)
    
80.         {
    
81.             try
    
82.             {
    
83.                 System.IO.Stream s = request.InputStream;
    
84.                 int count = 0;
    
85.                 byte[] buffer = new byte[1024];
    
86.                 StringBuilder builder = new StringBuilder();
    
87.                 while ((count = s.Read(buffer, 0, 1024)) > 0)
    
88.                 {
    
89.                     builder.Append(Encoding.UTF8.GetString(buffer, 0, count));
    
90.                 }
    
91.                 s.Flush();
    
92.                 s.Close();
    
93.                 s.Dispose();
    
94.                 return builder.ToString();
    
95.             }
    
96.             catch {
    
97.                 return null;
    
98.             }
    
99.         }
    
100. 
     
101.         /// <summary>
     
102.         /// 响应内容
     
103.         /// </summary>
     
104.         /// <param name="str"></param>
     
105.         /// <param name="context"></param>
     
106.         public void Writer(string str, HttpListenerContext context)
     
107.         {
     
108.             HttpListenerRequest request = context.Request;
     
109.             HttpListenerResponse response = context.Response;
     
110.             // 构造回应内容
     
111.             string responseString = str;
     
112.             // 设置回应头部内容，长度，编码
     
113.             response.ContentLength64
     
114.                 = System.Text.Encoding.UTF8.GetByteCount(responseString);
     
115.             response.ContentType = "text/html; charset=UTF-8";
     
116.             // 输出回应内容
     
117.             System.IO.Stream output = response.OutputStream;
     
118.             System.IO.StreamWriter writer = new System.IO.StreamWriter(output);
     
119.             writer.Write(responseString);
     
120.             // 必须关闭输出流
     
121.             writer.Close();
     
122.         }
     
123.     }
     
124. }
     

复制代码

小渣渣

// 注意: GetContext 方法将阻塞线程，直到请求到达
HttpListenerContext context = listeren.GetContext();

小渣渣

登录可见。

小渣渣

基于 HttpSelfHostServer 的控制台 Web Api 服务
https://www.itsvse.com/thread-9448-1-1.html