Golang 从串行读取

jdb*_*org 6 serial-port go

我正在尝试从串行端口(Raspberry Pi 上的 GPS 设备)读取数据。

按照http://www.modmypi.com/blog/raspberry-pi-gps-hat-and-python的说明进行操作

我可以使用从 shell 读取

stty -F /dev/ttyAMA0 raw 9600 cs8 clocal -cstopb
cat /dev/ttyAMA0
Run Code Online (Sandbox Code Playgroud)

我得到格式良好的输出

$GNGLL,5133.35213,N,00108.27278,W,160345.00,A,A*65
$GNRMC,160346.00,A,5153.35209,N,00108.27286,W,0.237,,290418,,,A*75
$GNVTG,,T,,M,0.237,N,0.439,K,A*35
$GNGGA,160346.00,5153.35209,N,00108.27286,W,1,12,0.67,81.5,M,46.9,M,,*6C
$GNGSA,A,3,29,25,31,20,26,23,21,16,05,27,,,1.11,0.67,0.89*10
$GNGSA,A,3,68,73,83,74,84,75,85,67,,,,,1.11,0.67,0.89*1D
$GPGSV,4,1,15,04,,,34,05,14,040,21,09,07,330,,16,45,298,34*40
$GPGSV,4,2,15,20,14,127,18,21,59,154,30,23,07,295,26,25,13,123,22*74
$GPGSV,4,3,15,26,76,281,40,27,15,255,20,29,40,068,19,31,34,199,33*7C
$GPGSV,4,4,15,33,29,198,,36,23,141,,49,30,172,*4C
$GLGSV,3,1,11,66,00,325,,67,13,011,20,68,09,062,16,73,12,156,21*60
$GLGSV,3,2,11,74,62,177,20,75,53,312,36,76,08,328,,83,17,046,25*69
$GLGSV,3,3,11,84,75,032,22,85,44,233,32,,,,35*62
$GNGLL,5153.35209,N,00108.27286,W,160346.00,A,A*6C
$GNRMC,160347.00,A,5153.35205,N,00108.27292,W,0.216,,290418,,,A*7E
$GNVTG,,T,,M,0.216,N,0.401,K,A*3D
$GNGGA,160347.00,5153.35205,N,00108.27292,W,1,12,0.67,81.7,M,46.9,M,,*66
$GNGSA,A,3,29,25,31,20,26,23,21,16,05,27,,,1.11,0.67,0.89*10
$GNGSA,A,3,68,73,83,74,84,75,85,67,,,,,1.11,0.67,0.89*1D
$GPGSV,4,1,15,04,,,34,05,14,040,21,09,07,330,,16,45,298,34*40
Run Code Online (Sandbox Code Playgroud)

(我已经放入了一些随机数据)

我正在尝试在 Go 中阅读此内容。目前,我有

package main

import "fmt"
import "log"
import "github.com/tarm/serial"

func main() {
        config := &serial.Config{
                Name: "/dev/ttyAMA0",
                Baud: 9600,
                ReadTimeout: 1,
                Size: 8,
        }

        stream, err := serial.OpenPort(config)
        if err != nil {
                log.Fatal(err)
        }

        buf := make([]byte, 1024)

        for {
                n, err := stream.Read(buf)
                if err != nil {
                        log.Fatal(err)
                }
                s := string(buf[:n])
                fmt.Println(s)
        }
}
Run Code Online (Sandbox Code Playgroud)

但这会打印格式错误的数据。我怀疑这是由于缓冲区大小或价值Sizeconfig结构存在错了,但我不知道如何从获取这些值stty的设置。

回顾过去,我认为问题在于我得到了一个流,我希望能够遍历 stty 的行,而不是块。这是流的输出方式:

$GLGSV,3
,1,09,69
,10,017,
,70,43,0
69,,71,3
2,135,27
,76,23,2
32,22*6F

$GLGSV
,3,2,09,
77,35,30
0,21,78,
11,347,,
85,31,08
1,30,86,
72,355,3
6*6C
$G
LGSV,3,3
,09,87,2
4,285,30
*59
$GN
GLL,5153
.34919,N
,00108.2
7603,W,1
92901.00
,A,A*6A
Run Code Online (Sandbox Code Playgroud)

Mic*_*ton 8

您返回的结构serial.OpenPort()包含一个指向os.File与打开的串行端口连接相对应的打开的指针。当您Read()从这里开始时,库调用Read()底层os.File.

此函数调用文档是:

Read 从文件中读取最多 len(b) 个字节。它返回读取的字节数和遇到的任何错误。在文件末尾,Read 返回 0,io.EOF。

这意味着您必须跟踪读取了多少数据。如果这对您很重要,您还必须跟踪是否有换行符。不幸的是,底层*os.File没有导出,所以你会发现很难使用像bufio.ReadLine(). 可能值得修改库并发送拉取请求。


正如 Matthew Rankin 在评论中指出的那样,Port实现了io.ReadWriter您可以简单地用于bufio按行阅读。

    stream, err := serial.OpenPort(config)
    if err != nil {
            log.Fatal(err)
    }

    scanner := bufio.NewScanner(stream)
    for scanner.Scan() {
        fmt.Println(scanner.Text()) // Println will add back the final '\n'
    }
    if err := scanner.Err(); err != nil {
        log.Fatal(err)
    }
Run Code Online (Sandbox Code Playgroud)