Goの標準入力パイプ処理について解説

package main
import (
	"fmt"
	"os"
)
func main() {
	// ユーザーに入力を促すメッセージを表示
	fmt.Print("入力してください: ")
	// 入力された内容を格納する変数
	var input string
	// os.Stdinから一行読み取る
	_, err := fmt.Fscanln(os.Stdin, &input)
	if err != nil {
		fmt.Println("入力エラー:", err)
		return
	}
	// 入力内容を表示
	fmt.Println("入力された内容:", input)
}

入力してください: (ここに入力した文字列)
入力された内容: (入力した文字列)

package main
import (
	"bufio"
	"fmt"
	"os"
)
func main() {
	// bufio.Readerを生成し、os.Stdinに紐付ける
	reader := bufio.NewReader(os.Stdin)
	// ユーザーに入力を促す
	fmt.Print("文章を入力してください: ")
	// バッファを活用して1行読み込む
	input, err := reader.ReadString('\n')
	if err != nil {
		fmt.Println("読み込みエラー:", err)
		return
	}
	// 入力された内容を表示
	fmt.Println("入力は:", input)
}

文章を入力してください: (ユーザーが入力した文章)
入力は: (ユーザーが入力した文章)

package main
import (
	"bufio"
	"fmt"
	"os"
)
func main() {
	// Scannerを生成し、os.Stdinを対象にする
	scanner := bufio.NewScanner(os.Stdin)
	fmt.Println("複数行の入力をしてください(終了するにはEOFを入力):")
	// Scannerを使って行単位で入力内容を読み込む
	for scanner.Scan() {
		// 読み込んだ行を取得
		line := scanner.Text()
		fmt.Println("入力行:", line)
	}
	// エラーチェック
	if err := scanner.Err(); err != nil {
		fmt.Println("読み込み中にエラーが発生しました:", err)
	}
}

複数行の入力をしてください(終了するにはEOFを入力):
(ユーザーが入力した行)
入力行: (1行目の内容)
(ユーザーが入力した行)
入力行: (2行目の内容)
...

package main
import (
	"bufio"
	"fmt"
	"os"
	"strings"
)
func main() {
	// Scannerを生成
	scanner := bufio.NewScanner(os.Stdin)
	fmt.Print("データを入力してください: ")
	scanner.Scan()
	// 入力された文字列を取得し、前後の空白を削除
	input := strings.TrimSpace(scanner.Text())
	// 整形後のデータを表示
	fmt.Println("整形済みデータ:", input)
}

データを入力してください: (入力文字列と余分な空白)
整形済みデータ: (前後の空白が除去された文字列)

package main
import (
	"bufio"
	"fmt"
	"os"
)
func main() {
	// パイプ経由で渡された入力を読み込むためのScannerを生成
	scanner := bufio.NewScanner(os.Stdin)
	// 入力データを行ごとに読み込み、出力する
	for scanner.Scan() {
		line := scanner.Text()
		fmt.Println("処理した行:", line)
	}
	if err := scanner.Err(); err != nil {
		fmt.Println("エラーが発生しました:", err)
	}
}

(パイプで渡された入力行ごとに)
処理した行: (入力された各行の内容)

echo -e "初行\n次行" | ./sample_program

package main
import (
	"bufio"
	"fmt"
	"os"
	"sync"
)
func main() {
	var wg sync.WaitGroup
	dataChannel := make(chan string)
	// 複数の入力ストリームをゴルーチンで処理する例
	streams := []string{"入力受付1", "入力受付2"}
	// 擬似的に標準入力の代わりとなる処理
	for _, streamName := range streams {
		wg.Add(1)
		go func(name string) {
			defer wg.Done()
			// 擬似的な入力処理(ここでは名前をそのまま送信)
			dataChannel <- fmt.Sprintf("%sからのデータ", name)
		}(streamName)
	}
	// 別ゴルーチンでチャネルのデータを受け取る
	go func() {
		wg.Wait()
		close(dataChannel)
	}()
	// チャネルからデータを読み取り、出力する
	for data := range dataChannel {
		fmt.Println("受信データ:", data)
	}
}

受信データ: 入力受付1からのデータ
受信データ: 入力受付2からのデータ

package main
import (
	"bufio"
	"fmt"
	"os"
	"strings"
)
func main() {
	// 標準入力からデータを読み込み、エラーをチェックするサンプル
	reader := bufio.NewReader(os.Stdin)
	fmt.Print("文章を入力してください(エラー例を入力時に 'error' を含めてください): ")
	input, err := reader.ReadString('\n')
	if err != nil {
		// 入力エラーがあった場合の処理
		fmt.Println("入力エラー:", err)
		return
	}
	// 入力内容を整形してエラーキーワードをチェック
	trimmedInput := strings.TrimSpace(input)
	if strings.Contains(trimmedInput, "error") {
		// エラーとみなす処理
		fmt.Println("エラーを検出しました。内容を確認してください。")
	} else {
		// 正常な入力の場合の処理
		fmt.Println("受け取った内容:", trimmedInput)
	}
}

文章を入力してください(エラー例を入力時に 'error' を含めてください): (入力例)
受け取った内容: (整形された入力例)