## 操做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包
- 使用表驅動測試
- 使用第三方測試工具
- 模糊測試
- 行為驅動測試
- 第九章 并發和并行
- 第十章 分布式系統
- 第十一章 響應式編程和數據流
- 第十二章 無服務器編程
- 第十三章 性能改進