2

私は現在 Go と ZeroMQ の両方を学んでおり、その精神でZguideの Go の例に貢献しようとしています。割り込みの例で少し苦労しています。問題を処理する慣用的な方法が何であるかはわかりません。

私が現在持っている解決策は次のとおりです。SIGINTシグナルを受信するチャネルを作成します。そうなったら、メインループでブレークするために使用される他のチャネルに bool を書き込みます。問題は、Recv がブロックされており、ループがループ状態をチェックできないことです。NOBLOCK 定数を Recv に渡すことで、この問題を回避しています。しかし、中断されたときにRecvがEINTRを返す必要があるため、より良い方法があると思います（私が知る限りではそうではありません）。読者の皆さんは、私よりもこの質問に答える能力がはるかに優れていますが、どう思いますか?

あなたの便宜のために、私がこれまでに持っているコード:

package main

import (
    "os/signal"
    "os"
    "fmt"
    zmq "github.com/alecthomas/gozmq"
)

func listenForSignals(exit_channel chan bool) {
    signal_channel := make(chan os.Signal)
    signal.Notify(signal_channel)
    <- signal_channel
    fmt.Println("stopping")
    exit_channel <- true
}

func main() {
    exit := make(chan bool)
    exit_signal := false
    go listenForSignals(exit)

    context, _ := zmq.NewContext()
    defer context.Close()

    socket, _ := context.NewSocket(zmq.REP)
    defer socket.Close()
    socket.Bind("tcp://*:5555")

    for exit_signal == false {
      select {
      case exit_signal = <- exit:
        fmt.Println("W: interrupt received, killing server...")
      default:
        msgbytes, err := socket.Recv(zmq.NOBLOCK)
        fmt.Printf("%s.\n", string(msgbytes))
      }
    }

}

編集は、フィードバックに基づいてコードをいくらか簡素化しました

4

2 に答える 2

2

select ステートメントを使用してチャネルを切り替える場合は、socket.Recv の結果もチャネルで返す必要があります。これにより、ゴルーチンで socket.Recv を実行することもできるため、ブロッキングの性質は問題になりません。

現実的には、発生したエラーも処理する必要があります。これは、シバン全体に別のチャネルを追加することで実行できます。

func main() {
    ...

    data := make(chan []byte)
    errors := make(chan error)
    go function() {
      for {
        msgbytes, err := socket.Recv(0)
        if err != nil {
          errors <- err
        } else {
          data <- msgbytes
        }
      }
    }()

    for exit_signal == false {
      select {
      case exit_signal = <- exit:
        fmt.Println("W: interrupt received, killing server...")
      case err := <- errors:
        fmt.Println("Receive Error:", err.Error())
      case msgbytes := <- data:
        fmt.Printf("%s.\n", string(msgbytes))
      }
    }

}
于 2012-07-02T18:45:30.100 に答える
0

これは少し複雑に見えます。メインでは、割り込みシグナルを待っているゴルーチンを開始できます。

go func() {
    sigchan := make(chan os.Signal, 10)
    signal.Notify(sigchan, os.Interrupt)
    <-sigchan
    log.Println("Application killed !")
    // do things like writing your last will or cursing the killer before you really die        
    os.Exit(2)
}()
// starts the things your application has to do
于 2012-06-18T10:34:58.003 に答える