## 操做Unix系统下的pipe管道
将一个程序的输出传递给另一个程序的输入时,Unix管道很有用。 例如:
```
echo "test case" | wc -l
1
```
在Go应用程序中,可以使用os.Stdin读入管道的左侧,并像文件描述符一样工作。为了证明这一点,本节将在管道的左侧进行输入并返回单词列表及其出现次数。这些单词将以空白为分隔标记。
### 实践
1. 建立 pipes.go:
```
package main
import (
"bufio"
"fmt"
"io"
"os"
)
// WordCount 获取一个io.Reader并返回一个map,每个单词作为一个键,它的出现次数为对应的值
func WordCount(f io.Reader) map[string]int {
result := make(map[string]int)
// 建立scanner处理文件io.Reader接口
scanner := bufio.NewScanner(f)
scanner.Split(bufio.ScanWords)
for scanner.Scan() {
result[scanner.Text()]++
}
if err := scanner.Err(); err != nil {
fmt.Fprintln(os.Stderr, "reading input:", err)
}
return result
}
func main() {
fmt.Printf("string: number_of_occurrences\n\n")
for key, value := range WordCount(os.Stdin) {
fmt.Printf("%s: %d\n", key, value)
}
}
```
2. 运行:
```
echo "some string" | go run pipes.go
```
3. 多执行一些输入:
```
$ echo "test case" | go run pipes.go
string: number_of_occurrences
test: 1
case: 1
$ echo "test case test" | go run pipes.go
string: number_of_occurrences
test: 2
case: 1
```
### 说明
在go中使用管道非常简单,特别是如果你熟悉使用I/O接口。例如第1章 I/O 和文件系统中的管道配方创建应用程序(https//en.wikipedia.org/wiki/Tee_(command)),其中所有管道输入都会立即写入到标准输出和文件。
本节使用scanner来标记os.Stdin对象的io.Reader接口。请注意在完成所有读取后必须检查错误。
* * * *
学识浅薄,错误在所难免。欢迎在群中就本书提出修改意见,以飨后来者,长风拜谢。
Golang中国(211938256)
beego实战(258969317)
Go实践(386056972)
- 前言
- 第一章 I/O和文件系统
- 常见 I/O 接口
- 使用bytes和strings包
- 操作文件夹和文件
- 使用CSV格式化数据
- 操作临时文件
- 使用 text/template和HTML/templates包
- 第二章 命令行工具
- 解析命令行flag标识
- 解析命令行参数
- 读取和设置环境变量
- 操作TOML,YAML和JSON配置文件
- 操做Unix系统下的pipe管道
- 处理信号量
- ANSI命令行着色
- 第三章 数据类型转换和解析
- 数据类型和接口转换
- 使用math包和math/big包处理数字类型
- 货币转换和float64注意事项
- 使用指针和SQL Null类型进行编码和解码
- 对Go数据编码和解码
- Go中的结构体标签和反射
- 通过闭包实现集合操作
- 第四章 错误处理
- 错误接口
- 使用第三方errors包
- 使用log包记录错误
- 结构化日志记录
- 使用context包进行日志记录
- 使用包级全局变量
- 处理恐慌
- 第五章 数据存储
- 使用database/sql包操作MySQL
- 执行数据库事务接口
- SQL的连接池速率限制和超时
- 操作Redis
- 操作MongoDB
- 创建存储接口以实现数据可移植性
- 第六章 Web客户端和APIs
- 使用http.Client
- 调用REST API
- 并发操作客户端请求
- 使用OAuth2
- 实现OAuth2令牌存储接口
- 封装http请求客户端
- 理解GRPC的使用
- 第七章 网络服务
- 处理Web请求
- 使用闭包进行状态处理
- 请求参数验证
- 内容渲染
- 使用中间件
- 构建反向代理
- 将GRPC导出为JSON API
- 第八章 测试
- 使用标准库进行模拟
- 使用Mockgen包
- 使用表驱动测试
- 使用第三方测试工具
- 模糊测试
- 行为驱动测试
- 第九章 并发和并行
- 第十章 分布式系统
- 第十一章 响应式编程和数据流
- 第十二章 无服务器编程
- 第十三章 性能改进