サーバーレスに置いた MCP サーバーで、listen ストリームが張り直され続けていました

# repro.py — 固定タイムアウトで黙るサーバーと、それに再購読するクライアント
import socket, threading, time, json
 
SILENT_AFTER = 1.0        # 実機の固定タイムアウトを縮めた相似値
open_conns = 0
lock = threading.Lock()
samples = []
 
def server(port, stop):
    s = socket.socket()
    s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
    s.bind(("127.0.0.1", port)); s.listen(128); s.settimeout(0.2)
 
    def handle(c):
        global open_conns
        with lock:
            open_conns += 1
        try:
            c.recv(1024)
            c.sendall(b"HTTP/1.1 200 OK\r\n"
                      b"Content-Type: text/event-stream\r\n\r\n: open\n\n")
            time.sleep(SILENT_AFTER)      # ここから無言。FIN は送らない
            while not stop.is_set():      # クライアントが閉じるまで保持し続ける
                try:
                    c.settimeout(0.2)
                    if c.recv(1) == b"":
                        break
                except socket.timeout:
                    continue
                except Exception:
                    break
        finally:
            with lock:
                open_conns -= 1
            c.close()
 
    while not stop.is_set():
        try:
            c, _ = s.accept()
        except socket.timeout:
            continue
        threading.Thread(target=handle, args=(c,), daemon=True).start()
    s.close()
 
def client(port, stop, close_old):
    socks = []
    while not stop.is_set():
        try:
            c = socket.create_connection(("127.0.0.1", port), timeout=1)
            c.sendall(b"GET /subscriptions/listen HTTP/1.1\r\nHost: x\r\n\r\n")
            c.settimeout(1.2)             # 無音が続いたら切れたとみなす
            socks.append(c)
            while True:
                if not c.recv(1024):
                    break
        except socket.timeout:
            if close_old:                 # 修正版: 古い購読を畳んでから張り直す
                for s0 in socks:
                    s0.close()
                socks = []
                time.sleep(0.5)           # バックオフ
            # close_old=False は古い接続を放置したまま次を張る
        except Exception:
            time.sleep(0.2)

claude --version
claude mcp list          # 接続先と現在の状態を確認

# 自前サーバーのアクセスログから listen だけを抜き、分ごとの本数を数える
awk '$7 ~ /subscriptions\/listen/ {print substr($4, 2, 17)}' access.log \
  | sort | uniq -c | tail -30

// Cloudflare Workers 想定の擬似コード
const streams = new Map<string, WritableStreamDefaultWriter>();
 
async function onListen(sessionId: string, writer: WritableStreamDefaultWriter) {
  const prev = streams.get(sessionId);
  if (prev) {
    // 同一セッションの古い購読は、新しいものを受ける前に必ず閉じる
    try { await prev.close(); } catch { /* 既に閉じている場合は無視 */ }
  }
  streams.set(sessionId, writer);
}

const MAX_HOLD_MS = 50_000;   // プラットフォーム上限より手前で自分から閉じる
const RETRY_MS    = 3_000;    // 次の接続までクライアントに待ってもらう
 
await writer.write(encoder.encode(`retry: ${RETRY_MS}\n\n`));
setTimeout(() => writer.close(), MAX_HOLD_MS);

setInterval(() => writer.write(encoder.encode(": keepalive\n\n")), 15_000);