http.Server {} - 多个处理程序?
珍惜时间,勤奋学习!今天给大家带来《http.Server {} - 多个处理程序?》,正文内容主要涉及到等等,如果你正在学习Golang,或者是对Golang有疑问,欢迎大家关注我!后面我会持续更新相关内容的,希望都能帮到正在学习的大家!
问题内容我有一个结构性问题:我不知道如何使用我现在构建它的方式(我可以找到可以看到它与其他模型一起工作的解决方案)。
我使用标准 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 个(不同的队列,不同的配置)但具有相同的全局变量结构。
但是这个只有一个我可以设置的处理程序 - 我如何添加多个可以理解其寻址不同全局变量变量的处理程序(我不想要多个服务器,必须在同一端口上运行)?
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
服务 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值,所以没问题。然而,一旦对变量/字段进行写入,您就需要适当的同步。
以上就是本文的全部内容了,是否有顺利帮助你解决问题?若是能给你带来学习上的帮助,请大家多多支持编程网!更多关于Golang的相关知识,也可关注编程网公众号。
免责声明:
① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。
② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341