「労働者が自分の仕事をうまくやりたいなら、まず自分の道具を研ぎ澄まさなければなりません。」 - 孔子、「論語。陸霊公」
表紙 > プログラミング > Go TCP サーバーを正常にシャットダウンし、「(*TCPListener) Accept」ゴルーチンを中断する方法は?

Go TCP サーバーを正常にシャットダウンし、「(*TCPListener) Accept」ゴルーチンを中断する方法は?

2024 年 11 月 12 日に公開
ブラウズ:265

How to Gracefully Shut Down a Go TCP Server and Interrupt the `(*TCPListener) Accept` Goroutine?

Go ルーチンの実行を中断しています (*TCPListener) Accept

Go で TCP サーバーを作成しているときに、正常に実行するという課題に遭遇する可能性があります。サーバーをシャットダウンし、ゴルーチン処理を中断します func (*TCPListener) Accept.

Go では、 func (*TCPListener) Accept は、接続が受信されるまで実行をブロックします。このゴルーチンを中断するには、次のようにする必要があります:

net.Listener を閉じる:

Accept ゴルーチンを中断する鍵は、net から取得した net.Listener を閉じることです。聞く(...)。リスナーを閉じることで、これ以上接続を受信しないことをオペレーティング システムに通知し、Accept ゴルーチンを終了させます。

Goroutine からのリターン:

終了後リスナーは、Goroutine が戻ってくることを確認してください。ゴルーチンに Accept 呼び出しの後にコードがある場合、実行が継続され、意図しない動作やエラーが発生する可能性があります。

コード例:

package main

import (
    "fmt"
    "net"
)

func main() {
    ln, err := net.Listen("tcp", ":8080")
    if err != nil {
        // Handle error
    }

    go func() {
        for {
            conn, err := ln.Accept()
            if err != nil {
                if err == net.ErrClosed {
                    return // Listener was closed
                }
                // Handle other errors
            }
            // Handle connection
            conn.Close()
        }
    }()

    fmt.Println("Press enter to stop...")
    var input string
    fmt.Scanln(&input)

    ln.Close() // Close the listener, interrupting the Accept loop
}

このコードは、ポート 8080 で TCPListener を作成し、無限ループで受信接続を処理するゴルーチンを起動します。ユーザーが Enter キーを押すと、プログラムはリスナーを閉じ、ブロックしている Accept 呼び出しを中断し、ゴルーチンを返します。

最新のチュートリアル もっと>

免責事項: 提供されるすべてのリソースの一部はインターネットからのものです。お客様の著作権またはその他の権利および利益の侵害がある場合は、詳細な理由を説明し、著作権または権利および利益の証拠を提出して、電子メール [email protected] に送信してください。 できるだけ早く対応させていただきます。

Copyright© 2022 湘ICP备2022001581号-3