Go 中的缓冲通道

Question

我正在使用 raspberry pi 和 arduino 开发一个项目。我正在树莓派上编写一个 GO 程序，以每秒 115200 波特率从 Arduino 接收 UART 数据。树莓派读取 UART 数据，将其保存到文件（基于 file1 或 file2 等的值），然后将文件发送到 ftp 服务器。

由于上传到服务器可能需要一些时间，具体取决于网络，我想使用 go 并发，以便 UART 读取和保存到文件不会中断。以下是我尝试应用的伪代码（骨架）。我在代码中的想法是文件路径将按顺序缓冲在通道中，并且上传以相同的顺序执行。我做得对吗？有没有更好的方法来解决这个问题？

package main

import "strings"

func SendFile(filePath string) {

}
// based on the value of the data, SaveToFile saves the data to either file1, file2 or file3
func SaveToFile(uartData []string) filePath string {

    return filePath
}

func main() {


    ch := make(chan string, 1000)

    //uartInit initialization goes here
    uart := uartInit()

    //infinite loop for reading UART...
    for {
        buf := 1024 // UART buffer
        data := uart.Read(buf)
        uartData = strings.Split(string(buf), " ")

        //channel receives filepath 
        ch <- SaveToFile(uartData)

        //channel sends filepath
        go SendFile(<-ch)

    }
}

Answer 1

您正在将一个字符串写入通道，然后将其读回。 sendFile() 在不同的 goroutine 中运行，但您使用它的方式不需要通道。你可以简单地做

 fname:= SaveToFile(uartData)
 go SendFile(fname)

但是，我不认为这是你想要做的。

相反，您应该有一个 goroutine，您可以在其中从 UART 读取数据，并写入缓冲通道。监听该通道是另一个将数据块写入文件的 goroutine。当它准备好发送时，创建第三个 goroutine 来发送文件。

Answer 2

在阅读了 cmets 和一些在线资源之后，到目前为止，以下方法似乎运行良好。 video 的前 8 分钟对理解这个概念很有帮助。不过，我不确定defer close(ch)。

package main

import "strings"

func SendFile(ch chan string) {
  for filePath := range ch {
   //upload file here
  }

}

func SaveToFile(uartData []string) filePath string {

    return filePath
}

func main() {


    ch := make(chan string, 1000)
    defer close(ch)
    go SendFile(<-ch)

    uart := uartInit()


    for {

        data := uart.Read(buf)
        uartData = strings.Split(string(buf), " ")
        ch <- SaveToFile(uartData)

    }
}