通过通道处理 HTTP 请求的模式

从现在开始，我们要努力学习啦！今天我给大家带来《通过通道处理 Http 请求的模式》，感兴趣的朋友请继续看下去吧！下文中的内容我们主要会涉及到等等知识点，如果在阅读本文过程中有遇到不清楚的地方，欢迎留言呀！我们一起讨论，一起学习！

我正在编写一个 WEB 应用程序，其中有一个长时间运行的 Goroutine。 我想通过通道将所有 http 请求委托给这个 goroutine。 我遇到的模式是：

// Internal long running goroutine
for{
  select{
  case e := <-event: //web request
    req := e.req
    // do something
    ....
    select {
    case <-ctx.Done():
       //log  
    default: 
      e.replyTo <- result
    }
  }
}

// Web handler
http.HandleFunc("/bar", func(w http.ResponseWriter, r *http.Request) {
  //decode request etc
  ...

  replyTo := make(chan interface{}, 1)
  ctx, cancel := context.WithCancel(context.BackGround())
  event <- Event{req: req, ctx: ctx, replyTo: replyTo}
  select{
  case <-time.After(time.Second):
     cancel()
     //return 500
  case r := <-replyTo:
    // return some response
  }
})

我确实看到最后只有一个 go 例程，因此并行性丢失了，但我对此感到满意。

这种模式是执行此操作的正确方法吗？ 还可以建议哪些其他方法？

解决方案

假设您试图在单个 go 例程中管理 where 状态，我会说不。我认为最好有某种形式的状态管理器来负责线程安全。因此，处理程序应该接受一些可以管理状态的东西，并简单地向处理程序公开一些方法。

type State interface{
  Load() (string, error)
  Save(something string) error
}

解耦代码将在稍后为您带来回报。它还允许对处理程序和状态进行单元测试，使其具有焦点和可读性。

今天关于《通过通道处理 HTTP 请求的模式》的内容介绍就到此结束，如果有什么疑问或者建议，可以在编程网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！