gRPC（3）：拦截器

在 gRPC 调用过程中，我们可以拦截 RPC 的执行，在 RPC 服务执行前或执行后运行一些自定义逻辑，这在某些场景下很有用，例如身份验证、日志等，我们可以在 RPC 服务执行前检查调用方的身份信息，若未通过验证，则拒绝执行，也可以在执行前后记录下详细的请求响应信息到日志。这种拦截机制与 Gin 中的中间件技术类似，在 gRPC 中被称为 拦截器 ，它是 gRPC 核心扩展机制之一

拦截器不止可以作用在服务端上，客户端同样可以拦截，在请求发出之前和收到响应之后执行一些自定义逻辑，根据拦截的 RPC 类型，可分为 一元拦截器 和 流拦截器

在 gRPC 服务端，可以插入一个或多个拦截器，收到的请求按注册顺序通过各个拦截器，返回响应时则倒序通过：

通过以下步骤实现一元拦截器：

流拦截器包括前置处理阶段和流 *** 作阶段，前置处理阶段可以在流 RPC 进入具体服务实现之前进行拦截，而在流 *** 作阶段，可以对流中的每一条消息进行拦截，通过以下步骤实现流拦截器：

在服务端可以拦截收到的 RPC 调用，客户端同样可以拦截发出去的 RPC 请求以及收到的响应，同样可以实现一元拦截器以及流拦截器：

和服务端一元拦截器一样的方法，只是方法参数略微有所差别，此外在建立连接的时候注册拦截器，同样可以注册多个拦截器：

流拦截器也是和服务端一样的步骤：

参考： >内网穿透即是使用公网服务器作为代理，转发内网（如办公室、家里）的网络请求使其能够在外网中被访问到。

server端监听两个端口，一个用来和接收用户的>俗称远程过程调用，是常用的一种高效的服务调用方式，也是性能压测时经常遇到的一种服务调用形式。常见的RPC有GRPC、Thrift、Dubbo等。

RPC简单理解就是说两台服务器A，B，一个应用部署在A服务器上，想要调用B服务器上应用提供的函数/方法，由于不在个内存空间，不能直接调用，需要通过网络来表达调用的语义和传达调用的数据。

RPC就是要像调用本地的函数一样去调远程函数。假设我们要调用函数Add来计算value1 value2的结果，直接调用Add方法即可。在远程调用时，我们要执行的函数在远程的机器上。

有关gRPC官方介绍（ >

之前写的同步发送通知随着业务量的增长，已经不再适用，所以快速实现一个基本的rq队列+grpc的方式来投递通知数据并交给rq的worker去调用grpc的服务。
但是之前调用的地方太多了，所以最好还是以patch的方式去修改

原有的结构大致为图1所示

首先flask调用grpc再由grpc请求微信服务器发送消息，然后由微信响应请求后返回通知结果给grpc，grpc再返回结果给flask最终返回给客户端，所以除非等到grpc返回调用结果，否则将会一直阻塞
现在则为

这里暂时只创建一个队列去分发所有类型的通知所以message的格式需要固定
{"method":"method_name", "data":{}} ，客户端调用publish传入对应的参数即可

给标题后面加了个（1），我知道这玩意儿很快就会还要修改
可能看到这里就会有同学问了，为啥不new一个thread去执行嘞？

---