Le travailleur et le serveur HTTP se sont arrêtés correctement

l'éditeur php Xigua vous présente l'arrêt normal des Workers et des serveurs HTTP dans cet article. Pendant le processus de développement, il est très important d'arrêter correctement le Worker et le serveur HTTP pour assurer la libération des ressources et la sortie normale du programme. Cet article explique en détail comment arrêter correctement les serveurs Workers et HTTP, ainsi que certains problèmes et solutions courants. Apprenons ensemble comment assurer l'arrêt normal du serveur et améliorer la stabilité et la fiabilité de l'application.

Contenu de la question

J'essaie de créer un processus de travail et un serveur http qui sont démarrés indépendamment et écoutent la fin et se terminent gracieusement une fois terminé.

Pour une raison quelconque, le thread de travail démarre mais le serveur http ne démarre pas tant que l'événement sigterm n'est pas envoyé. Le serveur http ne démarrera qu'après l'envoi de l'événement sigterm. Quel est le problème ci-dessous ?

Sortie

https://gosamples.dev is the best
https://gosamples.dev is the best
https://gosamples.dev is the best
^c2023/05/27 15:07:52 listening on http server port:

process finished with the exit code 0

Code

package main

import (
    "context"
    "fmt"
    "log"
    "net/http"
    "os"
    "os/signal"
    "sync"
    "syscall"
    "time"
)

func main() {
    ctx, cancel := context.WithCancel(context.Background())

    go func() {
        signals := make(chan os.Signal, 1)
        signal.Notify(signals, os.Interrupt, syscall.SIGTERM)
        <-signals

        cancel()
    }()

    var wg sync.WaitGroup

    wg.Add(1)
    go func() {
        if err := myWorker(ctx); err != nil {
            cancel()
        }
        wg.Done()
    }()

    wg.Add(1)
    go func() {
        if err := startServer(ctx); err != nil {
            cancel()
        }
        wg.Done()
    }()

    wg.Wait()
}

func myWorker(ctx context.Context) error {
    shouldStop := false

    go func() {
        <-ctx.Done()
        shouldStop = true
    }()

    for !shouldStop {
        fmt.Println("https://gosamples.dev is the best")
        time.Sleep(1 * time.Second)
    }

    return nil
}

func startServer(ctx context.Context) error {
    var srv http.Server

    go func() {
        <-ctx.Done() // Wait for the context to be done

        // Shutdown the server
        if err := srv.Shutdown(context.Background()); err != nil {
            // Error from closing listeners, or context timeout:
            log.Printf("HTTP server Shutdown: %v", err)
        }
    }()

    if err := srv.ListenAndServe(); err != http.ErrServerClosed {
        // Error starting or closing listener:
        return fmt.Errorf("HTTP server ListenAndServe: %w", err)
    }

    log.Printf("Listening on HTTP server port: %s", srv.Addr)

    http.HandleFunc("/readiness", func(w http.ResponseWriter, r *http.Request) {
        w.WriteHeader(200)
    })
    http.HandleFunc("/liveness", func(w http.ResponseWriter, r *http.Request) {
        w.WriteHeader(200)
    })

    return nil
}

Solution de contournement

Si j'ai lu correctement votre code, vous démarrez le serveur avant de définir le gestionnaire de route. Cela signifie que lorsque le serveur démarre, il ne connaît pas vos /readiness 和 /liveness points de terminaison car vous ne les avez pas encore ajoutés. En conséquence, le serveur démarre, mais il ne fait rien car il n'a aucune route à traiter.

Alors, vous ne serez pas dans http.server 实例中定义 addr 字段。 listenandserve() 使用调用它的 http.server 实例的 addr 字段中定义的地址。如果为空，则默认为 ":http", mais cela n'est pas explicitement indiqué dans votre code et peut prêter à confusion.

J'ai déménagé srv.listenandserve à la toute fin de startserver. Qu'est-ce que j'ai raté?

Le problème n'est pas où se trouve srv.listenandserve 在函数中的位置，而在于如何配置 http.server dans la fonction, mais comment http.server est configuré et quand le gestionnaire http est défini.

Dans le code d'origine, vous définissez le gestionnaire http après le démarrage du serveur. Les gestionnaires doivent être définis avant de démarrer le serveur, car une fois le serveur exécuté, il ne récupérera aucun nouveau gestionnaire défini ultérieurement.

Et après la déclaration du journal log.printf("listening on http server port: %s", srv.addr)位于srv.listenandserve(), il s'agit d'un appel bloquant. Cela signifie que l'instruction de journalisation ne sera exécutée qu'après l'arrêt du serveur, c'est pourquoi vous ne pourrez la voir qu'après avoir envoyé le signal sigterm.

Essayez de réorganiser votre startserver fonction comme ceci :

func startServer(ctx context.Context) error {
    srv := &http.Server{
        Addr: ":8080", // Define the address where you want the server to listen
    }

    http.HandleFunc("/readiness", func(w http.ResponseWriter, r *http.Request) {
        w.WriteHeader(200)
    })
    http.HandleFunc("/liveness", func(w http.ResponseWriter, r *http.Request) {
        w.WriteHeader(200)
    })

    go func() {
        <-ctx.Done() // Wait for the context to be done

        // Shutdown the server
        if err := srv.Shutdown(context.Background()); err != nil {
            // Error from closing listeners, or context timeout:
            log.Printf("HTTP server Shutdown: %v", err)
        }
    }()

    log.Printf("Listening on HTTP server port: %s", srv.Addr)

    if err := srv.ListenAndServe(); err != nil && err != http.ErrServerClosed {
        // Error starting or closing listener:
        return fmt.Errorf("HTTP server ListenAndServe: %w", err)
    }

    return nil
}

Dans la version modifiée de la fonction startserver 函数的修改版本中，服务器现在知道您的 /readiness 和 /liveness, le serveur connaît désormais vos points de terminaison
car ils ont été définis avant le démarrage du serveur. addr Les gestionnaires http sont définis avant le démarrage du serveur et les instructions de journal sont imprimées avant le démarrage du serveur. Cela devrait résoudre votre problème et permettre au serveur de démarrer et de traiter les requêtes comme prévu. De plus, le serveur sait désormais où écouter car

est clairement défini. 🎜

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!