CC源码剖析 #12 · 跨进程通信：RemoteBridge 与远程模式

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13

interface RemoteBridgeCore {
  // 连接管理
  connect(sessionId: string): Promise<void>
  disconnect(): Promise<void>

  // 消息传递
  sendMessage(msg: SDKMessage): void
  onMessage(handler: (msg: SDKMessage) => void): void

  // 状态同步
  syncState(): Promise<State>
  onStateChange(handler: (state: State) => void): void
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10

// 支持多种传输方式
type Transport =
  | 'websocket'   // WebSocket 连接
  | 'ssh'         // SSH 隧道
  | 'http'        // HTTP 流（stream-json）

// 传输选择逻辑：
// 1. 优先 WebSocket（低延迟）
// 2. SSH（企业防火墙环境）
// 3. HTTP（最后兜底）

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16

interface SSHSession {
  sessionId: string
  host: string
  port: number
  user: string
  auth: SSHAuth  // password | key | agent
  process: ChildProcess
}

// 创建 SSH 会话
async function createSSHSession(config: SSHConfig): Promise<SSHSession> {
  // 1. 建立 SSH 连接
  // 2. 启动远程 CLI 进程
  // 3. 建立双向通信
  // 4. 返回会话句柄
}

1
2
3
4

type SSHAuth =
  | { type: 'password'; password: string }
  | { type: 'key'; keyPath: string; passphrase?: string }
  | { type: 'agent' }  // SSH Agent 转发

1
2
3
4

// 本地端口转发：远程 CLI 的端口映射到本地
// 使得 IDE 可以像连接本地一样连接远程

// Agent forwarding：让远程 Agent 感知本地 IDE 上下文

 1
 2
 3
 4
 5
 6
 7
 8
 9
10

interface WebSocketTransportConfig {
  url: string
  headers?: Record<string, string>
  reconnect?: boolean
  heartbeatInterval?: number
}

// 心跳保活
// 自动重连
// 消息队列（离线缓冲）

 1
 2
 3
 4
 5
 6
 7
 8
 9
10

// 使用 JSON-RPC 2.0 格式
interface JSONRPCMessage {
  jsonrpc: '2.0'
  id?: string | number
  method: string
  params?: unknown
}

// 支持批处理
// 双向通信

1
2
3
4
5
6
7
8

interface RemoteSession {
  sessionId: string
  remoteId: string
  status: 'connecting' | 'connected' | 'disconnected' | 'error'
  startTime: number
  lastActivity: number
  transport: Transport
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10

// 断线后尝试恢复
// 恢复时重建状态
// 消息不丢失

async function resumeRemoteSession(sessionId: string): Promise<void> {
  // 1. 重连传输层
  // 2. 请求远程状态
  // 3. 同步本地状态
  // 4. 恢复消息流
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11

// IDE → Bridge → Remote CLI
// 用于：
// - 用户输入
// - 文件变更通知
// - IDE 上下文

interface InboundMessage {
  type: 'user_message' | 'ide_context' | 'file_change'
  payload: unknown
  timestamp: number
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11

// Remote CLI → Bridge → IDE
// 用于：
// - Agent 输出
// - 工具执行结果
// - 状态更新

interface OutboundMessage {
  type: 'assistant_message' | 'tool_result' | 'status_update'
  payload: unknown
  timestamp: number
}

1
2
3
4
5
6
7
8
9

// 当连接断开时，消息缓冲到队列
// 重连后按序发送
// 防止消息丢失

class MessageQueue {
  enqueue(msg: Message): void
  flush(): Message[]
  clear(): void
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12

// 不通过 Bridge，直接连接远程 CLI
// 适用于信任的网络环境

interface DirectConnectConfig {
  host: string
  port: number
  authToken: string
  sessionId: string
}

// 使用流式 HTTP（stream-json）
// 双向通信

1
2
3

// Token 认证
// Token 在连接时交换
// 支持过期和刷新

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13

// 定期同步状态
// 状态包括：
// - 消息历史
// - 文件系统状态
// - 工具状态

interface StateSnapshot {
  sessionId: string
  messages: Message[]
  files: FileState[]
  tools: Tool[]
  timestamp: number
}

1
2
3
4
5
6
7
8

// 不传输完整状态
// 只传输差异（diff）

interface StateDiff {
  added: Message[]
  modified: FileState[]
  removed: string[]  // file paths
}

1
2
3
4
5
6

// 大消息压缩传输
// 支持：
// - gzip
// - brotli

compressMessage(msg: Message, threshold: number): CompressedMessage

1
2
3

// 避免大消息缓冲
// 流式处理
// 边收边处理

1
2
3
4
5
6
7

// 复用连接
// 减少建立连接的开销

class ConnectionPool {
  acquire(): Connection
  release(conn: Connection): void
}

1
2
3

// 所有传输使用 TLS
// SSH 隧道加密
// WebSocket over WSS

1
2
3

// Bearer Token
// OAuth 2.0（企业环境）
// SSH Key

1
2
3

// 企业网络隔离
// VPC 配置
// 防火墙规则