diff --git "a/\346\234\215\346\234\215\344\272\222\351\200\232\350\201\212\345\244\251/__init__.py" "b/\346\234\215\346\234\215\344\272\222\351\200\232\350\201\212\345\244\251/__init__.py"
new file mode 100644
index 00000000..03a1e621
--- /dev/null
+++ "b/\346\234\215\346\234\215\344\272\222\351\200\232\350\201\212\345\244\251/__init__.py"
@@ -0,0 +1,359 @@
+import asyncio
+import json
+import threading
+
+from tooldelta import Config, Plugin, plugin_entry, game_utils
+from tooldelta.constants import PacketIDS
+
+
+class CrossServerChat(Plugin):
+    """服服互通聊天插件 (频道鉴权版)。"""
+
+    name = "服服互通聊天"
+    author = "哈茶块"
+    version = (2, 3, 2)
+
+    # 扩展配置，增加鉴权信息
+    CONFIG_TEMPLATE = {
+        "中转服务器地址": "ws://core.aurorabot.top",
+        "当前服务器名称": "你的服务器名称",
+        # 默认进入官方公开频道。如需建立私人网络请改为自定义名称
+        "频道名称": "全球大厅",
+        "频道类型(公开/私密)": "公开",
+        "频道密钥(仅私密需填)": ""
+    }
+
+    def __init__(self, frame):
+        """初始化插件，处理热重载。"""
+        super().__init__(frame)
+
+        if hasattr(self.frame, "_cross_server_chat_instance"):
+            old_inst = getattr(self.frame, "_cross_server_chat_instance", None)
+            if old_inst:
+                try:
+                    old_inst.stop()
+                except Exception:
+                    pass
+        self.frame._cross_server_chat_instance = self
+
+        self.is_running = True
+
+        self.cfg, _ = Config.get_plugin_config_and_version(
+            self.name,
+            Config.auto_to_std(self.CONFIG_TEMPLATE),
+            self.CONFIG_TEMPLATE,
+            self.version
+        )
+        self.ws_conn = None
+        self.msg_queue = asyncio.Queue()
+        self.loop = None
+
+        self.ListenPreload(self.on_def)
+        self.ListenPacket(PacketIDS.Text, self.on_chat)
+
+    def stop(self):
+        """停止后台服务，供重载时安全清理旧线程。"""
+        self.is_running = False
+        if self.ws_conn and self.loop:
+            try:
+                asyncio.run_coroutine_threadsafe(self.ws_conn.close(), self.loop)
+            except Exception:
+                pass
+
+    def get_online_players(self):
+        """获取所有在线玩家列表，兼容多核心版本。"""
+        players = []
+        try:
+            res = game_utils.getTarget("@a")
+            if isinstance(res, list):
+                players = res
+        except Exception:
+            pass
+
+        if players:
+            return players
+
+        try:
+            if hasattr(self.game_ctrl, "players"):
+                p_list = self.game_ctrl.players.getAllPlayers()
+                players = [
+                    p.name if hasattr(p, 'name') else str(p) for p in p_list
+                ]
+        except Exception:
+            pass
+
+        if players:
+            return players
+
+        try:
+            has_all = hasattr(self.game_ctrl, "all_players")
+            if has_all and isinstance(self.game_ctrl.all_players, list):
+                players = self.game_ctrl.all_players
+        except Exception:
+            pass
+
+        return players
+
+    def on_def(self):
+        """插件预加载时检查依赖并启动线程。"""
+        try:
+            self.GetPluginAPI("pip").require("websockets")
+        except Exception as e:
+            err_msg = f"无法调用内置 pip 模块检查依赖: {e}"
+            self.print_err(err_msg)
+            return
+
+        c_type = self.cfg.get("频道类型(公开/私密)", "公开")
+        lock_icon = "🔒" if c_type == "私密" else "🌐"
+        self.print_inf(f"准备连接到频道: {lock_icon} [{self.cfg['频道名称']}]")
+        threading.Thread(target=self.run_ws_client, daemon=True).start()
+
+    def run_ws_client(self):
+        """在新线程中初始化异步事件循环。"""
+        self.loop = asyncio.new_event_loop()
+        asyncio.set_event_loop(self.loop)
+        self.loop.run_until_complete(self.ws_main())
+
+    async def ws_main(self):
+        """维持与中转服务器的持久连接。"""
+        import websockets
+
+        uri = self.cfg["中转服务器地址"]
+        channel = self.cfg["频道名称"]
+
+        while self.is_running:
+            try:
+                self.print_inf(f"正在尝试连接中转服务器: {uri} ...")
+                async with websockets.connect(uri) as ws:
+
+                    # 1. 鉴权握手
+                    auth_data = {
+                        "type": "auth",
+                        "channel": channel,
+                        "server_name": self.cfg["当前服务器名称"],
+                        "channel_type": self.cfg.get("频道类型(公开/私密)", "公开"),
+                        "channel_key": self.cfg.get("频道密钥(仅私密需填)", "")
+                    }
+                    await ws.send(json.dumps(auth_data))
+
+                    # 2. 等待服务端反馈 (5秒超时)
+                    auth_resp_str = await asyncio.wait_for(ws.recv(), timeout=5.0)
+                    auth_resp = json.loads(auth_resp_str)
+
+                    if auth_resp.get("type") == "auth_fail":
+                        self.print_err(f"❌ 互通连接被拒绝: {auth_resp.get('msg')}")
+                        self.print_war("请修改配置后使用 reload 重载插件。")
+                        self.is_running = False  # 彻底阻断，防止刷屏重连
+                        return
+
+                    self.ws_conn = ws
+                    self.print_suc("✅ 鉴权通过，互通服务已上线！")
+
+                    # 3. 正常建立并发任务
+                    recv_task = asyncio.create_task(self.ws_recv(ws))
+                    send_task = asyncio.create_task(self.ws_send(ws))
+                    report_task = asyncio.create_task(self.status_report_loop(ws))
+
+                    _, pending = await asyncio.wait(
+                        [recv_task, send_task, report_task],
+                        return_when=asyncio.FIRST_COMPLETED
+                    )
+
+                    for task in pending:
+                        task.cancel()
+
+            except Exception as e:
+                if self.is_running:
+                    self.print_err(f"❌ 与中转服务器连接断开或无法连接: {e}")
+            finally:
+                self.ws_conn = None
+
+            if not self.is_running:
+                break
+
+            if self.is_running:
+                self.print_war("5秒后尝试重新连接...")
+                for _ in range(5):
+                    if not self.is_running:
+                        break
+                    await asyncio.sleep(1)
+
+    async def status_report_loop(self, ws):
+        """定时高频上报本服务器的真实玩家名单给后端缓存。"""
+        while self.is_running:
+            try:
+                local_players = self.get_online_players()
+                payload = {
+                    "type": "status",
+                    "players": local_players
+                }
+                await ws.send(json.dumps(payload))
+            except Exception:
+                pass
+            await asyncio.sleep(3)
+
+    async def ws_recv(self, ws):
+        """接收中转服务器发来的跨服消息。"""
+        async for msg in ws:
+            if not self.is_running:
+                break
+            try:
+                data = json.loads(msg)
+                msg_type = data.get("type")
+                server_name = data.get("server", "未知服务器")
+                sender = data.get("player", "未知玩家")
+                content = data.get("msg", "")
+
+                if msg_type == "chat":
+                    fmt_msg = f"§7[§b{server_name}§7] §e{sender} §f> §r{content}"
+                    self.game_ctrl.say_to("@a", fmt_msg)
+
+                elif msg_type == "event":
+                    sub_type = data.get("sub_type")
+                    if sub_type == "reply_list":
+                        target = data.get("target")
+                        reply_content = data.get("content")
+                        self.game_ctrl.say_to(target, reply_content)
+
+                    elif sub_type == "private_msg_error":
+                        target = data.get("target")
+                        error_msg = data.get("msg")
+                        self.game_ctrl.say_to(target, error_msg)
+
+                elif msg_type == "private_msg":
+                    target = data.get("target")
+                    local_players = self.get_online_players()
+                    if target in local_players:
+                        fmt_msg = (
+                            f"§d[私聊] §7[§b{server_name}§7] §e{sender} "
+                            f"§f-> §e你§f: §r{content}"
+                        )
+                        self.game_ctrl.say_to(target, fmt_msg)
+
+            except Exception as e:
+                self.print_err(f"处理跨服消息时出错: {e}")
+
+    async def ws_send(self, ws):
+        """将队列里的本地消息发送给中转服务器。"""
+        while self.is_running:
+            try:
+                msg = await asyncio.wait_for(self.msg_queue.get(), timeout=1.0)
+                await ws.send(msg)
+            except asyncio.TimeoutError:
+                continue
+            except Exception:
+                break
+
+    def on_chat(self, pkt):  # skipcq: PY-R1000
+        """监听本地玩家聊天并处理指令分发。"""
+        player = pkt.get("SourceName", "")
+        msg = pkt.get("Message", "").strip()
+        text_type = pkt.get("TextType", 0)
+
+        if not player or not msg:
+            return False
+        if text_type != 1:
+            return False
+        if player == self.game_ctrl.bot_name:
+            return False
+
+        if msg.startswith(".msg ") or msg.startswith(".w "):
+            cmd_str = msg.split(" ", 1)[1].strip()
+            target_player = ""
+            content = ""
+
+            if cmd_str.startswith('"'):
+                end_idx = cmd_str.find('"', 1)
+                if end_idx != -1:
+                    target_player = cmd_str[1:end_idx]
+                    content = cmd_str[end_idx+1:].strip()
+                else:
+                    parts = cmd_str.split(" ", 1)
+                    target_player = parts[0]
+                    content = parts[1] if len(parts) > 1 else ""
+            else:
+                parts = cmd_str.split(" ", 1)
+                if len(parts) < 2:
+                    self.game_ctrl.say_to(
+                        player,
+                        "§c格式错误！用法: .msg <玩家名> <内容> (名字带空格请用双引号)"
+                    )
+                    return True
+                target_player = parts[0]
+                content = parts[1]
+
+            local_players = self.get_online_players()
+
+            if target_player in local_players:
+                self.game_ctrl.say_to(
+                    target_player,
+                    f"§d[私聊] §7[§b{self.cfg['当前服务器名称']}§7] "
+                    f"§e{player} §f-> §e你§f: §r{content}"
+                )
+                self.game_ctrl.say_to(
+                    player,
+                    f"§d[私聊] §f你 -> §e{target_player}§f: §r{content}"
+                )
+                return True
+
+            if self.is_running and self.loop and self.ws_conn:
+                data = {
+                    "type": "private_msg",
+                    "server": self.cfg["当前服务器名称"],
+                    "player": player,
+                    "target": target_player,
+                    "msg": content
+                }
+                asyncio.run_coroutine_threadsafe(
+                    self.msg_queue.put(json.dumps(data)),
+                    self.loop
+                )
+                self.game_ctrl.say_to(
+                    player,
+                    f"§d[私聊] §f你 -> §e{target_player}§f: §r{content}"
+                )
+            else:
+                self.game_ctrl.say_to(player, "§c互通服务未连接，无法发送跨服私聊。")
+            return True
+
+        if msg in [".list", ".在线"]:
+            if self.is_running and self.loop and self.ws_conn:
+                data = {
+                    "type": "event",
+                    "sub_type": "request_list",
+                    "requester": player
+                }
+                asyncio.run_coroutine_threadsafe(
+                    self.msg_queue.put(json.dumps(data)),
+                    self.loop
+                )
+            else:
+                local_players = self.get_online_players()
+                local_str = ", ".join(local_players)
+                msg_str = (
+                    f"§e==== 🌐 本服在线: {len(local_players)} 人 ====\n"
+                    f"§7[§b{self.cfg['当前服务器名称']}§7] §f{local_str}\n"
+                    "§c(跨服网络未连接)"
+                )
+                self.game_ctrl.say_to(player, msg_str)
+            return True
+
+        if msg.startswith("/") or msg.startswith("."):
+            return False
+
+        if self.is_running and self.loop and self.ws_conn:
+            data = {
+                "type": "chat",
+                "server": self.cfg["当前服务器名称"],
+                "player": player,
+                "msg": msg
+            }
+            asyncio.run_coroutine_threadsafe(
+                self.msg_queue.put(json.dumps(data)),
+                self.loop
+            )
+
+        return False
+
+
+entry = plugin_entry(CrossServerChat)
diff --git "a/\346\234\215\346\234\215\344\272\222\351\200\232\350\201\212\345\244\251/core_server.py" "b/\346\234\215\346\234\215\344\272\222\351\200\232\350\201\212\345\244\251/core_server.py"
new file mode 100644
index 00000000..4376aea0
--- /dev/null
+++ "b/\346\234\215\346\234\215\344\272\222\351\200\232\350\201\212\345\244\251/core_server.py"
@@ -0,0 +1,640 @@
+import asyncio
+import json
+import logging
+import os
+import websockets
+from aiohttp import web
+
+# 配置日志输出格式
+logging.basicConfig(
+    level=logging.INFO,
+    format='%(asctime)s - %(levelname)s - %(message)s'
+)
+
+# 存储所有连接的客户端详细信息
+# 结构: { websocket: {"channel": "大厅", "server_name": "一区", "players": []} }
+clients = {}
+
+META_FILE = "channels_meta.json"
+
+
+def load_channels_meta():
+    """从本地加载频道鉴权数据防抢注。"""
+    if os.path.exists(META_FILE):
+        with open(META_FILE, "r", encoding="utf-8") as file_obj:
+            return json.load(file_obj)
+    return {}
+
+
+# 存储频道元数据 (类型、密钥)
+channels_meta = load_channels_meta()
+
+# 强制锁定官方默认频道，任何人无法抢注更改
+channels_meta["全球大厅"] = {"type": "public", "key": ""}
+
+
+def save_meta():
+    """将频道鉴权数据永久保存到本地防抢注。"""
+    with open(META_FILE, "w", encoding="utf-8") as file_obj:
+        json.dump(channels_meta, file_obj, ensure_ascii=False, indent=4)
+
+
+# ==================== 🌐 Web UI 模板 ====================
+WEB_UI_HTML = """
+<!DOCTYPE html>
+<html lang="zh-CN">
+<head>
+    <meta charset="UTF-8">
+    <meta name="viewport" content="width=device-width, initial-scale=1.0">
+    <title>服服互通 - 全网实时监控大屏</title>
+    <script src="https://cdn.tailwindcss.com"></script>
+    <script src="https://unpkg.com/vue@3/dist/vue.global.js"></script>
+    <style>
+        [v-cloak] { display: none; }
+        ::-webkit-scrollbar { width: 6px; }
+        ::-webkit-scrollbar-track { background: transparent; }
+        ::-webkit-scrollbar-thumb {
+            background: #cbd5e1;
+            border-radius: 3px;
+        }
+        ::-webkit-scrollbar-thumb:hover { background: #94a3b8; }
+    </style>
+</head>
+<body class="bg-slate-50 min-h-screen text-slate-800
+             selection:bg-blue-200 font-sans">
+    <div id="app" v-cloak class="max-w-7xl mx-auto p-4 sm:p-8">
+
+        <!-- 头部 -->
+        <header class="flex flex-col sm:flex-row justify-between
+                       items-center mb-8 gap-4">
+            <div>
+                <h1 class="text-3xl font-extrabold text-slate-900
+                           tracking-tight flex items-center">
+                    <span class="text-blue-600 mr-2">✦</span>
+                    跨服互通枢纽
+                    <span class="ml-3 px-3 py-1 bg-blue-100 text-blue-700
+                                 text-sm rounded-full animate-pulse border
+                                 border-blue-200">Active</span>
+                </h1>
+                <p class="text-slate-500 mt-2 ml-1 text-sm font-medium">
+                    Global Network & Authorization Gateway
+                </p>
+            </div>
+            <div class="text-sm font-mono bg-white px-4 py-2 rounded-lg
+                        shadow-sm border border-slate-100 text-slate-500">
+                Data refreshed {{ lastUpdate }}
+            </div>
+        </header>
+
+        <!-- 数据总览卡片 -->
+        <div class="grid grid-cols-1 md:grid-cols-3 gap-6 mb-8">
+            <div class="bg-white rounded-2xl shadow-sm border border-slate-100
+                        p-6 relative overflow-hidden group hover:shadow-md
+                        transition-all">
+                <div class="absolute -right-4 -top-4 w-24 h-24 bg-blue-50
+                            rounded-full group-hover:scale-150 transition-transform
+                            duration-500 ease-out z-0"></div>
+                <div class="relative z-10">
+                    <div class="text-slate-500 text-sm font-semibold mb-1
+                                uppercase tracking-wider">活跃频道数</div>
+                    <div class="text-4xl font-black text-slate-800">
+                        {{ Object.keys(channels).length }}
+                    </div>
+                </div>
+            </div>
+            <div class="bg-white rounded-2xl shadow-sm border border-slate-100
+                        p-6 relative overflow-hidden group hover:shadow-md
+                        transition-all">
+                <div class="absolute -right-4 -top-4 w-24 h-24 bg-emerald-50
+                            rounded-full group-hover:scale-150 transition-transform
+                            duration-500 ease-out z-0"></div>
+                <div class="relative z-10">
+                    <div class="text-slate-500 text-sm font-semibold mb-1
+                                uppercase tracking-wider">在线子服数</div>
+                    <div class="text-4xl font-black text-slate-800">
+                        {{ totalServers }}
+                    </div>
+                </div>
+            </div>
+            <div class="bg-white rounded-2xl shadow-sm border border-slate-100
+                        p-6 relative overflow-hidden group hover:shadow-md
+                        transition-all">
+                <div class="absolute -right-4 -top-4 w-24 h-24 bg-purple-50
+                            rounded-full group-hover:scale-150 transition-transform
+                            duration-500 ease-out z-0"></div>
+                <div class="relative z-10">
+                    <div class="text-slate-500 text-sm font-semibold mb-1
+                                uppercase tracking-wider">全网在线玩家</div>
+                    <div class="text-4xl font-black text-slate-800">
+                        {{ totalPlayers }}
+                    </div>
+                </div>
+            </div>
+        </div>
+
+        <!-- 个人私密频道排行榜 -->
+        <div v-if="topPrivateByServers.length > 0"
+             class="mb-10 grid grid-cols-1 md:grid-cols-2 gap-6">
+            <div class="bg-white rounded-2xl shadow-sm border
+                        border-slate-200 overflow-hidden">
+                <div class="bg-gradient-to-r from-amber-500 to-orange-400
+                            px-6 py-4">
+                    <h3 class="text-lg font-bold text-white flex items-center
+                               shadow-sm">
+                        <svg class="w-5 h-5 mr-2" fill="none"
+                             stroke="currentColor" viewBox="0 0 24 24">
+                            <path stroke-linecap="round" stroke-linejoin="round"
+                                  stroke-width="2"
+                                  d="M19 11H5m14 0a2 2 0 012 2v6a2 2 0 01-2
+                                     2H5a2 2 0 01-2-2v-6a2 2 0 012-2m14 0V9a2
+                                     2 0 00-2-2M5 11V9a2 2 0 012-2m0 0V5a2 2
+                                     0 012-2h6a2 2 0 012 2v2M7 7h10"></path>
+                        </svg>
+                        私密频道 · 子服规模榜
+                    </h3>
+                </div>
+                <ul class="divide-y divide-slate-100">
+                    <li v-for="(ch, idx) in topPrivateByServers" :key="ch.name"
+                        class="px-6 py-4 flex justify-between items-center
+                               hover:bg-slate-50">
+                        <div class="flex items-center">
+                            <span class="w-6 h-6 rounded-full flex items-center
+                                         justify-center text-xs font-bold mr-3"
+                                  :class="idx === 0 ? 'bg-yellow-100 text-yellow-700' :
+                                          (idx === 1 ? 'bg-slate-200 text-slate-700' :
+                                          (idx === 2 ? 'bg-orange-100 text-orange-800' :
+                                          'text-slate-400'))">
+                                {{ idx + 1 }}
+                            </span>
+                            <span class="font-medium text-slate-700">
+                                {{ ch.name }}
+                            </span>
+                        </div>
+                        <span class="font-bold text-amber-600">
+                            {{ ch.serverCount }}
+                            <span class="text-xs font-normal text-slate-400">
+                                个服务器
+                            </span>
+                        </span>
+                    </li>
+                </ul>
+            </div>
+
+            <div class="bg-white rounded-2xl shadow-sm border border-slate-200
+                        overflow-hidden">
+                <div class="bg-gradient-to-r from-indigo-500 to-purple-500
+                            px-6 py-4">
+                    <h3 class="text-lg font-bold text-white flex items-center
+                               shadow-sm">
+                        <svg class="w-5 h-5 mr-2" fill="none"
+                             stroke="currentColor" viewBox="0 0 24 24">
+                            <path stroke-linecap="round" stroke-linejoin="round"
+                                  stroke-width="2"
+                                  d="M12 4.354a4 4 0 110 5.292M15 21H3v-1a6 6 0
+                                     0112 0v1zm0 0h6v-1a6 6 0 00-9-5.197M13 7a4
+                                     4 0 11-8 0 4 4 0 018 0z"></path>
+                        </svg>
+                        私密频道 · 在线人数榜
+                    </h3>
+                </div>
+                <ul class="divide-y divide-slate-100">
+                    <li v-for="(ch, idx) in topPrivateByPlayers" :key="ch.name"
+                        class="px-6 py-4 flex justify-between items-center
+                               hover:bg-slate-50">
+                        <div class="flex items-center">
+                            <span class="w-6 h-6 rounded-full flex items-center
+                                         justify-center text-xs font-bold mr-3"
+                                  :class="idx === 0 ? 'bg-yellow-100 text-yellow-700' :
+                                          (idx === 1 ? 'bg-slate-200 text-slate-700' :
+                                          (idx === 2 ? 'bg-orange-100 text-orange-800' :
+                                          'text-slate-400'))">
+                                {{ idx + 1 }}
+                            </span>
+                            <span class="font-medium text-slate-700">
+                                {{ ch.name }}
+                            </span>
+                        </div>
+                        <span class="font-bold text-indigo-600">
+                            {{ ch.playerCount }}
+                            <span class="text-xs font-normal text-slate-400">
+                                名玩家
+                            </span>
+                        </span>
+                    </li>
+                </ul>
+            </div>
+        </div>
+
+        <!-- 频道及服务器拓扑 -->
+        <div v-for="(channelData, channelName) in channels" :key="channelName"
+             class="mb-10">
+            <div class="flex items-center mb-5">
+                <h2 class="text-2xl font-bold text-slate-800 flex items-center">
+                    <span class="bg-slate-800 text-white w-8 h-8 rounded-lg flex
+                                 items-center justify-center mr-3 text-sm">#</span>
+                    {{ channelName }}
+                    <span v-if="channelData.meta.type === 'private'"
+                          class="ml-3 px-2 py-0.5 bg-amber-100 text-amber-700
+                                 text-xs rounded border border-amber-200 flex
+                                 items-center font-normal">
+                        <svg class="w-3 h-3 mr-1" fill="currentColor"
+                             viewBox="0 0 20 20">
+                            <path fill-rule="evenodd" clip-rule="evenodd"
+                                  d="M5 9V7a5 5 0 0110 0v2a2 2 0 012 2v5a2 2 0
+                                     01-2 2H5a2 2 0 01-2-2v-5a2 2 0 012-2zm8-2v2H7
+                                     V7a3 3 0 016 0z"></path>
+                        </svg>
+                        私密
+                    </span>
+                    <span v-else
+                          class="ml-3 px-2 py-0.5 bg-emerald-100 text-emerald-700
+                                 text-xs rounded border border-emerald-200 flex
+                                 items-center font-normal">
+                        <svg class="w-3 h-3 mr-1" fill="currentColor"
+                             viewBox="0 0 20 20">
+                            <path d="M10 12a2 2 0 100-4 2 2 0 000 4z"></path>
+                            <path fill-rule="evenodd" clip-rule="evenodd"
+                                  d="M.458 10C1.732 5.943 5.522 3 10 3s8.268
+                                     2.943 9.542 7c-1.274 4.057-5.064 7-9.542
+                                     7S1.732 14.057.458 10zM14 10a4 4 0
+                                     11-8 0 4 4 0 018 0z"></path>
+                        </svg>
+                        公开
+                    </span>
+                </h2>
+                <div class="ml-4 h-px bg-slate-200 flex-grow"></div>
+            </div>
+
+            <div class="grid grid-cols-1 lg:grid-cols-2 gap-6">
+                <div v-for="server in channelData.servers"
+                     :key="server.server_name"
+                     class="bg-white rounded-2xl shadow-sm border
+                            border-slate-100 overflow-hidden hover:border-blue-200
+                            transition-colors">
+                    <div class="bg-slate-50/50 px-6 py-4 border-b border-slate-100
+                                flex justify-between items-center">
+                        <div class="font-bold text-lg text-slate-800 flex
+                                    items-center">
+                            <span class="w-2.5 h-2.5 rounded-full mr-3
+                                         shadow-[0_0_8px_rgba(34,197,94,0.6)]"
+                                  :class="server.player_count > 0 ?
+                                          'bg-green-500' : 'bg-slate-300'">
+                            </span>
+                            {{ server.server_name }}
+                        </div>
+                        <span class="text-xs text-slate-400 font-mono bg-slate-100
+                                     px-2 py-1 rounded">
+                            {{ server.ip }}
+                        </span>
+                    </div>
+                    <div class="p-6">
+                        <div class="flex justify-between items-end mb-4">
+                            <div class="text-sm text-slate-500 font-medium">
+                                在线玩家
+                            </div>
+                            <div class="text-2xl font-bold"
+                                 :class="server.player_count > 0 ?
+                                         'text-blue-600' : 'text-slate-400'">
+                                {{ server.player_count }}
+                                <span class="text-sm font-medium text-slate-400">
+                                    人
+                                </span>
+                            </div>
+                        </div>
+
+                        <div class="flex flex-wrap gap-2 max-h-32 overflow-y-auto
+                                    pr-2">
+                            <span v-if="server.player_count === 0"
+                                  class="text-slate-400 text-sm italic py-1">
+                                💤 当前服务器无人在线
+                            </span>
+                            <span v-for="player in server.players" :key="player"
+                                  class="bg-blue-50 text-blue-700 text-sm
+                                         font-medium px-3 py-1.5 rounded-md border
+                                         border-blue-100 flex items-center">
+                                <svg class="w-3.5 h-3.5 mr-1.5 opacity-70"
+                                     fill="currentColor" viewBox="0 0 20 20">
+                                    <path fill-rule="evenodd" clip-rule="evenodd"
+                                          d="M10 9a3 3 0 100-6 3 3 0 000 6zm-7
+                                             9a7 7 0 1114 0H3z"></path>
+                                </svg>
+                                {{ player }}
+                            </span>
+                        </div>
+                    </div>
+                </div>
+            </div>
+        </div>
+
+        <div v-if="Object.keys(channels).length === 0"
+             class="text-center text-slate-400 mt-20 p-10 border-2 border-dashed
+                    border-slate-200 rounded-2xl">
+            <svg class="mx-auto h-12 w-12 text-slate-300 mb-4" fill="none"
+                 viewBox="0 0 24 24" stroke="currentColor">
+                <path stroke-linecap="round" stroke-linejoin="round"
+                      stroke-width="2" d="M13 10V3L4 14h7v7l9-11h-7z" />
+            </svg>
+            <h3 class="text-lg font-medium text-slate-900 mb-1">网络空闲</h3>
+            <p>目前没有连接到中转枢纽的子服务器。</p>
+        </div>
+
+        <footer class="mt-16 pt-8 border-t border-slate-200 text-center text-sm
+                       text-slate-400 pb-8">
+            Driven by ToolDelta Cross-Server Hub & Vue.js
+        </footer>
+    </div>
+
+    <script>
+        const { createApp, ref, computed, onMounted } = Vue
+
+        createApp({
+            setup() {
+                const channels = ref({})
+                const lastUpdate = ref('00:00:00')
+
+                const totalServers = computed(() => {
+                    let count = 0
+                    for (const key in channels.value) {
+                        count += channels.value[key].servers.length
+                    }
+                    return count
+                })
+
+                const totalPlayers = computed(() => {
+                    let count = 0
+                    for (const key in channels.value) {
+                        channels.value[key].servers.forEach(s => {
+                            count += s.player_count
+                        })
+                    }
+                    return count
+                })
+
+                const topPrivateByServers = computed(() => {
+                    const privates = Object.entries(channels.value)
+                        .filter(([_, data]) => data.meta.type === 'private')
+                        .map(([name, data]) => ({
+                            name,
+                            serverCount: data.servers.length
+                        }));
+                    return privates.sort(
+                        (a, b) => b.serverCount - a.serverCount
+                    ).slice(0, 5);
+                });
+
+                const topPrivateByPlayers = computed(() => {
+                    const privates = Object.entries(channels.value)
+                        .filter(([_, data]) => data.meta.type === 'private')
+                        .map(([name, data]) => ({
+                            name,
+                            playerCount: data.servers.reduce(
+                                (sum, s) => sum + s.player_count, 0
+                            )
+                        }));
+                    return privates.sort(
+                        (a, b) => b.playerCount - a.playerCount
+                    ).slice(0, 5);
+                });
+
+                const fetchData = async () => {
+                    try {
+                        const res = await fetch('/api/status')
+                        const data = await res.json()
+                        channels.value = data
+
+                        const now = new Date()
+                        const timeStr = now.toLocaleTimeString(
+                            'en-US', { hour12: false }
+                        )
+                        const msStr = now.getMilliseconds().toString()
+                                         .padStart(3, '0').slice(0,1)
+                        lastUpdate.value = `${timeStr}.${msStr}`
+                    } catch (e) {
+                        console.error("Fetch API error:", e)
+                    }
+                }
+
+                onMounted(() => {
+                    fetchData()
+                    setInterval(fetchData, 1500)
+                })
+
+                return {
+                    channels, totalServers, totalPlayers,
+                    topPrivateByServers, topPrivateByPlayers, lastUpdate
+                }
+            }
+        }).mount('#app')
+    </script>
+</body>
+</html>
+"""
+
+
+async def web_index(_request):
+    """处理 WebUI 首页请求。"""
+    return web.Response(text=WEB_UI_HTML, content_type="text/html", charset="utf-8")
+
+
+async def web_status_api(_request):
+    """处理 WebUI 数据获取 API。"""
+    data = {}
+    for ws, info in clients.items():
+        chan = info["channel"]
+        srv = info["server_name"]
+        players = info["players"]
+
+        ip_addr = "未知 IP"
+        if ws.remote_address:
+            ip_addr = f"{ws.remote_address[0]}:{ws.remote_address[1]}"
+
+        if chan not in data:
+            meta = channels_meta.get(chan, {"type": "public"})
+            data[chan] = {
+                "meta": {"type": meta["type"]},
+                "servers": []
+            }
+
+        data[chan]["servers"].append({
+            "server_name": srv,
+            "player_count": len(players),
+            "players": players,
+            "ip": ip_addr
+        })
+
+    return web.json_response(data)
+
+
+async def start_web_server(host, port):
+    """启动独立运行在同一事件循环内的 Web 服务。"""
+    app = web.Application()
+    app.router.add_get("/", web_index)
+    app.router.add_get("/api/status", web_status_api)
+
+    runner = web.AppRunner(app)
+    await runner.setup()
+    site = web.TCPSite(runner, host, port)
+    await site.start()
+    logging.info("🌐 WebUI 管理大屏已就绪，请在浏览器访问 http://%s:%d", host, port)
+
+
+async def handle_client(websocket, _path):  # skipcq: PY-R1000
+    """处理每个客户端连接及数据路由。"""
+    try:
+        auth_msg = await websocket.recv()
+        auth_data = json.loads(auth_msg)
+
+        if auth_data.get("type") != "auth":
+            logging.warning("非法的连接请求，已拒绝")
+            return
+
+        channel = auth_data.get("channel", "default")
+        server_name = auth_data.get("server_name", "未知子服")
+        c_type = "private" if auth_data.get("channel_type") == "私密" else "public"
+        c_key = auth_data.get("channel_key", "")
+
+        # ================= 权限校验模块 =================
+        if channel in channels_meta:
+            meta = channels_meta[channel]
+            if meta["type"] == "private" and meta["key"] != c_key:
+                reject_msg = {"type": "auth_fail", "msg": "该频道为私密频道，密钥错误！"}
+                await websocket.send(json.dumps(reject_msg))
+                logging.warning(
+                    "拒绝接入: %s 尝试连接私密频道 [%s] 密码错误 (%s)",
+                    server_name, channel, websocket.remote_address
+                )
+                return
+        else:
+            # 若是第一个连接的，则永久注册该频道并保存元数据
+            channels_meta[channel] = {"type": c_type, "key": c_key}
+            save_meta()
+            logging.info("⭐ 新频道永久注册: [%s] (类型: %s)", channel, c_type)
+
+        # 告诉前端验证成功
+        await websocket.send(json.dumps({"type": "auth_success"}))
+
+        clients[websocket] = {
+            "channel": channel,
+            "server_name": server_name,
+            "players": []
+        }
+
+        logging.info(
+            "🔗 新子服接入: [%s] (%s) | 当前总节点: %d",
+            server_name, channel, len(clients)
+        )
+
+        # 智能数据路由
+        async for message in websocket:
+            data = json.loads(message)
+            msg_type = data.get("type")
+            my_info = clients[websocket]
+
+            if msg_type == "chat":
+                targets = [
+                    ws for ws, info in list(clients.items())
+                    if info["channel"] == my_info["channel"] and ws != websocket
+                ]
+                for target_ws in targets:
+                    try:
+                        await target_ws.send(message)
+                    except Exception:
+                        pass
+
+            elif msg_type == "status":
+                clients[websocket]["players"] = data.get("players", [])
+
+            elif msg_type == "event":
+                sub_type = data.get("sub_type")
+
+                if sub_type == "request_list":
+                    requester = data.get("requester")
+                    total_players = 0
+                    servers_data = {}
+
+                    for ws, info in clients.items():
+                        if info["channel"] == my_info["channel"]:
+                            p_list = info["players"]
+                            servers_data[info["server_name"]] = p_list
+                            total_players += len(p_list)
+
+                    lines = [f"§e==== 🌐 全网同频道在线: {total_players} 人 ===="]
+                    for srv, p_list in servers_data.items():
+                        p_str = ", ".join(p_list) if p_list else "§8无人在线"
+                        lines.append(f"§7[§b{srv}§7] §a({len(p_list)}人) §f{p_str}")
+
+                    reply_msg = {
+                        "type": "event",
+                        "sub_type": "reply_list",
+                        "target": requester,
+                        "content": "\n".join(lines)
+                    }
+                    try:
+                        await websocket.send(json.dumps(reply_msg))
+                    except Exception:
+                        pass
+
+            elif msg_type == "private_msg":
+                target = data.get("target")
+                sender = data.get("player")
+
+                routed = False
+                for ws, info in clients.items():
+                    is_same_channel = info["channel"] == my_info["channel"]
+                    if is_same_channel and target in info["players"]:
+                        try:
+                            await ws.send(message)
+                            routed = True
+                            logging.info(
+                                "✉️ 跨服私聊路由: %s -> %s (投递至 %s)",
+                                sender, target, info["server_name"]
+                            )
+                        except Exception:
+                            pass
+                        break
+
+                if not routed:
+                    error_msg = {
+                        "type": "event",
+                        "sub_type": "private_msg_error",
+                        "target": sender,
+                        "msg": f"§c跨服私聊失败: 全网未找到玩家 {target} (可能不在线或拼写有误)。"
+                    }
+                    try:
+                        await websocket.send(json.dumps(error_msg))
+                    except Exception:
+                        pass
+
+    except websockets.exceptions.ConnectionClosed:
+        pass
+    except Exception as e:
+        logging.error("客户端连接异常: %s", e)
+    finally:
+        # 断开清理逻辑
+        if websocket in clients:
+            info = clients[websocket]
+            chan = info["channel"]
+            del clients[websocket]
+            logging.info(
+                "❌ 子服断开: [%s] (%s) | 剩余节点: %d",
+                info["server_name"], chan, len(clients)
+            )
+
+
+async def main():
+    """启动 WebSocket 服务器与 Web 监控页面。"""
+    host = "0.0.0.0"  # skipcq: BAN-B104
+    ws_port = 8765
+    web_port = 8766
+
+    logging.info("🚀 互通中转核心鉴权网关已启动")
+
+    await start_web_server(host, web_port)
+
+    logging.info("🕹️  跨服 WS 网关正在监听 ws://%s:%d", host, ws_port)
+    async with websockets.serve(handle_client, host, ws_port):
+        await asyncio.Future()
+
+
+if __name__ == "__main__":
+    asyncio.run(main())
diff --git "a/\346\234\215\346\234\215\344\272\222\351\200\232\350\201\212\345\244\251/datas.json" "b/\346\234\215\346\234\215\344\272\222\351\200\232\350\201\212\345\244\251/datas.json"
new file mode 100644
index 00000000..9e8c0a33
--- /dev/null
+++ "b/\346\234\215\346\234\215\344\272\222\351\200\232\350\201\212\345\244\251/datas.json"
@@ -0,0 +1,10 @@
+{
+  "plugin-id": "server-interconnection",
+  "author": "哈茶块",
+  "version": "2.3.2",
+  "description": "实现服服互通！可以让多个服务器内的聊天消息互通并且拥有webUI",
+  "plugin-type": "classic",
+  "pre-plugins": {
+    "pip模块支持": "0.0.6"
+  }
+}
diff --git "a/\346\234\215\346\234\215\344\272\222\351\200\232\350\201\212\345\244\251/readme.txt" "b/\346\234\215\346\234\215\344\272\222\351\200\232\350\201\212\345\244\251/readme.txt"
new file mode 100644
index 00000000..cfc8dd95
--- /dev/null
+++ "b/\346\234\215\346\234\215\344\272\222\351\200\232\350\201\212\345\244\251/readme.txt"
@@ -0,0 +1 @@
+这是一个服服互通聊天的插件您可以选择部署自己的中转服务器下载 core_server.py 文件并使用 python3 core_server.py 运行随后在配置文件内修改服务器地址即可如果您听不懂以上内容您可以不修改中转服务器地址使用默认的 ws://core.aurorabot.top
\ No newline at end of file