函数柯里化在 websocket 消息订阅中固定频道，本质是把“频道名”作为预设参数提前绑定，生成专用于该频道的订阅函数，后续调用只需传入回调，无需重复写 topic 字符串，既减少出错又提升复用性。
函数柯里化在 WebSocket 消息订阅中固定频道，本质是把“频道名”作为预设参数提前绑定，生成一个专用于该频道的订阅函数，后续调用只需传入回调，无需重复写 topic 字符串。这既减少出错，又提升复用性。
用柯里化封装 subscribe 方法
原生 WebSocket 不支持频道概念，需靠自定义协议实现订阅。假设服务端约定消息格式为 { type: 'subscribe', topic: 'chat' }，客户端每次调用都要手动拼 topic ——容易拼错、难维护。用柯里化可把 topic 提前固化：
- 写一个高阶函数
createSubscriber(ws)，返回能生成频道专属订阅器的工厂函数 - 再用柯里化构造
subscribeTo(topic)，它返回一个只接受回调的函数：(callback) => { ... } - 实际使用时：
const onChat = subscribeTo('chat'); onChat(handleNewMsg);
结合闭包记忆频道与连接状态
柯里化的真正优势在于闭包：它让 topic 和底层 WebSocket 实例（ws）都被封闭在作用域内，不污染全局，也不依赖外部变量。例如：
function subscribeTo(ws, topic) { return function(callback) { ws.send(JSON.stringify({ type: 'subscribe', topic })); ws.addEventListener('message', (e) => { const data = JSON.parse(e.data); if (data.topic === topic && data.type === 'message') callback(data.payload); }); }; }- 调用
const subChat = subscribeTo(ws, 'chat');后，subChat已经“记住”了 ws 和 'chat'，后续只管传回调 - 多个频道可并行存在：
const subOrder = subscribeTo(ws, 'order');，彼此隔离无干扰
配合发布订阅总线统一管理
若项目已封装 PubSubBus 类（如基于 WebSocket 的简易总线），柯里化可进一步简化业务层调用：
- 在总线实例上扩展方法：
bus.subscribeTo = (topic) => (cb) => bus.subscribe(topic, cb); - 这样就能写出更简洁的订阅逻辑：
bus.subscribeTo('notification')(showToast); - 还能链式复用：const notify = bus.subscribeTo('notification'); notify(logEvent); notify(showBadge);
注意 this 绑定与执行时机
柯里化函数若内部用到 this（比如调用 this.ws.send），需确保上下文正确：
- 避免直接返回箭头函数（无
this绑定能力），优先用普通函数或显式.bind() - 不要在柯里化过程中触发实际发送，应延迟到最终回调传入时才执行
send，否则频道未就绪就发了 subscribe 指令 - 若需支持占位符或异步初始化（如等待连接建立），柯里化函数应返回 Promise 或加入状态检查，而非立即执行
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
