Go で名前付きパイプを使用するにはどうすればよいですか?

名前付きパイプは、オペレーティング システムにおける比較的低レベルのプロセス通信方法であり、ファイルを仲介として使用するプロセス通信方法です。 Go 言語では、名前付きパイプのサポートが os パッケージを通じて提供されます。この記事では、Go でプロセス間通信に名前付きパイプを使用する方法を紹介します。

1. 名前付きパイプの概念

名前付きパイプは、複数のプロセスが同時にアクセスできる特別なファイルです。 Linux システムでは、名前付きパイプはファイル システムのどこかに存在し、異なるプロセス間で共有できる特別なファイル タイプです。名前付きパイプを使用すると、異なるプロセス間でデータを転送できます。名前付きパイプはファイル システム上のファイルであるため、ファイル システムにアクセスできるすべてのプロセス間の通信に使用できます。

2. Go で名前付きパイプを使用する基本原則

Go 言語では、名前付きパイプに接続するには、os パッケージの関数を使用します。名前付きパイプは、os パッケージ内の対応する関数を使用して開閉されます。プロセスは名前付きパイプ ファイルを他のプロセスに渡すことで共有でき、名前付きパイプ ファイルにアクセスする他のプロセスはデータの読み取りと書き込みができます。

3. 名前付きパイプを使用して 2 つの Go プロセス間で通信する

名前付きパイプを使用して 2 つの Go プロセス間で通信するのは非常に簡単です。ここでは 2 つの Go プログラムを作成します。そのうちの 1 つは名前付きパイプにメッセージを書き込み、もう 1 つのプログラムは名前付きパイプからメッセージを読み取って出力します。

1. コード例-1: 名前付きパイプへの書き込み

package main

import (
    "fmt"
    "os"
)

func main() {
    fifo := "/tmp/myfifo" // 命名管道文件路径
    msg := "Hello World!" // 要写入管道的消息

    // 打开管道文件
    pipeout, err := os.OpenFile(fifo, os.O_WRONLY|os.O_CREATE|os.O_TRUNC, 0666)
    if err != nil {
        fmt.Println("Error: ", err)
        return
    }
    defer pipeout.Close()

    // 写入消息到管道
    _, err = pipeout.WriteString(msg)
    if err != nil {
        fmt.Println("Error: ", err)
        return
    }

    fmt.Println("Message sent to named pipe!")
}

5 行目では、名前付きパイプを表す定数 fifo を定義します。ファイルが置かれているパス。次に、6 行目で、パイプに書き込まれるメッセージを定義します。次に、名前付きパイプ ファイルを開き、メッセージをパイプに書き込みます。 11 行目では、os.OpenFile() 関数と os.O_WRONLY オプションを使用して、名前付きパイプ ファイルを書き込み専用モードで開きます。次に、15 行目で、pipeout.WriteString() 関数を使用して、名前付きパイプにメッセージを書き込みます。

2. コード例 2: 名前付きパイプからのメッセージの読み取りと出力

package main

import (
    "fmt"
    "os"
)

func main() {
    fifo := "/tmp/myfifo" // 命名管道文件路径
    msg := make([]byte, 1024)

    // 打开管道文件
    pipein, err := os.OpenFile(fifo, os.O_RDONLY, 0)
    if err != nil {
        fmt.Println("Error: ", err)
        return
    }
    defer pipein.Close()

    // 读取消息从管道
    n, err := pipein.Read(msg)
    if err != nil {
        fmt.Println("Error: ", err)
        return
    }

    fmt.Println("Message received from named pipe: ", string(msg[:n]))
}

5 行目では、定数 fifoパスを示します名前付きパイプファイルが置かれている場所。次に、6 行目で、パイプから読み取られたメッセージを格納するバイト配列 msg を定義します。次に、名前付きパイプ ファイルを開いて、パイプからメッセージを読み取ります。 11 行目では、os.OpenFile() 関数を使用して名前付きパイプ ファイルを開き、os.O_RDONLY オプションを使用して読み取り専用モードでファイルを開きます。次に、17 行目で、pipein.Read() 関数を使用して、名前付きパイプからメッセージを読み取り、msg 配列に保存します。最後に、19 行目で、受信したメッセージを出力します。

4. 概要

この記事では、名前付きパイプを使用して Go 言語でプロセス間通信を実現する方法を紹介します。私たちは 2 つの Go プログラムを作成しました。1 つは名前付きパイプにメッセージを書き込み、もう 1 つは名前付きパイプからメッセージを読み取って出力します。名前付きパイプを使用する場合、各プロセスはパイプの使用順序をネゴシエートする必要があることに注意してください。そうしないと、読み取りと書き込みの競合が発生し、プログラムがクラッシュします。

以上がGo で名前付きパイプを使用するにはどうすればよいですか?の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。