添加client时注册path

Author: liguoliang

src/DotNetCoreRpc.Client/ClientOptions.cs

@@ -13,6 +13,11 @@ public class ClientOptions
         private IServiceCollection _services;
         private readonly string _serviceName;
 
+        /// <summary>
+        /// 服务请求路径
+        /// </summary>
+        public string Path { get; set; }
+
         public ClientOptions(IServiceCollection services, string serviceName)
         {
             _services = services;
@@ -24,7 +29,8 @@ public ClientOptions AddRpcClient<T>() where T : class
             _services.TryAddScoped(provider => {
                 var httpClientFactory = provider.GetRequiredService<IHttpClientFactory>();
                 var proxyGenerator = provider.GetRequiredService<ProxyGenerator>();
-                RpcClient rpcClient = new RpcClient(httpClientFactory.CreateClient(_serviceName), proxyGenerator);
+                var httpClient = httpClientFactory.CreateClient(_serviceName);
+                RpcClient rpcClient = new RpcClient(httpClient, proxyGenerator, Path);
                 return rpcClient.CreateClient<T>();
             });
             return this;

src/DotNetCoreRpc.Client/RpcClient.cs

@@ -1,6 +1,7 @@
 using Castle.DynamicProxy;
 using System;
 using System.Collections.Generic;
+using System.IO;
 using System.Net.Http;
 using System.Text;
 
@@ -10,18 +11,37 @@ internal class RpcClient
     {
         private HttpClient _httpClient;
         private ProxyGenerator _proxyGenerator;
+        private string _path;
 
-        public RpcClient(HttpClient httpClient, ProxyGenerator proxyGenerator)
+        public RpcClient(HttpClient httpClient, ProxyGenerator proxyGenerator, string path)
         {
             _httpClient = httpClient;
-            _httpClient.DefaultRequestHeaders.Add("req-source", "dncrpc");
             _proxyGenerator = proxyGenerator;
+            _path = path;
         }
 
         internal T CreateClient<T>() where T : class
         {
+            InitalHttpClient();
+
             HttpRequestInterceptor httpRequestInterceptor = new HttpRequestInterceptor(_httpClient);
             return _proxyGenerator.CreateInterfaceProxyWithoutTarget<T>(httpRequestInterceptor);
         }
+
+        private void InitalHttpClient()
+        {
+            _httpClient.DefaultRequestHeaders.Add("req-source", "dncrpc");
+            if (!string.IsNullOrWhiteSpace(_path))
+            {
+                string path = _path;
+
+                if (_path.StartsWith("/"))
+                {
+                    path = path.TrimStart('/');
+                }
+
+                _httpClient.BaseAddress = new Uri(_httpClient.BaseAddress.ToString() + path);
+            }
+        }
     }
 }