Go语言中如何将内存缓冲区内容通过分页器输出到标准输出

import (
    "os/exec"
)

// 声明你的分页器命令
cmd := exec.Command("less")

import (
    "io"
)

// 创建一个管道 (阻塞的)
r, stdinPipeWriter := io.Pipe()

import (
    "os"
)

// 设置分页器的I/O
cmd.Stdin = r              // 分页器的标准输入来自管道的读取端
cmd.Stdout = os.Stdout     // 分页器的标准输出到Go程序的标准输出
cmd.Stderr = os.Stderr     // 分页器的标准错误到Go程序的标准错误

// 创建一个阻塞通道，运行分页器并在完成后解除阻塞
c := make(chan struct{})
go func() {
    defer close(c) // 确保在goroutine退出时关闭通道
    cmd.Run()      // 运行分页器命令
}()

import (
    "fmt"
)

// 假设我们有一个大的字节缓冲区
largeBuffer := []byte("这是一段模拟的大量文本内容，它将被发送到分页器。\n")
for i := 0; i < 100; i++ {
    largeBuffer = append(largeBuffer, []byte(fmt.Sprintf("第 %d 行数据。\n", i))...)
}

// 将数据写入管道
// 对于 []byte 类型的数据，可以直接使用 Write 方法
_, err := stdinPipeWriter.Write(largeBuffer)
if err != nil {
    // 处理写入错误
    fmt.Fprintf(os.Stderr, "写入管道失败: %v\n", err)
}

// 如果你的数据源是 io.Reader，可以使用 io.Copy
// _, err := io.Copy(stdinPipeWriter, yourBufferReader)
// if err != nil { /* 处理错误 */ }

// 关闭 stdinPipeWriter (会导致分页器退出)
stdinPipeWriter.Close()

// 等待分页器完成
<-c

package main

import (
    "fmt"
    "io"
    "os"
    "os/exec"
    "strings" // 用于生成示例大文本
)

func main() {
    // 1. 声明你的分页器命令
    cmd := exec.Command("less") // 也可以是 "more"

    // 2. 创建一个管道 (阻塞的)
    r, stdinPipeWriter := io.Pipe()

    // 3. 设置分页器的I/O
    cmd.Stdin = r              // 分页器的标准输入来自管道的读取端
    cmd.Stdout = os.Stdout     // 分页器的标准输出到Go程序的标准输出
    cmd.Stderr = os.Stderr     // 分页器的标准错误到Go程序的标准错误

    // 4. 在独立的goroutine中运行分页器并等待其完成
    c := make(chan struct{})
    go func() {
        defer close(c) // 确保在goroutine退出时关闭通道
        err := cmd.Run() // 运行分页器命令
        if err != nil {
            fmt.Fprintf(os.Stderr, "分页器命令执行失败: %v\n", err)
        }
    }()

    // 5. 模拟一个大的内存缓冲区数据
    var builder strings.Builder
    for i := 0; i < 500; i++ {
        builder.WriteString(fmt.Sprintf("这是第 %d 行数据，用于演示通过分页器输出大量内容。\n", i+1))
        builder.WriteString("Lorem ipsum dolor sit amet, consectetur adipiscing elit. Sed do eiusmod tempor incididunt ut labore et dolore magna aliqua.\n")
    }
    largeBuffer := []byte(builder.String())

    // 将数据写入管道
    _, err := stdinPipeWriter.Write(largeBuffer)
    if err != nil {
        fmt.Fprintf(os.Stderr, "写入管道失败: %v\n", err)
    }

    // 6. 关闭 stdinPipeWriter。这会向分页器发送EOF，使其在显示完所有数据后退出。
    err = stdinPipeWriter.Close()
    if err != nil {
        fmt.Fprintf(os.Stderr, "关闭管道写入端失败: %v\n", err)
    }

    // 7. 等待分页器完成
    <-c
    fmt.Println("分页器已退出。")
}