当前位置：首页 > 文章列表 > 文章 > 前端 > WebSocket实现Icecast元数据实时推送

WebSocket实现Icecast元数据实时推送

2025-07-25 12:33:29 0浏览收藏

怎么入门文章编程？需要学习哪些知识点？这是新手们刚接触编程时常见的问题；下面golang学习网就来给大家整理分享一些知识点，希望能够给初学者一些帮助。本篇文章就来介绍《WebSocket 实现 Icecast 元数据实时更新》，涉及到，有需要的可以收藏一下

使用 WebSocket 实现 Icecast 流媒体元数据实时更新

本文将介绍如何使用 WebSocket 技术，优化 Icecast 流媒体元数据的获取方式，避免客户端轮询请求带来的服务器压力。传统的客户端轮询方式，即使少量用户也会对服务器造成较大的负载。本文将详细阐述如何搭建一个简单的 WebSocket 服务器，并编写服务端脚本定时从 Icecast 服务器获取元数据，一旦元数据发生变化，服务端将通过 WebSocket 推送给所有连接的客户端。客户端只需要监听 WebSocket 连接，即可实时获取最新的元数据信息，从而极大地降低服务器负载。

WebSocket 服务器搭建

首先，我们需要搭建一个简单的 WebSocket 服务器。这里推荐使用 Python 的 simple-websocket-server 库，它易于安装和使用。

pip install simple-websocket-server

安装完成后，我们可以创建一个 Python 脚本 websocket_server.py，用于启动 WebSocket 服务器。

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

# Icecast 服务器地址
ICECAST_URL = 'https://listen.abengnews.com/status-json.xsl'
# WebSocket 服务器端口
WS_PORT = 8000

clients = []

class MetadataServer(WebSocket):

    def handleMessage(self):
        pass

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

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

def get_metadata():
    try:
        response = requests.get(ICECAST_URL)
        response.raise_for_status()  # 检查请求是否成功
        data = response.json()
        metadata = data['icestats']['source']['title'] # 获取歌曲名称
        return 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(metadata)

if __name__ == "__main__":
    last_metadata = None
    ws_server = SimpleWebSocketServer('', WS_PORT, MetadataServer)

    try:
        while True:
            metadata = get_metadata()
            if metadata and metadata != last_metadata:
                print(f"Metadata changed: {metadata}")
                broadcast_metadata(metadata)
                last_metadata = metadata
            time.sleep(5) # 每 5 秒检查一次
            ws_server.serveonce()

    except KeyboardInterrupt:
        print("Server stopped.")
        ws_server.close()

代码解释：

导入必要的库: 导入 SimpleWebSocketServer 用于创建 WebSocket 服务器, time 用于定时任务, requests 用于获取 Icecast 元数据。
配置参数: 定义了 ICECAST_URL 为 Icecast 服务器的 JSON 状态页地址, WS_PORT 为 WebSocket 服务器监听的端口。
MetadataServer 类: 继承自 WebSocket 类, 处理客户端的连接和断开事件。
get_metadata() 函数: 向 Icecast 服务器发送 GET 请求，解析 JSON 响应，提取歌曲标题，并返回。如果请求失败或解析出错，会打印错误信息并返回 None。
broadcast_metadata() 函数: 遍历所有连接的客户端，将新的元数据发送给它们。
主循环: 在一个无限循环中，定期调用 get_metadata() 函数获取元数据。如果元数据与上次获取的不同，则调用 broadcast_metadata() 函数将新的元数据广播给所有客户端，并更新 last_metadata 变量。time.sleep(5) 使程序每 5 秒检查一次元数据。ws_server.serveonce() 处理 WebSocket 连接。
异常处理: 使用 try...except 块捕获 KeyboardInterrupt 异常，以便在用户按下 Ctrl+C 时安全地停止服务器。

运行这个脚本，WebSocket 服务器将在 8000 端口启动。

客户端实现

接下来，我们需要在客户端（例如，网页中的 JavaScript 代码）建立 WebSocket 连接，并监听服务器推送的元数据。




    Icecast Metadata Display


    Now Playing:

代码解释：

创建 WebSocket 对象: 使用 new WebSocket('ws://localhost:8000/') 创建一个 WebSocket 对象，连接到运行在 localhost 的 8000 端口的 WebSocket 服务器。
onopen 事件: 当 WebSocket 连接成功建立时，会触发 onopen 事件。这里只是简单地在控制台输出一条消息。
onmessage 事件: 当服务器向客户端发送消息时，会触发 onmessage 事件。event.data 包含服务器发送的数据（元数据）。这里将元数据显示在 id 为 metadata 的 HTML 元素中。
onclose 事件: 当 WebSocket 连接关闭时，会触发 onclose 事件。这里只是简单地在控制台输出一条消息。
onerror 事件: 当 WebSocket 连接发生错误时，会触发 onerror 事件。这里在控制台输出错误信息。

将此 HTML 文件保存为 index.html，并在浏览器中打开。