🐛 HttpVersion 因按原本逻辑转发

xygkevin · Jul 1, 2024 · 49fdead · 49fdead
1 parent bca8024
commit 49fdead
Showing 1 changed file with 20 additions and 11 deletions.
diff --git a/....ReverseProxy/Services.Implementation/HttpServer/Middleware/HttpReverseProxyMiddleware.cs b/....ReverseProxy/Services.Implementation/HttpServer/Middleware/HttpReverseProxyMiddleware.cs
@@ -57,7 +57,16 @@ public async Task InvokeAsync(HttpContext context, RequestDelegate next)
             {
                 var httpClient = httpClientFactory.CreateHttpClient("GlobalProxy", defaultDomainConfig);
                 var destinationPrefix = GetDestinationPrefix(context.Request.Scheme, context.Request.Host, null);
-                var error = await httpForwarder.SendAsync(context, destinationPrefix, httpClient, ForwarderRequestConfig.Empty, HttpTransformer.Empty);
+                var forwarderRequestConfig = new ForwarderRequestConfig()
+                {
+                    Version = context.Request.Protocol switch
+                    {
+                        var protocol when protocol.StartsWith("HTTP/2") => System.Net.HttpVersion.Version20,
+                        var protocol when protocol.StartsWith("HTTP/3") => System.Net.HttpVersion.Version30,
+                        _ => System.Net.HttpVersion.Version11,
+                    },
+                };
+                var error = await httpForwarder.SendAsync(context, destinationPrefix, httpClient, forwarderRequestConfig, HttpTransformer.Empty);
                 if (error != ForwarderError.None)
                 {
                     await HandleErrorAsync(context, error);
@@ -109,22 +118,22 @@ public async Task InvokeAsync(HttpContext context, RequestDelegate next)
                 context.Request.Headers.UserAgent = domainConfig.UserAgent.Replace("${origin}", context.Request.Headers.UserAgent, StringComparison.OrdinalIgnoreCase);
             }
 
-            //var forwarderRequestConfig = new ForwarderRequestConfig()
-            //{
-            //    Version = context.Request.Protocol switch
-            //    {
-            //        var protocol when protocol.StartsWith("HTTP/2") => System.Net.HttpVersion.Version20,
-            //        var protocol when protocol.StartsWith("HTTP/3") => System.Net.HttpVersion.Version30,
-            //        _ => System.Net.HttpVersion.Version11,
-            //    },
-            //};
+            var forwarderRequestConfig = new ForwarderRequestConfig()
+            {
+                Version = context.Request.Protocol switch
+                {
+                    var protocol when protocol.StartsWith("HTTP/2") => System.Net.HttpVersion.Version20,
+                    var protocol when protocol.StartsWith("HTTP/3") => System.Net.HttpVersion.Version30,
+                    _ => System.Net.HttpVersion.Version11,
+                },
+            };
 
             if (domainConfig.IsServerSideProxy)
             {
                 SetWattHeaders(context, reverseProxyConfig.Service.ServerSideProxyToken);
             }
 
-            var error = await httpForwarder.SendAsync(context, destinationPrefix, httpClient, ForwarderRequestConfig.Empty, HttpTransformer.Empty);
+            var error = await httpForwarder.SendAsync(context, destinationPrefix, httpClient, forwarderRequestConfig, HttpTransformer.Empty);
 
             if (error != ForwarderError.None)
             {