Nekoxy/HttpProxy.cs

   1 using System;\r
   2 using System.Collections.Generic;\r
   3 using System.Linq;\r
   4 using System.Threading.Tasks;\r
   5 using TrotiNet;\r
   6 \r
   7 namespace Nekoxy\r
   8 {\r
   9     /// <summary>\r
  10     /// HTTPプロキシサーバー。\r
  11     /// HTTPプロトコルにのみ対応し、HTTPS等はサポートしない。\r
  12     /// </summary>\r
  13     public static class HttpProxy\r
  14     {\r
  15         private static TcpServer server;\r
  16 \r
  17         /// <summary>\r
  18         /// HTTPレスポンスをプロキシクライアントに送信完了した際に発生。\r
  19         /// </summary>\r
  20         public static event Action<Session> AfterSessionComplete;\r
  21 \r
  22         /// <summary>\r
  23         /// アップストリームプロキシの指定を有効にする。\r
  24         /// 既定値false。\r
  25         /// trueの場合、Startup メソッド時に設定されたシステムプロキシを無視し、\r
  26         /// UpstreamProxyHost プロパティと UpstreamProxyPort プロパティをアップストリームプロキシに設定する。\r
  27         /// </summary>\r
  28         public static bool IsEnableUpstreamProxy\r
  29         {\r
  30             get { return TransparentProxyLogic.IsEnableUpstreamProxy; }\r
  31             set { TransparentProxyLogic.IsEnableUpstreamProxy = value; }\r
  32         }\r
  33 \r
  34         /// <summary>\r
  35         /// アップストリームプロキシのホスト名。\r
  36         /// Startupメソッド時に設定されたシステムプロキシより優先して利用される。\r
  37         /// アップストリームプロキシは UpstreamProxyHost が null の場合はダイレクトアクセスとなる。\r
  38         /// TrotiNet は Dns.GetHostAddresses で取得されたアドレスを順番に接続試行するため、\r
  39         /// 接続先によっては動作が遅くなる可能性がある。\r
  40         /// 例えば 127.0.0.1 で待ち受けているローカルプロキシに対して接続したい場合、\r
  41         /// localhost を指定するとまず ::1 へ接続試行するため、動作が遅くなってしまう。\r
  42         /// </summary>\r
  43         public static string UpstreamProxyHost\r
  44         {\r
  45             get { return TransparentProxyLogic.UpstreamProxyHost; }\r
  46             set { TransparentProxyLogic.UpstreamProxyHost = value; }\r
  47         }\r
  48 \r
  49         /// <summary>\r
  50         /// アップストリームプロキシのポート番号。\r
  51         /// アップストリームプロキシは UpstreamProxyHost が null の場合無効となる。\r
  52         /// </summary>\r
  53         public static int UpstreamProxyPort\r
  54         {\r
  55             get { return TransparentProxyLogic.UpstreamProxyPort; }\r
  56             set { TransparentProxyLogic.UpstreamProxyPort = value; }\r
  57         }\r
  58 \r
  59         /// <summary>\r
  60         /// プロキシサーバーが Listening 中かどうかを取得。\r
  61         /// </summary>\r
  62         public static bool IsInListening => server != null && server.IsListening;\r
  63 \r
  64         /// <summary>\r
  65         /// ローカルポート番号を取得する。\r
  66         /// </summary>\r
  67         public static int LocalPort { get; private set; }\r
  68 \r
  69         /// <summary>\r
  70         /// 指定ポートで Listening を開始する。\r
  71         /// Shutdown() を呼び出さずに2回目の Startup() を呼び出した場合、InvalidOperationException が発生する。\r
  72         /// </summary>\r
  73         /// <param name="listeningPort">Listeningするポート。</param>\r
  74         /// <param name="useIpV6">falseの場合、127.0.0.1で待ち受ける。trueの場合、::1で待ち受ける。既定false。</param>\r
  75         /// <param name="isSetIEProxySettings">trueの場合、プロセス内IEプロキシの設定を実施し、アップストリームプロキシにシステム設定プロキシを設定する。既定true。</param>\r
  76         public static void Startup(int listeningPort, bool useIpV6 = false, bool isSetIEProxySettings = true)\r
  77         {\r
  78             if (server != null) throw new InvalidOperationException("Calling Startup() twice without calling Shutdown() is not permitted.");\r
  79 \r
  80             TransparentProxyLogic.AfterSessionComplete += InvokeAfterSessionComplete;\r
  81             try\r
  82             {\r
  83                 if (isSetIEProxySettings)\r
  84                 {\r
  85                     WinInetUtil.SetProxyInProcessByUrlmon(listeningPort);\r
  86                     var systemProxyHost = WinInetUtil.GetSystemHttpProxyHost();\r
  87                     var systemProxyPort = WinInetUtil.GetSystemHttpProxyPort();\r
  88                     if (systemProxyPort != listeningPort || systemProxyHost.IsLoopbackHost())\r
  89                     {\r
  90                         //自身が指定されていた場合上流には指定しない\r
  91                         TransparentProxyLogic.DefaultUpstreamProxyHost = systemProxyHost;\r
  92                         TransparentProxyLogic.DefaultUpstreamProxyPort = systemProxyPort;\r
  93                     }\r
  94                 }\r
  95 \r
  96                 server = new TcpServer(listeningPort, useIpV6);\r
  97                 server.Start(TransparentProxyLogic.CreateProxy);\r
  98                 server.InitListenFinished.WaitOne();\r
  99                 LocalPort = server.LocalPort;\r
 100                 if (server.InitListenException != null) throw server.InitListenException;\r
 101             }\r
 102             catch (Exception)\r
 103             {\r
 104                 Shutdown();\r
 105                 throw;\r
 106             }\r
 107         }\r
 108 \r
 109         /// <summary>\r
 110         /// Listening しているスレッドを終了し、ソケットを閉じる。\r
 111         /// </summary>\r
 112         public static void Shutdown()\r
 113         {\r
 114             TransparentProxyLogic.AfterSessionComplete -= InvokeAfterSessionComplete;\r
 115             server?.Stop();\r
 116             server = null;\r
 117         }\r
 118 \r
 119         private static void InvokeAfterSessionComplete(Session session)\r
 120             => AfterSessionComplete?.Invoke(session);\r
 121     }\r
 122 }\r