DEV Community
·
使用Node.js原生WebSocket和TypeScript实现Coinbase实时Ticker数据流
💡
原文英文，约1100词，阅读约需4分钟。
📝
内容提要
Coinbase提供WebSocket数据流，用户可实时获取BTC-USD、ETH-USD和BNB-USD的市场数据。通过Node.js和TypeScript，用户可以订阅ticker频道，处理实时价格和成交量，并实现错误处理和自动重连。教程涵盖连接建立、订阅消息发送及优雅关闭连接的步骤。
🎯
关键要点
-
Coinbase提供WebSocket数据流，用户可实时获取BTC-USD、ETH-USD和BNB-USD的市场数据。
-
用户需发送JSON格式的订阅消息以订阅ticker频道，获取实时价格、成交量等信息。
-
教程涵盖了连接建立、发送订阅消息和优雅关闭连接的步骤。
-
使用Node.js的内置WebSocket API和TypeScript，无需外部库。
-
实现代码包括连接Coinbase、发送订阅消息、处理消息和错误、自动重连等功能。
-
在连接建立后，服务器会发送包含市场状态的消息。
-
支持动态订阅管理，用户可以在运行时添加或移除订阅。
-
教程提供了优雅关闭连接的机制，确保在进程终止时清理资源。
❓
延伸问答
如何使用Node.js和TypeScript连接Coinbase的WebSocket数据流？
使用Node.js的内置WebSocket API，连接到wss://ws-feed.pro.coinbase.com，并发送JSON格式的订阅消息。
Coinbase的WebSocket数据流支持哪些市场数据？
支持BTC-USD、ETH-USD和BNB-USD的实时价格、成交量等市场数据。
如何处理WebSocket连接中的错误和重连？
在onerror和onclose事件中管理错误，并在非正常关闭时设置5秒后重连。
如何优雅地关闭WebSocket连接？
在进程终止时，发送取消订阅消息并正常关闭连接，确保资源清理。
如何动态管理WebSocket的订阅？
可以在运行时发送JSON消息来添加或移除订阅，而无需重新打开连接。
Coinbase WebSocket数据流的消息格式是什么？
消息格式包含类型、产品ID、价格、24小时开盘价、成交量等字段。
🏷️
标签
➡️
