網(wǎng)站首頁 編程語言 正文
阻塞方式(需要執(zhí)行結(jié)果)
主要用于執(zhí)行shell命令,并且返回shell的標準輸出
適用于執(zhí)行普通非阻塞shell命令,且需要shell標準輸出的
//阻塞式的執(zhí)行外部shell命令的函數(shù),等待執(zhí)行完畢并返回標準輸出 func exec_shell(s string) (string, error){ //函數(shù)返回一個*Cmd,用于使用給出的參數(shù)執(zhí)行name指定的程序 cmd := exec.Command("/bin/bash", "-c", s) //讀取io.Writer類型的cmd.Stdout,再通過bytes.Buffer(緩沖byte類型的緩沖器)將byte類型轉(zhuǎn)化為string類型(out.String():這是bytes類型提供的接口) var out bytes.Buffer cmd.Stdout = &out //Run執(zhí)行c包含的命令,并阻塞直到完成。 這里stdout被取出,cmd.Wait()無法正確獲取stdin,stdout,stderr,則阻塞在那了 err := cmd.Run() checkErr(err) return out.String(), err }
需要對shell標準輸出的逐行實時進行處理的
func execCommand(commandName string, params []string) bool { //函數(shù)返回一個*Cmd,用于使用給出的參數(shù)執(zhí)行name指定的程序 cmd := exec.Command(commandName, params...) //顯示運行的命令 fmt.Println(cmd.Args) //StdoutPipe方法返回一個在命令Start后與命令標準輸出關(guān)聯(lián)的管道。Wait方法獲知命令結(jié)束后會關(guān)閉這個管道,一般不需要顯式的關(guān)閉該管道。 stdout, err := cmd.StdoutPipe() if err != nil { fmt.Println(err) return false } cmd.Start() //創(chuàng)建一個流來讀取管道內(nèi)內(nèi)容,這里邏輯是通過一行一行的讀取的 reader := bufio.NewReader(stdout) //實時循環(huán)讀取輸出流中的一行內(nèi)容 for { line, err2 := reader.ReadString('\n') if err2 != nil || io.EOF == err2 { break } fmt.Println(line) } //阻塞直到該命令執(zhí)行完成,該命令必須是被Start方法開始執(zhí)行的 cmd.Wait() return true }
非阻塞方式(不需要執(zhí)行結(jié)果)
通過shell調(diào)用自己的程序,并且程序是死循環(huán),此時無法獲取返回結(jié)果(否則程序會一直阻塞直至調(diào)用的 程序結(jié)束)
適用于調(diào)用自己寫的程序(服務(wù)器死循環(huán),且不需要返回結(jié)果的)
//不需要執(zhí)行命令的結(jié)果與成功與否,執(zhí)行命令馬上就返回 func exec_shell_no_result(command string) { //處理啟動參數(shù),通過空格分離 如:setsid /home/luojing/gotest/src/test_main/iwatch/test/while_little & command_name_and_args := strings.FieldsFunc(command, splite_command) //開始執(zhí)行c包含的命令,但并不會等待該命令完成即返回 cmd.Start() if err != nil { fmt.Printf("%v: exec command:%v error:%v\n", get_time(), command, err) } fmt.Printf("Waiting for command:%v to finish...\n", command) //阻塞等待fork出的子進程執(zhí)行的結(jié)果,和cmd.Start()配合使用[不等待回收資源,會導(dǎo)致fork出執(zhí)行shell命令的子進程變?yōu)榻┦M程] err = cmd.Wait() if err != nil { fmt.Printf("%v: Command finished with error: %v\n", get_time(), err) } return }
/錯誤處理函數(shù) func checkErr(err error) { if err != nil { fmt.Println(err) panic(err) } }
引用部分文檔
func (*Cmd) Run func (c *Cmd) Run() error
Run執(zhí)行c包含的命令,并阻塞直到完成。
如果命令成功執(zhí)行,stdin、stdout、stderr的轉(zhuǎn)交沒有問題,并且返回狀態(tài)碼為0,方法的返回值為nil;如果命令沒有執(zhí)行或者執(zhí)行失敗,會返回*ExitError類型的錯誤;否則返回的error可能是表示I/O問題。
func (*Cmd) Start func (c *Cmd) Start() error
Start開始執(zhí)行c包含的命令,但并不會等待該命令完成即返回。Wait方法會返回命令的返回狀態(tài)碼并在命令返回后釋放相關(guān)的資源。
func (*Cmd) Wait func (c *Cmd) Wait() error
Wait會阻塞直到該命令執(zhí)行完成,該命令必須是被Start方法開始執(zhí)行的。
如果命令成功執(zhí)行,stdin、stdout、stderr的轉(zhuǎn)交沒有問題,并且返回狀態(tài)碼為0,方法的返回值為nil;如果命令沒有執(zhí)行或者執(zhí)行失敗,會返回*ExitError類型的錯誤;否則返回的error可能是表示I/O問題。Wait方法會在命令返回后釋放相關(guān)的資源。
func (*Cmd) Output func (c *Cmd) Output() ([]byte, error)
執(zhí)行命令并返回標準輸出的切片。
func (*Cmd) StderrPipe func (c *Cmd) StderrPipe() (io.ReadCloser, error)
StderrPipe方法返回一個在命令Start后與命令標準錯誤輸出關(guān)聯(lián)的管道。Wait方法獲知命令結(jié)束后會關(guān)閉這個管道,一般不需要顯式的關(guān)閉該管道。但是在從管道讀取完全部數(shù)據(jù)之前調(diào)用Wait是錯誤的;同樣使用StderrPipe方法時調(diào)用Run函數(shù)也是錯誤的。
原文鏈接:https://blog.csdn.net/qq_36874881/article/details/78234005
相關(guān)推薦
- 2022-08-27 Python?Pandas聚合函數(shù)的應(yīng)用示例_python
- 2022-04-27 Shell獲取路徑操作(dirname?$0?pwd)的實現(xiàn)_linux shell
- 2022-08-15 詳解Redis分布式鎖的原理與實現(xiàn)_Redis
- 2022-03-20 C++靜態(tài)成員函數(shù)和this指針詳解_C 語言
- 2022-05-25 Properties與ResourceBundle的基本使用以及區(qū)別
- 2022-06-26 asp.net使用WebAPI和EF框架結(jié)合實現(xiàn)數(shù)據(jù)的基本操作_實用技巧
- 2022-05-15 Element框架里日期選擇器限制時間,最多選31天
- 2022-12-01 docker-compose簡單使用方法詳解_docker
- 最近更新
-
- window11 系統(tǒng)安裝 yarn
- 超詳細win安裝深度學(xué)習(xí)環(huán)境2025年最新版(
- Linux 中運行的top命令 怎么退出?
- MySQL 中decimal 的用法? 存儲小
- get 、set 、toString 方法的使
- @Resource和 @Autowired注解
- Java基礎(chǔ)操作-- 運算符,流程控制 Flo
- 1. Int 和Integer 的區(qū)別,Jav
- spring @retryable不生效的一種
- Spring Security之認證信息的處理
- Spring Security之認證過濾器
- Spring Security概述快速入門
- Spring Security之配置體系
- 【SpringBoot】SpringCache
- Spring Security之基于方法配置權(quán)
- redisson分布式鎖中waittime的設(shè)
- maven:解決release錯誤:Artif
- restTemplate使用總結(jié)
- Spring Security之安全異常處理
- MybatisPlus優(yōu)雅實現(xiàn)加密?
- Spring ioc容器與Bean的生命周期。
- 【探索SpringCloud】服務(wù)發(fā)現(xiàn)-Nac
- Spring Security之基于HttpR
- Redis 底層數(shù)據(jù)結(jié)構(gòu)-簡單動態(tài)字符串(SD
- arthas操作spring被代理目標對象命令
- Spring中的單例模式應(yīng)用詳解
- 聊聊消息隊列,發(fā)送消息的4種方式
- bootspring第三方資源配置管理
- GIT同步修改后的遠程分支