>  기사  >  백엔드 개발  >  Go를 사용하여 실시간으로 명령 출력을 스트리밍하는 방법은 무엇입니까?

Go를 사용하여 실시간으로 명령 출력을 스트리밍하는 방법은 무엇입니까?

Mary-Kate Olsen
Mary-Kate Olsen원래의
2024-11-22 00:04:17878검색

How to Stream Command Output in Real-Time Using Go?

명령 출력 온라인 스트리밍

명령을 실행하고 해당 출력을 캡처하는 다음 코드를 고려하세요.

cmdParams := [][]string{
    {filepath.Join(dir, path), "npm", "install"},
    {filepath.Join(pdir, n.path), "gulp"},
}
for _, cp := range cmdParams {
    log.Printf("Starting %s in folder %s...", cp[1:], cp[0])
    cmd := exec.Command(cp[1], cp[2:]...)
    cmd.Dir = cp[0]
    // Wait to finish, get output:
    out, err := cmd.Output()
    if err != nil {
        log.Printf("Error running %s: %v\n", cp[1:], err)
        return
    }
    log.Println("Finished %s, output: %s", cp[1:], out)
}

이 코드는 명령의 전체 출력을 캡처하고 명령 실행이 완료된 후에만 인쇄합니다. 하지만 실시간으로 출력을 스트리밍해야 하는 경우가 있습니다.

라이브 출력 스트리밍을 구현하려면 다음과 같이 코드를 수정할 수 있습니다.

cmdParams := [][]string{
    {filepath.Join(dir, path), "npm", "install"},
    {filepath.Join(pdir, n.path), "gulp"},
}
for _, cp := range cmdParams {
    log.Printf("Starting %s in folder %s...", cp[1:], cp[0])
    cmd := exec.Command(cp[1], cp[2:]...)
    cmd.Dir = cp[0]

    stdout, err := cmd.StdoutPipe()
    if err != nil {
        log.Printf("%s cmd.StdoutPipe() error: %v\n", cp[1:], err)
        return
    }
    // Start command:
    if err = cmd.Start(); err != nil {
        log.Printf("%s start error: %v\n", cp[1:], err)
        return
    }

    // Stream command output:
    scanner := bufio.NewScanner(stdout)
    scanner.Split(bufio.ScanRunes)
    for scanner.Scan() {
        fmt.Print(scanner.Text())
    }
    if scanner.Err() != nil {
        log.Printf("Reading %s stdout error: %v\n", cp[1:], err)
        return
    }

    // Get execution success or failure:
    if err = cmd.Wait(); err != nil {
        log.Printf("Error running %s: %v\n", cp[1:], err)
        return
    }
    log.Printf("Finished %s", cp[1:])
}

다음은 변경 사항에 대한 설명입니다. :

  • cmd.StdoutPipe()는 명령의 표준을 읽기 위한 파이프를 생성합니다. output.
  • cmd.Start()는 백그라운드에서 명령을 시작합니다.
  • bufio.NewScanner(stdout)는 stdout 파이프에서 읽기 위한 스캐너를 생성합니다.
  • 스캐너. Split(bufio.ScanRunes)은 스캐너가 룬 문자로 읽도록 설정하여 라이브 스트리밍을 제공합니다.
  • scanner의 Scan() 루프는 명령에 의해 생성된 각 룬(문자)을 지속적으로 읽고 인쇄합니다.
  • 루프가 완료된 후(stdout에 대한 명령 쓰기가 완료된 후) scanner.Err()는 오류가 있는지 확인합니다.
  • cmd.Wait()는 명령이 완료되기를 기다리고 오류를 확인합니다.
  • 최종 log.Println() 문 명령 완료를 기록합니다.

위 내용은 Go를 사용하여 실시간으로 명령 출력을 스트리밍하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

성명:
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.