github
/
v2rayN
mirror of https://github.com/2dust/v2rayN
1
0
Fork 0
Code Issues Releases Wiki Activity

e

2dust 2019-09-30 19:07:40 +08:00
parent 4eb7f312b5
commit 74852be816
3 changed files with 13 additions and 197 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

181
v2rayN/v2rayN/HttpProxyHandler/HttpWebServerB.cs
View File

@ -1,181 +0,0 @@
using System;
using System.Collections;
using System.IO;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
namespace v2rayN.HttpProxyHandler
{
public class HttpWebServerB
{
TcpListener listener;
bool is_active = true;
private Stream inputStream;
public StreamWriter outputStream;
public String http_method;
public String http_url;
public String http_protocol_versionstring;
public Hashtable httpHeaders = new Hashtable();
private int port;
private Func<string, string> _responderMethod;
public HttpWebServerB(int port, Func<string, string> method)
{
this.port = port;
this._responderMethod = method;
Thread thread = new Thread(WorkThread);
thread.IsBackground = true;
thread.Start();
}
public void Stop()
{
//if (listener != null)
//{
// listener.Stop();
// listener = null;
//}
}
public void WorkThread()
{
listen();
}
private void listen()
{
listener = new TcpListener(IPAddress.Any, port);
listener.Start();
while (is_active)
{
TcpClient socket = listener.AcceptTcpClient();
//HttpProcessor processor = new HttpProcessor(s, this);
//Thread thread = new Thread(new ThreadStart(process));
Thread thread = new Thread(new ParameterizedThreadStart(process));
thread.Start(socket);
//thread.Start();
Thread.Sleep(1);
}
}
private void process(object obj)
{
try
{
var socket = obj as TcpClient;
inputStream = new BufferedStream(socket.GetStream());
outputStream = new StreamWriter(new BufferedStream(socket.GetStream()));
parseRequest();
readHeaders();
if (http_method.Equals("GET"))
{
handleGETRequest(socket);
}
outputStream.BaseStream.Flush();
inputStream = null; outputStream = null; // bs = null;
socket.Close();
}
catch (Exception ex)
{
}
}
/// <summary>
/// 复制请求
/// </summary>
private void parseRequest()
{
String request = streamReadLine(inputStream);
string[] tokens = request.Split(' ');
if (tokens.Length != 3)
{
throw new Exception("invalid http request line");
}
http_method = tokens[0].ToUpper();
http_url = tokens[1];
http_protocol_versionstring = tokens[2];
}
/// <summary>
/// 读取请求头
/// </summary>
private void readHeaders()
{
String line;
while ((line = streamReadLine(inputStream)) != null)
{
if (line.Equals(""))
{
return;
}
int separator = line.IndexOf(':');
if (separator == -1)
{
throw new Exception("invalid http header line: " + line);
}
String name = line.Substring(0, separator);
int pos = separator + 1;
while ((pos < line.Length) && (line[pos] == ' '))
{
pos++; // strip any spaces
}
string value = line.Substring(pos, line.Length - pos);
httpHeaders[name] = value;
}
}
private string streamReadLine(Stream inputStream)
{
int next_char;
string data = "";
while (true)
{
next_char = inputStream.ReadByte();
if (next_char == '\n') { break; }
if (next_char == '\r') { continue; }
if (next_char == -1) { Thread.Sleep(1); continue; };
data += Convert.ToChar(next_char);
}
return data;
}
/// <summary>
/// 重载相应Get方法
/// </summary>
/// <param name="p"></param>
private void handleGETRequest(TcpClient socket)
{
String executeResult = String.Empty;
if (http_url.ToLower().Contains("/pac/"))
{
var address = ((IPEndPoint)socket.Client.LocalEndPoint).Address.ToString();
string pac = _responderMethod(address);
writeSuccess("application/x-ns-proxy-autoconfig");
outputStream.WriteLine(pac);
outputStream.Flush();
return;
}
}
/// <summary>
/// 回复成功
/// </summary>
/// <param name="content_type"></param>
private void writeSuccess(string content_type = "text/html")
{
outputStream.WriteLine("HTTP/1.0 200 OK");
outputStream.WriteLine(String.Format("Content-Type:{0};", content_type));
outputStream.WriteLine("Connection: close");
outputStream.WriteLine("");
}
}
}

28
v2rayN/v2rayN/HttpProxyHandler/PACServerHandle.cs
View File

@ -26,22 +26,20 @@ namespace v2rayN.HttpProxyHandler
public static void Init(Config config)
{
var serverB = new HttpWebServerB(Global.pacPort, SendResponse);
pacPort = Global.pacPort;
//if (InitServer("*"))
//{
// pacPort = Global.pacPort;
//}
//else if (InitServer("127.0.0.1"))
//{
// pacPort = Global.pacPort;
//}
//else
//{
// Utils.SaveLog("Webserver init failed ");
// pacPort = 0;
//}
if (InitServer("*"))
{
pacPort = Global.pacPort;
}
else if (InitServer("127.0.0.1"))
{
pacPort = Global.pacPort;
}
else
{
Utils.SaveLog("Webserver init failed ");
pacPort = 0;
}
}
private static bool InitServer(string address)

1
v2rayN/v2rayN/v2rayN.csproj
View File

@ -182,7 +182,6 @@
<Compile Include="Handler\StatisticsHandler.cs" />
<Compile Include="Handler\V2rayUpdateHandle.cs" />
<Compile Include="HttpProxyHandler\HttpWebServer.cs" />
<Compile Include="HttpProxyHandler\HttpWebServerB.cs" />
<Compile Include="HttpProxyHandler\PACFileWatcherHandle.cs" />
<Compile Include="HttpProxyHandler\PrivoxyHandler.cs" />
<Compile Include="HttpProxyHandler\PACListHandle.cs" />