客户端输出日志：
{"id":"go.micro.client","code":408,"detail":"context deadline exceeded","status":"Request Timeout"}2、使用 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"}%
阅读上面的运行结果，可以发现我们构建的服务端和客户端运行正常。
3、模拟返回 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。
4、解决方法
我们在了解完问题出现的原因之后，聪明的读者朋友们可能已经有了解决问题的方法。
解决该问题，有两种解决方法，第一种是修改 client 的超时时间，延长超时时间至足够接收到响应结果的时长，但是需要注意的是，http server 的读写时间也要满足可以接收到响应结果的时长，本文我们设置为 20s，如下所示：
server := &http.Server{
Addr: ":8080",
Handler: r,
ReadTimeout: time.Second * 20,
WriteTimeout: time.Second * 20,
MaxHeaderBytes: 1 << 20,
}而且还需要注意其上下游服务之间的超时时间，避免出现雪崩等问题。
第二种是优化服务端方法的响应时间，将其响应时间缩短至客户端的超时时间以内。具体如何优化，要根据实际情况决定，比如是否因为数据库读写耗时太长，代码的时间复杂度太高等。
5、总结
本文我们介绍怎么解决客户端 RPC 调用服务端的方法，返回错误码 408 的问题，我们使用 go-micro 和 gin 构建了示例代码，并通过修改示例代码，分析出现返回错误码 408 问题的原因。
读者朋友们在遇到该问题时，建议优先采用第二种方法解决，如果使用第一种方法，需要特别注意避免分布式系统的雪崩问题。
免责声明：
① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的，并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据，供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。
② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341
