golang Websocket教程：如何开发在线音乐播放功能

package main

import (
    "net/http"
    "golang.org/x/net/websocket"
)

func main() {
    // 在路径"/play"上开启Websocket服务
    http.Handle("/play", websocket.Handler(playHandler))
    http.ListenAndServe(":8080", nil)
}

func playHandler(ws *websocket.Conn) {
    // 读取客户端发送的音乐播放请求
    playReq := make([]byte, 512)
    n, err := ws.Read(playReq)
    if err != nil {
        return
    }
    playReq = playReq[:n]
    playMusic(playReq, ws)
}

func playMusic(playReq []byte, ws *websocket.Conn) {
    // 解析请求，获取要播放的音乐文件名
    filename := string(playReq)
    filename = filename[:strings.Index(filename, "
")]

    // 使用Golang处理获取音乐文件
    musicFile, err := ioutil.ReadFile(filename)
    if err != nil {
        fmt.Fprintf(os.Stderr, "Error: %v
", err)
        return
    }
    musicData, err := mp3.Decode(audiocontext, bytes.NewReader(musicFile), len(musicFile))
    if err != nil {
        fmt.Fprintf(os.Stderr, "Error: %v
", err)
        return
    }
    
    // 将播放任务交给一个协程处理
    go func() {
        for {
            // 读取客户端发送的播放位置控制数据
            pos := make([]byte, 8)
            n, err := ws.Read(pos)
            if err != nil {
                // 断开与客户端的连接
                ws.Close()
                break
            }
            pos = pos[:n]

            // 把客户端发送的控制数据转换成时间（秒）
            t := float64(binary.LittleEndian.Uint64(pos)) / float64(SampleRate) + 1.0

            // 每秒播放一次音乐
            time.Sleep(time.Second)

            // 从指定位置开始播放音乐
            musicData.Seek(time.Duration(t)*time.Second, 0)
            buf := make([]byte, 1024)
            // 把音乐数据分帧发送给客户端
            for musicData.Err() == nil {
                n, err := musicData.Read(buf)
                if err != nil {
                    break
                }
                ws.Write(buf[:n])
            }
            // 音乐播放完成后，关闭连接
            ws.Close()
            break
        }
    }()
}

func main() {
    // 使用Golang内置的WebSocket库连接服务器
    ws, err := websocket.Dial("ws://127.0.0.1:8080/play", "", "http://127.0.0.1:8080")
    if err != nil {
        log.Fatal(err)
    }
    defer ws.Close()

    // 发送播放请求
    filename := "music.mp3
"
    pos := make([]byte, 8)

    for {
        // 持续发送控制数据
        binary.LittleEndian.PutUint64(pos, uint64(time.Now().UnixNano()))
        ws.Write(pos)

        // 一秒钟发送一次控制数据
        time.Sleep(time.Second)
    }
}