Go言語でのホットリロードと接続の維持方法はどう実装しますか？

1年 ago
蓮, 翼
1 minute

Go言語でホットリロードを実装して接続を維持するには、以下の手順に従うことができます。

  1. シグナル
  2. シギント
  3. 終了シグナルSIGTERM
  4. ネット機 Listen
  5. ネットワーク接続を受け入れる
  6. bufio.NewReader を日本語で言い換えると、bufio.NewReader です。
  7. 文字列を読む
  8. os / exec を日本語で言うと、「os / 実行」です。
  9. 再起動後、アドレスとポートを再度監視して、新しい接続を受け入れることができます。

以下は単純なサンプルコードです。

package main

import (
    "bufio"
    "fmt"
    "net"
    "os"
    "os/exec"
    "os/signal"
    "syscall"
)

func handleConnection(conn net.Conn) {
    defer conn.Close()

    reader := bufio.NewReader(conn)
    for {
        line, err := reader.ReadString('\n')
        if err != nil {
            fmt.Println("Error reading from connection:", err)
            return
        }

        // 处理读取到的数据
        fmt.Println("Received:", line)
    }
}

func main() {
    // 捕获SIGINT和SIGTERM信号
    sigChan := make(chan os.Signal, 1)
    signal.Notify(sigChan, syscall.SIGINT, syscall.SIGTERM)
    go func() {
        <-sigChan
        // 接收到信号时执行一些清理操作
        fmt.Println("Received signal, shutting down...")
        // 关闭之前的连接
        // 执行一些清理操作
        // 重启程序
        cmd := exec.Command(os.Args[0])
        cmd.Stdout = os.Stdout
        cmd.Stderr = os.Stderr
        err := cmd.Start()
        if err != nil {
            fmt.Println("Error restarting program:", err)
        }
        os.Exit(0)
    }()

    // 监听指定的地址和端口
    listener, err := net.Listen("tcp", "localhost:8080")
    if err != nil {
        fmt.Println("Error listening:", err)
        os.Exit(1)
    }
    defer listener.Close()

    fmt.Println("Listening on localhost:8080")

    for {
        // 接收新的连接
        conn, err := listener.Accept()
        if err != nil {
            fmt.Println("Error accepting connection:", err)
            continue
        }
        // 处理连接
        go handleConnection(conn)
    }
}

このサンプルコードは、localhost:8080のTCP接続を監視し、接続を受けたときにデータをプリントします。また、SIGINTやSIGTERMシグナルを受け取ると、清掃作業を実行し、プログラムを再起動します。

bannerAds