Pekerja dan pelayan HTTP ditutup dengan baik

editor php Xigua memperkenalkan anda kepada penutupan biasa Pekerja dan pelayan HTTP dalam artikel ini. Semasa proses pembangunan, adalah sangat penting untuk menutup pelayan Pekerja dan HTTP dengan betul untuk memastikan pelepasan sumber dan keluar biasa program. Artikel ini akan menerangkan secara terperinci cara untuk menutup pelayan Pekerja dan HTTP dengan betul, serta beberapa masalah dan penyelesaian biasa. Marilah kita belajar bersama cara memastikan penutupan biasa pelayan dan meningkatkan kestabilan dan kebolehpercayaan aplikasi.

Kandungan soalan

Saya cuba mencipta proses pekerja dan pelayan http yang dimulakan secara bebas dan mendengar penamatan dan keluar dengan anggun apabila selesai.

Atas sebab tertentu urutan pekerja bermula tetapi pelayan http tidak bermula sehingga acara sigterm dihantar. Pelayan http akan bermula hanya selepas menghantar acara sigterm. Apakah masalah di bawah?

Output

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

Kod

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
}

Penyelesaian

Jika saya membaca kod anda dengan betul, anda sedang memulakan pelayan sebelum menentukan pengendali laluan. Ini bermakna apabila pelayan bermula, ia tidak tahu tentang /readiness 和 /liveness titik akhir anda kerana anda belum menambahkannya lagi. Akibatnya, pelayan bermula, tetapi ia tidak melakukan apa-apa kerana ia tidak mempunyai laluan untuk diproses.

Kemudian, anda tidak akan berada di http.server 实例中定义 addr 字段。 listenandserve() 使用调用它的 http.server 实例的 addr 字段中定义的地址。如果为空，则默认为 ":http", tetapi ini tidak dinyatakan secara jelas dalam kod anda dan boleh menyebabkan kekeliruan.

Saya berpindah srv.listenandserve ke penghujung pelayan permulaan. Apa yang saya hilang?

Masalahnya bukan di mana srv.listenandserve 在函数中的位置，而在于如何配置 http.server berada dalam fungsi, tetapi bagaimana http.server dikonfigurasikan dan apabila pengendali http ditetapkan.

Dalam kod asal, anda menetapkan pengendali http selepas pelayan bermula. Pengendali perlu ditetapkan sebelum memulakan pelayan kerana sebaik sahaja pelayan berjalan ia tidak akan mengambil mana-mana pengendali baharu yang ditentukan kemudian.

Dan selepas pernyataan log log.printf("listening on http server port: %s", srv.addr)位于srv.listenandserve(), ini adalah panggilan menyekat. Ini bermakna pernyataan log hanya akan dijalankan selepas pelayan dihentikan, itulah sebabnya anda hanya boleh melihatnya selepas menghantar isyarat sigterm.

Cuba susun semula fungsi startserver anda seperti ini:

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
}

Dalam versi ubah suai fungsi startserver 函数的修改版本中，服务器现在知道您的 /readiness 和 /liveness, pelayan kini mengetahui tentang
titik akhir anda kerana ia ditakrifkan sebelum pelayan bermula. addr Pengendali http ditetapkan sebelum pelayan bermula, dan penyata log dicetak sebelum pelayan bermula. Ini sepatutnya menyelesaikan isu anda dan membenarkan pelayan memulakan dan mengendalikan permintaan seperti yang diharapkan. Selain itu, kini pelayan tahu di mana hendak mendengar kerana

ditakrifkan dengan jelas. 🎜

Atas ialah kandungan terperinci Pekerja dan pelayan HTTP ditutup dengan baik. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!