Update

.dockerignore

@@ -0,0 +1,5 @@
+node_modules
+npm-debug.log
+.git
+.DS_Store
+

.gitignore

@@ -0,0 +1,3 @@
+node_modules/
+.DS_Store
+

Dockerfile

@@ -0,0 +1,16 @@
+FROM node:20-alpine
+
+WORKDIR /app
+
+COPY package.json /app/package.json
+COPY server.js /app/server.js
+COPY public /app/public
+
+ENV NODE_ENV=production
+ENV HOST=0.0.0.0
+ENV PORT=7860
+
+EXPOSE 7860
+
+CMD ["node", "server.js"]
+

README.md

@@ -0,0 +1,20 @@
+# Node.js 聊天室（无依赖）
+
+这是一个最小可用的聊天室示例：服务端使用 Node.js 内置 `http`，消息推送使用 SSE（Server-Sent Events），不需要安装任何 npm 依赖。
+
+## 运行
+
+```bash
+npm start
+```
+
+然后打开：
+
+http://localhost:3000
+
+## 接口
+
+- `GET /events?username=xxx`：SSE 消息流（加入/离开/消息）
+- `POST /message`：发送消息（JSON：`{ "username": "xx", "text": "hello" }`）
+- `GET /healthz`：健康检查
+

package.json

@@ -0,0 +1,14 @@
+{
+  "name": "chatroom",
+  "version": "0.1.0",
+  "private": true,
+  "description": "A minimal Node.js chatroom (no deps) using HTTP + Server-Sent Events (SSE).",
+  "main": "server.js",
+  "scripts": {
+    "start": "node server.js"
+  },
+  "engines": {
+    "node": ">=18"
+  }
+}
+

public/app.js

@@ -0,0 +1,103 @@
+const loginEl = document.getElementById("login");
+const chatEl = document.getElementById("chat");
+const statusEl = document.getElementById("status");
+const messagesEl = document.getElementById("messages");
+const loginForm = document.getElementById("loginForm");
+const composer = document.getElementById("composer");
+const usernameInput = document.getElementById("username");
+const messageInput = document.getElementById("message");
+const loginErrorEl = document.getElementById("loginError");
+
+let username = null;
+let es = null;
+
+function setStatus(text) {
+  statusEl.textContent = text;
+}
+
+function escapeText(text) {
+  const div = document.createElement("div");
+  div.textContent = text;
+  return div.textContent;
+}
+
+function appendItem({ kind, at, from, text }) {
+  const li = document.createElement("li");
+  li.className = `msg ${kind}`;
+
+  const time = new Date(at || Date.now());
+  const ts = time.toLocaleTimeString("zh-CN", { hour: "2-digit", minute: "2-digit" });
+
+  li.innerHTML =
+    kind === "message"
+      ? `<span class="meta">${escapeText(from)} · ${escapeText(ts)}</span><span class="text">${escapeText(text)}</span>`
+      : `<span class="meta">系统 · ${escapeText(ts)}</span><span class="text">${escapeText(text)}</span>`;
+
+  messagesEl.appendChild(li);
+  messagesEl.scrollTop = messagesEl.scrollHeight;
+}
+
+function connect() {
+  if (!username) return;
+  if (es) es.close();
+
+  setStatus("连接中…");
+  es = new EventSource(`/events?username=${encodeURIComponent(username)}`);
+
+  es.onopen = () => setStatus("已连接");
+  es.onerror = () => setStatus("连接异常，自动重连中…");
+
+  es.addEventListener("system", (e) => {
+    const data = JSON.parse(e.data);
+    if (data.type === "welcome") appendItem({ kind: "system", at: data.at, text: data.text });
+    if (data.type === "join" || data.type === "leave") appendItem({ kind: "system", at: data.at, text: data.text });
+  });
+
+  es.addEventListener("message", (e) => {
+    const data = JSON.parse(e.data);
+    appendItem({ kind: "message", at: data.at, from: data.username, text: data.text });
+  });
+}
+
+async function sendMessage(text) {
+  const resp = await fetch("/message", {
+    method: "POST",
+    headers: { "content-type": "application/json" },
+    body: JSON.stringify({ username, text })
+  });
+  if (!resp.ok) {
+    const payload = await resp.json().catch(() => ({}));
+    throw new Error(payload.error || "send_failed");
+  }
+}
+
+loginForm.addEventListener("submit", (e) => {
+  e.preventDefault();
+  loginErrorEl.textContent = "";
+
+  const raw = usernameInput.value.trim();
+  if (!raw) {
+    loginErrorEl.textContent = "请输入用户名";
+    return;
+  }
+
+  username = raw;
+  loginEl.classList.add("hidden");
+  chatEl.classList.remove("hidden");
+  messageInput.focus();
+  connect();
+});
+
+composer.addEventListener("submit", async (e) => {
+  e.preventDefault();
+  const text = messageInput.value.trim();
+  if (!text) return;
+  messageInput.value = "";
+
+  try {
+    await sendMessage(text);
+  } catch (err) {
+    appendItem({ kind: "system", at: Date.now(), text: `发送失败：${String(err.message || err)}` });
+  }
+});
+

public/index.html

@@ -0,0 +1,56 @@
+<!doctype html>
+<html lang="zh-CN">
+  <head>
+    <meta charset="utf-8" />
+    <meta name="viewport" content="width=device-width,initial-scale=1" />
+    <title>Node.js 聊天室</title>
+    <link rel="stylesheet" href="/public/styles.css" />
+  </head>
+  <body>
+    <main class="app">
+      <header class="topbar">
+        <div class="brand">聊天室</div>
+        <div class="status" id="status">未连接</div>
+      </header>
+
+      <section class="panel">
+        <div class="login" id="login">
+          <div class="card">
+            <h1>进入聊天室</h1>
+            <p class="muted">用户名支持中文/字母/数字/下划线/短横线（1–24）</p>
+            <form id="loginForm">
+              <input
+                id="username"
+                name="username"
+                placeholder="输入用户名"
+                autocomplete="nickname"
+                maxlength="24"
+                required
+              />
+              <button type="submit">进入</button>
+            </form>
+            <div class="error" id="loginError" aria-live="polite"></div>
+          </div>
+        </div>
+
+        <div class="chat hidden" id="chat">
+          <ol class="messages" id="messages"></ol>
+          <form class="composer" id="composer">
+            <input
+              id="message"
+              name="message"
+              placeholder="输入消息，回车发送"
+              autocomplete="off"
+              maxlength="500"
+              required
+            />
+            <button type="submit">发送</button>
+          </form>
+        </div>
+      </section>
+    </main>
+
+    <script src="/public/app.js"></script>
+  </body>
+</html>
+

public/styles.css

@@ -0,0 +1,188 @@
+:root {
+  --bg: #0b1220;
+  --panel: #101b33;
+  --text: #eaf0ff;
+  --muted: #a8b4d6;
+  --accent: #6ea8fe;
+  --danger: #ff6b6b;
+  --border: rgba(255, 255, 255, 0.12);
+}
+
+* {
+  box-sizing: border-box;
+}
+
+html,
+body {
+  height: 100%;
+}
+
+body {
+  margin: 0;
+  font-family: ui-sans-serif, system-ui, -apple-system, "Segoe UI", Roboto, "Noto Sans", "PingFang SC",
+    "Hiragino Sans GB", "Microsoft YaHei", Arial, "Apple Color Emoji", "Segoe UI Emoji";
+  background: radial-gradient(1000px 700px at 20% 20%, rgba(110, 168, 254, 0.18), transparent 55%),
+    radial-gradient(900px 700px at 80% 10%, rgba(255, 107, 107, 0.12), transparent 55%), var(--bg);
+  color: var(--text);
+}
+
+.app {
+  max-width: 900px;
+  margin: 0 auto;
+  padding: 16px;
+  height: 100%;
+  display: flex;
+  flex-direction: column;
+  gap: 12px;
+}
+
+.topbar {
+  display: flex;
+  align-items: center;
+  justify-content: space-between;
+  padding: 12px 14px;
+  background: rgba(16, 27, 51, 0.6);
+  border: 1px solid var(--border);
+  border-radius: 14px;
+  backdrop-filter: blur(10px);
+}
+
+.brand {
+  font-weight: 700;
+  letter-spacing: 0.5px;
+}
+
+.status {
+  font-size: 12px;
+  color: var(--muted);
+}
+
+.panel {
+  flex: 1;
+  min-height: 0;
+  background: rgba(16, 27, 51, 0.65);
+  border: 1px solid var(--border);
+  border-radius: 16px;
+  overflow: hidden;
+  backdrop-filter: blur(10px);
+}
+
+.hidden {
+  display: none !important;
+}
+
+.login {
+  height: 100%;
+  display: grid;
+  place-items: center;
+  padding: 24px;
+}
+
+.card {
+  width: min(520px, 100%);
+  background: rgba(11, 18, 32, 0.55);
+  border: 1px solid var(--border);
+  border-radius: 16px;
+  padding: 18px;
+}
+
+.card h1 {
+  margin: 0 0 8px;
+  font-size: 22px;
+}
+
+.muted {
+  margin: 0 0 12px;
+  color: var(--muted);
+  font-size: 13px;
+}
+
+form {
+  display: flex;
+  gap: 10px;
+}
+
+input {
+  flex: 1;
+  padding: 12px 12px;
+  border-radius: 12px;
+  border: 1px solid var(--border);
+  background: rgba(255, 255, 255, 0.06);
+  color: var(--text);
+  outline: none;
+}
+
+input:focus {
+  border-color: rgba(110, 168, 254, 0.6);
+  box-shadow: 0 0 0 4px rgba(110, 168, 254, 0.18);
+}
+
+button {
+  padding: 12px 14px;
+  border-radius: 12px;
+  border: 1px solid rgba(110, 168, 254, 0.55);
+  background: rgba(110, 168, 254, 0.18);
+  color: var(--text);
+  cursor: pointer;
+}
+
+button:hover {
+  background: rgba(110, 168, 254, 0.26);
+}
+
+.error {
+  margin-top: 10px;
+  color: var(--danger);
+  min-height: 18px;
+  font-size: 13px;
+}
+
+.chat {
+  height: 100%;
+  display: flex;
+  flex-direction: column;
+  min-height: 0;
+}
+
+.messages {
+  list-style: none;
+  margin: 0;
+  padding: 14px 14px 0;
+  overflow: auto;
+  flex: 1;
+  min-height: 0;
+}
+
+.msg {
+  padding: 10px 12px;
+  border: 1px solid rgba(255, 255, 255, 0.09);
+  border-radius: 14px;
+  margin-bottom: 10px;
+  background: rgba(11, 18, 32, 0.45);
+}
+
+.msg.system {
+  border-style: dashed;
+  color: var(--muted);
+}
+
+.msg .meta {
+  display: block;
+  font-size: 12px;
+  color: var(--muted);
+  margin-bottom: 6px;
+}
+
+.msg .text {
+  display: block;
+  white-space: pre-wrap;
+  word-break: break-word;
+  line-height: 1.4;
+}
+
+.composer {
+  padding: 14px;
+  border-top: 1px solid var(--border);
+  background: rgba(11, 18, 32, 0.35);
+}
+

server.js

@@ -0,0 +1,214 @@
+const http = require("http");
+const fs = require("fs");
+const path = require("path");
+const { randomUUID } = require("crypto");
+
+const HOST = process.env.HOST || "127.0.0.1";
+const PORT = Number.parseInt(process.env.PORT || "3000", 10);
+const PUBLIC_DIR = path.join(__dirname, "public");
+
+const clients = new Map(); // clientId -> { res, username }
+let nextEventId = 1;
+
+function sendSse(res, { event, data, id }) {
+  if (typeof id === "number") res.write(`id: ${id}\n`);
+  if (event) res.write(`event: ${event}\n`);
+  if (data !== undefined) {
+    const payload = typeof data === "string" ? data : JSON.stringify(data);
+    for (const line of payload.split("\n")) res.write(`data: ${line}\n`);
+  }
+  res.write("\n");
+}
+
+function broadcast(event, data) {
+  const id = nextEventId++;
+  for (const { res } of clients.values()) {
+    sendSse(res, { event, data, id });
+  }
+}
+
+function sanitizeUsername(raw) {
+  const username = String(raw || "").trim();
+  if (!username) return null;
+  if (username.length > 24) return null;
+  if (!/^[\p{L}\p{N}_-]+$/u.test(username)) return null;
+  return username;
+}
+
+function sanitizeMessage(raw) {
+  const text = String(raw || "").trim();
+  if (!text) return null;
+  if (text.length > 500) return null;
+  return text;
+}
+
+function serveFile(req, res, filePath) {
+  fs.readFile(filePath, (err, buf) => {
+    if (err) {
+      res.writeHead(404, { "content-type": "text/plain; charset=utf-8" });
+      res.end("Not found");
+      return;
+    }
+    const ext = path.extname(filePath).toLowerCase();
+    const contentType =
+      ext === ".html"
+        ? "text/html; charset=utf-8"
+        : ext === ".js"
+          ? "text/javascript; charset=utf-8"
+          : ext === ".css"
+            ? "text/css; charset=utf-8"
+            : "application/octet-stream";
+
+    res.writeHead(200, {
+      "content-type": contentType,
+      "cache-control": "no-store"
+    });
+    res.end(buf);
+  });
+}
+
+function readJson(req) {
+  return new Promise((resolve, reject) => {
+    let body = "";
+    req.on("data", (chunk) => {
+      body += chunk;
+      if (body.length > 64 * 1024) {
+        reject(new Error("payload_too_large"));
+        req.destroy();
+      }
+    });
+    req.on("end", () => {
+      try {
+        resolve(body ? JSON.parse(body) : {});
+      } catch {
+        reject(new Error("invalid_json"));
+      }
+    });
+    req.on("error", reject);
+  });
+}
+
+const server = http.createServer(async (req, res) => {
+  try {
+    const url = new URL(req.url || "/", `http://${req.headers.host || "localhost"}`);
+
+    if (req.method === "GET" && (url.pathname === "/" || url.pathname === "/index.html")) {
+      return serveFile(req, res, path.join(PUBLIC_DIR, "index.html"));
+    }
+
+    if (req.method === "GET" && url.pathname.startsWith("/public/")) {
+      const relative = url.pathname.replace(/^\/public\//, "");
+      const safePath = path.normalize(relative).replace(/^(\.\.(\/|\\|$))+/, "");
+      return serveFile(req, res, path.join(PUBLIC_DIR, safePath));
+    }
+
+    if (req.method === "GET" && url.pathname === "/healthz") {
+      res.writeHead(200, { "content-type": "application/json; charset=utf-8" });
+      res.end(JSON.stringify({ ok: true, clients: clients.size }));
+      return;
+    }
+
+    if (req.method === "GET" && url.pathname === "/events") {
+      const username = sanitizeUsername(url.searchParams.get("username"));
+      if (!username) {
+        res.writeHead(400, { "content-type": "application/json; charset=utf-8" });
+        res.end(JSON.stringify({ error: "invalid_username" }));
+        return;
+      }
+
+      const clientId = randomUUID();
+      res.writeHead(200, {
+        "content-type": "text/event-stream; charset=utf-8",
+        "cache-control": "no-cache, no-transform",
+        connection: "keep-alive",
+        "x-accel-buffering": "no"
+      });
+
+      res.write(": connected\n\n");
+      clients.set(clientId, { res, username });
+
+      broadcast("system", {
+        type: "join",
+        at: Date.now(),
+        username,
+        text: `${username} 加入了聊天室`
+      });
+
+      sendSse(res, {
+        event: "system",
+        data: { type: "welcome", at: Date.now(), text: "欢迎来到聊天室！" },
+        id: nextEventId++
+      });
+
+      const keepAlive = setInterval(() => {
+        try {
+          res.write(": ping\n\n");
+        } catch {
+          // ignore
+        }
+      }, 25_000);
+
+      req.on("close", () => {
+        clearInterval(keepAlive);
+        const existing = clients.get(clientId);
+        clients.delete(clientId);
+        if (existing) {
+          broadcast("system", {
+            type: "leave",
+            at: Date.now(),
+            username: existing.username,
+            text: `${existing.username} 离开了聊天室`
+          });
+        }
+      });
+      return;
+    }
+
+    if (req.method === "POST" && url.pathname === "/message") {
+      const contentType = (req.headers["content-type"] || "").toLowerCase();
+      if (!contentType.includes("application/json")) {
+        res.writeHead(415, { "content-type": "application/json; charset=utf-8" });
+        res.end(JSON.stringify({ error: "expected_application_json" }));
+        return;
+      }
+
+      let payload;
+      try {
+        payload = await readJson(req);
+      } catch (err) {
+        res.writeHead(400, { "content-type": "application/json; charset=utf-8" });
+        res.end(JSON.stringify({ error: err.message || "bad_request" }));
+        return;
+      }
+
+      const username = sanitizeUsername(payload.username);
+      const text = sanitizeMessage(payload.text);
+      if (!username || !text) {
+        res.writeHead(400, { "content-type": "application/json; charset=utf-8" });
+        res.end(JSON.stringify({ error: "invalid_message" }));
+        return;
+      }
+
+      broadcast("message", { at: Date.now(), username, text });
+
+      res.writeHead(200, { "content-type": "application/json; charset=utf-8" });
+      res.end(JSON.stringify({ ok: true }));
+      return;
+    }
+
+    res.writeHead(404, { "content-type": "text/plain; charset=utf-8" });
+    res.end("Not found");
+  } catch {
+    res.writeHead(500, { "content-type": "text/plain; charset=utf-8" });
+    res.end("Internal server error");
+  }
+});
+
+server.on("error", (err) => {
+  console.error("Server error:", err && err.message ? err.message : err);
+  process.exitCode = 1;
+});
+
+server.listen(PORT, HOST, () => {
+  console.log(`Chatroom running: http://${HOST}:${PORT}`);
+});