using http_filetransfer;
|
using Newtonsoft.Json;
|
using Sodao.FastSocket.Server.Config;
|
using System;
|
using System.Collections.Generic;
|
using System.Configuration;
|
using System.IO;
|
using System.Linq;
|
using System.Net;
|
using System.Net.Sockets;
|
using System.Text;
|
using System.Threading.Tasks;
|
using XImaging.Automation.Library.HxDriverLib;
|
using XImaging.Automation.Service;
|
|
namespace BiosenSocketService
|
{
|
public class BiosenHttpServer
|
{
|
public static int BufferSize = 8192;
|
public const string DeleteMethod = "DELETE";
|
public const int NotFounded = 404;
|
public const int BadRequest = 400;
|
public const int NotImplemented = 501;
|
|
|
private static HttpListener httplistener;
|
public BiosenHttpServer()
|
{
|
|
}
|
|
public static void Init()
|
{
|
PostServerSection section = ConfigurationManager.GetSection("fileServer") as PostServerSection;
|
string server = section.Server.URI;
|
|
string folder = ConfigurationManager.AppSettings.Get("UploadFolder");
|
string uploadPath = AppDomain.CurrentDomain.BaseDirectory + folder;
|
if(!Directory.Exists(uploadPath))
|
{
|
Directory.CreateDirectory(uploadPath);
|
}
|
|
httplistener = new HttpListener();
|
try
|
{
|
httplistener.Prefixes.Add(server);
|
httplistener.Start();
|
Console.WriteLine("server successfully runned");
|
|
httplistener.BeginGetContext(Result, null);
|
|
LogConstant.logger.Print("[httpserver =]" + server + " 已启动");
|
/*while (true)
|
{
|
IHttpCommand command;
|
HttpListenerContext httplistenercontext = httplistener.GetContext();
|
string commandname = httplistenercontext.Request.HttpMethod;
|
|
|
}*/
|
}
|
catch (Exception ex)
|
{
|
LogConstant.logger.Print("start httpserver exception:" + ex.ToString());
|
}
|
//finally
|
//{
|
// httplistener.Close();
|
//}
|
}
|
|
public static void Stop()
|
{
|
try
|
{
|
if (httplistener == null)
|
return;
|
httplistener.Close();
|
httplistener = null;
|
}
|
catch(Exception ex)
|
{
|
LogConstant.logger.Print("Stop():" + ex.ToString());
|
}
|
}
|
|
private static void Result(IAsyncResult ar)
|
{
|
//当接收到请求后程序流会走到这里
|
try
|
{
|
if (httplistener == null)
|
return;
|
//继续异步监听
|
httplistener.BeginGetContext(Result, null);
|
|
var guid = Guid.NewGuid().ToString();
|
Console.ForegroundColor = ConsoleColor.White;
|
Console.WriteLine($"接到新的请求:{guid},时间：{DateTime.Now.ToString()}");
|
//获得context对象
|
var context = httplistener.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;//定义返回客户端的信息
|
|
IHttpCommand command = null;
|
string commandname = request.HttpMethod;
|
|
switch (commandname)
|
{
|
/*case WebRequestMethods.Http.Put:
|
command = new PutCmd();
|
Console.WriteLine("method PUT was called");
|
break;
|
case DeleteMethod:
|
command = new DeleteCmd();
|
Console.WriteLine("method DELETE was called");
|
break;
|
case WebRequestMethods.Http.Head:
|
command = new HeadCmd();
|
Console.WriteLine("method HEAD was called");
|
break;*/
|
case WebRequestMethods.Http.Get:
|
command = new GetCmd();
|
Console.WriteLine("method GET was called");
|
break;
|
default:
|
Console.WriteLine("Unrecognized Method!");
|
response.StatusCode = NotImplemented;
|
response.OutputStream.Close();
|
break;
|
}
|
|
if (command != null)
|
command.Process(request, ref response);
|
|
|
}
|
catch (Exception ex)
|
{
|
LogConstant.logger.Print("Stop():" + ex.ToString());
|
}
|
}
|
}
|
|
/*public class PutCmd : IHttpCommand
|
{
|
public void Process(HttpListenerRequest request, ref HttpListenerResponse response)
|
{
|
string fullPath = BiosenHttpServer.ServerDirectory + request.RawUrl;
|
try
|
{
|
string copyHeader = ConfigurationManager.AppSettings["Copy"];
|
var copyPath = request.Headers[copyHeader];
|
if (copyPath != null)
|
{
|
string tempPath = BiosenHttpServer.ServerDirectory + "/" + copyPath.TrimStart('/');
|
if (File.Exists(tempPath))
|
{
|
|
File.Copy(tempPath, fullPath);
|
}
|
else
|
{
|
throw new DirectoryNotFoundException();
|
}
|
}
|
else
|
{
|
var dirname = Path.GetDirectoryName(fullPath);
|
|
if (!Directory.Exists(dirname))
|
{
|
Directory.CreateDirectory(dirname);
|
}
|
|
using (var newFile = new FileStream(fullPath, FileMode.OpenOrCreate))
|
{
|
request.InputStream.CopyTo(newFile);
|
|
}
|
}
|
}
|
catch (FileNotFoundException)
|
{
|
response.StatusCode = BiosenHttpServer.NotFounded;
|
}
|
catch (DirectoryNotFoundException)
|
{
|
response.StatusCode = BiosenHttpServer.NotFounded;
|
}
|
catch (Exception ex)
|
{
|
response.StatusCode = BiosenHttpServer.NotFounded;
|
Console.WriteLine(ex);
|
}
|
finally
|
{
|
response.OutputStream.Close();
|
}
|
}
|
}
|
|
|
public class DeleteCmd : IHttpCommand
|
{
|
|
public void Process(HttpListenerRequest request, ref HttpListenerResponse response)
|
{
|
try
|
{
|
if (Directory.Exists(BiosenHttpServer.ServerDirectory + request.RawUrl))
|
Directory.Delete(BiosenHttpServer.ServerDirectory + request.RawUrl);
|
else if (File.Exists(BiosenHttpServer.ServerDirectory + request.RawUrl))
|
File.Delete(BiosenHttpServer.ServerDirectory + request.RawUrl);
|
}
|
catch (FileNotFoundException)
|
{
|
response.StatusCode = BiosenHttpServer.NotFounded;
|
}
|
catch (DirectoryNotFoundException)
|
{
|
response.StatusCode = BiosenHttpServer.NotFounded;
|
}
|
catch (Exception)
|
{
|
response.StatusCode = BiosenHttpServer.BadRequest;
|
}
|
finally { response.OutputStream.Close(); }
|
}
|
}
|
|
|
|
public class HeadCmd : IHttpCommand
|
{
|
|
public void Process(HttpListenerRequest request, ref HttpListenerResponse response)
|
{
|
string fullPath = BiosenHttpServer.ServerDirectory + request.RawUrl;
|
|
try
|
{
|
var fileInfo = new FileInfo(fullPath);
|
response.Headers.Add("Name", fileInfo.Name);
|
response.Headers.Add("FileLength", fileInfo.Length.ToString());
|
response.Headers.Add("LastWriteTime", fileInfo.LastWriteTime.ToString("dd/MM/yyyy hh:mm"));
|
}
|
catch (FileNotFoundException)
|
{
|
response.StatusCode = BiosenHttpServer.NotFounded;
|
}
|
catch (DirectoryNotFoundException)
|
{
|
response.StatusCode = BiosenHttpServer.NotFounded;
|
}
|
catch (Exception)
|
{
|
response.StatusCode = BiosenHttpServer.NotFounded;
|
}
|
finally { response.OutputStream.Close(); }
|
}
|
}*/
|
|
public class GetCmd : IHttpCommand
|
{
|
|
public void Process(HttpListenerRequest request, ref HttpListenerResponse response)
|
{
|
Stream output = response.OutputStream;
|
|
var writer = new StreamWriter(output);
|
|
string subPath = request.RawUrl.Substring(1);
|
subPath = subPath.Replace('/', '\\');
|
string fullPath = AppDomain.CurrentDomain.BaseDirectory + subPath;
|
|
try
|
{
|
if (File.Exists(fullPath))
|
{
|
Stream file = new FileStream(fullPath, FileMode.Open);
|
file.CopyTo(output, BiosenHttpServer.BufferSize);
|
file.Close();
|
}
|
else
|
{
|
var directories = Directory.EnumerateFiles(fullPath);
|
|
foreach (var entry in directories)
|
{
|
writer.Write(JsonConvert.SerializeObject(entry));
|
}
|
writer.Flush();
|
}
|
}
|
catch (FileNotFoundException)
|
{
|
response.StatusCode = BiosenHttpServer.NotFounded;
|
}
|
catch (DirectoryNotFoundException)
|
{
|
response.StatusCode = BiosenHttpServer.NotFounded;
|
}
|
catch
|
{
|
response.StatusCode = BiosenHttpServer.BadRequest;
|
}
|
finally
|
{
|
output.Close();
|
writer.Dispose();
|
}
|
}
|
}
|
}
|
