可以在每 0.5 秒发布一次音频数据吗？

有志者，事竟成！如果你在学习Golang，那么本文《可以在每 0.5 秒发布一次音频数据吗？》，就很适合你！文章讲解的知识点主要包括，若是你对本文感兴趣，或者是想搞懂其中某个知识点，就请你继续往下看吧~

是否可以收集音频数据，然后每 0.5 秒发布一次音频数据？

我正在使用 go rtmp server 和 https://github.com/yutopp/go-rtmp 这个包，效果很好。

函数onaudio()内部：这是处理音频数据的函数，它从obs接收数据并decodeaudiodata并发布到vlc播放器

这是onaudio()的原始代码

func (h *handler) onaudio(timestamp uint32, payload io.reader) error {
    var audio flvtag.audiodata
    if err := flvtag.decodeaudiodata(payload, &audio); err != nil {
        return err
    }

    flvbody := new(bytes.buffer)
    if _, err := io.copy(flvbody, audio.data); err != nil {
        return err
    }
    audio.data = flvbody
    _ = h.pub.publish(&flvtag.flvtag{
        tagtype:   flvtag.tagtypeaudio,
        timestamp: timestamp,
        data:      &audio,
    })

    return nil
}

此代码每 0.02 秒接收一次音频数据并发布它。 我想更改收集音频数据直到 0.5 秒并发布音频数据的代码 所以尝试这样...

func (h *Handler) OnAudio(timestamp uint32, payload io.Reader) error {

    var audio flvtag.AudioData
    if err := flvtag.DecodeAudioData(payload, &audio); err != nil {
        return err
    }
       // if flag == true, startTimeStamp Control
    if h.Flag == true {
        h.startTimeStamp = timestamp
        h.Buf.Reset()
    }
    h.Flag = false

    buf := new(bytes.Buffer)
    if _, err := io.Copy(buf, audio.Data); err != nil {
        return err
    }

    if audio.AACPacketType == 0 {
        audio.Data = buf
        tag := &flvtag.FlvTag{
            TagType:   flvtag.TagTypeAudio,
            Timestamp: h.startTimeStamp,
            Data:      &audio,
        }
        timestamp, (timestamp - h.startTimeStamp), buf.Len())
        _ = h.pub.Publish(tag)
        h.Flag = true
        return nil
    }

    h.Buf.Write(buf.Bytes())

        // collect audio data into h.Buf and then publish every 0.5 seconds
    if timestamp-h.startTimeStamp >= 500 {
        h.lastTimeStamp = timestamp
        audio.Data = h.Buf
        tag := &flvtag.FlvTag{
            TagType:   flvtag.TagTypeAudio,
            Timestamp: h.startTimeStamp,
            Data:      &audio,
        }

        _ = h.pub.Publish(tag)
        h.Flag = true
    }

    return nil
}

当我检查音频数据大小时，没有数据丢失，但音频数据正在中断。 我的代码有问题吗？

正确答案

我将您的更改应用到了官方 server_relay_demo （请参阅此提交） 。然后构建并运行这个演示：

go build -v -o server_relay_demo .
./server_relay_demo

然后我下载了http://commondatastorage.googleapis.com/ gtv-videos-bucket/sample/forbiggerblazes.mp4，并使用 ffmpeg 发布：

ffmpeg -re -stream_loop -1 -i forbiggerblazes.mp4 -acodec copy -vcodec copy -f flv rtmp://localhost/appname/stream

最后用vlc播放：

$ vlc rtmp://localhost/appname/stream
vlc media player 3.0.18 vetinari (revision 3.0.18-0-ge9eceaed4d)
[000055c1cc8f3b10] main libvlc: running vlc with the default interface. use 'cvlc' to use vlc without interface.
qt: session management error: could not open network socket
[tcp @ 0x7f84280045c0] rtmp packet size mismatch 14272640 != 5642

它无法播放此错误：rtmp数据包大小不匹配14272640！= 5642。

然后我用 timestamp 替换了 h.starttimestamp （参见此提交） ：

tag := &flvtag.FlvTag{
    TagType:   flvtag.TagTypeAudio,
    Timestamp: h.startTimeStamp,
    Data:      &audio,
}

它适用于此更改。虽然音频和视频不同步。

请尝试此解决方案。如果仍然无法正常工作，请提供演示和详细的分步指南来重现问题。

到这里，我们也就讲完了《可以在每 0.5 秒发布一次音频数据吗？》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于的知识点！