go - Http.Server {} - 多个处理程序?
问题描述
我有一个结构性问题:我不知道如何使用我现在构建它的方式(我可以找到可以看到它与其他模型一起使用的解决方案)。
我正在使用标准的 Net/Http,并使用以下代码启动我的服务器:
gv := GlobalVars{
jobs: make(chan QueueElement),
appConfig: appConfig,
}
go worker(&gv)
server := http.Server{
Handler: &gv,
Addr: ":" + appConfig.Port,
}
log.Fatal(server.ListenAndServe())
然后我有一个处理程序来检查一个案例中的所有路由:
func (gv *GlobalVars) ServeHTTP(w http.ResponseWriter, r *http.Request) {
}
该应用程序正在启动一些将作业传递到队列的 api。
我的问题是,我需要启动其中的 3 个(不同的队列,不同的配置)但相同的 globalvar 结构。
但是这个只有一个我可以设置的处理程序 - 我将如何添加多个处理程序(我不想要多个服务器,必须在同一个端口上运行)可以理解它对不同 globalvars 变量的寻址?
server := http.Server{
Handler: &gv,
Addr: ":" + appConfig.Port,
}
解决方案
看看net.http.ServeMux类型:
ServeMux 是一个 HTTP 请求多路复用器。它将每个传入请求的 URL 与已注册模式列表进行匹配,并为与 URL 最匹配的模式调用处理程序。
ServeMux本身就是一个并通过请求路由http.Handler
多路复用到不同的子处理程序。根据我对您的问题的理解,您希望在同一台服务器上拥有不同的处理程序,并且每个处理程序使用不同的配置处理不同的队列。
使用 ServeMux 可以轻松实现:
gv1 := GlobalVars{
jobs: make(chan QueueElement),
appConfig: appConfig1,
}
gv2 := GlobalVars{
jobs: make(chan QueueElement),
appConfig: appConfig2,
}
gv3 := GlobalVars{
jobs: make(chan QueueElement),
appConfig: appConfig3,
}
sm := http.NewServeMux()
// Let gv{1,2,3} handle routes{1,2,3} respectively
sm.Handle("/route1", &gv1)
sm.Handle("/route2", &gv2)
sm.Handle("/route3", &gv3)
// Register the ServeMux as the sole Handler. It will delegate to the subhandlers.
server := http.Server{
Handler: sm,
Addr: ":" + globalAppConfig.Port,
}
请注意,您不必http.Server
自己构建一个。如果你只需要一台服务器,你可以使用 http 包级函数http.ListenAndServe和http.Handle来为你创建一个服务器和默认的 ServeMux。
// same GlobalVars as above
// ...
// Instead of creating a ServeMux we can use the global DefaultServeMux
http.Handle("/route1", &gv1)
http.Handle("/route2", &gv2)
http.Handle("/route3", &gv3)
// Calling the package level ListenAndServe uses the single global server.
// Passing nil as the Handler uses the DefaultServeMux as Handler on which we registered the Handlers above.
log.Fatal(http.ListenAndServe(":" + globalAppConfig.Port, nil)
更新
一个标准的小例子,ServeMux
两个Handler
s 服务 3 个路线
// Keeping this type simple for the example
type GlobalVars struct {
appConfig string
}
// This method makes every GlobalVars a net.http.Handler
func (gv *GlobalVars) ServeHTTP(w http.ResponseWriter, req *http.Request) {
fmt.Fprintf(w, "%s here. Receiving request for %s\n", gv.appConfig, req.URL.Path)
}
func main() {
gv1 := &GlobalVars{
appConfig: "gv1",
}
gv2 := &GlobalVars{
appConfig: "gv2",
}
// Handle requires a route and a Handler, our gvs are Handlers.
// gv1 handles two routes, while gv2 handles only one.
http.Handle("/route1", gv1)
http.Handle("/route2", gv1)
http.Handle("/route3", gv2)
log.Fatal(http.ListenAndServe(":8000", nil))
}
如果我依次调用所有三个路由,我将收到以下响应:
$ curl localhost:8000/route1
gv1 here. Receiving request for /route1
$ curl localhost:8000/route2
gv1 here. Receiving request for /route2
$ curl localhost:8000/route3
gv2 here. Receiving request for /route3
这显示了如何使用有状态变量作为处理程序(例如 GlobalVars 类型的变量)。
注意:处理程序方法ServeHTTP
有一个指针接收器用于GlobalVars
. 这意味着该方法可能会更改GlobalVars
变量。HTTP 处理程序是同时执行的(想象在很短的时间内对同一个处理程序的多个请求,您将希望尽可能保持响应)。这个例子只读取 appConfig 的值,所以没问题。但是,一旦对变量/字段的写入混合在一起,您将需要适当的同步。
推荐阅读
- asp.net-identity - IdentityServer4 中的查询字符串
- asp.net-core - 使用(本地)Gitlab 服务器作为 OAuth 提供者
- symfony - Doctrine 在更新 CURRENT_TIMESTAMP 上不断更新 DATETIME
- javascript - 如何从打字稿控制器调用 javascript 指令链接函数 l
- java - 使用 Get 方法仅提取数组列表中索引的特定部分
- php - 使用 Google 注册 API 如何获取用户的电话号码?
- php - 我可以使用 google drive api 上传受密码保护的 pdf 吗?
- c++ - 使用 noexcept 运算符依赖
- postgresql - Postgres - 将最近邻距离插入另一个表
- azure - 您如何处理用于 Azure VM 的 Terraform 中有多个 storage_os_disk 块?