go基础库之writer和reader之间的管道

栏目: Go · 发布时间: 6年前

内容简介:进程之间的管道是使用第一个进程的输出作为其他进程的输入的简单方法。这可以在Go中执行相同的概念,例如,将数据从一个套接字传输到另一个套接字,以创建隧道连接。本文将向你展示如何使用Go内置库创建管道。

进程之间的管道是使用第一个进程的输出作为其他进程的输入的简单方法。这可以在 Go 中执行相同的概念,例如,将数据从一个套接字传输到另一个套接字,以创建隧道连接。本文将向你展示如何使用Go内置库创建管道。

writer和reader之间的管道

Golang 版本

1.12.1

前言

进程之间的管道是使用第一个进程的输出作为其他进程的输入的简单方法。这可以在Go中执行相同的概念,例如,将数据从一个套接字传输到另一个套接字,以创建隧道连接。本文将向你展示如何使用Go内置库创建管道。

实现

package main

import (
	"io"
	"log"
	"os"
	"os/exec"
)

func main() {
	pReader, pWriter := io.Pipe()

	cmd := exec.Command("echo", "Hello Go!\nThis is example")
	cmd.Stdout = pWriter

	go func() {
		defer pReader.Close()
		if _, err := io.Copy(os.Stdout, pReader); err != nil {
			log.Fatal(err)
		}
	}()

	if err := cmd.Run(); err != nil {
		log.Fatal(err)
	}

}
$ go run main.go
Hello Go!
This is example

原理

io.Pipe 函数创建内存管道并返回管道的两端,一侧是 PipeReader ,另一侧是 PipeWriter 。 每个Write到PipeWriter都被阻塞,直到另一端被 Read 消耗为止。

该示例显示从执行的命令到父程序的标准输出的管道输出。通过将 pWriter 分配给 cmd.Stdout ,子进程的标准输出被写入管道, goroutine 中的 io.Copy 通过将数据复制到 os.Stdout 来消耗写入的数据。


以上所述就是小编给大家介绍的《go基础库之writer和reader之间的管道》,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对 码农网 的支持!

查看所有标签

猜你喜欢:

本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们

可伸缩架构

可伸缩架构

【美】Lee Atchison / 张若飞、张现双 / 电子工业出版社 / 2017-7 / 65

随着互联网的发展越来越成熟,流量和数据量飞速增长,许多公司的关键应用程序都面临着伸缩性的问题,系统变得越来越复杂和脆弱,从而导致风险上升、可用性降低。《可伸缩架构:面向增长应用的高可用》是一本实践指南,让IT、DevOps和系统稳定性管理员能够了解到,如何避免应用程序在发展过程中变得缓慢、数据不一致或者彻底不可用等问题。规模增长并不只意味着处理更多的用户,还包括管理更多的风险和保证系统的可用性。作......一起来看看 《可伸缩架构》 这本书的介绍吧!

JS 压缩/解压工具
JS 压缩/解压工具

在线压缩/解压 JS 代码

XML、JSON 在线转换
XML、JSON 在线转换

在线XML、JSON转换工具