mapleafgo
788327047c
核心变更: - 实现全局 oto.Context 单例管理（sync.Once） - 实现一次性播放：PlayWav/PlayMP3（支持 context 取消） - 实现 BGM 循环播放：PlayMP3Loop（atomic.Bool + WaitGroup） - 迁移所有业务层到新 API（TTS/BGM/待机音频） - 添加完整的单元测试（6/6 通过） 技术栈: - oto/v3 v3.3.2（低级音频播放） - hajimehoshi/go-mp3 v0.3.4（MP3 解码） - youpy/go-wav v0.3.2（WAV 解码） 移除依赖: - gopxl/beep/v2 及所有相关依赖 优化: - 流式播放，无需预先加载 - 并发安全，无竞态条件 - 资源管理清晰（defer cleanup） - Sleep 间隔优化（1ms → 10ms，降低 CPU 占用）
37 lines
714 B
Go
37 lines
714 B
Go
package standby
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"game-driver/internal/schema"
|
|
"game-driver/pkg/audio"
|
|
"game-driver/pkg/utils"
|
|
|
|
"go.uber.org/zap"
|
|
)
|
|
|
|
func Audio(item schema.WaitItemModel) func(c context.Context) error {
|
|
return func(c context.Context) error {
|
|
data, err := utils.LinkAudio(item.Data)
|
|
if err != nil {
|
|
return fmt.Errorf("音频数据获取异常: %w", err)
|
|
}
|
|
if data == nil {
|
|
return fmt.Errorf("音频数据获取为空")
|
|
}
|
|
|
|
zap.S().Infoln("播放待机音乐")
|
|
defer zap.S().Infoln("结束待机音乐")
|
|
|
|
_, cleanup, err := audio.PlayMP3Loop(data)
|
|
if err != nil {
|
|
return fmt.Errorf("播放待机音乐异常: %w", err)
|
|
}
|
|
defer cleanup()
|
|
|
|
<-c.Done()
|
|
|
|
return nil
|
|
}
|
|
}
|