Bagaimana untuk berhenti mendengar pada pelayan dalam Go

Dalam bahasa Go, cara berhenti mendengar pelayan adalah soalan biasa. Apabila kami perlu menghentikan pelayan, kami mahu dapat menutup semua sambungan dengan anggun tanpa menjejaskan permintaan yang sedang diproses. Artikel ini akan memperkenalkan beberapa kaedah biasa untuk membantu anda menyelesaikan masalah ini. Pertama, kita boleh menggunakan semafor untuk mengawal penutupan pelayan. Pakej os dalam bahasa Go menyediakan kaedah Isyarat yang boleh digunakan untuk menangkap isyarat yang dihantar oleh sistem pengendalian. Kita boleh mencetuskan penutupan pelayan dengan mendengar isyarat os.Interrupt, iaitu Ctrl+C. Dalam fungsi pemprosesan isyarat, kami boleh melakukan beberapa kerja pembersihan, seperti menutup sambungan pangkalan data, menyimpan data, dsb. Kemudian, hubungi kaedah Shutdown pelayan, yang akan menunggu permintaan sedia ada untuk diproses sebelum menutup pelayan. Dengan cara ini, kami boleh menghentikan pelayan mendengar dengan anggun. Perlu diingat bahawa jika pelayan tidak boleh ditutup dalam tempoh masa tertentu, kita boleh menggunakan kaedah WithTimeout dalam pakej konteks untuk menetapkan tamat masa Selepas masa ini melebihi, pelayan akan dipaksa untuk ditutup. Dengan menggunakan pendekatan ini, kami boleh memastikan pelayan ditutup dengan baik dalam apa jua keadaan. Selain menggunakan semaphore, kita juga boleh menggunakan pembolehubah jenis bool untuk mengawal penutupan pelayan. Apabila pelayan bermula, kita boleh menentukan pembolehubah bool global, seperti isShutdown. Kemudian, dalam fungsi yang mengendalikan permintaan, kita boleh menyemak nilai pembolehubah ini, dan jika ia benar, kembali serta-merta dan hentikan memproses permintaan semasa. Apabila menutup pelayan, kami menetapkan isShutdown kepada benar dan kemudian menunggu semua permintaan diproses sebelum keluar dari program. Kaedah ini agak mudah, tetapi memerlukan penambahan pertimbangan logik tambahan pada fungsi yang mengendalikan permintaan, yang mungkin sedikit menjejaskan prestasi. Ringkasnya, sama ada menggunakan pembolehubah semafor atau bool, kita boleh melaksanakan fungsi menghentikan pelayan mendengar dengan anggun dalam bahasa Go. Kaedah yang manakah untuk dipilih bergantung pada keperluan khusus anda dan kerumitan projek anda

Kandungan soalan

Saya telah cuba mencari cara untuk menghentikan pelayan mendengar yang sedang berjalan dengan anggun. Kerana listen.accept menyekat, soket pendengaran perlu ditutup untuk menandakan penamat, tetapi saya tidak dapat membezakan antara ralat itu dan sebarang ralat lain kerana ralat yang berkaitan tidak dieksport.

Bolehkah saya berbuat lebih baik? Sila rujuk fixme中以下代码中的serve()

package main

import (
    "io"
    "log"
    "net"
    "time"
)

// echo server struct
type echoserver struct {
    listen net.listener
    done   chan bool
}

// respond to incoming connection
//
// write the address connected to then echo
func (es *echoserver) respond(remote *net.tcpconn) {
    defer remote.close()
    _, err := io.copy(remote, remote)
    if err != nil {
        log.printf("error: %s", err)
    }
}

// listen for incoming connections
func (es *echoserver) serve() {
    for {
        conn, err := es.listen.accept()
        // fixme i'd like to detect "use of closed network connection" here
        // fixme but it isn't exported from net
        if err != nil {
            log.printf("accept failed: %v", err)
            break
        }
        go es.respond(conn.(*net.tcpconn))
    }
    es.done <- true
}

// stop the server by closing the listening listen
func (es *echoserver) stop() {
    es.listen.close()
    <-es.done
}

// make a new echo server
func newechoserver(address string) *echoserver {
    listen, err := net.listen("tcp", address)
    if err != nil {
        log.fatalf("failed to open listening socket: %s", err)
    }
    es := &echoserver{
        listen: listen,
        done:   make(chan bool),
    }
    go es.serve()
    return es
}

// main
func main() {
    log.println("starting echo server")
    es := newechoserver("127.0.0.1:18081")
    // run the server for 1 second
    time.sleep(1 * time.second)
    // close the server
    log.println("stopping echo server")
    es.stop()
}

Ini akan mencetak

2012/11/16 12:53:35 Starting echo server
2012/11/16 12:53:36 Stopping echo server
2012/11/16 12:53:36 Accept failed: accept tcp 127.0.0.1:18081: use of closed network connection

Saya mahu menyembunyikan mesej terima gagal, tetapi jelas sekali saya tidak mahu menyembunyikan ralat lain yang boleh dilaporkan oleh terima. Saya sudah tentu boleh melihat ujian ralat untuk penggunaan sambungan rangkaian tertutup tetapi itu akan menjadi sangat hodoh. Saya boleh menetapkan bendera untuk menunjukkan bahawa saya akan menutup dan mengabaikan ralat jika ia ditetapkan, saya rasa - adakah terdapat cara yang lebih baik? accept failed 消息，但显然我不想掩盖 accept 可以报告的其他错误。我当然可以查看 use of closed network connection 的错误测试，但这真的很难看。我可以设置一个标志，表示我即将关闭并忽略错误（如果已设置），我想 - 有更好的方法吗？

解决方法

在 accept() 调用之后检查循环中的一些“是时候停止”标志，然后从 mainPenyelesaian Semak bendera "masa untuk berhenti" dalam gelung selepas panggilan accept(), kemudian flip ia daripada utama dan kemudian sambung

ke anda Port mendengar untuk mendapatkan soket pelayan "tanpa tersekat". Ini sangat mirip dengan 🎜"helah paip diri"🎜 lama. 🎜

Atas ialah kandungan terperinci Bagaimana untuk berhenti mendengar pada pelayan dalam Go. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!