发布摘要

go语言实战流媒体视频网站，启动工程增加对流的发布订阅的单元测试和基准测试

• 修复发布和订阅并发创建流产生的panic

• 修复IdleTimeout无效问题

• 修复订阅者阻塞导致读写并发问题

• preview插件修复https默认端口

• gb28181插件PR合并

   

  升级模块	升级后版本
  engine	4.13.5
  gb28181	4.3.6
  hls	4.3.1
  preview	4.1.2
  record	4.3.7

详细说明

单元测试和基准测试

测试用例所在目录：github.com/langhuihui/monibuca工程下的test目录

推荐使用vscode打开工程，方便一键测试单个用例，也可以通过vscode侧边栏里的单元测试栏目管理。

TestPubAndSub

func TestPubAndSub(t *testing.T) {  t.Cleanup(FreeEngine)  UseEngine()  t.Run("publish", func(t *testing.T) {   t.Parallel()   var pub UnitTestPublisher   unitTestPlugin.Publish("test/001", &pub)  })  t.Run("subscribe", func(t *testing.T) {   t.Parallel()   var sub UnitTestSubsciber   sub.TB = t   err := unitTestPlugin.Subscribe("test/001", &sub)   if err != nil {    t.Fatal(err)   } else {    sub.PlayRaw()   }  }) }

该用例会启动一个发布者和一个订阅者，发布者将会写入假数据，订阅者读取后会校验数据是否正确。

BenchmarkPubAndSub

func BenchmarkPubAndSub(b *testing.B) {  b.Cleanup(FreeEngine)  UseEngine()  for i := 0; i < 10; i++ {   i := i   go func(i int) {    var pub UnitTestPublisher    unitTestPlugin.Publish(fmt.Sprintf("testb/%d", i), &pub)   }(i)   go b.RunParallel(func(pb *testing.PB) {    var sub UnitTestSubsciber    sub.TB = b    err := unitTestPlugin.Subscribe(fmt.Sprintf("testb/%d", i), &sub)    if err != nil {     // b.Fatal(err)    } else {     sub.PlayRaw()    }   })  }  time.Sleep(time.Second * 10) }

该用例为基准测试，启动10个发布者，每个流会批量订阅，以测试并发性能以及稳定性。

TestSlowSubscriber

func TestSlowSubscriber(t *testing.T) {  t.Cleanup(FreeEngine)  UseEngine()  var pub UnitTestPublisher  unitTestPlugin.Publish("test/slow", &pub)  var suber SlowSubsciber  unitTestPlugin.Subscribe("test/slow", &suber)  suber.PlayRaw() }

这个用例会模拟一个订阅者被阻塞（sleep）后导致发布者写入的位置追上，此时engine通过标记这个写入点废弃来避免并发读写问题，废弃后订阅者如果被唤醒就会自动停止订阅。

通常出现这种情况是订阅者进行了某种耗时操作，比如写文件，或者网络阻塞等。

其他修复问题

并发创建流

修复如下：

func findOrCreateStream(streamPath string, waitTimeout time.Duration) (s *Stream, created bool) {  p := strings.Split(streamPath, "/")  if len(p) < 2 {   log.Warn(Red("Stream Path Format Error:"), streamPath)   return nil, false  }  actual, loaded := Streams.LoadOrStore(streamPath, &Stream{   Path:       streamPath,   AppName:    p[0],   StreamName: strings.Join(p[1:], "/"),   StartTime:  time.Now(), +  Logger:     log.LocaleLogger.With(zap.String("stream", streamPath)), +  timeout:    time.NewTimer(waitTimeout),  })  if s := actual.(*Stream); loaded {   s.Debug("Stream Found")   return s, false  } else { -  s.timeout = time.NewTimer(waitTimeout)   s.Subscribers.Init() -  s.Logger = log.LocaleLogger.With(zap.String("stream", streamPath)) -  s.Info("created")   s.actionChan.Init(1) +  s.Info("created")   go s.run()   return s, true  } }

原理：当并发调用findOrCreateStream函数时，前者尚未来得及对Logger赋值，后者就调用了s.Debug导致空指针错误。

修复读写并发问题

这个问题在前面的单元测试中已经提到，就是订阅者阻塞引起的。

订阅者阻塞后，读取点移动很慢或者不移动，导致写入点追上

由于RingBuffer是由链表结构实现，因此很容易将节点剥离主环

废弃后，这个订阅者将无法再读取主环内容，也将遭到抛弃

抛弃

https默认端口

默认https端口已经设置为8443，preview插件在选择WebTransport的时候跳转错了端口号。

https证书已经嵌入到程序里面，可以直接设置host文件127.0.0.1 local.monibuca.com 访问https://local.monibuca.com:8443/preview/

gb28181 合并PR #95

本次PR主要修改了定时任务相关功能，包括：

定时删除超时设备

• 修改注册有效期配置默认值为3600s

• 设备状态变更处理

具体可以看代码变动

声明：本文由用户投稿上传，本站不保证内容的真实与正确性，并且不承担相关法律责任，如有侵权请提供版权资料并联系删除！

编程笔记 » go语言实战流媒体视频网站,Monibuca v4.6.5 发布 —— 开源 Go 语言流媒体服务器