背景
由于公司數(shù)據(jù)上傳到阿里云，采用到音頻格式是amr，在h5播放amr格式到時候，如果長度比較長，那么會出現(xiàn)播放不了到問題。具體可以看下原理。html插件播放音頻。
處理方案
將amr轉(zhuǎn)mp3。插件天然支持mp3的播放。具體原因，大家自己去了解下，這里不是重點闡述這個玩意兒的。
處理過程
不得不了解的一些常識
- ffmpeg
https://www.ffmpeg.org/
A complete, cross-platform solution to record, convert and stream audio and video.
- 環(huán)境需要安裝ffmpeg。不安裝，那么程序無法執(zhí)行命令。
- go的 日期格式化，很奇葩：
fmt.Println(time.Now().Format("2006-01-02 15:04:05")) # 這是個奇葩,必須是這個時間點, 據(jù)說是go誕生之日, 記憶方法:6-1-2-3-4-5
步驟
- 創(chuàng)建目錄:每天從阿里云oss download下來昨天的，放在一個目錄里
//創(chuàng)建當(dāng)天的目錄
func mkTodayDir() {
today := time.Now().Format("20060102")
_,err2 := os.Stat(myfolder+today)
if os.IsNotExist(err2) {
err3 := os.Mkdir(myfolder+today,os.ModePerm)
if err3 == nil {
println("mkdir"+myfolder+today+" success..")
}else {
println("mkdir"+myfolder+today+" fail..")
}
}else {
println("dir "+myfolder+today+" exists.")
}
todayFolder = myfolder+today +"/"
}
- 初始化阿里云oss實例
func bucketo() *oss.Bucket {
// 創(chuàng)建OSSClient實例。
client, err := oss.New("oss-cn-shanghai.aliyuncs.com", "xxx", "xxx")
if err != nil {
fmt.Println("Error:", err)
os.Exit(-1)
}
// 獲取存儲空間。
bucket, err := client.Bucket("paifenle-tars")
if err != nil {
fmt.Println("Error:", err)
os.Exit(-1)
}
return bucket
}
- 開始下載
func getAndDownload() {
d, _ := time.ParseDuration("-24h")
// 分頁列舉包含指定前綴的文件。每頁列舉80個。
prefix := oss.Prefix("audio/")
//prefix := oss.Prefix("audio/00271621-ec5c-485c-a425-d31fffa62a77.amr")
marker := oss.Marker("")
for {
lsRes, err := bucket.ListObjects(oss.MaxKeys(80), marker, prefix)
if err != nil {
fmt.Println("Error:", err)
os.Exit(-1)
}
prefix = oss.Prefix(lsRes.Prefix)
marker = oss.Marker(lsRes.NextMarker)
// 打印結(jié)果。
for _, object := range lsRes.Objects {
//列舉所有aac文件：audio/00005d64-783c-40da-8f90-05b534a2b353.aac
objectName := object.Key
if objectName != "audio/" && strings.Contains(objectName,".amr") {
if object.LastModified.Format("20060102") != time.Now().Add(d).Format("20060102") {
println("跳過...")
continue
}
//fmt.Println("-Object:", objectName)
objectNameSuffix := strings.Split(objectName,"/")[1]
//判斷是否有mp3文件，有點話就不下載了
exists,err2 := bucket.IsObjectExist(strings.Replace(objectName,"amr","mp3",1))
if err2 != nil {
fmt.Println("Error:", err)
os.Exit(-1)
}
if exists {
println(strings.Replace(objectName,"amr","mp3",1)+"在oss存在，不下載到本地.")
}else{
// 下載文件到本地文件。
err = bucket.GetObjectToFile(objectName, todayFolder+objectNameSuffix,oss.Progress(&OssProgressListener{}))
if err != nil {
fmt.Println("Error:", err)
os.Exit(-1)
}
fmt.Println("Transfer Completed.")
}
}
}
if !lsRes.IsTruncated {
break
}
}
}
- 轉(zhuǎn)換處理
func convertToMp3(filenames ...string) error {
var tofilename string
fromfilename := filenames[0]
switch len(filenames) {
case 1:
tofilename = filenames[0]
break
case 2:
tofilename = filenames[1]
break
default:
tofilename = filenames[0]
}
comm := exec.Command("ffmpeg", "-i", fromfilename+".amr", "-ar", AudioSamplingRateMP3, tofilename+".mp3")
//判斷mp3文件是否存在
fileInfo,err1 := os.Stat(tofilename+".mp3")
if fileInfo != nil && err1 == nil {
println(tofilename+".mp3"+"文件存在，不轉(zhuǎn)換...")
return nil
}else {
println(fromfilename+".amr"+"轉(zhuǎn)換....")
if err := comm.Run(); err != nil {
return err
}
println("=>"+tofilename+".mp3"+"轉(zhuǎn)換成功。")
}
println("=>"+tofilename+".mp3"+"開始上傳...")
//上傳本地文件。
arr := strings.Split(tofilename,"/")
fileName := arr[len(arr)-1]
// 判斷文件是否存在。
isExist, err := bucket.IsObjectExist("audio/"+fileName+".mp3")
if err != nil {
fmt.Println("Error:", err)
os.Exit(-1)
}
if isExist {
println("audio/"+fileName+".mp3 文件存在,不上傳.")
}else {
err1 = bucket.PutObjectFromFile("audio/"+fileName+".mp3", tofilename+".mp3",oss.Progress(&OssProgressListener{}))
if err1 != nil {
fmt.Println("Error:", err1)
os.Exit(-1)
}
fmt.Println("upload Completed.")
}
return nil
}
