class Program
{
static HttpListener httpobj;
static void Main(string[] args)
{
//提供一個簡單的、可通過編程方式控制的 HTTP 協議偵聽器。此類不能被繼承。
httpobj = new HttpListener();
//定義url及埠號,通常設定為組態檔
httpobj.Prefixes.Add("http://+:8080/");
//啟動監聽器
httpobj.Start();
//異步監聽客戶端請求,當客戶端的網路請求到來時會自動執行Result委托
//該委托沒有回傳值,有一個IAsyncResult介面的引數,可通過該引數獲取context物件
httpobj.BeginGetContext(Result, null);
Console.WriteLine($"服務端初始化完畢,正在等待客戶端請求,時間:{DateTime.Now.ToString()}\r\n");
Console.ReadKey();
}
private static void Result(IAsyncResult ar)
{
//當接收到請求后程式流會走到這里
//繼續異步監聽
httpobj.BeginGetContext(Result, null);
var guid = Guid.NewGuid().ToString();
Console.ForegroundColor = ConsoleColor.White;
Console.WriteLine($"接到新的請求:{guid},時間:{DateTime.Now.ToString()}");
//獲得context物件
var context = httpobj.EndGetContext(ar);
var request = context.Request;
var response = context.Response;
////如果是js的ajax請求,還可以設定跨域的ip地址與引數
//context.Response.AppendHeader("Access-Control-Allow-Origin", "*");//后臺跨域請求,通常設定為組態檔
//context.Response.AppendHeader("Access-Control-Allow-Headers", "ID,PW");//后臺跨域引數設定,通常設定為組態檔
//context.Response.AppendHeader("Access-Control-Allow-Method", "post");//后臺跨域請求設定,通常設定為組態檔
context.Response.ContentType = "text/plain;charset=UTF-8";//告訴客戶端回傳的ContentType型別為純文本格式,編碼為UTF-8
context.Response.AddHeader("Content-type", "text/plain");//添加回應頭資訊
context.Response.ContentEncoding = Encoding.UTF8;
string returnObj = null;//定義回傳客戶端的資訊
if (request.HttpMethod == "POST" && request.InputStream != null)
{
//處理客戶端發送的請求并回傳處理資訊
returnObj = HandleRequest(request, response);
}
else
{
returnObj = $"不是post請求或者傳過來的資料為空";
}
var returnByteArr = Encoding.UTF8.GetBytes(returnObj);//設定客戶端回傳資訊的編碼
try
{
using (var stream = response.OutputStream)
{
//把處理資訊回傳到客戶端
stream.Write(returnByteArr, 0, returnByteArr.Length);
}
}
catch (Exception ex)
{
Console.ForegroundColor = ConsoleColor.Red;
Console.WriteLine($"網路蹦了:{ex.ToString()}");
}
Console.ForegroundColor = ConsoleColor.Yellow;
Console.WriteLine($"請求處理完成:{guid},時間:{ DateTime.Now.ToString()}\r\n");
}
private static string HandleRequest(HttpListenerRequest request, HttpListenerResponse response)
{
string data = null;
try
{
var byteList = new List<byte>();
var byteArr = new byte[2048];
int readLen = 0;
int len = 0;
//接收客戶端傳過來的資料并轉成字串型別
do
{
readLen = request.InputStream.Read(byteArr, 0, byteArr.Length);
len += readLen;
byteList.AddRange(byteArr);
} while (readLen != 0);
data = Encoding.UTF8.GetString(byteList.ToArray(),0, len);
//獲取得到資料data可以進行其他操作
}
catch (Exception ex)
{
response.StatusDescription = "404";
response.StatusCode = 404;
Console.ForegroundColor = ConsoleColor.Red;
Console.WriteLine($"在接收資料時發生錯誤:{ex.ToString()}");
return $"在接收資料時發生錯誤:{ex.ToString()}";//把服務端錯誤資訊直接回傳可能會導致資訊不安全,此處僅供參考
}
response.StatusDescription = "200";//獲取或設定回傳給客戶端的 HTTP 狀態代碼的文本說明。
response.StatusCode = 200;// 獲取或設定回傳給客戶端的 HTTP 狀態代碼。
Console.ForegroundColor = ConsoleColor.Green;
Console.WriteLine($"接收資料完成:{data.Trim()},時間:{DateTime.Now.ToString()}");
return $"接收資料完成";
}
}
這個代碼是建立一個簡單的HTTP服務,問題就是異步穿回來的資料,我怎么回傳給控制元件。。
控制元件要使用Async關鍵字么?
uj5u.com熱心網友回復:
結貼給分,我自己拿,自己定義一個公有事件也就傳遞過來了。uj5u.com熱心網友回復:
自己還能給自己分,
uj5u.com熱心網友回復:
得你自己開小號才能拿
轉載請註明出處,本文鏈接:https://www.uj5u.com/net/24419.html
標籤:C#
上一篇:VB.NET 防注入 DEBUG時能不能看到最終的SQL文
下一篇:nuget幫忙看看以下問題
