想要远程停止http服务器

Question

我想远程停止http服务器（我可以做到），但我也想在停止后收到一条指示它已停止的消息。这给我带来了一些问题。我能找到的唯一解决方案如下所示，我认为这并不理想。 谁能提供更好的解决方案。问题是发送到客户端的最终消息无法通过，除非我使用“go func() {”末尾所示的 goroutine。

代码如下：

//*************
func stopServer(ohtWriter http.ResponseWriter, phtRequest *http.Request) {// Stop The Server
//*************

    var iBytesSent  int
    var oOsError    os.Error
    var sErmes  string

    println("Stopping Server")

    iBytesSent,oOsError = ohtWriter.Write([]byte("Message from server - server now stopped."))

    if oOsError != nil {
        sErmes = ". Error = " +oOsError.String()
    } else {
        sErmes = ". No error on write"
    }

    println("stopServer: Bytes sent = " +strconv.Itoa(iBytesSent) +sErmes)

    ohtFlusher, tCanFlush := ohtWriter.(http.Flusher)
    if tCanFlush {
        ohtFlusher.Flush()
    }

    go func() {
        time.Sleep(3e9)
        os.Exit(0)
    }()
}

Answer 1

是的，我认为如果没有 http 包的支持，优雅的关闭是不可能的。这可能不那么令人畏惧，但仍然会猛烈关闭在此请求时正在运行的任何其他并发请求。也许可以尝试在 Go 问题跟踪器 上提交功能请求。更好的是，打开http包，添加一个优雅的关闭方法，然后提交。

编辑：我想如果您控制应用程序中的所有 http.Handler，您可以保留进行中请求的计数（使用适当的线程同步），并将下面的代码修改为 a) 拒绝一旦调用“关闭”，就会建立新的连接 b) 在关闭之前等待所有正在进行的请求完成...

package main

import (
    "http"
    "os"
    "io"
    "log"
    "strconv"
)

func main() {
    http.HandleFunc("/", ServeHTTP)
    http.ListenAndServe(":8081", nil)
}

const responseString = "Shutting down\n"

func ServeHTTP(w http.ResponseWriter, req *http.Request) {
    w.Header().Set("Content-Type", "text/plain; charset=utf-8")
    w.Header().Set("Content-Length", strconv.Itoa(len(responseString)))
    io.WriteString(w, responseString)

    f, canFlush := w.(http.Flusher)
    if canFlush {
        f.Flush()
    }

    conn, _, err := w.(http.Hijacker).Hijack()
    if err != nil {
        log.Fatalf("error while shutting down: %v", err)
    }

    conn.Close()

    log.Println("Shutting down")
    os.Exit(0)
}   

Answer 2

还没尝试过，但是直接使用 http.ServerConn可能会起作用。

Answer 3

这是一个足够适合本地开发的简单方法。

http://www.sergiotapia.me/how-to-停止你的http服务器/

---

package main

import (  
    "net/http"
    "os"

    "github.com/bmizerany/pat"
)

var mux = pat.New()

func main() {  
    mux.Get("/kill", http.HandlerFunc(kill))
    http.Handle("/", mux)
    http.ListenAndServe(":8080", nil)
}

func kill(w http.ResponseWriter, r *http.Request) {  
    os.Exit(0)
}