Skip to content

Commit a21ab63

Browse files
author
liguoliang
committed
添加请求标识
1 parent 1ac951e commit a21ab63

2 files changed

Lines changed: 5 additions & 2 deletions

File tree

src/DotNetCoreRpc.Client/RpcClient.cs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@ public T CreateClient<T>(string serviceName) where T : class
2323

2424
public T CreateClient<T>(HttpClient httpClient) where T : class
2525
{
26+
httpClient.DefaultRequestHeaders.Add("req-source", "dncrpc");
2627
HttpRequestInterceptor httpRequestInterceptor = new HttpRequestInterceptor(httpClient);
2728
return _proxyGenerator.CreateInterfaceProxyWithoutTarget<T>(httpRequestInterceptor);
2829
}

src/DotNetCoreRpc.Server/DncRpcIApplicationBuilderExtensions.cs

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -7,8 +7,10 @@ public static class DncRpcIApplicationBuilderExtensions
77
{
88
public static IApplicationBuilder UseDotNetCoreRpc(this IApplicationBuilder applicationBuilder)
99
{
10-
return applicationBuilder.UseWhen(context => string.Equals(context.Request.Method,"post",StringComparison.OrdinalIgnoreCase)
11-
&& context.Request.Path.Value.Contains("/DotNetCoreRpc/ServerRequest"),
10+
return applicationBuilder.UseWhen(context => context.Request.Path.Value.Contains("/DotNetCoreRpc/ServerRequest")
11+
&& context.Request.Headers.ContainsKey("req-source")
12+
&& context.Request.Headers["req-source"] == "dncrpc"
13+
&& string.Equals(context.Request.Method, "post", StringComparison.OrdinalIgnoreCase),
1214
appBuilder => appBuilder.UseMiddleware<DotNetCoreRpcMiddleware>());
1315
}
1416
}

0 commit comments

Comments
 (0)