本指南说明如何将基于浏览器的终端连接到沙箱 shell。你可以使用带有 xterm.js 的 SandboxAddon,或直接通过 WebSocket 连接。
你需要一个已有沙箱绑定(binding)的 Cloudflare Worker。如果还没有,请参阅快速入门。
在前端项目中安装终端依赖:
npm install @xterm/xterm @xterm/addon-fit @cloudflare/sandboxyarn install @xterm/xterm @xterm/addon-fit @cloudflare/sandboxpnpm install @xterm/xterm @xterm/addon-fit @cloudflare/sandboxbun install @xterm/xterm @xterm/addon-fit @cloudflare/sandbox如果不使用 xterm.js,你只需要 @cloudflare/sandbox 以获取类型。
添加一条将 WebSocket 连接代理到沙箱终端的路由。以下示例通过查询参数同时支持默认会话与命名会话:
import { getSandbox } from "@cloudflare/sandbox";
export { Sandbox } from "@cloudflare/sandbox";
export default {
async fetch(request, env) {
const url = new URL(request.url);
if (
url.pathname === "/ws/terminal" &&
request.headers.get("Upgrade") === "websocket"
) {
const sandbox = getSandbox(env.Sandbox, "my-sandbox");
const sessionId = url.searchParams.get("session");
if (sessionId) {
const session = await sandbox.getSession(sessionId);
return await session.terminal(request);
}
return await sandbox.terminal(request, { cols: 80, rows: 24 });
}
return new Response("Not found", { status: 404 });
},
};import { getSandbox } from '@cloudflare/sandbox';
export { Sandbox } from '@cloudflare/sandbox';
export default {
async fetch(request: Request, env: Env): Promise<Response> {
const url = new URL(request.url);
if (url.pathname === '/ws/terminal' && request.headers.get('Upgrade') === 'websocket') {
const sandbox = getSandbox(env.Sandbox, 'my-sandbox');
const sessionId = url.searchParams.get('session');
if (sessionId) {
const session = await sandbox.getSession(sessionId);
return await session.terminal(request);
}
return await sandbox.terminal(request, { cols: 80, rows: 24 });
}
return new Response('Not found', { status: 404 });
}
};在浏览器代码中创建终端并挂载 SandboxAddon。该 addon 管理 WebSocket 连接、自动重连以及尺寸调整转发。
import { Terminal } from "@xterm/xterm";
import { FitAddon } from "@xterm/addon-fit";
import { SandboxAddon } from "@cloudflare/sandbox/xterm";
import "@xterm/xterm/css/xterm.css";
const terminal = new Terminal({ cursorBlink: true });
const fitAddon = new FitAddon();
terminal.loadAddon(fitAddon);
const addon = new SandboxAddon({
getWebSocketUrl: ({ sandboxId, sessionId, origin }) => {
const params = new URLSearchParams({ id: sandboxId });
if (sessionId) params.set("session", sessionId);
return `${origin}/ws/terminal?${params}`;
},
onStateChange: (state, error) => {
console.log(`Terminal ${state}`, error ?? "");
},
});
terminal.loadAddon(addon);
terminal.open(document.getElementById("terminal"));
fitAddon.fit();
// Connect to the default session
addon.connect({ sandboxId: "my-sandbox" });
// Or connect to a specific session
// addon.connect({ sandboxId: 'my-sandbox', sessionId: 'development' });
window.addEventListener("resize", () => fitAddon.fit());import { Terminal } from '@xterm/xterm';
import { FitAddon } from '@xterm/addon-fit';
import { SandboxAddon } from '@cloudflare/sandbox/xterm';
import '@xterm/xterm/css/xterm.css';
const terminal = new Terminal({ cursorBlink: true });
const fitAddon = new FitAddon();
terminal.loadAddon(fitAddon);
const addon = new SandboxAddon({
getWebSocketUrl: ({ sandboxId, sessionId, origin }) => {
const params = new URLSearchParams({ id: sandboxId });
if (sessionId) params.set('session', sessionId);
return `${origin}/ws/terminal?${params}`;
},
onStateChange: (state, error) => {
console.log(`Terminal ${state}`, error ?? '');
}
});
terminal.loadAddon(addon);
terminal.open(document.getElementById('terminal'));
fitAddon.fit();
// Connect to the default session
addon.connect({ sandboxId: 'my-sandbox' });
// Or connect to a specific session
// addon.connect({ sandboxId: 'my-sandbox', sessionId: 'development' });
window.addEventListener('resize', () => fitAddon.fit());完整的 addon API,请参阅 终端 API 参考。
如果你正在构建自定义终端 UI,或运行在没有 xterm.js 的环境中,可直接通过 WebSocket 连接。协议使用二进制帧传输终端数据,使用 JSON 文本帧传输控制消息。
const ws = new WebSocket("wss://example.com/ws/terminal?id=my-sandbox");
ws.binaryType = "arraybuffer";
const decoder = new TextDecoder();
const encoder = new TextEncoder();
ws.addEventListener("message", (event) => {
if (event.data instanceof ArrayBuffer) {
// Terminal output (binary) — includes ANSI escape sequences
const text = decoder.decode(event.data);
appendToDisplay(text);
return;
}
// Control message (JSON text)
const msg = JSON.parse(event.data);
switch (msg.type) {
case "ready":
// Terminal is accepting input — send initial resize
ws.send(JSON.stringify({ type: "resize", cols: 80, rows: 24 }));
break;
case "exit":
console.log(`Shell exited: code ${msg.code}`);
break;
case "error":
console.error("Terminal error:", msg.message);
break;
}
});
// Send keystrokes as binary
function sendInput(text) {
if (ws.readyState === WebSocket.OPEN) {
ws.send(encoder.encode(text));
}
}const ws = new WebSocket('wss://example.com/ws/terminal?id=my-sandbox');
ws.binaryType = 'arraybuffer';
const decoder = new TextDecoder();
const encoder = new TextEncoder();
ws.addEventListener('message', (event) => {
if (event.data instanceof ArrayBuffer) {
// Terminal output (binary) — includes ANSI escape sequences
const text = decoder.decode(event.data);
appendToDisplay(text);
return;
}
// Control message (JSON text)
const msg = JSON.parse(event.data);
switch (msg.type) {
case 'ready':
// Terminal is accepting input — send initial resize
ws.send(JSON.stringify({ type: 'resize', cols: 80, rows: 24 }));
break;
case 'exit':
console.log(`Shell exited: code ${msg.code}`);
break;
case 'error':
console.error('Terminal error:', msg.message);
break;
}
});
// Send keystrokes as binary
function sendInput(text: string): void {
if (ws.readyState === WebSocket.OPEN) {
ws.send(encoder.encode(text));
}
}关键协议细节:
- 连接前将
binaryType设为arraybuffer。 - 来自先前连接的缓冲输出会在
ready消息之前以二进制帧到达。 - 将按键作为二进制(UTF-8)发送。将控制消息(
resize)作为 JSON 文本发送。 - 客户端断开时 PTY 保持存活。重新连接会回放缓冲输出。
完整协议规范请参阅 API 参考中的 WebSocket 协议部分。
- 始终使用 FitAddon — 否则终端尺寸与容器不匹配,文本会错误换行。
- 处理 resize 事件 — 在窗口调整大小时调用
fitAddon.fit(),使终端与 PTY 保持同步。 - 卸载时清理 — 从页面移除终端时调用
addon.disconnect()。 - 将终端限定到用户沙箱 — 在同一工作区中为多个终端上下文使用会话。为不同用户使用不同沙箱。