.net naudoja "HttpListener" turiniui klausytis ir naudoja gijas, kad atsakytų vartotojams, kad būtų išvengta blokavimo

Mažai purvo · Paskelbta 2015-12-17 12:28:28

/// <summary>
/// 开启监听
/// </summary>
private void Init()
{
try
{
//指定身份验证 Anonymous匿名访问
listeren.AuthenticationSchemes = AuthenticationSchemes.Anonymous;
//创建IP地址
IPAddress address = IPAddress.Parse(Args.RunningArgs[0]);
listeren.Prefixes.Add("http://" + address + ":" + Args.RunningArgs[1] + "/");
listeren.Start();
Thread threadlistener = new Thread(new ThreadStart(ThreadStartListener));
threadlistener.IsBackground = true;
threadlistener.Start();
MessageBox.Show("监听成功");
}
catch (Exception ex)
{
cfg.Logs.Add(new LogClass { LogStr = "HttpListener error", ExInfo = ex });
}
}
/// <summary>
/// 监听连接线程
/// </summary>
private void ThreadStartListener()
{
while (true)
{
//int i = 0;
// 注意: GetContext 方法将阻塞线程，直到请求到达
HttpListenerContext context = listeren.GetContext();
//接收到请求，用线程去处理，防止阻塞
Thread subThread = new Thread(new ParameterizedThreadStart((currContext) =>
{
int i = 0;
var request = (HttpListenerContext)currContext;
try
{
//post请求
if (request.Request.HttpMethod.ToLower().Equals("post"))
{
this.Dispatcher.Invoke(new Action(() =>
{
try
{
i = 1;
string QRcode = PostInput(request.Request);
var data = Convert.FromBase64String(QRcode);
BitmapImage bmp = new BitmapImage();
bmp.BeginInit();
bmp.StreamSource = new MemoryStream(data);
bmp.EndInit();
codeimg.Source = bmp;
Writer("success", request);
return;
}
catch (Exception ex)
{
Writer("img_error", request);
cfg.Logs.Add(new LogClass { LogStr = "HttpListener error", ExInfo = ex });
return;
}
}));
}
else if (request.Request.HttpMethod.ToLower().Equals("get"))//get请求
{
Writer("get", request);
return;
}
if (i.Equals(0))
{
Writer("no", request);
return;
}
}
catch (Exception)
{
Writer("error", request);
return;
}
}));
subThread.Start(context);
}
}
/// <summary>
/// HttpListener接收post请求
/// </summary>
/// <param name="request"></param>
/// <returns></returns>
private string PostInput(HttpListenerRequest request)
{
try
{
System.IO.Stream s = request.InputStream;
int count = 0;
byte[] buffer = new byte[1024];
StringBuilder builder = new StringBuilder();
while ((count = s.Read(buffer, 0, 1024)) > 0)
{
builder.Append(Encoding.UTF8.GetString(buffer, 0, count));
}
s.Flush();
s.Close();
s.Dispose();
return builder.ToString();
}
catch (Exception ex)
{ throw ex; }
}
/// <summary>
/// 响应内容
/// </summary>
/// <param name="str"></param>
/// <param name="context"></param>
public void Writer(string str, HttpListenerContext context)
{
HttpListenerRequest request = context.Request;
HttpListenerResponse response = context.Response;
// 构造回应内容
string responseString = str;
// 设置回应头部内容，长度，编码
response.ContentLength64
= System.Text.Encoding.UTF8.GetByteCount(responseString);
response.ContentType = "text/html; charset=UTF-8";
// 输出回应内容
System.IO.Stream output = response.OutputStream;
System.IO.StreamWriter writer = new System.IO.StreamWriter(output);
writer.Write(responseString);
// 必须关闭输出流
writer.Close();
}

Kopijuoti kodą

[Šaltinis] .net naudoja "HttpListener" turiniui klausytis ir naudoja gijas, kad atsakytų vartotojams, kad būtų išvengta blokavimo

Susijusios žinutės

Peržiūrėtos sekcijos