blocks|key|3961541|text|可以为客户端和服务器端定义您的自定义拦截器。在这两种情况下，您都需要创建一个继承自Interceptor类的新类，并覆盖您想要拦截的方法。因为客户端拦截器与整个客户端类相连。在服务器端，拦截器只为服务定义创建-这意味着如果你想拥有日志拦截器，你需要为每个服务定义指定它。此外，对于客户端，您可以使用已有的带Func的扩展方法作为参数，该参数可用于简单的拦截场景(我不会向您展示它的代码，因为我现在无法访问它)。|type|unstyled|depth|inlineStyleRanges|entityRanges|offset|length|data|3961542|下面是一个简单的拦截器：|3961543|public+class+GlobalServerLoggerInterceptor+:+Interceptor
{
++++private+readonly+ILogger+logger;

++++public+GlobalServerLoggerInterceptor(ILogger+logger)
++++{
++++++++this.logger+=+logger;
++++}

++++public+override+async+Task<TResponse>+UnaryServerHandler<TRequest,+TResponse>(TRequest+request,+ServerCallContext+context,+UnaryServerMethod<TRequest,+TResponse>+continuation)
++++{
++++++++logger.Debug($"{Environment.NewLine}GRPC+Request{Environment.NewLine}Method:+{context.Method}{Environment.NewLine}Data:+{JsonConvert.SerializeObject(request,+Formatting.Indented)}");

++++++++var+response+=+await+base.UnaryServerHandler(request,+context,+continuation);

++++++++logger.Debug($"{Environment.NewLine}GRPC+Response{Environment.NewLine}Method:+{context.Method}{Environment.NewLine}Data:+{JsonConvert.SerializeObject(response,+Formatting.Indented)}");

++++++++return+response;
++++}
}|code-block|syntax|javascript|3961544|服务器端拦截器的初始化(伪代码)：|3961545|+++var+server+=+new+Grpc.Core.Server
++++++++++++{
++++++++++++++++Services+=
++++++++++++++++{

TestService.BindService(new+TestImplementationService()).Intercept(IoC.Resolve<GlobalServerLoggerInterceptor>())
++++++++++++++++},
++++++++++++++++Ports+=+{+new+ServerPort("localhost",+1234,+ServerCredentials.Insecure)+}
++++++++++++};|3961546|在上面的示例中，您可能会注意到这样的语句：|3961547|.Intercept(IoC.Resolve<GlobalServerLoggerInterceptor>())|3961548|如果您的拦截器需要一些其他类的引用，则需要在运行服务器之前对其进行初始化。|3961549|entityMap|0|LINK|mutability|MUTABLE|url|https://github.com/grpc/grpc/blob/618a3f561d4a93f263cca23abad086ed8f4d5e86/src/csharp/Grpc.Core/Interceptors/Interceptor.cs^0|15|B|0|0|0|0|0|0|0|0|0^^$0|@$1|2|3|4|5|6|7|12|8|@]|9|@$A|13|B|14|1|15]]|C|$]]|$1|D|3|E|5|6|7|16|8|@]|9|@]|C|$]]|$1|F|3|G|5|H|7|17|8|@]|9|@]|C|$I|J]]|$1|K|3|L|5|6|7|18|8|@]|9|@]|C|$]]|$1|M|3|N|5|H|7|19|8|@]|9|@]|C|$I|J]]|$1|O|3|P|5|6|7|1A|8|@]|9|@]|C|$]]|$1|Q|3|R|5|H|7|1B|8|@]|9|@]|C|$I|J]]|$1|S|3|T|5|6|7|1C|8|@]|9|@]|C|$]]|$1|U|3|-4|5|6|7|1D|8|@]|9|@]|C|$]]]|V|$W|$5|X|Y|Z|C|$10|11]]]]

It's possible to define your custom interceptor for a client and a server side. In both cases, you need to create a new class which inherit from <a href="https://github.com/grpc/grpc/blob/618a3f561d4a93f263cca23abad086ed8f4d5e86/src/csharp/Grpc.Core/Interceptors/Interceptor.cs" rel="noreferrer">Interceptor</a> class and override methods that you want to intercept. For a client-side interceptor is connected with the entire client class. In Server side interceptor is created only for a service definition - it means that if you want to have logging interceptor, you need to specify it for an every service definition. Additionally, for a client side, you can use an already available extended method with Func as a parameter that can be used for straightforward intercept scenarios (I will not show you a code for it because I don't' have access to it right now).

Below you have simple interceptor:

<pre><code>public class GlobalServerLoggerInterceptor : Interceptor
{
 private readonly ILogger logger;

 public GlobalServerLoggerInterceptor(ILogger logger)
 {
 this.logger = logger;
 }

 public override async Task&lt;TResponse&gt; UnaryServerHandler&lt;TRequest, TResponse&gt;(TRequest request, ServerCallContext context, UnaryServerMethod&lt;TRequest, TResponse&gt; continuation)
 {
 logger.Debug($"{Environment.NewLine}GRPC Request{Environment.NewLine}Method: {context.Method}{Environment.NewLine}Data: {JsonConvert.SerializeObject(request, Formatting.Indented)}");

 var response = await base.UnaryServerHandler(request, context, continuation);

 logger.Debug($"{Environment.NewLine}GRPC Response{Environment.NewLine}Method: {context.Method}{Environment.NewLine}Data: {JsonConvert.SerializeObject(response, Formatting.Indented)}");

 return response;
 }
}
</code></pre>

Initialiation of the interceptor for a server side (pseudo code):

<pre><code> var server = new Grpc.Core.Server
 {
 Services =
 {

TestService.BindService(new TestImplementationService()).Intercept(IoC.Resolve&lt;GlobalServerLoggerInterceptor&gt;())
 },
 Ports = { new ServerPort("localhost", 1234, ServerCredentials.Insecure) }
 };
</code></pre>

In the above example you may notice such statement:

<pre><code>.Intercept(IoC.Resolve&lt;GlobalServerLoggerInterceptor&gt;())
</code></pre>

If your interceptor needs a reference to some other classes you need to initialize them before you run a server.

blocks|key|3961588|text|要使用Grpc.Core创建客户端截取程序，可以执行以下操作：|type|unstyled|depth|inlineStyleRanges|entityRanges|data|3961589|var+clientInterceptor+=+new+YourClientInterceptor();
var+channel+=+new+Channel($"localhost",+ChannelCredentials.Insecure);
var+interceptingInvoker+=+channel.Intercept(clientInterceptor);
var+client+=+new+YourServiceClient(interceptingInvoker);|code-block|syntax|javascript|3961590|注意channel.Intercept(clientInterceptor)如何返回一个新的调用调用器，以便您将其传递给客户端。这是一个有点不直观的命名，但这就是我们目前的情况。|offset|length|style|CODE|3961591|要拦截客户端调用，请让拦截器覆盖/实现所需的所有...Call方法，例如BlockingUnaryCall(...)和AsyncUnaryCall(...)。|3961592|entityMap^0|0|0|2|10|0|O|7|10|M|1N|J|0^^$0|@$1|2|3|4|5|6|7|Q|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|R|8|@]|9|@]|A|$E|F]]|$1|G|3|H|5|6|7|S|8|@$I|T|J|U|K|L]]|9|@]|A|$]]|$1|M|3|N|5|6|7|V|8|@$I|W|J|X|K|L]|$I|Y|J|Z|K|L]|$I|10|J|11|K|L]]|9|@]|A|$]]|$1|O|3|-4|5|6|7|12|8|@]|9|@]|A|$]]]|P|$]]

To create a client interceptor with Grpc.Core, you can do the following:
<pre><code>var clientInterceptor = new YourClientInterceptor();
var channel = new Channel($&quot;localhost&quot;, ChannelCredentials.Insecure);
var interceptingInvoker = channel.Intercept(clientInterceptor);
var client = new YourServiceClient(interceptingInvoker);
</code></pre>
Notice how <code>channel.Intercept(clientInterceptor)</code> returns a new call invoker for you to pass on to the client. A little unintuitive naming there, but that's what we have for now.
To intercept client calls, let your interceptor override/implement all the <code>...Call</code> methods you need, for example <code>BlockingUnaryCall(...)</code> and <code>AsyncUnaryCall(...)</code>.

I'm using gRPC in C# (NETCore). I would like to log each single method call, and I expect to have some way of intercpt each call at once, instead of putting a log on each service method. Did not find how, but does not exist some interceptor strategy?

gRCP intercept calls in C#

我在C# (NETCore)中使用gRPC。我想记录每个单独的方法调用，并且我希望有一些方法可以一次中断每个调用，而不是在每个服务方法上都有一个日志。没有找到如何，但不存在一些拦截器的策略？

问C#中的gRCP截取调用
EN

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问C#中的gRCP截取调用EN

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问C#中的gRCP截取调用
EN