WebSocket API

概述

ChainStream DEX WebSocket API 提供实时数据订阅服务，支持以下数据类型：

K线数据 (Candles)
代币相关 (Token Series)
交易相关 (Trade Series)
钱包相关 (Wallet Series)
盈亏相关 (PnL Series)

基础 URL

wss://realtime-dex.chainstream.io/connection/websocket

快速开始

1. 建立连接

首先需要创建 WebSocket 连接并进行认证：

const ws = new WebSocket("wss://realtime-dex.chainstream.io/connection/websocket");

ws.onopen = () => {
  // 发送认证消息
  ws.send(JSON.stringify({
    type: "auth",
    token: "YOUR_ACCESS_TOKEN"
  }));
};

2. 订阅数据

选择需要的数据类型进行订阅：

// 订阅K线数据示例
ws.send(JSON.stringify({
  type: "subscribe",
  channel: "dex-candle:sol_6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN_1m"
}));

3. 处理数据

ws.onmessage = (event) => {
  const data = JSON.parse(event.data);
  console.log('收到数据:', data);
};

数据订阅

K线数据

实时获取代币价格走势的K线图数据。 订阅格式

dex-candle:{chain}_{tokenAddress}_{resolution}

参数说明

chain

string

required

区块链名称，例如：sol

tokenAddress

string

required

代币合约地址，例如：6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN

resolution

string

required

K线周期，支持：1m, 5m, 15m, 1h, 4h, 1d

响应数据格式

WebSocket API 返回简短字段名以优化传输效率，SDK 返回完整字段名以提高代码可读性。

{
  "o": number,    // 开盘价
  "c": number,    // 收盘价
  "h": number,    // 最高价
  "l": number,    // 最低价
  "v": number,    // 交易量
  "r": string,    // 周期
  "t": number     // 时间戳
}

代币统计

实时获取代币的市场统计数据。 订阅格式

dex-token-stats:{chain}_{tokenAddress}

参数说明

chain

string

required

区块链名称，例如：sol

tokenAddress

string

required

代币合约地址，例如：6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN

响应数据格式

WebSocket API 返回简短字段名以优化传输效率，SDK 返回完整字段名以提高代码可读性。

{
  "a": string,      // 代币地址
  "t": number,      // 时间戳
  "b1m": number,    // 1分钟内买入次数
  "s1m": number,    // 1分钟内卖出次数
  "be1m": number,   // 1分钟内买入人数
  "se1m": number,   // 1分钟内卖出人数
  "bviu1m": number, // 1分钟内买入美元金额
  "sviu1m": number, // 1分钟内卖出美元金额
  "p1m": number,    // 1分钟价格
  "b5m": number,    // 5分钟内买入次数
  "s5m": number,    // 5分钟内卖出次数
  "be5m": number,   // 5分钟内买入人数
  "se5m": number,   // 5分钟内卖出人数
  "bviu5m": number, // 5分钟内买入美元金额
  "sviu5m": number, // 5分钟内卖出美元金额
  "p5m": number,    // 5分钟价格
  "b15m": number,   // 15分钟内买入次数
  "s15m": number,   // 15分钟内卖出次数
  "be15m": number,  // 15分钟内买入人数
  "se15m": number,  // 15分钟内卖出人数
  "bviu15m": number,// 15分钟内买入美元金额
  "sviu15m": number,// 15分钟内卖出美元金额
  "p15m": number,   // 15分钟价格
  "b30m": number,   // 30分钟内买入次数
  "s30m": number,   // 30分钟内卖出次数
  "be30m": number,  // 30分钟内买入人数
  "se30m": number,  // 30分钟内卖出人数
  "bviu30m": number,// 30分钟内买入美元金额
  "sviu30m": number,// 30分钟内卖出美元金额
  "p30m": number,   // 30分钟价格
  "b1h": number,    // 1小时内买入次数
  "s1h": number,    // 1小时内卖出次数
  "be1h": number,   // 1小时内买入人数
  "se1h": number,   // 1小时内卖出人数
  "bviu1h": number, // 1小时内买入美元金额
  "sviu1h": number, // 1小时内卖出美元金额
  "p1h": number,    // 1小时价格
  "b4h": number,    // 4小时内买入次数
  "s4h": number,    // 4小时内卖出次数
  "be4h": number,   // 4小时内买入人数
  "se4h": number,   // 4小时内卖出人数
  "bviu4h": number, // 4小时内买入美元金额
  "sviu4h": number, // 4小时内卖出美元金额
  "p4h": number,    // 4小时价格
  "b24h": number,   // 24小时内买入次数
  "s24h": number,   // 24小时内卖出次数
  "be24h": number,  // 24小时内买入人数
  "se24h": number,  // 24小时内卖出人数
  "bviu24h": number,// 24小时内买入美元金额
  "sviu24h": number,// 24小时内卖出美元金额
  "p24h": number,   // 24小时价格
  "p": number       // 当前价格
}

新币统计

实时获取新上线代币的市场统计数据。 订阅格式

dex-ranking-new-tokens-stats:{chain}

参数说明

chain

string

required

区块链名称，例如：sol

响应数据格式

WebSocket API 返回简短字段名以优化传输效率，SDK 返回完整字段名以提高代码可读性。

{
  "a": string,      // 代币地址
  "t": number,      // 时间戳
  "b1m": number,    // 1分钟内买入次数
  "s1m": number,    // 1分钟内卖出次数
  "be1m": number,   // 1分钟内买入人数
  "se1m": number,   // 1分钟内卖出人数
  "bviu1m": number, // 1分钟内买入美元金额
  "sviu1m": number, // 1分钟内卖出美元金额
  "p1m": number,    // 1分钟价格
  "b5m": number,    // 5分钟内买入次数
  "s5m": number,    // 5分钟内卖出次数
  "be5m": number,   // 5分钟内买入人数
  "se5m": number,   // 5分钟内卖出人数
  "bviu5m": number, // 5分钟内买入美元金额
  "sviu5m": number, // 5分钟内卖出美元金额
  "p5m": number,    // 5分钟价格
  "b15m": number,   // 15分钟内买入次数
  "s15m": number,   // 15分钟内卖出次数
  "be15m": number,  // 15分钟内买入人数
  "se15m": number,  // 15分钟内卖出人数
  "bviu15m": number,// 15分钟内买入美元金额
  "sviu15m": number,// 15分钟内卖出美元金额
  "p15m": number,   // 15分钟价格
  "b30m": number,   // 30分钟内买入次数
  "s30m": number,   // 30分钟内卖出次数
  "be30m": number,  // 30分钟内买入人数
  "se30m": number,  // 30分钟内卖出人数
  "bviu30m": number,// 30分钟内买入美元金额
  "sviu30m": number,// 30分钟内卖出美元金额
  "p30m": number,   // 30分钟价格
  "b1h": number,    // 1小时内买入次数
  "s1h": number,    // 1小时内卖出次数
  "be1h": number,   // 1小时内买入人数
  "se1h": number,   // 1小时内卖出人数
  "bviu1h": number, // 1小时内买入美元金额
  "sviu1h": number, // 1小时内卖出美元金额
  "p1h": number,    // 1小时价格
  "b4h": number,    // 4小时内买入次数
  "s4h": number,    // 4小时内卖出次数
  "be4h": number,   // 4小时内买入人数
  "se4h": number,   // 4小时内卖出人数
  "bviu4h": number, // 4小时内买入美元金额
  "sviu4h": number, // 4小时内卖出美元金额
  "p4h": number,    // 4小时价格
  "b24h": number,   // 24小时内买入次数
  "s24h": number,   // 24小时内卖出次数
  "be24h": number,  // 24小时内买入人数
  "se24h": number,  // 24小时内卖出人数
  "bviu24h": number,// 24小时内买入美元金额
  "sviu24h": number,// 24小时内卖出美元金额
  "p24h": number,   // 24小时价格
  "p": number       // 当前价格
}

新代币元数据

获取新上市代币的实时元数据信息。 订阅格式

dex-new-tokens-metadata:{chain}

参数说明

chain

string

required

区块链名称，例如：sol

响应数据格式

WebSocket API 返回简短字段名以优化传输效率，SDK 返回完整字段名以提高代码可读性。

{
  "a": string,      // 代币地址
  "n": string,      // 名称
  "s": string,      // 符号
  "iu": string,     // 图片URL
  "de": string,     // 描述
  "sm": {           // 社交媒体
    "tw": string,   // Twitter
    "tg": string,   // Telegram
    "w": string,    // 网站
    "tt": string,   // TikTok
    "dc": string,   // Discord
    "fb": string,   // Facebook
    "gh": string,   // GitHub
    "ig": string,   // Instagram
    "li": string,   // LinkedIn
    "md": string,   // Medium
    "rd": string,   // Reddit
    "yt": string,   // YouTube
    "bb": string    // BitBucket
  },
  "cts": number     // 创建时间戳（毫秒）
}

新代币

获取新创建代币的实时信息。 订阅格式

dex-new-tokens:{chain}

参数说明

chain

string

required

区块链名称，例如：sol

响应数据格式

WebSocket API 返回简短字段名以优化传输效率，SDK 返回完整字段名以提高代码可读性。

{
  "a": string,      // 代币地址
  "n": string,      // 名称
  "s": string,      // 符号
  "de": string,     // 描述
  "cts": number     // 创建时间戳（毫秒）
}

代币持有者统计

实时获取代币持有者统计信息。 订阅格式

dex-token-general-stat-num:{chain}_{tokenAddress}

参数说明

chain

string

required

区块链名称，例如：sol

tokenAddress

string

required

代币合约地址，例如：6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN

响应数据格式

WebSocket API 返回简短字段名以优化传输效率，SDK 返回完整字段名以提高代码可读性。

{
  "a": string,    // 代币地址
  "v": number,    // 持有者数量
  "ts": number    // 时间戳
}

代币供应量

实时获取代币的供应量和市值信息。 订阅格式

dex-token-supply:{chain}_{tokenAddress}

参数说明

chain

string

required

区块链名称，例如：sol

tokenAddress

string

required

代币合约地址，例如：6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN

响应数据格式

WebSocket API 返回简短字段名以优化传输效率，SDK 返回完整字段名以提高代码可读性。

{
  "a": string,    // 代币地址
  "s": number,    // 供应量
  "mc": number,   // 市值（美元）
  "ts": number    // 时间戳
}

代币流动性

实时获取代币的流动性统计信息。 订阅格式

dex-token-general-stat-num:{chain}_{tokenAddress}

参数说明

chain

string

required

区块链名称，例如：sol

tokenAddress

string

required

代币合约地址

响应数据格式

WebSocket API 返回简短字段名以优化传输效率，SDK 返回完整字段名以提高代码可读性。

{
  "a": string,    // 代币地址
  "t": string,    // 指标类型
  "v": number,    // 数值
  "ts": number    // 时间戳
}

代币交易

实时获取代币的交易事件。 订阅格式

dex-trades:{chain}_{tokenAddress}

参数说明

chain

string

required

区块链名称，例如：sol

tokenAddress

string

required

代币合约地址，例如：6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN

响应数据格式

WebSocket API 返回简短字段名以优化传输效率，SDK 返回完整字段名以提高代码可读性。

{
  "bwa": string,     // maker地址
  "ba": number,      // 基础代币数量
  "sa": number,      // 报价代币数量
  "swa": string,     // 报价代币地址
  "bais": number,    // 美元金额
  "t": number,       // 时间戳
  "k": string,       // 事件类型
  "h": string,       // 交易哈希
  "a": string        // 代币地址
}

钱包交易

实时获取指定钱包的交易事件。 订阅格式

dex-wallet-trade:{chain}_{walletAddress}

参数说明

chain

string

required

区块链名称，例如：sol

walletAddress

string

required

钱包地址，例如：GDekof7TtgeBKJtoVpkvzPin5mvhxSDyoUY2c1FK1T3i

响应数据格式

WebSocket API 返回简短字段名以优化传输效率，SDK 返回完整字段名以提高代码可读性。

{
  "bwa": string,     // maker地址
  "ba": number,      // 基础代币数量
  "sa": number,      // 报价代币数量
  "swa": string,     // 报价代币地址
  "bais": number,    // 美元金额
  "t": number,       // 时间戳
  "k": string,       // 事件类型
  "h": string,       // 交易哈希
  "a": string        // 代币地址
}

钱包余额

实时获取钱包的余额信息。 订阅格式

dex-wallet-balance:{chain}_{walletAddress}

参数说明

chain

string

required

区块链名称，例如：sol

walletAddress

string

required

钱包地址，例如：HN7cABqLq46Es1jh92dQQisAq662SmxELLLsHHe4YWrH

响应数据格式

WebSocket API 返回简短字段名以优化传输效率，SDK 返回完整字段名以提高代码可读性。

{
  "a": string,      // 钱包地址
  "ta": string,     // 代币地址
  "tpiu": number,   // 代币美元价格
  "t": number,      // 时间戳
}

钱包盈亏数据

实时获取钱包的盈亏(PnL)统计数据。 订阅格式

dex-wallet-pnl-list:{chain}_{walletAddress}

参数说明

chain

string

required

区块链名称，例如：sol

walletAddress

string

required

钱包地址

响应数据格式

WebSocket API 返回简短字段名以优化传输效率，SDK 返回完整字段名以提高代码可读性。

{
  "a": string,     // 钱包地址
  "bs": number,    // 买入次数
  "ba": number,    // 买入数量
  "baiu": number,  // 买入美元金额
  "abpiu": number, // 平均买入美元价格
  "sa": number,    // 卖出数量
  "saiu": number,  // 卖出美元金额
  "ss": number,    // 卖出次数
  "ws": number,    // 盈利次数
  "wr": number,    // 胜率
  "piu": number,   // 美元盈亏
  "apiu": number,  // 平均美元盈亏
  "pr": number,    // 盈亏比率
  "pd": number,    // 盈利天数
  "ld": number,    // 亏损天数
  "ts": number,    // 交易代币数
  "r": string      // 统计周期
}

DEX 资金池余额

实时获取 DEX 资金池的余额信息。 订阅格式

dex-pool-balance:{chain}_{poolAddress}

参数说明

chain

string

required

区块链名称，例如：sol

poolAddress

string

required

资金池地址

响应数据格式

WebSocket API 返回简短字段名以优化传输效率，SDK 返回完整字段名以提高代码可读性。

{
  "a": string,     // 资金池地址
  "taa": string,   // 代币A地址
  "taliu": number, // 代币A流动性（美元）
  "tba": string,   // 代币B地址
  "tbliu": number  // 代币B流动性（美元）
}

使用示例

const streamApi = new StreamApi(context);

// 订阅K线数据
streamApi.subscribeTokenCandles({
  chain: "sol",
  tokenAddress: "6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN",
  resolution: "1m",
  callback: (data) => {
    console.log("K线数据:", data);
  }
});

// 订阅钱包余额
streamApi.subscribeWalletBalance({
  chain: "sol",
  walletAddress: "YOUR_WALLET_ADDRESS",
  callback: (data) => {
    console.log("钱包余额:", data);
  }
});

重连策略

推荐使用指数退避算法进行重连：

function reconnect(attempt) {
  const delay = Math.min(1000 * Math.pow(2, attempt), 10000);
  setTimeout(() => {
    connect();
  }, delay);
}

使用限制

限制项	限制值	说明
最大订阅数	100个/连接	超出将被拒绝
消息大小	100KB	超出将被截断
心跳间隔	30秒	需定期发送

最佳实践

连接管理
- 保持单个WebSocket连接
- 实现自动重连机制
- 定期发送心跳
错误处理
- 实现完整的错误处理流程
- 记录详细的错误日志
- 使用指数退避重连
性能优化
- 合理控制订阅数量
- 实现消息队列机制
- 及时清理无用订阅

完整示例

class DexWebSocket {
  private ws: WebSocket;
  private reconnectAttempts = 0;
  private maxReconnectAttempts = 5;
  private messageHandlers = new Map<string, Set<(data: any) => void>>();

  constructor(
    private url: string,
    private accessToken: string
  ) {
    this.connect();
  }

  private connect() {
    this.ws = new WebSocket(this.url);
    
    this.ws.onopen = () => {
      // 发送认证
      this.authenticate();
      // 重新订阅
      this.resubscribe();
    };

    this.ws.onmessage = (event) => {
      this.handleMessage(JSON.parse(event.data));
    };

    this.ws.onclose = () => {
      this.reconnect();
    };
  }

  private authenticate() {
    this.send({
      type: "auth",
      token: this.accessToken
    });
  }

  public subscribe(channel: string, handler: (data: any) => void) {
    // 订阅实现
  }

  public unsubscribe(channel: string) {
    // 取消订阅实现
  }
}

API 文档

Dex Api

Dex SDK

概述

快速开始

1. 建立连接

2. 订阅数据

3. 处理数据

数据订阅

K线数据

代币统计

热门代币统计

新币统计

新代币元数据

新代币

代币持有者统计

代币供应量

代币流动性

代币交易

钱包交易

钱包余额

钱包盈亏数据

DEX 资金池余额

使用示例

重连策略

使用限制

最佳实践

完整示例

API 文档

Dex Api

Dex SDK

​概述

​快速开始

​1. 建立连接

​2. 订阅数据

​3. 处理数据

​数据订阅

​K线数据

​代币统计

​热门代币统计

​新币统计

​新代币元数据

​新代币

​代币持有者统计

​代币供应量

​代币流动性

​代币交易

​钱包交易

​钱包余额

​钱包盈亏数据

​DEX 资金池余额

​使用示例

​重连策略

​使用限制

​最佳实践

​完整示例

概述

快速开始

1. 建立连接

2. 订阅数据

3. 处理数据

数据订阅

K线数据

代币统计

热门代币统计

新币统计

新代币元数据

新代币

代币持有者统计

代币供应量

代币流动性

代币交易

钱包交易

钱包余额

钱包盈亏数据

DEX 资金池余额

使用示例

重连策略

使用限制

最佳实践

完整示例