如果连接丢失,golang gin 停止处理程序如何立即运行
How golang gin stop handler function immediately if connection is lost
我正在使用 gin-gonic/gin 编写我的服务器。
好像连掉线了,处理函数还在运行。比如我访问http://127.0.0.1:8080/ping,突然关闭浏览器,屏幕会继续打印所有的数字。
package main
import (
"github.com/gin-gonic/gin"
"log"
"time"
)
func main() {
r := gin.Default()
r.GET("/ping", func(c *gin.Context) {
for i := 1; i < 15; i++ {
time.Sleep(time.Second * 1)
log.Println(i)
}
c.JSON(200, gin.H{
"message": "pong",
})
})
r.Run("127.0.0.1:8080")
}
我应该如何立即停止处理函数(例如减少服务器负载)?
request context is canceled when the client disconnects, so simply check if c.Done() 已准备好接收:
package main
import (
"log"
"time"
"github.com/gin-gonic/gin"
)
func main() {
r := gin.Default()
r.GET("/ping", func(c *gin.Context) {
t := time.NewTicker(1 * time.Second)
defer t.Stop()
for i := 1; i < 15; i++ {
select {
case <-t.C:
log.Println(i)
case <-c.Request.Context().Done():
// client gave up
return
}
}
c.JSON(200, gin.H{
"message": "pong",
})
})
r.Run("127.0.0.1:8080")
}
我正在使用 gin-gonic/gin 编写我的服务器。
好像连掉线了,处理函数还在运行。比如我访问http://127.0.0.1:8080/ping,突然关闭浏览器,屏幕会继续打印所有的数字。
package main
import (
"github.com/gin-gonic/gin"
"log"
"time"
)
func main() {
r := gin.Default()
r.GET("/ping", func(c *gin.Context) {
for i := 1; i < 15; i++ {
time.Sleep(time.Second * 1)
log.Println(i)
}
c.JSON(200, gin.H{
"message": "pong",
})
})
r.Run("127.0.0.1:8080")
}
我应该如何立即停止处理函数(例如减少服务器负载)?
request context is canceled when the client disconnects, so simply check if c.Done() 已准备好接收:
package main
import (
"log"
"time"
"github.com/gin-gonic/gin"
)
func main() {
r := gin.Default()
r.GET("/ping", func(c *gin.Context) {
t := time.NewTicker(1 * time.Second)
defer t.Stop()
for i := 1; i < 15; i++ {
select {
case <-t.C:
log.Println(i)
case <-c.Request.Context().Done():
// client gave up
return
}
}
c.JSON(200, gin.H{
"message": "pong",
})
})
r.Run("127.0.0.1:8080")
}