后台打印程序概念/API 和通道：将作业从 serveHTTP 传递到队列
在这里已经得到了一些帮助，这让我在我正在尝试的这个概念上取得了进展，但它仍然不太奏效，我遇到了一个我似乎无法解决的冲突。
我在这里尝试在流程图中说明我想要的内容 - 请注意，客户端可以是许多将发送 printjobs 的客户端，因此我们无法回复工作人员当时正在处理我们的工作，但对于大多数情况而言（高峰时间不会，因为打印的处理工作可能需要时间）。
type QueueElement struct {
jobid string
rw http.ResponseWriter
doneChan chan struct{}
}
type GlobalVars struct {
db *sql.DB
wg sync.WaitGroup
jobs chan QueueElement
}
func (gv *GlobalVars) ServeHTTP(w http.ResponseWriter, r *http.Request) {
switch r.URL.Path {
case "/StartJob":
fmt.Printf ("incoming\r\n")
doneC := make(chan struct{}, 1) //Buffered channel in order not to block the worker routine
newPrintJob := QueueElement{
doneChan: doneC,
jobid: "jobid",
}
上面的代码是 serveHTTP 和 worker 的帮助，最初 ServeHTTP 中的 func 是一个 go 例程，在这里对我来说整个冲突都出现了 - 这个概念是在 serveHTTP 中它产生一个将得到回复的进程如果工人能够在 5 秒内及时处理作业，则从工人处获得。
如果工作能够在 1 秒内完成，我想在 1 秒后立即回复客户，如果需要 3 秒，我想在 3 秒后回复，如果超过 5 秒，我会在 5 秒后回复（如果工作需要 13 秒，我仍然想在 5 秒后回复）。从现在开始，客户必须对工作进行轮询——但冲突是：
a) 当 ServeHTTP 退出时 - 然后 ResponseWriter 关闭 - 为了能够回复客户端，我们必须将答案写入 ResponseWriter。
b) 如果我阻止 serveHTTP（就像在下面的代码示例中，我没有将 func 称为 go 例程）那么它不仅会影响单个 API 调用，而且似乎会影响之后的所有其他调用，所以第一个呼叫将被及时正确地服务，但是在第一个呼叫之后同时进入的呼叫将被阻塞操作顺序延迟。
c) 如果我不阻止它 ex - 并将其更改为 go 例程：
gv.jobs <- newPrintJob
go func(doneChan chan struct{},w http.ResponseWriter) {
然后没有延迟 - 可以调用许多 API - 但问题是 serveHTTP 立即存在并因此杀死 ResponseWriter 然后我无法回复客户端。
我不确定如何解决这个冲突，因为我不会对 serveHTTP 造成任何阻塞，所以我可以并行处理所有请求，但仍然能够回复有问题的 ResponseWriter。
有什么方法可以防止 serveHTTP 在函数退出时关闭响应编写器？
慕妹31465933回答
-
UYOU
是的，如果我不阻止它，你的观点“c) 是正确的” 。为了保存响应编写器，您不应该在其中调用 go routine。相反，您应该将ServeHTTP作为 go-routine 调用，大多数 http 服务器实现都这样做。这样你就不会阻止任何 api 调用，每个 api 调用将在不同的 go-routine 中运行，被它们的功能阻止。由于您的“jobs chan QueueElement”是单个通道（不是缓冲通道），因此您的所有进程都在“gv.jobs <- newPrintJob”处被阻塞。您应该使用缓冲通道，以便所有 api 调用都可以将其添加到队列中并根据工作完成或超时获得响应。拥有缓冲通道也可以模拟打印机在现实世界中的内存限制。（队列长度 1 是特例） -
慕的地6264312
我已经为您的代码添加了一些更新。现在它像你描述的那样工作。package mainimport ( "database/sql" "fmt" "log" "math/rand" "net/http" "sync" "time")type QueueElement struct { jobid string rw http.ResponseWriter doneChan chan struct{}}type GlobalVars struct { db *sql.DB wg sync.WaitGroup jobs chan QueueElement}func (gv *GlobalVars) ServeHTTP(w http.ResponseWriter, r *http.Request) { switch r.URL.Path { case "/StartJob": fmt.Printf("incoming\r\n") doneC := make(chan struct{}, 1) //Buffered channel in order not to block the worker routine go func(doneChan chan struct{}, w http.ResponseWriter) { gv.jobs <- QueueElement{ doneChan: doneC, jobid: "jobid", } }(doneC, w) select { case <-time.Tick(time.Second * 5): fmt.Fprintf(w, "job is taking more than 5 seconds to complete\r\n") fmt.Printf("took longer than 5 secs\r\n") case <-doneC: fmt.Fprintf(w, "instant reply from serveHTTP\r\n") fmt.Printf("instant\r\n") } default: fmt.Fprintf(w, "No such Api") }}func worker(jobs <-chan QueueElement) { for { job := <-jobs fmt.Println("START /i /b try.cmd") fmt.Printf("job done") randTimeDuration := time.Second * time.Duration(rand.Intn(7)) time.Sleep(randTimeDuration) // processExec("START /i /b processAndPrint.exe -" + job.jobid) job.doneChan <- struct{}{} }}func main() { // create a GlobalVars instance gv := GlobalVars{ //db: db, jobs: make(chan QueueElement), } go worker(gv.jobs) // create an http.Server instance and specify our job manager as // the handler for requests. server := http.Server{ Handler: &gv, Addr: ":8888", } // start server and accept connections. log.Fatal(server.ListenAndServe())} -
牛魔王的故事
select语句应该在 goroutine 函数之外并阻止请求直到作业执行结束或达到超时。
随时随地看视频慕课网APP
相关分类
Go