登录
首页 >  Golang >  Go问答

如何重置或丢弃缓冲数据

来源:stackoverflow

时间:2024-04-13 23:48:33 312浏览 收藏

学习Golang要努力,但是不要急!今天的这篇文章《如何重置或丢弃缓冲数据》将会介绍到等等知识点,如果你想深入学习Golang,可以关注我!我会持续更新相关文章的,希望对大家都能有所帮助!

问题内容

无法重置或丢弃缓冲区。

我正在尝试通过串行端口获取数据,每 10 秒我就会收到一些固定长度的数据包。我有一个无限循环来连续接收数据包。收到新数据包后,我正在重置缓冲区,但是当我收到下一个数据包时,它会覆盖缓冲区,并且我得到混合数据包。

假设我应该每 n 秒连续接收数据包 abcdef 。但是当我尝试以下代码时,我收到数据包 bcdefa 然后在 n 秒后 cdefab 然后 defabc 等等

package main

import (
    "bufio"
    "log"
    "time"
    "github.com/tarm/serial"
)

func main() {
    c := &serial.Config{Name: "/dev/ttyUSB0", Baud: 57600}
    s, err := serial.OpenPort(c)
    if err != nil {
        log.Println(err)
        return
    }
    for {
        time.Sleep(time.Second / 2)
        reader := bufio.NewReader(s)
        pck, err := reader.Peek(46)
        if err != nil {
            log.Println(err)
        }
        go parse(pck)
        reader.Reset(s)
    }
}

如何有效地重置或丢弃缓冲区数据,以便接收到准确的数据包。


解决方案


请记住,我无法检查我在这里所说的内容...

1/您不得在每次迭代时实例化 bufio 读取器

2/ bufio.reader.peek 不会推进阅读器 https://golang.org/pkg/bufio/#Reader.Peek

3/除非您收到格式错误的数据包,否则我认为您根本不需要重置。

4/ 请在 play.golang.org 上缩进您的代码

5/您没有检查读取错误是否终止

6/ 我发现在 go 中使用串行端口的所有包都公开了 io.reader 的实例,因此使用额外的 bufio.reader 可能是无用的。我怀疑您正在使用 https://godoc.org/github.com/tarm/serial#OpenPort

这可能不是最终的答案,但应该有所帮助。

package main

import (
    "io"
    "log"
    "time"
)

func main() {
    s, err := serial.OpenPort(c)
    if err != nil {
        log.Fatal(err)
    }

    pck := make([]byte, 46)
    for {
        time.Sleep(time.Second / 2)
        n, err := s.Read(pck)
        if err != nil {
            if err == io.EOF {
                break
            }
            log.Println(err)
        }
        pck = pck[:n]
        go parse(pck)
    }
}

以上就是《如何重置或丢弃缓冲数据》的详细内容,更多关于的资料请关注golang学习网公众号!

声明:本文转载于:stackoverflow 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>