Go 微服务框架 go-micro 使用客户端 RPC 调用服务端方法返回 408 怎么解决?

简介: Go 微服务框架 go-micro 使用客户端 RPC 调用服务端方法返回 408 怎么解决?

介绍

本文我们使用 go-micro 构建微服务的服务端和客户端,并使用 gin 集成客户端构建 HTTP Api,在代码中模拟客户端 RPC 调用服务端方法返回 408 的问题,以及怎么解决?

客户端输出日志:

{"id":"go.micro.client","code":408,"detail":"context deadline exceeded","status":"Request Timeout"}

使用 go-micro 构建服务端和客户端

关于 proto 和 consul 的相关内容,不是本文的重点,将不再赘述,感兴趣的读者朋友们可以查阅公众号的历史文章。

创建服务端服务的代码:

func main() {
 registry := consul.NewRegistry(func(options *registry.Options) {
  options.Addrs = []string{"127.0.0.1:8500"}
  options.Timeout = 5 * time.Second
 })
 // create a new service
 service := grpc.NewService(
  micro.Name("go.micro.srv.user"),
  micro.Registry(registry),
 )
 // handler
 user.RegisterUserHandler(service.Server(), new(user_handler.User))
 // initialise flags
 service.Init()
 // start the service
 service.Run()
}

服务端方法:

type User struct{}
func (u *User) Login(ctx context.Context, req *user.LoginRequest, rsp *user.LoginResponse) error {
 time.Sleep(10 * time.Second) // 模拟超时响应
 rsp.Username = "Welcome " + req.Email
 return nil
}

客户端代码:

func main() {
 r := NewRouter()
 server := &http.Server{
  Addr:           ":8080",
  Handler:        r,
  ReadTimeout:    time.Second * 20,
  WriteTimeout:   time.Second * 20,
  MaxHeaderBytes: 1 << 20,
 }
 if err := server.ListenAndServe(); err != nil {
  log.Fatal(err)
 }
}
// 省略 User.Login 相关代码
func NewRouter() *gin.Engine {
 r := gin.New()
 userHandler := new(User)
 r.GET("/login", userHandler.Login)
 return r
}
func NewClient() user.UserService {
 registry := consul.NewRegistry(func(options *registry.Options) {
  options.Addrs = []string{"127.0.0.1:8500"}
  options.Timeout = 5 * time.Second
 })
 client := grpc.NewClient(
  client.DialTimeout(15*time.Second),
  client.RequestTimeout(15*time.Second),
  client.Registry(registry),
 )
 userClient := user.NewUserService("go.micro.srv.user", client)
 return userClient
}

分别启动服务端和客户端, 然后使用 curl 请求 Api:

➜  /Users/frank curl http://127.0.0.1:8080/login
{"data":"Welcome gopher@88.com"}%

阅读上面的运行结果,可以发现我们构建的服务端和客户端运行正常。

03

模拟返回 408 的问题

我们在服务端的方法中使用 time.Sleep(10 * time.Second) 模拟延长响应时长,我们修改客户端代码,将客户端超时时间也设置为 10s

修改客户端代码:

client.DialTimeout(10*time.Second),
client.RequestTimeout(10*time.Second),

阅读上面这段代码,我们将客户端超时时间改为 10s,然后重启客户端应用,使用 curl 请求 Api:

/Users/frank curl http://127.0.0.1:8080/login

运行 curl,没有返回响应结果,我们查看客户端的日志发现:

{"id":"go.micro.client","code":408,"detail":"context deadline exceeded","status":"Request Timeout"}

原因是服务端方法中,我们在代码中使用 time.Sleep(10 * time.Second) 模拟响应需要 10s,而在客户端中,我们定义的客户端超时时间由原来的 15s 改为 10s,所以导致返回 408 的问题。

需要注意的是,go-micro 中 client 的默认超时时间是 5s

04

解决方法

我们在了解完问题出现的原因之后,聪明的读者朋友们可能已经有了解决问题的方法。

解决该问题,有两种解决方法,第一种是修改 client 的超时时间,延长超时时间至足够接收到响应结果的时长,但是需要注意的是,http server 的读写时间也要满足可以接收到响应结果的时长,本文我们设置为 20s,如下所示:

server := &http.Server{
  Addr:           ":8080",
  Handler:        r,
  ReadTimeout:    time.Second * 20,
  WriteTimeout:   time.Second * 20,
  MaxHeaderBytes: 1 << 20,
 }

而且还需要注意其上下游服务之间的超时时间,避免出现雪崩等问题。

第二种是优化服务端方法的响应时间,将其响应时间缩短至客户端的超时时间以内。具体如何优化,要根据实际情况决定,比如是否因为数据库读写耗时太长,代码的时间复杂度太高等。

05

总结

本文我们介绍怎么解决客户端 RPC 调用服务端的方法,返回错误码 408 的问题,我们使用 go-micro 和 gin 构建了示例代码,并通过修改示例代码,分析出现返回错误码 408 问题的原因。

读者朋友们在遇到该问题时,建议优先采用第二种方法解决,如果使用第一种方法,需要特别注意避免分布式系统的雪崩问题。

推荐阅读:

参考资料:

  1. https://github.com/go-micro/go-micro
  2. https://gin-gonic.com/docs/


目录
相关文章
|
5月前
|
监控 算法 NoSQL
Go 微服务限流与熔断最佳实践:滑动窗口、令牌桶与自适应阈值
🌟蒋星熠Jaxonic:Go微服务限流熔断实践者。分享基于滑动窗口、令牌桶与自适应阈值的智能防护体系,助力高并发系统稳定运行。
Go 微服务限流与熔断最佳实践:滑动窗口、令牌桶与自适应阈值
|
8月前
|
人工智能 测试技术 Go
Go 语言的主流框架
本文全面解析了 Go 语言主流技术生态,涵盖 Web 框架、微服务、数据库工具、测试与部署等多个领域。重点介绍了 Gin、Echo、Beego 等高性能框架,以及 gRPC-Go、Go-Micro 等微服务组件。同时分析了 GORM、Ent 等 ORM 工具与测试部署方案,并结合场景提供选型建议,助力开发者构建高效稳定的 Go 应用。
2112 0
|
6月前
|
消息中间件 缓存 NoSQL
Redis各类数据结构详细介绍及其在Go语言Gin框架下实践应用
这只是利用Go语言和Gin框架与Redis交互最基础部分展示;根据具体业务需求可能需要更复杂查询、事务处理或订阅发布功能实现更多高级特性应用场景。
399 86
|
5月前
|
JavaScript 前端开发 Java
【GoWails】Go做桌面应用开发?本篇文章带你上手Wails框架!一步步带你玩明白前后端双端的数据绑定!
wails是一个可以让你使用Go和Web技术编写桌面应用的项目 可以将它看作Go的快并且轻量级的Electron替代品。可以使用Go的功能,并结合现代化UI完成桌面应用程序的开发
1096 5
|
5月前
|
存储 安全 Java
【Golang】(4)Go里面的指针如何?函数与方法怎么不一样?带你了解Go不同于其他高级语言的语法
结构体可以存储一组不同类型的数据,是一种符合类型。Go抛弃了类与继承,同时也抛弃了构造方法,刻意弱化了面向对象的功能,Go并非是一个传统OOP的语言,但是Go依旧有着OOP的影子,通过结构体和方法也可以模拟出一个类。
310 2
|
5月前
|
开发框架 前端开发 Go
【GoGin】(0)基于Go的WEB开发框架,GO Gin是什么?怎么启动?本文给你答案
Gin:Go语言编写的Web框架,以更好的性能实现类似Martini框架的APInet/http、Beego:开源的高性能Go语言Web框架、Iris:最快的Go语言Web框架,完备的MVC支持。
545 1
|
10月前
|
Go C++
Go语言方法与接收者 -《Go语言实战指南》
本文介绍了 Go 语言中方法的相关概念和用法。方法是绑定到特定类型上的函数,包含值接收者和指针接收者两种形式。值接收者不会改变原始数据,而指针接收者可修改原始数据,且在处理大型结构体时性能更优。文章详细对比了方法与普通函数的区别,并说明了选择指针接收者的原因,如修改原始值、提升性能及保持一致性。此外,Go 支持为任意自定义类型定义方法,不仅限于结构体。最后通过表格总结了方法的核心概念和使用场景。
276 34
|
9月前
|
开发框架 JSON 中间件
Go语言Web开发框架实践:路由、中间件、参数校验
Gin框架以其极简风格、强大路由管理、灵活中间件机制及参数绑定校验系统著称。本文详解其核心功能:1) 路由管理,支持分组与路径参数;2) 中间件机制,实现全局与局部控制;3) 参数绑定,涵盖多种来源;4) 结构体绑定与字段校验,确保数据合法性;5) 自定义校验器扩展功能;6) 统一错误处理提升用户体验。Gin以清晰模块化、流程可控及自动化校验等优势,成为开发者的优选工具。
|
9月前
|
开发框架 安全 前端开发
Go Web开发框架实践:模板渲染与静态资源服务
Gin 是一个功能强大的 Go Web 框架,不仅适用于构建 API 服务,还支持 HTML 模板渲染和静态资源托管。它可以帮助开发者快速搭建中小型网站,并提供灵活的模板语法、自定义函数、静态文件映射等功能,同时兼容 Go 的 html/template 引擎,具备高效且安全的页面渲染能力。
|
9月前
|
开发框架 JSON 中间件
Go语言Web开发框架实践:使用 Gin 快速构建 Web 服务
Gin 是一个高效、轻量级的 Go 语言 Web 框架,支持中间件机制,非常适合开发 RESTful API。本文从安装到进阶技巧全面解析 Gin 的使用:快速入门示例(Hello Gin)、定义 RESTful 用户服务(增删改查接口实现),以及推荐实践如参数校验、中间件和路由分组等。通过对比标准库 `net/http`,Gin 提供更简洁灵活的开发体验。此外,还推荐了 GORM、Viper、Zap 等配合使用的工具库,助力高效开发。

热门文章

最新文章