gRPC超时拦截器实现示例
更新时间:2022年6月16日 10:32 点击:287 作者:尹东勋
介绍
本文介绍如何通过 rk-boot 快速搭建 gRPC 超时拦截器。
什么是 gRPC 超时拦截器?
拦截器会拦截 gRPC 请求,并根据策略返回超时错误。
安装
go get github.com/rookie-ninja/rk-boot go get github.com/rookie-ninja/rk-grpc
快速开始
使用 rk-boot 启动的 gRPC 服务。
支持全局超时和 API 超时设定。
1.创建 boot.yaml
boot.yaml 文件告诉 rk-boot 如何启动 gRPC 服务。
为了验证,我们启动了 commonService,commonService 里包含了一系列常用 API,例如 /rk/v1/gc。
设定全局超时为 5秒,让 GC 的超时时间定位 1 毫秒,GC 一般会超过 1 毫秒。
--- grpc: - name: greeter # Required port: 8080 # Required enabled: true # Required commonService: enabled: true # Optional, Enable common service for testing interceptors: timeout: enabled: true # Optional, default: false timeoutMs: 5000 # Optional, default: 5000 paths: - path: "/rk.api.v1.RkCommonService/Gc" # Optional, default: "" timeoutMs: 1 # Optional, default: 5000
2.创建 main.go
// Copyright (c) 2021 rookie-ninja // // Use of this source code is governed by an Apache-style // license that can be found in the LICENSE file. package main import ( "context" "github.com/rookie-ninja/rk-boot" _ "github.com/rookie-ninja/rk-grpc/boot" ) // Application entrance. func main() { // Create a new boot instance. boot := rkboot.NewBoot() // Bootstrap boot.Bootstrap(context.Background()) // Wait for shutdown sig boot.WaitForShutdownSig(context.Background()) }
3.启动 main.go
$ go run main.go
4.验证
发送 GC 请求。
$ grpcurl -plaintext localhost:8080 rk.api.v1.RkCommonService.Gc ERROR: Code: Canceled Message: Request timed out! Details: 1) {"@type":"type.googleapis.com/rk.api.v1.ErrorDetail","code":1,"message":"[from-grpc] Request timed out!","status":"Canceled"}
$ curl -X GET localhost:8080/rk/v1/gc { "error":{ "code":408, "status":"Request Timeout", "message":"Request timed out!", "details":[ { "code":1, "status":"Canceled", "message":"[from-grpc] Request timed out!" } ] } }
以上就是gRPC超时拦截器实现示例的详细内容,更多关于gRPC超时拦截器的资料请关注猪先飞其它相关文章!
原文出处:https://juejin.cn/post/7030478524523741221
相关文章
- 这篇文章主要介绍了解决Java处理HTTP请求超时的问题,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-03-29
- 这篇文章主要介绍了Nodejs回调加超时限制两种实现方法的相关资料,需要的朋友可以参考下...2017-06-15
- 这篇文章主要介绍了C#百万数据查询出现超时问题的解决方法,是非常实用的技巧,需要的朋友可以参考下...2020-06-25
- 这篇文章主要介绍了golang在GRPC中设置client的超时时间,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-04-27
- 任何时候,如果我们想要为请求添加全局功能,例如身份认证、错误处理等,在请求发送给服务器之前或服务器返回时对其进行拦截,是比较好的实现手段...2016-01-05
springboot配置多数据源后mybatis拦截器失效的解决
这篇文章主要介绍了springboot配置多数据源后mybatis拦截器失效的解决方案,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教...2021-09-23- 可能有不少用户会发现自己的ecshop经常会使用关就超时了,这个问题解决办法有很多种,我们可以直接在ecsho中进行修改,具体方法如下 在includescls_session.php中修改...2016-11-25
- 本篇文章是对C#键盘勾子(Hook)拦截器,屏蔽键盘活动进行了详细的分析介绍,需要的朋友参考下...2020-06-25
- 这篇文章主要介绍了基于FeignClient调用超时的处理方案,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教...2021-07-05
- 这篇文章主要给大家介绍了关于Spring Boot连接超时导致502错误的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2020-09-04
- 本文介绍了使用spring拦截器实现日志管理实例的教程,非常实用,有兴趣的同学可以参考一下本文 使用HandlerInterceptor拦截器,可以拦截请求,实现通用的日志管理操作 一...2017-07-06
SpringBoot之HandlerInterceptor拦截器的使用详解
这篇文章主要介绍了SpringBoot之HandlerInterceptor拦截器的使用详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2020-10-26- php中session默认是30分钟超时,但是有的时间压根就没到30分钟就自动超时了,这对很多操作带来不便,下面我们来看看解决30分钟超时的办法。 第一种回答 那么, 最常见的...2016-11-25
使用Spring的拦截器监测每个Controller或方法的执行时长
这篇文章主要介绍了使用Spring的拦截器监测每个Controller或方法的执行时长,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教...2021-10-28- angularjs作为一个全ajax的框架,对于请求,如果页面上不做任何操作的话,在结果反回来之前,页面是没有任何响应的,不像普通的HTTP请求,会有进度条之类...2015-12-29
- 这篇文章主要介绍了解决Shiro 处理ajax请求拦截登录超时的问题,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教...2021-09-06
- 这篇文章主要给大家介绍了关于C#利用Task实现任务超时,多任务一起执行的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友下面来一起看看吧。...2020-06-25
- 这篇文章主要介绍了SpringMVC自定义拦截器登录检测功能的实现,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下...2021-08-08
- 这篇文章主要介绍了Nginx服务器中配置超时时间的方法,同时也对Nginx中的时间管理机制作了详细的介绍,需要的朋友可以参考下...2016-01-27
- 这篇文章主要介绍了C# Socket连接请求超时机制实现,下面提供代码分享,大家可以参考使用...2020-06-25