使用 WebSocket 获取 Icecast 流元数据，避免频繁请求服务器-js教程-PHP中文网

使用 WebSocket 获取 Icecast 流元数据，避免频繁请求服务器

花韻仙語

发布： 2025-07-14 18:00:23

原创

1045人浏览过

使用 websocket 获取 icecast 流元数据，避免频繁请求服务器

使用 WebSocket 优化 Icecast 元数据获取

摘要：本文介绍了如何使用 WebSocket 技术，在不频繁请求 Icecast 服务器的情况下，实时获取流元数据（如歌曲标题、艺术家等）。通过建立一个简单的 WebSocket 服务器，并使用服务器端脚本定期从 Icecast 获取元数据，并在数据变化时推送给客户端，有效降低了服务器负载，提升了用户体验。

在流媒体应用中，实时显示当前播放的歌曲信息（元数据）是一项常见需求。传统的实现方式通常是客户端（如网页播放器）定时向服务器发送请求，获取最新的元数据。然而，当用户数量较多时，这种频繁的请求会对服务器造成较大的压力。本文将介绍一种更高效的方案：使用 WebSocket 技术，实现服务器主动推送元数据，从而避免客户端的频繁请求。

方案概述

该方案的核心思想是建立一个中间层：WebSocket 服务器。该服务器负责定期从 Icecast 服务器获取元数据，并在元数据发生变化时，通过 WebSocket 连接将新的元数据推送给所有连接的客户端。

具体步骤如下：

搭建 WebSocket 服务器: 选择一个合适的 WebSocket 服务器框架。例如，可以使用 Python 的 simple-websocket-server 库。
编写服务器端脚本: 编写一个服务器端脚本，负责以下任务：
- 定期（例如每秒）向 Icecast 服务器发送 GET 请求，获取元数据。
- 比较新获取的元数据与之前的元数据是否相同。
- 如果元数据发生变化，则将新的元数据通过 WebSocket 连接推送给所有已连接的客户端。
客户端实现: 在客户端（如网页播放器）中，建立与 WebSocket 服务器的连接，并监听服务器推送的元数据更新事件。当收到新的元数据时，更新播放器界面上的显示信息。

代码示例

以下是一些示例代码，用于说明如何实现上述方案。

1. Python WebSocket 服务器端脚本 (使用 simple-websocket-server)

首先，确保安装了 simple-websocket-server:

AppMall应用商店

AI应用商店，提供即时交付、按需付费的人工智能应用服务

查看详情

pip install simple-websocket-server

登录后复制

然后，创建 server.py 文件，内容如下：

import time
import json
import requests
from SimpleWebSocketServer import WebSocket, SimpleWebSocketServer

ICECAST_URL = 'https://listen.abengnews.com/status-json.xsl' # 替换为你的 Icecast URL
METADATA = None
CLIENTS = []

class MetadataWebSocket(WebSocket):
    def handleMessage(self):
        pass

    def handleConnected(self):
        print(self.address, 'connected')
        CLIENTS.append(self)
        # 发送初始元数据给新连接的客户端
        if METADATA:
            self.sendMessage(json.dumps(METADATA))

    def handleClose(self):
        print(self.address, 'closed')
        CLIENTS.remove(self)

def get_metadata():
    global METADATA
    try:
        response = requests.get(ICECAST_URL)
        response.raise_for_status()  # 检查请求是否成功
        data = response.json()
        new_metadata = data['icestats']['source']
        return new_metadata
    except requests.exceptions.RequestException as e:
        print(f"Error fetching metadata: {e}")
        return None
    except (KeyError, TypeError) as e:
        print(f"Error parsing metadata: {e}")
        return None

def broadcast_metadata(metadata):
    for client in CLIENTS:
        client.sendMessage(json.dumps(metadata))

if __name__ == "__main__":
    server = SimpleWebSocketServer('', 8000, MetadataWebSocket) # 监听 8000 端口

    try:
        while True:
            new_metadata = get_metadata()
            if new_metadata and new_metadata != METADATA:
                METADATA = new_metadata
                print("Metadata changed, broadcasting...")
                broadcast_metadata(METADATA)
            server.serveonce()
            time.sleep(1)  # 每秒检查一次
    except KeyboardInterrupt:
        print("Exiting...")
    finally:
        server.close()

登录后复制

2. HTML 客户端代码 (JavaScript)

<!DOCTYPE html>
<html>
<head>
    <title>Icecast Metadata Display</title>
</head>
<body>
    <h1>Now Playing:</h1>
    <div id="metadata">Loading...</div>

    <script>
        const websocket = new WebSocket("ws://localhost:8000"); // 连接到 WebSocket 服务器

        websocket.onopen = () => {
            console.log("Connected to WebSocket server");
        };

        websocket.onmessage = (event) => {
            const metadata = JSON.parse(event.data);
            document.getElementById("metadata").innerText = `Title: ${metadata.title}, Artist: ${metadata.artist || 'Unknown'}`; // 假设元数据包含 title 和 artist
        };

        websocket.onclose = () => {
            console.log("Disconnected from WebSocket server");
        };

        websocket.onerror = (error) => {
            console.error("WebSocket error:", error);
        };
    </script>
</body>
</html>

登录后复制

3. Icecast状态JSON的格式

上述代码假设Icecast状态JSON包含icestats.source.title 和 icestats.source.artist。实际情况可能不同，请根据你的Icecast配置调整代码。常见的格式如下：

{
  "icestats": {
    "admin": "admin@example.com",
    "host": "example.com",
    "location": "Somewhere",
    "serverid": "Icecast 2.4.4",
    "serversoftware": "source",
    "serverstart": "Wed, 08 Nov 2023 14:00:00 GMT",
    "source": {
      "artist": "Artist Name",
      "avg_bitrate": 128,
      "genre": "Various",
      "listeners": 10,
      "listenurl": "http://example.com:8000/stream",
      "samplerate": 44100,
      "server_description": "My Radio Station",
      "server_name": "My Station",
      "title": "Song Title",
      "url": "http://example.com"
    }
  }
}

登录后复制

你需要修改客户端代码，以正确解析你的 Icecast 状态 JSON。