WebSocket API

概述

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

K线数据 (Candles)
代币相关 (Token Series)
钱包相关 (Wallet Series)
排名相关 (Ranking Series)
交易相关 (Trade Series)
流动池相关 (DexPool 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线数据

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

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

参数说明

chain

string

required

区块链名称，例如：sol

tokenAddress

string

required

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

resolution

string

required

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

filter

string

可选的过滤条件，使用Google Common Expression Language (CEL)表达式语言语法。例如：volume > 1000

响应数据格式

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

filter

string

可选的过滤条件，使用Google Common Expression Language (CEL)表达式语言语法。例如：price > 0.01

响应数据格式

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分钟价格
  "oiu1m": number,  // 1分钟内开盘价格
  "ciu1m": number,  // 1分钟内收盘价格
  "b5m": number,    // 5分钟内买入次数
  "s5m": number,    // 5分钟内卖出次数
  "be5m": number,   // 5分钟内买入人数
  "se5m": number,   // 5分钟内卖出人数
  "bviu5m": number, // 5分钟内买入美元金额
  "sviu5m": number, // 5分钟内卖出美元金额
  "p5m": number,    // 5分钟价格
  "oiu5m": number,  // 5分钟内开盘价格
  "ciu5m": number,  // 5分钟内收盘价格
  "b15m": number,   // 15分钟内买入次数
  "s15m": number,   // 15分钟内卖出次数
  "be15m": number,  // 15分钟内买入人数
  "se15m": number,  // 15分钟内卖出人数
  "bviu15m": number,// 15分钟内买入美元金额
  "sviu15m": number,// 15分钟内卖出美元金额
  "p15m": number,   // 15分钟价格
  "oiu15m": number, // 15分钟内开盘价格
  "ciu15m": number, // 15分钟内收盘价格
  "b30m": number,   // 30分钟内买入次数
  "s30m": number,   // 30分钟内卖出次数
  "be30m": number,  // 30分钟内买入人数
  "se30m": number,  // 30分钟内卖出人数
  "bviu30m": number,// 30分钟内买入美元金额
  "sviu30m": number,// 30分钟内卖出美元金额
  "p30m": number,   // 30分钟价格
  "oiu30m": number, // 30分钟内开盘价格
  "ciu30m": number, // 30分钟内收盘价格
  "b1h": number,    // 1小时内买入次数
  "s1h": number,    // 1小时内卖出次数
  "be1h": number,   // 1小时内买入人数
  "se1h": number,   // 1小时内卖出人数
  "bviu1h": number, // 1小时内买入美元金额
  "sviu1h": number, // 1小时内卖出美元金额
  "p1h": number,    // 1小时价格
  "oiu1h": number,  // 1小时内开盘价格
  "ciu1h": number,  // 1小时内收盘价格
  "b4h": number,    // 4小时内买入次数
  "s4h": number,    // 4小时内卖出次数
  "be4h": number,   // 4小时内买入人数
  "se4h": number,   // 4小时内卖出人数
  "bviu4h": number, // 4小时内买入美元金额
  "sviu4h": number, // 4小时内卖出美元金额
  "p4h": number,    // 4小时价格
  "oiu4h": number,  // 4小时内开盘价格
  "ciu4h": number,  // 4小时内收盘价格
  "b24h": number,   // 24小时内买入次数
  "s24h": number,   // 24小时内卖出次数
  "be24h": number,  // 24小时内买入人数
  "se24h": number,  // 24小时内卖出人数
  "bviu24h": number,// 24小时内买入美元金额
  "sviu24h": number,// 24小时内卖出美元金额
  "p24h": number,   // 24小时价格
  "oiu24h": number, // 24小时内开盘价格
  "ciu24h": number, // 24小时内收盘价格
  "p": number       // 当前价格
}

代币持有者统计

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

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

参数说明

chain

string

required

区块链名称，例如：sol

tokenAddress

string

required

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

filter

string

可选的过滤条件，使用Google Common Expression Language (CEL)表达式语言语法。例如：holders > 200

响应数据格式

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

{
  "a": string,      // 代币地址
  "h": number,      // 持有者数量
  "t100a": number,  // 前100名持有者持有总量
  "t10a": number,   // 前10名持有者持有总量
  "t100h": number,  // 前100名持有者数量
  "t10h": number,   // 前10名持有者数量
  "t100r": number,  // 前100名持有者持有比例
  "t10r": number,   // 前10名持有者持有比例
  "ch": number,     // 创建者持有者数量
  "ca": number,     // 创建者持有量
  "cr": number,     // 创建者持有比例
  "ts": number      // 时间戳
}

新代币元数据

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

dex-new-tokens-metadata:{chain}

参数说明

chain

string

required

区块链名称，例如：sol

filter

string

可选的过滤条件，使用Google Common Expression Language (CEL)表达式语言语法。例如：name == “USDC”

响应数据格式

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-token:{chain}

参数说明

chain

string

required

区块链名称，例如：sol

响应数据格式

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

{
  "a": string,      // 代币地址
  "n": string,      // 名称
  "s": string,      // 符号
  "dec": number,    // 小数位数
  "cts": number,    // 创建时间戳（毫秒）
  "lf": {           // 启动来源信息
    "pa": string,   // 程序地址
    "pf": string,   // 协议家族
    "pn": string    // 协议名称
  }
}

代币供应量

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

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

参数说明

chain

string

required

区块链名称，例如：sol

tokenAddress

string

required

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

filter

string

可选的过滤条件，使用Google Common Expression Language (CEL)表达式语言语法。例如：supply > 1000000

响应数据格式

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

代币合约地址

filter

string

可选的过滤条件，使用Google Common Expression Language (CEL)表达式语言语法。例如：value > 1000000

响应数据格式

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

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

排名

排名的代币统计数据

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

dex-ranking-token-stats-list:{chain}_{channelType}

参数说明

chain

string

required

区块链名称，例如：sol

channelType

string

required

频道类型，支持：new、trending、us_stocks、completed、graduated

响应数据格式

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分钟价格
    "oiu1m": number,  // 1分钟内开盘价格
    "ciu1m": number,  // 1分钟内收盘价格
    "b5m": number,    // 5分钟内买入次数
    "s5m": number,    // 5分钟内卖出次数
    "be5m": number,   // 5分钟内买入人数
    "se5m": number,   // 5分钟内卖出人数
    "bviu5m": number, // 5分钟内买入美元金额
    "sviu5m": number, // 5分钟内卖出美元金额
    "p5m": number,    // 5分钟价格
    "oiu5m": number,  // 5分钟内开盘价格
    "ciu5m": number,  // 5分钟内收盘价格
    "b15m": number,   // 15分钟内买入次数
    "s15m": number,   // 15分钟内卖出次数
    "be15m": number,  // 15分钟内买入人数
    "se15m": number,  // 15分钟内卖出人数
    "bviu15m": number,// 15分钟内买入美元金额
    "sviu15m": number,// 15分钟内卖出美元金额
    "p15m": number,   // 15分钟价格
    "oiu15m": number, // 15分钟内开盘价格
    "ciu15m": number, // 15分钟内收盘价格
    "b30m": number,   // 30分钟内买入次数
    "s30m": number,   // 30分钟内卖出次数
    "be30m": number,  // 30分钟内买入人数
    "se30m": number,  // 30分钟内卖出人数
    "bviu30m": number,// 30分钟内买入美元金额
    "sviu30m": number,// 30分钟内卖出美元金额
    "p30m": number,   // 30分钟价格
    "oiu30m": number, // 30分钟内开盘价格
    "ciu30m": number, // 30分钟内收盘价格
    "b1h": number,    // 1小时内买入次数
    "s1h": number,    // 1小时内卖出次数
    "be1h": number,   // 1小时内买入人数
    "se1h": number,   // 1小时内卖出人数
    "bviu1h": number, // 1小时内买入美元金额
    "sviu1h": number, // 1小时内卖出美元金额
    "p1h": number,    // 1小时价格
    "oiu1h": number,  // 1小时内开盘价格
    "ciu1h": number,  // 1小时内收盘价格
    "b4h": number,    // 4小时内买入次数
    "s4h": number,    // 4小时内卖出次数
    "be4h": number,   // 4小时内买入人数
    "se4h": number,   // 4小时内卖出人数
    "bviu4h": number, // 4小时内买入美元金额
    "sviu4h": number, // 4小时内卖出美元金额
    "p4h": number,    // 4小时价格
    "oiu4h": number,  // 4小时内开盘价格
    "ciu4h": number,  // 4小时内收盘价格
    "b24h": number,   // 24小时内买入次数
    "s24h": number,   // 24小时内卖出次数
    "be24h": number,  // 24小时内买入人数
    "se24h": number,  // 24小时内卖出人数
    "bviu24h": number,// 24小时内买入美元金额
    "sviu24h": number,// 24小时内卖出美元金额
    "p24h": number,   // 24小时价格
    "oiu24h": number, // 24小时内开盘价格
    "ciu24h": number, // 24小时内收盘价格
    "p": number       // 当前价格
  }
]

排名的代币持有者统计

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

dex-ranking-token-holding-list:{chain}_{channelType}

参数说明

chain

string

required

区块链名称，例如：sol

channelType

string

required

频道类型，支持：new、trending、us_stocks、completed、graduated

响应数据格式

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

[
  {
    "a": string,      // 代币地址
    "h": number,      // 持有者数量
    "t100a": number,  // 前100名持有者持有总量
    "t10a": number,   // 前10名持有者持有总量
    "t100h": number,  // 前100名持有者数量
    "t10h": number,   // 前10名持有者数量
    "t100r": number,  // 前100名持有者持有比例
    "t10r": number,   // 前10名持有者持有比例
    "ts": number      // 时间戳
  }
]

排名的代币供应量数据

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

dex-ranking-token-supply-list:{chain}_{channelType}

参数说明

chain

string

required

区块链名称，例如：sol

channelType

string

required

频道类型，支持：new、trending、us_stocks、completed、graduated

响应数据格式

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

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

排名的代币流动性数据

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

dex-ranking-token-general_stat_num-list:{chain}_{channelType}

参数说明

chain

string

required

区块链名称，例如：sol

channelType

string

required

频道类型，支持：new、trending、us_stocks、completed、graduated

响应数据格式

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

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

排名的代币列表

实时获取排名代币的完整信息列表，包括元数据、持有者统计、供应量和市场数据。 订阅格式

dex-ranking-list:{chain}_{ranking_type}
# 或者指定DEX
dex-ranking-list:{chain}_{ranking_type}_{dex}

参数说明

chain

string

required

区块链名称，例如：sol

ranking_type

string

required

排名类型，支持：new、trending、us_stocks、completed、graduated

dex

string

可选的DEX平台，支持：pump_fun、raydium_launchpad、meteora_dynamic_bounding_curve、bonk_fun、boop_fun、moonit_fun

响应数据格式

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

[
  {
    // TokenMetadata (t)
    "t": {
      "a": string,      // 代币地址
      "n": string,      // 名称
      "s": string,      // 符号
      "iu": string,     // 图片URL
      "de": string,     // 描述
      "dec": number,    // 小数位数
      "cts": number,    // 创建时间戳（毫秒）
      "lf": {           // 启动来源信息
        "pa": string,   // 程序地址
        "pf": string,   // 协议家族
        "pn": string    // 协议名称
      },
      "mt": {           // 迁移目标信息
        "pa": string,   // 程序地址
        "pf": string,   // 协议家族
        "pn": 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
      }
    },
    // TokenBondingCurve (bc)
    "bc": {
      "pr": number      // 进度比例
    },
    // TokenHolder (h)
    "h": {
      "a": string,      // 代币地址
      "h": number,      // 持有者数量
      "t100a": number,  // 前100名持有者持有总量
      "t10a": number,   // 前10名持有者持有总量
      "t100h": number,  // 前100名持有者数量
      "t10h": number,   // 前10名持有者数量
      "t100r": number,  // 前100名持有者持有比例
      "t10r": number,   // 前10名持有者持有比例
      "ts": number      // 时间戳
    },
    // TokenSupply (s)
    "s": {
      "a": string,    // 代币地址
      "s": number,    // 供应量
      "mc": number,   // 市值（美元）
      "ts": number    // 时间戳
    },
    // TokenStat (ts)
    "ts": {
      "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分钟价格
      "oiu1m": number,  // 1分钟内开盘价格
      "ciu1m": number,  // 1分钟内收盘价格
      "b5m": number,    // 5分钟内买入次数
      "s5m": number,    // 5分钟内卖出次数
      "be5m": number,   // 5分钟内买入人数
      "se5m": number,   // 5分钟内卖出人数
      "bviu5m": number, // 5分钟内买入美元金额
      "sviu5m": number, // 5分钟内卖出美元金额
      "p5m": number,    // 5分钟价格
      "oiu5m": number,  // 5分钟内开盘价格
      "ciu5m": number,  // 5分钟内收盘价格
      "b15m": number,   // 15分钟内买入次数
      "s15m": number,   // 15分钟内卖出次数
      "be15m": number,  // 15分钟内买入人数
      "se15m": number,  // 15分钟内卖出人数
      "bviu15m": number,// 15分钟内买入美元金额
      "sviu15m": number,// 15分钟内卖出美元金额
      "p15m": number,   // 15分钟价格
      "oiu15m": number, // 15分钟内开盘价格
      "ciu15m": number, // 15分钟内收盘价格
      "b30m": number,   // 30分钟内买入次数
      "s30m": number,   // 30分钟内卖出次数
      "be30m": number,  // 30分钟内买入人数
      "se30m": number,  // 30分钟内卖出人数
      "bviu30m": number,// 30分钟内买入美元金额
      "sviu30m": number,// 30分钟内卖出美元金额
      "p30m": number,   // 30分钟价格
      "oiu30m": number, // 30分钟内开盘价格
      "ciu30m": number, // 30分钟内收盘价格
      "b1h": number,    // 1小时内买入次数
      "s1h": number,    // 1小时内卖出次数
      "be1h": number,   // 1小时内买入人数
      "se1h": number,   // 1小时内卖出人数
      "bviu1h": number, // 1小时内买入美元金额
      "sviu1h": number, // 1小时内卖出美元金额
      "p1h": number,    // 1小时价格
      "oiu1h": number,  // 1小时内开盘价格
      "ciu1h": number,  // 1小时内收盘价格
      "b4h": number,    // 4小时内买入次数
      "s4h": number,    // 4小时内卖出次数
      "be4h": number,   // 4小时内买入人数
      "se4h": number,   // 4小时内卖出人数
      "bviu4h": number, // 4小时内买入美元金额
      "sviu4h": number, // 4小时内卖出美元金额
      "p4h": number,    // 4小时价格
      "oiu4h": number,  // 4小时内开盘价格
      "ciu4h": number,  // 4小时内收盘价格
      "b24h": number,   // 24小时内买入次数
      "s24h": number,   // 24小时内卖出次数
      "be24h": number,  // 24小时内买入人数
      "se24h": number,  // 24小时内卖出人数
      "bviu24h": number,// 24小时内买入美元金额
      "sviu24h": number,// 24小时内卖出美元金额
      "p24h": number,   // 24小时价格
      "oiu24h": number, // 24小时内开盘价格
      "ciu24h": number, // 24小时内收盘价格
      "p": number       // 当前价格
    }
  }
]

钱包

钱包余额

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

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

参数说明

chain

string

required

区块链名称，例如：sol

walletAddress

string

required

钱包地址，例如：HN7cABqLq46Es1jh92dQQisAq662SmxELLLsHHe4YWrH

filter

string

可选的过滤条件，使用Google Common Expression Language (CEL)表达式语言语法。例如：balance > 1000

响应数据格式

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

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

钱包盈亏数据（代币级别）

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

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

参数说明

chain

string

required

区块链名称，例如：sol

walletAddress

string

required

钱包地址

filter

string

可选的过滤条件，使用Google Common Expression Language (CEL)表达式语言语法。例如：buyAmount > 1000

响应数据格式

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

{
  "a": string,      // 钱包地址
  "ta": string,     // 代币地址
  "tpiu": number,   // 代币美元价格
  "t": number,      // 时间戳
  "ot": number,     // 开仓时间
  "lt": number,     // 最后交易时间
  "ct": number,     // 平仓时间
  "ba": number,     // 买入数量
  "baiu": number,   // 买入美元金额
  "bs": number,     // 买入次数
  "bs30d": number,  // 30天买入次数
  "bs7d": number,   // 7天买入次数
  "sa": number,     // 卖出数量
  "saiu": number,   // 卖出美元金额
  "ss": number,     // 卖出次数
  "ss30d": number,  // 30天卖出次数
  "ss7d": number,   // 7天卖出次数
  "hdts": number,   // 持仓时长时间戳
  "abpiu": number,  // 平均买入美元价格
  "aspiu": number,  // 平均卖出美元价格
  "upiu": number,   // 未实现美元盈亏
  "upr": number,    // 未实现盈亏比率
  "rpiu": number,   // 已实现美元盈亏
  "rpr": number,    // 已实现盈亏比率
  "trpiu": number,  // 总已实现美元盈亏
  "trr": number     // 总已实现盈亏比率
}

钱包盈亏数据（钱包级别）

实时获取钱包的整体盈亏统计数据。 订阅格式

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-trade:{chain}_{tokenAddress}

参数说明

chain

string

required

区块链名称，例如：sol

tokenAddress

string

required

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

filter

string

可选的过滤条件，使用Google Common Expression Language (CEL)表达式语言语法。例如：buyAmount > 100

响应数据格式

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

{
  "a": string,      // 代币地址
  "t": number,      // 时间戳
  "k": string,      // 交易类型
  "ba": number,     // 买入数量
  "baiu": number,   // 买入美元金额
  "btma": string,   // 买入代币地址
  "btn": string,    // 买入代币名称
  "bts": string,    // 买入代币符号
  "bwa": string,    // 买入钱包地址
  "sa": number,     // 卖出数量
  "saiu": number,   // 卖出美元金额
  "stma": string,   // 卖出代币地址
  "stn": string,    // 卖出代币名称
  "sts": string,    // 卖出代币符号
  "swa": string,    // 卖出钱包地址
  "h": 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 资金池余额

实时获取 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) {
    // 取消订阅实现
  }
}

身份验证

REST API

SDK

概述

快速开始

1. 建立连接

2. 订阅数据

3. 处理数据

数据订阅

K线

K线数据

代币

代币统计

代币持有者统计

新代币元数据

新代币信息

代币供应量

代币流动性

排名

排名的代币统计数据

排名的代币持有者统计

排名的代币供应量数据

排名的代币流动性数据

排名的代币列表

钱包

钱包余额

钱包盈亏数据（代币级别）

钱包盈亏数据（钱包级别）

交易

代币交易

钱包交易

流动池

DEX 资金池余额

使用示例

重连策略

使用限制

最佳实践

完整示例

身份验证

REST API

SDK

​概述

​快速开始

​1. 建立连接

​2. 订阅数据

​3. 处理数据

​数据订阅

​K线

​K线数据

​代币

​代币统计

​代币持有者统计

​新代币元数据

​新代币信息

​代币供应量

​代币流动性

​排名

​排名的代币统计数据

​排名的代币持有者统计

​排名的代币供应量数据

​排名的代币流动性数据

​排名的代币列表

​钱包

​钱包余额

​钱包盈亏数据（代币级别）

​钱包盈亏数据（钱包级别）

​交易

​代币交易

​钱包交易

​流动池

​DEX 资金池余额

​使用示例

​重连策略

​使用限制

​最佳实践

​完整示例

概述

快速开始

1. 建立连接

2. 订阅数据

3. 处理数据

数据订阅

K线

K线数据

代币

代币统计

代币持有者统计

新代币元数据

新代币信息

代币供应量

代币流动性

排名

排名的代币统计数据

排名的代币持有者统计

排名的代币供应量数据

排名的代币流动性数据

排名的代币列表

钱包

钱包余额

钱包盈亏数据（代币级别）

钱包盈亏数据（钱包级别）

交易

代币交易

钱包交易

流动池

DEX 资金池余额

使用示例

重连策略

使用限制

最佳实践

完整示例