using System;
|
using System.Linq;
|
using System.Web;
|
|
namespace Shared.Net
|
{
|
public static class HttpListener
|
{
|
private static System.Net.HttpListener listener;
|
|
/// <summary>
|
/// 启动监听及处理
|
/// </summary>
|
public static void Start (System.Net.IPAddress ipAddress, int port)
|
{
|
try {
|
if (listener == null) {
|
listener = new System.Net.HttpListener ();
|
|
listener.AuthenticationSchemes = System.Net.AuthenticationSchemes.Anonymous;
|
|
listener.Prefixes.Add (string.Format ("http://{0}:{1}/", ipAddress.ToString (), port));
|
|
listener.Start ();
|
|
//beginGetContext(listener);
|
contextThread = new System.Threading.Thread (() => {
|
while (true) {
|
var context = listener.GetContext ();
|
System.Threading.Tasks.Task.Run (() => {
|
manager (context);
|
});
|
}
|
});
|
contextThread.Start ();
|
Utlis.WriteLine ("HttpListener已经启动!");
|
}
|
} catch (Exception e) {
|
Utlis.WriteLine ("HttpListener启动失败!\r\n" + e.Message);
|
}
|
}
|
/// <summary>
|
///
|
/// </summary>
|
static System.Threading.Thread contextThread;
|
/// <summary>
|
/// 请求事件
|
/// </summary>
|
/// <param name="commandType">请求命令</param>
|
/// <param name="outStream">输出流</param>
|
/// <param name="inStream">输入流</param>
|
public delegate void RequestEventHandler (System.Collections.Specialized.NameValueCollection nameValueCollection, System.IO.Stream outputStream, System.IO.Stream inputStream);
|
|
/// <summary>
|
/// 请求事件
|
/// </summary>
|
public static event RequestEventHandler EventHandler;
|
|
/// <summary>
|
/// 开始异步接收http请求
|
/// </summary>
|
/// <param name="listerner"></param>
|
private static void beginGetContext (System.Net.HttpListener listerner)
|
{
|
try {
|
if (listerner == null || !listerner.IsListening) {
|
return;
|
}
|
listerner.BeginGetContext (new System.AsyncCallback (getContextCallBack), null);
|
|
} catch {
|
System.Threading.Thread.Sleep (1);
|
beginGetContext (listerner);
|
}
|
}
|
|
/// <summary>
|
/// 获取http请求，并处理
|
/// </summary>
|
/// <param name="ar"></param>
|
private static void getContextCallBack (System.IAsyncResult ar)
|
{
|
beginGetContext (listener);
|
try {
|
System.Net.HttpListenerContext context = listener.EndGetContext (ar);
|
manager (context);
|
} catch { }
|
}
|
|
/// <summary>
|
/// 关闭
|
/// </summary>
|
public static void Close ()
|
{
|
try {
|
if (contextThread != null) {
|
contextThread.Abort ();
|
contextThread = null;
|
}
|
} catch { }
|
try {
|
if (listener != null) {
|
listener.Close ();
|
listener = null;
|
}
|
} catch { }
|
Utlis.WriteLine ("HttpListener已经关闭!");
|
}
|
|
private static void manager (System.Net.HttpListenerContext httpListenerContext)
|
{
|
System.Net.HttpListenerResponse httpListenerResponse = null;
|
|
try {
|
#region
|
httpListenerResponse = httpListenerContext.Response;
|
|
httpListenerResponse.StatusCode = 200;//设置返回给客服端http状态代码
|
httpListenerResponse.ContentEncoding = System.Text.Encoding.UTF8;
|
|
|
if (EventHandler != null) {
|
EventHandler (HttpUtility.ParseQueryString (System.IO.Path.GetFileName (httpListenerContext.Request.RawUrl)), httpListenerResponse.OutputStream, httpListenerContext.Request.InputStream);
|
}
|
//string commandType = nameValueCollection.Get("CommandType");
|
|
//byte[] sendBytes = null;
|
//switch (commandType)
|
//{
|
// case "测试":
|
// Test("测试");
|
// sendBytes = System.Text.Encoding.UTF8.GetBytes("测试成功");
|
// break;
|
// default:
|
// sendBytes = System.Text.Encoding.UTF8.GetBytes("指令暂时不支持");
|
// break;
|
//}
|
|
//stream.Write(sendBytes, 0, sendBytes.Length);
|
httpListenerResponse.OutputStream.Flush ();
|
|
#endregion
|
} catch {
|
|
} finally {
|
#region
|
try {
|
httpListenerContext.Request.InputStream.Close ();
|
} catch { }
|
|
try {
|
httpListenerResponse.OutputStream.Close ();
|
} catch { }
|
|
|
try {
|
httpListenerResponse.Close ();
|
} catch { }
|
|
#endregion
|
}
|
}
|
|
private static void Test (string text)
|
{
|
|
//System.IO.StreamWriter streamWriter = new System.IO.StreamWriter(System.IO.Path.Combine(File.RootPath,"Hello.txt"));
|
//streamWriter.WriteLine(text);
|
//streamWriter.Close();
|
|
Utlis.WriteLine ("HttpListener 接收到测试信息！");
|
|
}
|
|
|
public static void PostData (string url, string postJson)
|
{
|
System.IO.Stream outputStream = null;
|
System.IO.Stream inputStream = null;
|
try {
|
System.Net.HttpWebRequest webReq = (System.Net.HttpWebRequest)System.Net.WebRequest.Create (new Uri (url));
|
webReq.Method = "POST";
|
//webReq
|
|
byte [] byteData = System.Text.Encoding.UTF8.GetBytes (postJson);
|
//定义传送数据格式
|
webReq.ContentType = "application/json";
|
webReq.Accept = "application/json";
|
//webReq.ContentType = "application/x-www-form-urlencoded";
|
//webReq.Timeout = 1000*2;
|
webReq.ContentLength = byteData.Length;
|
//定义Stream信息
|
outputStream = webReq.GetRequestStream ();
|
outputStream.Write (byteData, 0, byteData.Length);
|
outputStream.Flush ();
|
outputStream.Close ();
|
|
//inputStream= webReq.GetResponse().GetResponseStream();
|
} catch {
|
throw new Exception ("发送失败");
|
} finally {
|
if (null != outputStream) {
|
outputStream.Close ();
|
}
|
if (null != inputStream) {
|
inputStream.Close ();
|
}
|
}
|
}
|
}
|
}
|
