获取 Icecast 流元数据的优化方案：使用 WebSocket 实现实时更新-js教程-PHP中文网

获取 Icecast 流元数据的优化方案：使用 WebSocket 实现实时更新

碧海醫心

发布： 2025-07-14 17:04:20

原创

328人浏览过

获取 icecast 流元数据的优化方案：使用 websocket 实现实时更新

本文介绍了一种优化 Icecast 流元数据获取的方法，通过建立 WebSocket 服务器，服务器端定时从 Icecast 获取元数据，并在发生变化时推送给客户端。这种方法避免了客户端频繁请求 Icecast 服务器，显著降低了服务器负载，实现了近乎实时的元数据更新。

传统的 Icecast 流元数据获取方式通常是客户端定时向服务器发送 HTTP 请求，这种方式在高并发场景下会给服务器带来较大的压力。为了解决这个问题，我们可以使用 WebSocket 技术，建立一个服务器端推送机制，将元数据的更新实时地推送给客户端。

实现原理

WebSocket 服务器搭建： 首先，我们需要搭建一个 WebSocket 服务器。可以使用各种编程语言和框架来实现，例如 Python 的 simple-websocket-server 库。

# 示例：使用 simple-websocket-server 搭建 WebSocket 服务器
from SimpleWebSocketServer import WebSocket, SimpleWebSocketServer
import time
import requests
import json

class MetadataServer(WebSocket):

    def handleMessage(self):
        pass

    def handleConnected(self):
        print(self.address, 'connected')
        self.server.clients.append(self)

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

class SimpleChatServer(SimpleWebSocketServer):

    def __init__(self, host, port, websocketclass):
        super().__init__(host, port, websocketclass)
        self.clients = []
        self.metadata_url = "https://listen.abengnews.com/status-json.xsl"  # 替换为你的 Icecast 元数据 URL
        self.last_metadata = None

    def update_metadata(self):
        try:
            response = requests.get(self.metadata_url)
            response.raise_for_status()  # 检查 HTTP 错误
            data = response.json()
            metadata = data['icestats']['source']['title'] #根据你的json结构修改
            if metadata != self.last_metadata:
                print(f"Metadata changed: {metadata}")
                for client in self.clients:
                    client.sendMessage(metadata)
                self.last_metadata = metadata
        except requests.exceptions.RequestException as e:
            print(f"Error fetching metadata: {e}")
        except json.JSONDecodeError as e:
            print(f"Error decoding JSON: {e}")
        except KeyError as e:
            print(f"KeyError: {e}, check your json structure")

    def run(self):
        try:
            while True:
                self.update_metadata()
                time.sleep(5)  # 每隔 5 秒检查一次元数据
        except KeyboardInterrupt:
            print("Server stopped.")

if __name__ == "__main__":
    server = SimpleChatServer('', 8000, MetadataServer)
    print("WebSocket server started on port 8000")
    server.run()

登录后复制

这个示例代码使用 simple-websocket-server 创建了一个简单的 WebSocket 服务器。它定期从 Icecast 服务器获取元数据，并在元数据发生更改时将其发送给所有连接的客户端。

服务器端元数据获取： 服务器端脚本定时（例如每秒一次）向 Icecast 服务器发送 HTTP 请求，获取元数据信息。由于只有服务器端进行请求，因此不会对 Icecast 服务器造成过大的负载。

ViiTor实时翻译
AI实时多语言翻译专家！强大的语音识别、AR翻译功能。

116

查看详情
元数据变更检测与推送： 服务器端脚本在获取到元数据后，需要与上次获取的元数据进行比较，如果发现元数据发生了变化，则将新的元数据通过 WebSocket 连接推送给所有连接的客户端。

客户端 WebSocket 连接与监听： 客户端（例如网页上的 JavaScript 代码）需要建立与 WebSocket 服务器的连接，并监听服务器推送的元数据更新事件。当接收到新的元数据时，客户端更新播放器上的显示信息。

// 客户端 JavaScript 代码示例
var ws = new WebSocket('ws://localhost:8000'); // 替换为你的 WebSocket 服务器地址

ws.onopen = function() {
  console.log('WebSocket 连接已建立');
};

ws.onmessage = function(event) {
  var metadata = event.data;
  console.log('接收到元数据：', metadata);
  document.getElementById("scroll-text").innerHTML = metadata; //更新html
};

ws.onclose = function() {
  console.log('WebSocket 连接已关闭');
};

ws.onerror = function(error) {
  console.error('WebSocket 发生错误：', error);
};

登录后复制

注意事项