日本综合一区二区|亚洲中文天堂综合|日韩欧美自拍一区|男女精品天堂一区|欧美自拍第6页亚洲成人精品一区|亚洲黄色天堂一区二区成人|超碰91偷拍第一页|日韩av夜夜嗨中文字幕|久久蜜综合视频官网|精美人妻一区二区三区

1、介紹

本文我們使用 go-micro 構(gòu)建微服務(wù)的服務(wù)端和客戶端，并使用 gin 集成客戶端構(gòu)建 HTTP Api，在代碼中模擬客戶端 RPC 調(diào)用服務(wù)端方法返回 408 的問題，以及怎么解決？

客戶端輸出日志：

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

2、使用 go-micro 構(gòu)建服務(wù)端和客戶端

關(guān)于 proto 和 consul 的相關(guān)內(nèi)容，不是本文的重點(diǎn)，將不再贅述，感興趣的讀者朋友們可以查閱公眾號(hào)的歷史文章。

創(chuàng)建服務(wù)端服務(wù)的代碼：

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()
}

服務(wù)端方法：

type User struct{}

func (u *User) Login(ctx context.Context, req *user.LoginRequest, rsp *user.LoginResponse) error {
 time.Sleep(10 * time.Second) // 模擬超時(shí)響應(yīng)
 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 相關(guān)代碼

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
}

分別啟動(dòng)服務(wù)端和客戶端， 然后使用 curl 請(qǐng)求 Api：

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

閱讀上面的運(yùn)行結(jié)果，可以發(fā)現(xiàn)我們構(gòu)建的服務(wù)端和客戶端運(yùn)行正常。

3、模擬返回 408 的問題

我們?cè)诜?wù)端的方法中使用 time.Sleep(10 * time.Second) 模擬延長響應(yīng)時(shí)長，我們修改客戶端代碼，將客戶端超時(shí)時(shí)間也設(shè)置為 10s。

修改客戶端代碼：

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

閱讀上面這段代碼，我們將客戶端超時(shí)時(shí)間改為 10s，然后重啟客戶端應(yīng)用，使用 curl 請(qǐng)求 Api：

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

運(yùn)行 curl，沒有返回響應(yīng)結(jié)果，我們查看客戶端的日志發(fā)現(xiàn)：

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

原因是服務(wù)端方法中，我們?cè)诖a中使用 time.Sleep(10 * time.Second) 模擬響應(yīng)需要 10s，而在客戶端中，我們定義的客戶端超時(shí)時(shí)間由原來的 15s 改為 10s，所以導(dǎo)致返回 408 的問題。

需要注意的是，go-micro 中 client 的默認(rèn)超時(shí)時(shí)間是 5s。

4、解決方法

我們?cè)诹私馔陠栴}出現(xiàn)的原因之后，聰明的讀者朋友們可能已經(jīng)有了解決問題的方法。

解決該問題，有兩種解決方法，第一種是修改 client 的超時(shí)時(shí)間，延長超時(shí)時(shí)間至足夠接收到響應(yīng)結(jié)果的時(shí)長，但是需要注意的是，http server 的讀寫時(shí)間也要滿足可以接收到響應(yīng)結(jié)果的時(shí)長，本文我們?cè)O(shè)置為 20s，如下所示：

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

而且還需要注意其上下游服務(wù)之間的超時(shí)時(shí)間，避免出現(xiàn)雪崩等問題。

第二種是優(yōu)化服務(wù)端方法的響應(yīng)時(shí)間，將其響應(yīng)時(shí)間縮短至客戶端的超時(shí)時(shí)間以內(nèi)。具體如何優(yōu)化，要根據(jù)實(shí)際情況決定，比如是否因?yàn)閿?shù)據(jù)庫讀寫耗時(shí)太長，代碼的時(shí)間復(fù)雜度太高等。

5、總結(jié)

本文我們介紹怎么解決客戶端 RPC 調(diào)用服務(wù)端的方法，返回錯(cuò)誤碼 408 的問題，我們使用 go-micro 和 gin 構(gòu)建了示例代碼，并通過修改示例代碼，分析出現(xiàn)返回錯(cuò)誤碼 408 問題的原因。

讀者朋友們?cè)谟龅皆搯栴}時(shí)，建議優(yōu)先采用第二種方法解決，如果使用第一種方法，需要特別注意避免分布式系統(tǒng)的雪崩問題。

分享名稱：Go微服務(wù)框架go-micro使用客戶端RPC調(diào)用服務(wù)端方法返回408怎么解決？
本文網(wǎng)址：http://www.dlmjj.cn/article/coishjg.html