Developers: TCP socket pattern…

# Cloudflare Workers TCP Socket 连接 Redis 示例

一、前提说明

• Workers 的 connect() API 来自 cloudflare:sockets 模块，仅支持出站 TCP。
• Workers 不支持监听入站 TCP，只能作为客户端发起连接。
• Redis RESP 协议基于行分隔（\r\n），可用其处理“粘包/半包”。

二、核心代码

```javascript

import { connect } from "cloudflare:sockets";

class RedisParser {

constructor(socket) {

this.socket = socket;

this.buffer = new Uint8Array(0);

this.waiter = null; // { resolve, reject }

socket.readable.pipeTo(new WritableStream({

write: (chunk) => this.onData(chunk),

})).catch(() => this.rejectWaiter(new Error("connection closed")));

}

onData(chunk) {

// 拼接到缓冲区，解决粘包

const merged = new Uint8Array(this.buffer.length + chunk.length);

merged.set(this.buffer);

merged.set(chunk, this.buffer.length);

this.buffer = merged;

// 尝试解析完整响应（以 \r\n 结尾，简化处理单行回复）

const text = new TextDecoder().decode(this.buffer);

const idx = text.indexOf("\r\n");

if (idx >= 0) {

const line = text.slice(0, idx);

// 消费已解析部分（简化：假设一行即一个完整响应）

this.buffer = new TextEncoder().encode(text.slice(idx + 2));

this.resolveWaiter(line);

}

}

resolveWaiter(line) {

if (this.waiter) {

const w = this.waiter;

this.waiter = null;

if (line.startsWith("-")) w.reject(new Error(line));

else w.resolve(line);

}

}

rejectWaiter(e) {

if (this.waiter) { const w = this.waiter; this.waiter = null; w.reject(e); }

}

command(...args) {

// RESP 协议：*N\r\n $len\r\n arg\r\n ...

let payload = *${args.length}\r\n;

for (const a of args) {

const s = String(a);