Дождитесь запуска джина HTTP-сервера - PullRequest
Новая
       25

Дождитесь запуска джина HTTP-сервера

0 голосов
/ 10 марта 2019

Мы используем gin для предоставления некоторых REST API в производство. Теперь мне нужно кое-что сделать после запуска HTTP-сервера.

Я не очень знаком с каналами, но приведенный ниже код - это то, что я пытаюсь сделать. Как только startHTPPRouter() запускает службу HTTP, я хочу отправить сигнал на main(). Основываясь на этом сигнале, я хочу заняться другими делами.

Пожалуйста, дайте мне знать, что я делаю неправильно в приведенном ниже коде. 

func startHTTPRouter(routerChannel chan bool){
    router := gin.New()
    // Many REST API routes definitions
    router.Run("<port>")
    routerChannel <- true  // Is this gonna work ? Because Run() again launches a go routine for Serve()
}

func main() {
    routerChannel := make(chan bool)
    defer close(routerChannel)
    go startHTTPRouter(routerChannel )
    for {
        select {
        case <-routerChannel:
            doStuff()  // Only when the REST APIs are available.
            time.Sleep(time.Second * 5)
        default:
            log.Info("Waiting for router channel...")
            time.Sleep(time.Second * 5)
        }
    }
}

1 Ответ

0 голосов
/ 10 марта 2019

gin.New (). Run () блокирует API.Сервер gin не возвращается до выхода. 

func startHTTPRouter(routerChannel chan bool) {
    router := gin.New()
    router.Run("<port>")
    routerChannel <- true  // Is this gonna work ? Because Run() again launches a go routine for Serve()
}

Ниже представлен API-интерфейс gin'Run ().https://github.com/gin-gonic/gin/blob/master/gin.go

// Run attaches the router to a http.Server and starts listening and serving HTTP requests.
// It is a shortcut for http.ListenAndServe(addr, router)
// Note: this method will block the calling goroutine indefinitely unless an error happens.
func (engine *Engine) Run(addr ...string) (err error) {
    defer func() { debugPrintError(err) }()

    address := resolveAddress(addr)
    debugPrint("Listening and serving HTTP on %s\n", address)
    err = http.ListenAndServe(address, engine)
    return
}
...