WebSocket API - ChainStream

概述

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 连接。WebSocket 连接需要在 URL 中通过 token 查询参数进行认证。

使用 SDK（推荐）
使用原生 WebSocket
命令行测试

如果使用 Go 或 JavaScript SDK，认证已内置处理，无需手动设置：

import { ChainStreamClient } from '@chainstream-io/sdk';
import { Resolution } from '@chainstream-io/sdk/openapi';

const client = new ChainStreamClient('YOUR_ACCESS_TOKEN');

// 直接订阅即可，SDK 会自动处理 WebSocket 连接和认证
client.stream.subscribeTokenCandles({
  chain: 'sol',
  tokenAddress: '6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN',
  resolution: Resolution._1m,
  callback: (data) => {
    console.log('收到数据:', data);
  }
});

调用 subscribeXXX 方法时，SDK 会自动检测连接状态，如果未连接会自动建立连接，无需手动调用 connect()。

SDK 安装：

TypeScript/JavaScript: npm install @chainstream-io/sdk (npm)
Python: pip install chainstream-sdk (PyPI)
Go: go get github.com/chainstream-io/chainstream-go-sdk (GitHub)
Rust: 添加 chainstream-sdk 到 Cargo.toml (crates.io)

使用浏览器原生 WebSocket 或其他 WebSocket 库时，需要在 URL 中拼接 token 参数：

// 浏览器或 Node.js 均可使用
const token = 'YOUR_ACCESS_TOKEN';
const ws = new WebSocket(
  `wss://realtime-dex.chainstream.io/connection/websocket?token=${token}`
);

ws.onopen = () => {
  console.log('连接成功');
};

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

通过 URL 参数传递 token，浏览器原生 WebSocket 和各种第三方库均可使用，无需特殊处理请求头。

使用 wscat 进行测试：

$ wscat -c "wss://realtime-dex.chainstream.io/connection/websocket?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}

参数说明

string

必填

区块链名称，例如：sol

string

必填

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

string

必填

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

string

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

响应数据格式

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

WebSocket API
SDK

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

{
  "open": number,       // 开盘价
  "close": number,      // 收盘价
  "high": number,       // 最高价
  "low": number,        // 最低价
  "volume": number,     // 交易量
  "resolution": string, // 周期
  "time": number       // 时间戳
}

代币

代币统计

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

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

参数说明

string

必填

区块链名称，例如：sol

string

必填

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

string

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

响应数据格式

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

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       // 当前价格
}

{
  "address": string,           // 代币地址
  "timestamp": number,         // 时间戳
  "buys1m": number,           // 1分钟内买入次数
  "sells1m": number,          // 1分钟内卖出次数
  "buyers1m": number,         // 1分钟内买入人数
  "sellers1m": number,        // 1分钟内卖出人数
  "buyVolumeInUsd1m": number, // 1分钟内买入美元金额
  "sellVolumeInUsd1m": number,// 1分钟内卖出美元金额
  "price1m": number,          // 1分钟价格
  "openInUsd1m": number,      // 1分钟内开盘价格
  "closeInUsd1m": number,     // 1分钟内收盘价格      
  "buys5m": number,           // 5分钟内买入次数
  "sells5m": number,          // 5分钟内卖出次数
  "buyers5m": number,         // 5分钟内买入人数
  "sellers5m": number,        // 5分钟内卖出人数
  "buyVolumeInUsd5m": number, // 5分钟内买入美元金额
  "sellVolumeInUsd5m": number,// 5分钟内卖出美元金额
  "price5m": number,          // 5分钟价格
  "openInUsd5m": number,      // 5分钟内开盘价格
  "closeInUsd5m": number,     // 5分钟内收盘价格
  "buys15m": number,          // 15分钟内买入次数
  "sells15m": number,         // 15分钟内卖出次数
  "buyers15m": number,        // 15分钟内买入人数
  "sellers15m": number,       // 15分钟内卖出人数
  "buyVolumeInUsd15m": number,// 15分钟内买入美元金额
  "sellVolumeInUsd15m": number,// 15分钟内卖出美元金额
  "price15m": number,         // 15分钟价格
  "openInUsd15m": number,     // 15分钟内开盘价格
  "closeInUsd15m": number,    // 15分钟内收盘价格
  "buys30m": number,          // 30分钟内买入次数
  "sells30m": number,         // 30分钟内卖出次数
  "buyers30m": number,        // 30分钟内买入人数
  "sellers30m": number,       // 30分钟内卖出人数
  "buyVolumeInUsd30m": number,// 30分钟内买入美元金额
  "sellVolumeInUsd30m": number,// 30分钟内卖出美元金额
  "price30m": number,         // 30分钟价格
  "openInUsd30m": number,     // 30分钟内开盘价格
  "closeInUsd30m": number,    // 30分钟内收盘价格
  "buys1h": number,           // 1小时内买入次数
  "sells1h": number,          // 1小时内卖出次数
  "buyers1h": number,         // 1小时内买入人数
  "sellers1h": number,        // 1小时内卖出人数
  "buyVolumeInUsd1h": number, // 1小时内买入美元金额
  "sellVolumeInUsd1h": number,// 1小时内卖出美元金额
  "price1h": number,          // 1小时价格
  "openInUsd1h": number,      // 1小时内开盘价格
  "closeInUsd1h": number,     // 1小时内收盘价格
  "buys4h": number,           // 4小时内买入次数
  "sells4h": number,          // 4小时内卖出次数
  "buyers4h": number,         // 4小时内买入人数
  "sellers4h": number,        // 4小时内卖出人数
  "buyVolumeInUsd4h": number, // 4小时内买入美元金额
  "sellVolumeInUsd4h": number,// 4小时内卖出美元金额
  "price4h": number,          // 4小时价格
  "openInUsd4h": number,      // 4小时内开盘价格
  "closeInUsd4h": number,     // 4小时内收盘价格
  "buys24h": number,          // 24小时内买入次数
  "sells24h": number,         // 24小时内卖出次数
  "buyers24h": number,        // 24小时内买入人数
  "sellers24h": number,       // 24小时内卖出人数
  "buyVolumeInUsd24h": number,// 24小时内买入美元金额
  "sellVolumeInUsd24h": number,// 24小时内卖出美元金额
  "price24h": number,         // 24小时价格
  "openInUsd24h": number,     // 24小时内开盘价格
  "closeInUsd24h": number,    // 24小时内收盘价格
  "price": number            // 当前价格
}

代币持有者统计

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

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

参数说明

string

必填

区块链名称，例如：sol

string

必填

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

string

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

响应数据格式

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

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      // 时间戳
}

{
  "tokenAddress": string,    // 代币地址
  "holders": number,         // 持有者数量
  "top100Amount": number,    // 前100名持有者持有总量
  "top10Amount": number,     // 前10名持有者持有总量
  "top100Holders": number,   // 前100名持有者数量
  "top10Holders": number,    // 前10名持有者数量
  "top100Ratio": number,     // 前100名持有者持有比例
  "top10Ratio": number,      // 前10名持有者持有比例
  "creatorsHolders": number, // 创建者持有者数量
  "creatorsAmount": number,  // 创建者持有量
  "creatorsRatio": number,   // 创建者持有比例
  "timestamp": number        // 时间戳
}

新代币元数据

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

dex-new-tokens-metadata:{chain}

参数说明

string

必填

区块链名称，例如：sol

string

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

响应数据格式

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

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     // 创建时间戳（毫秒）
  }
]

[
  {
    "tokenAddress": string,     // 代币地址
    "name": string,             // 名称
    "symbol": string,           // 符号
    "imageUrl": string,         // 图片URL
    "description": string,      // 描述
    "socialMedia": {            // 社交媒体
      "twitter": string,        // Twitter
      "telegram": string,       // Telegram
      "website": string,        // 网站
      "tiktok": string,         // TikTok
      "discord": string,        // Discord
      "facebook": string,       // Facebook
      "github": string,         // GitHub
      "instagram": string,      // Instagram
      "linkedin": string,       // LinkedIn
      "medium": string,         // Medium
      "reddit": string,         // Reddit
      "youtube": string,        // YouTube
      "bitbucket": string       // BitBucket
    },
    "createdAtMs": number       // 创建时间戳（毫秒）
  }
]

新代币信息

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

dex-new-token:{chain}

参数说明

string

必填

区块链名称，例如：sol

响应数据格式

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

WebSocket API
SDK

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

{
  "tokenAddress": string,     // 代币地址
  "name": string,             // 名称
  "symbol": string,           // 符号
  "decimals": number,         // 小数位数
  "createdAtMs": number,      // 创建时间戳（毫秒）
  "launchFrom": {             // 启动来源信息
    "programAddress": string, // 程序地址
    "protocolFamily": string, // 协议家族
    "protocolName": string    // 协议名称
  }
}

代币供应量

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

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

参数说明

string

必填

区块链名称，例如：sol

string

必填

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

string

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

响应数据格式

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

WebSocket API
SDK

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

{
  "tokenAddress": string,    // 代币地址
  "supply": number,          // 供应量
  "marketCapInUsd": number,  // 市值（美元）
  "timestamp": number        // 时间戳
}

代币流动性

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

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

参数说明

string

必填

区块链名称，例如：sol

string

必填

代币合约地址

string

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

响应数据格式

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

WebSocket API
SDK

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

{
  "tokenAddress": string,  // 代币地址
  "metricType": string,    // 指标类型
  "value": number,         // 数值
  "timestamp": number      // 时间戳
}

代币最大流动性

实时获取代币在单个池子中的最大流动性信息。 订阅格式

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

参数说明

string

必填

区块链名称，例如：sol

string

必填

代币合约地址

string

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

响应数据格式

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

WebSocket API
SDK

{
  "a": string,     // 代币地址
  "p": string,     // 池子地址
  "liu": string,   // 美元流动性
  "lin": string,   // 原生代币流动性
  "ts": number     // 时间戳
}

{
  "tokenAddress": string,       // 代币地址
  "poolAddress": string,        // 池子地址
  "liquidityInUsd": string,     // 美元流动性
  "liquidityInNative": string,  // 原生代币流动性
  "timestamp": number           // 时间戳
}

代币总流动性

实时获取代币在所有池子中的总流动性信息。 订阅格式

dex-token-total-liquidity:{chain}_{tokenAddress}

参数说明

string

必填

区块链名称，例如：sol

string

必填

代币合约地址

string

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

响应数据格式

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

WebSocket API
SDK

{
  "a": string,     // 代币地址
  "liu": string,   // 总美元流动性
  "lin": string,   // 总原生代币流动性
  "pc": number,    // 池子数量
  "ts": number     // 时间戳
}

{
  "tokenAddress": string,       // 代币地址
  "liquidityInUsd": string,     // 总美元流动性
  "liquidityInNative": string,  // 总原生代币流动性
  "poolCount": number,          // 池子数量
  "timestamp": number           // 时间戳
}

排名

排名的代币统计数据

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

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

参数说明

string

必填

区块链名称，例如：sol

string

必填

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

响应数据格式

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

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       // 当前价格
  }
]

[
  {
    "address": string,           // 代币地址
    "timestamp": number,         // 时间戳
    "buys1m": number,           // 1分钟内买入次数
    "sells1m": number,          // 1分钟内卖出次数
    "buyers1m": number,         // 1分钟内买入人数
    "sellers1m": number,        // 1分钟内卖出人数
    "buyVolumeInUsd1m": number, // 1分钟内买入美元金额
    "sellVolumeInUsd1m": number,// 1分钟内卖出美元金额
    "price1m": number,          // 1分钟价格
    "openInUsd1m": number,      // 1分钟内开盘价格
    "closeInUsd1m": number,     // 1分钟内收盘价格      
    "buys5m": number,           // 5分钟内买入次数
    "sells5m": number,          // 5分钟内卖出次数
    "buyers5m": number,         // 5分钟内买入人数
    "sellers5m": number,        // 5分钟内卖出人数
    "buyVolumeInUsd5m": number, // 5分钟内买入美元金额
    "sellVolumeInUsd5m": number,// 5分钟内卖出美元金额
    "price5m": number,          // 5分钟价格
    "openInUsd5m": number,      // 5分钟内开盘价格
    "closeInUsd5m": number,     // 5分钟内收盘价格
    "buys15m": number,          // 15分钟内买入次数
    "sells15m": number,         // 15分钟内卖出次数
    "buyers15m": number,        // 15分钟内买入人数
    "sellers15m": number,       // 15分钟内卖出人数
    "buyVolumeInUsd15m": number,// 15分钟内买入美元金额
    "sellVolumeInUsd15m": number,// 15分钟内卖出美元金额
    "price15m": number,         // 15分钟价格
    "openInUsd15m": number,     // 15分钟内开盘价格
    "closeInUsd15m": number,    // 15分钟内收盘价格
    "buys30m": number,          // 30分钟内买入次数
    "sells30m": number,         // 30分钟内卖出次数
    "buyers30m": number,        // 30分钟内买入人数
    "sellers30m": number,       // 30分钟内卖出人数
    "buyVolumeInUsd30m": number,// 30分钟内买入美元金额
    "sellVolumeInUsd30m": number,// 30分钟内卖出美元金额
    "price30m": number,         // 30分钟价格
    "openInUsd30m": number,     // 30分钟内开盘价格
    "closeInUsd30m": number,    // 30分钟内收盘价格
    "buys1h": number,           // 1小时内买入次数
    "sells1h": number,          // 1小时内卖出次数
    "buyers1h": number,         // 1小时内买入人数
    "sellers1h": number,        // 1小时内卖出人数
    "buyVolumeInUsd1h": number, // 1小时内买入美元金额
    "sellVolumeInUsd1h": number,// 1小时内卖出美元金额
    "price1h": number,          // 1小时价格
    "openInUsd1h": number,      // 1小时内开盘价格
    "closeInUsd1h": number,     // 1小时内收盘价格
    "buys4h": number,           // 4小时内买入次数
    "sells4h": number,          // 4小时内卖出次数
    "buyers4h": number,         // 4小时内买入人数
    "sellers4h": number,        // 4小时内卖出人数
    "buyVolumeInUsd4h": number, // 4小时内买入美元金额
    "sellVolumeInUsd4h": number,// 4小时内卖出美元金额
    "price4h": number,          // 4小时价格
    "openInUsd4h": number,      // 4小时内开盘价格
    "closeInUsd4h": number,     // 4小时内收盘价格
    "buys24h": number,          // 24小时内买入次数
    "sells24h": number,         // 24小时内卖出次数
    "buyers24h": number,        // 24小时内买入人数
    "sellers24h": number,       // 24小时内卖出人数
    "buyVolumeInUsd24h": number,// 24小时内买入美元金额
    "sellVolumeInUsd24h": number,// 24小时内卖出美元金额
    "price24h": number,         // 24小时价格
    "openInUsd24h": number,     // 24小时内开盘价格
    "closeInUsd24h": number,    // 24小时内收盘价格
    "price": number            // 当前价格
  }
]

排名的代币持有者统计

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

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

参数说明

string

必填

区块链名称，例如：sol

string

必填

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

响应数据格式

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

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      // 时间戳
  }
]

[
  {
    "tokenAddress": string,    // 代币地址
    "holders": number,         // 持有者数量
    "top100Amount": number,    // 前100名持有者持有总量
    "top10Amount": number,     // 前10名持有者持有总量
    "top100Holders": number,   // 前100名持有者数量
    "top10Holders": number,    // 前10名持有者数量
    "top100Ratio": number,     // 前100名持有者持有比例
    "top10Ratio": number,      // 前10名持有者持有比例
    "timestamp": number        // 时间戳
  }
]

排名的代币供应量数据

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

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

参数说明

string

必填

区块链名称，例如：sol

string

必填

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

响应数据格式

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

WebSocket API
SDK

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

[
  {
    "tokenAddress": string,    // 代币地址
    "supply": number,          // 供应量
    "marketCapInUsd": number,  // 市值（美元）
    "timestamp": number        // 时间戳
  }
]

排名的代币流动性数据

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

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

参数说明

string

必填

区块链名称，例如：sol

string

必填

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

响应数据格式

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

WebSocket API
SDK

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

[
  {
    "tokenAddress": string,  // 代币地址
    "metricType": string,    // 指标类型
    "value": number,         // 数值
    "timestamp": number      // 时间戳
  }
]

排名的代币列表

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

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

参数说明

string

必填

区块链名称，例如：sol

string

必填

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

string

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

响应数据格式

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

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       // 当前价格
    }
  }
]

[
  {
    // 代币元数据
    "metadata": {
    "tokenAddress": string,     // 代币地址
    "name": string,             // 名称
    "symbol": string,           // 符号
    "imageUrl": string,         // 图片URL
    "description": string,      // 描述
      "decimals": number,         // 小数位数
      "createdAtMs": number,      // 创建时间戳（毫秒）
      "launchFrom": {             // 启动来源信息
        "programAddress": string, // 程序地址
        "protocolFamily": string, // 协议家族
        "protocolName": string    // 协议名称
      },
      "migratedTo": {             // 迁移目标信息
        "programAddress": string, // 程序地址
        "protocolFamily": string, // 协议家族
        "protocolName": string    // 协议名称
      },
    "socialMedia": {            // 社交媒体
      "twitter": string,        // Twitter
      "telegram": string,       // Telegram
      "website": string,        // 网站
      "tiktok": string,         // TikTok
      "discord": string,        // Discord
      "facebook": string,       // Facebook
      "github": string,         // GitHub
      "instagram": string,      // Instagram
      "linkedin": string,       // LinkedIn
      "medium": string,         // Medium
      "reddit": string,         // Reddit
      "youtube": string,        // YouTube
      "bitbucket": string       // BitBucket
      }
    },
    
    // 绑定曲线信息
    "bondingCurve": {
      "progressRatio": number     // 进度比例
    },
    
    // 持有者统计
    "holder": {
      "tokenAddress": string,     // 代币地址
      "timestamp": number,        // 时间戳
    "holders": number,          // 持有者数量
    "top100Amount": number,     // 前100名持有者持有总量
    "top10Amount": number,      // 前10名持有者持有总量
    "top100Holders": number,    // 前100名持有者数量
    "top10Holders": number,     // 前10名持有者数量
    "top100Ratio": number,      // 前100名持有者持有比例
      "top10Ratio": number        // 前10名持有者持有比例
    },
    
    // 供应量信息
    "supply": {
      "tokenAddress": string,     // 代币地址
      "timestamp": number,        // 时间戳
    "supply": number,           // 供应量
      "marketCapInUsd": number    // 市值（美元）
    },
    
    // 市场统计数据
    "stat": {
      "address": string,          // 代币地址
      "timestamp": number,        // 时间戳
    "buys1m": number,           // 1分钟内买入次数
    "sells1m": number,          // 1分钟内卖出次数
    "buyers1m": number,         // 1分钟内买入人数
    "sellers1m": number,        // 1分钟内卖出人数
    "buyVolumeInUsd1m": number, // 1分钟内买入美元金额
    "sellVolumeInUsd1m": number,// 1分钟内卖出美元金额
    "price1m": number,          // 1分钟价格
    "openInUsd1m": number,      // 1分钟内开盘价格
    "closeInUsd1m": number,     // 1分钟内收盘价格
      "buys5m": number,           // 5分钟内买入次数
      "sells5m": number,          // 5分钟内卖出次数
      "buyers5m": number,         // 5分钟内买入人数
      "sellers5m": number,        // 5分钟内卖出人数
      "buyVolumeInUsd5m": number, // 5分钟内买入美元金额
      "sellVolumeInUsd5m": number,// 5分钟内卖出美元金额
      "price5m": number,          // 5分钟价格
      "openInUsd5m": number,      // 5分钟内开盘价格
      "closeInUsd5m": number,     // 5分钟内收盘价格
      "buys15m": number,          // 15分钟内买入次数
      "sells15m": number,         // 15分钟内卖出次数
      "buyers15m": number,        // 15分钟内买入人数
      "sellers15m": number,       // 15分钟内卖出人数
      "buyVolumeInUsd15m": number,// 15分钟内买入美元金额
      "sellVolumeInUsd15m": number,// 15分钟内卖出美元金额
      "price15m": number,         // 15分钟价格
      "openInUsd15m": number,     // 15分钟内开盘价格
      "closeInUsd15m": number,    // 15分钟内收盘价格
      "buys30m": number,          // 30分钟内买入次数
      "sells30m": number,         // 30分钟内卖出次数
      "buyers30m": number,        // 30分钟内买入人数
      "sellers30m": number,       // 30分钟内卖出人数
      "buyVolumeInUsd30m": number,// 30分钟内买入美元金额
      "sellVolumeInUsd30m": number,// 30分钟内卖出美元金额
      "price30m": number,         // 30分钟价格
      "openInUsd30m": number,     // 30分钟内开盘价格
      "closeInUsd30m": number,    // 30分钟内收盘价格
      "buys1h": number,           // 1小时内买入次数
      "sells1h": number,          // 1小时内卖出次数
      "buyers1h": number,         // 1小时内买入人数
      "sellers1h": number,        // 1小时内卖出人数
      "buyVolumeInUsd1h": number, // 1小时内买入美元金额
      "sellVolumeInUsd1h": number,// 1小时内卖出美元金额
      "price1h": number,          // 1小时价格
      "openInUsd1h": number,      // 1小时内开盘价格
      "closeInUsd1h": number,     // 1小时内收盘价格
      "buys4h": number,           // 4小时内买入次数
      "sells4h": number,          // 4小时内卖出次数
      "buyers4h": number,         // 4小时内买入人数
      "sellers4h": number,        // 4小时内卖出人数
      "buyVolumeInUsd4h": number, // 4小时内买入美元金额
      "sellVolumeInUsd4h": number,// 4小时内卖出美元金额
      "price4h": number,          // 4小时价格
      "openInUsd4h": number,      // 4小时内开盘价格
      "closeInUsd4h": number,     // 4小时内收盘价格
      "buys24h": number,          // 24小时内买入次数
      "sells24h": number,         // 24小时内卖出次数
      "buyers24h": number,        // 24小时内买入人数
      "sellers24h": number,       // 24小时内卖出人数
      "buyVolumeInUsd24h": number,// 24小时内买入美元金额
      "sellVolumeInUsd24h": number,// 24小时内卖出美元金额
      "price24h": number,         // 24小时价格
      "openInUsd24h": number,     // 24小时内开盘价格
      "closeInUsd24h": number,    // 24小时内收盘价格
      "price": number             // 当前价格
    }
  }
]

排名代币绑定曲线

实时获取新上市代币的绑定曲线进度。 订阅格式

dex-ranking-token-bounding-curve-list:{chain}_new

参数说明

string

必填

区块链名称，例如：sol

响应数据格式

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

WebSocket API
SDK

[
  {
    "a": string,    // 代币地址
    "pr": string    // 进度比例 (0-1)
  }
]

[
  {
    "tokenAddress": string,   // 代币地址
    "progressRatio": string   // 进度比例 (0-1)
  }
]

钱包

钱包余额

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

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

参数说明

string

必填

区块链名称，例如：sol

string

必填

钱包地址，例如：HN7cABqLq46Es1jh92dQQisAq662SmxELLLsHHe4YWrH

string

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

响应数据格式

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

WebSocket API
SDK

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

[
  {
    "walletAddress": string,    // 钱包地址
    "tokenAddress": string,     // 代币地址
    "tokenPriceInUsd": number, // 代币美元价格
    "balance": number,          // 余额
    "timestamp": number         // 时间戳
  }
]

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

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

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

参数说明

string

必填

区块链名称，例如：sol

string

必填

钱包地址

string

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

响应数据格式

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

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     // 总已实现盈亏比率
}

{
  "walletAddress": string,         // 钱包地址
  "tokenAddress": string,          // 代币地址
  "tokenPriceInUsd": number,       // 代币美元价格
  "timestamp": number,             // 时间戳
  "opentime": number,              // 开仓时间
  "lasttime": number,              // 最后交易时间
  "closetime": number,             // 平仓时间
  "buyAmount": number,             // 买入数量
  "buyAmountInUsd": number,        // 买入美元金额
  "buyCount": number,              // 买入次数
  "buyCount30d": number,           // 30天买入次数
  "buyCount7d": number,            // 7天买入次数
  "sellAmount": number,            // 卖出数量
  "sellAmountInUsd": number,       // 卖出美元金额
  "sellCount": number,             // 卖出次数
  "sellCount30d": number,          // 30天卖出次数
  "sellCount7d": number,           // 7天卖出次数
  "heldDurationTimestamp": number, // 持仓时长时间戳
  "averageBuyPriceInUsd": number,  // 平均买入美元价格
  "averageSellPriceInUsd": number, // 平均卖出美元价格
  "unrealizedProfitInUsd": number, // 未实现美元盈亏
  "unrealizedProfitRatio": number, // 未实现盈亏比率
  "realizedProfitInUsd": number,   // 已实现美元盈亏
  "realizedProfitRatio": number,   // 已实现盈亏比率
  "totalRealizedProfitInUsd": number, // 总已实现美元盈亏
  "totalRealizedProfitRatio": number  // 总已实现盈亏比率
}

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

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

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

参数说明

string

必填

区块链名称，例如：sol

string

必填

钱包地址

响应数据格式

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

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      // 统计周期
  }
]

[
  {
    "walletAddress": string,         // 钱包地址
    "buys": number,                  // 买入次数
    "buyAmount": number,             // 买入数量
    "buyAmountInUsd": number,        // 买入美元金额
    "averageBuyPriceInUsd": number,  // 平均买入美元价格
    "sellAmount": number,            // 卖出数量
    "sellAmountInUsd": number,       // 卖出美元金额
    "sells": number,                 // 卖出次数
    "wins": number,                  // 盈利次数
    "winRatio": number,              // 胜率
    "pnlInUsd": number,              // 美元盈亏
    "averagePnlInUsd": number,       // 平均美元盈亏
    "pnlRatio": number,              // 盈亏比率
    "profitableDays": number,        // 盈利天数
    "losingDays": number,            // 亏损天数
    "tokens": number,                // 交易代币数
    "resolution": string             // 统计周期
  }
]

交易

代币交易

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

dex-trade:{chain}_{tokenAddress}

参数说明

string

必填

区块链名称，例如：sol

string

必填

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

string

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

响应数据格式

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

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       // 交易哈希
}

{
  "tokenAddress": string,    // 代币地址
  "timestamp": number,       // 时间戳
  "kind": string,            // 交易类型
  "buyAmount": number,       // 买入数量
  "buyAmountInUsd": number,  // 买入美元金额
  "buyTokenAddress": string, // 买入代币地址
  "buyTokenName": string,    // 买入代币名称
  "buyTokenSymbol": string,  // 买入代币符号
  "buyWalletAddress": string,// 买入钱包地址
  "sellAmount": number,      // 卖出数量
  "sellAmountInUsd": number,// 卖出美元金额
  "sellTokenAddress": string,// 卖出代币地址
  "sellTokenName": string,   // 卖出代币名称
  "sellTokenSymbol": string,// 卖出代币符号
  "sellWalletAddress": string,// 卖出钱包地址
  "txHash": string          // 交易哈希
}

钱包交易

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

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

参数说明

string

必填

区块链名称，例如：sol

string

必填

钱包地址，例如：GDekof7TtgeBKJtoVpkvzPin5mvhxSDyoUY2c1FK1T3i

响应数据格式

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

WebSocket API
SDK

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

{
  "maker": string,        // maker地址
  "baseAmount": number,   // 基础代币数量
  "quoteAmount": number,  // 报价代币数量
  "quoteAddress": string, // 报价代币地址
  "amountInUsd": number,  // 美元金额
  "timestamp": number,    // 时间戳
  "event": string,       // 事件类型
  "txHash": string,      // 交易哈希
  "tokenAddress": string  // 代币地址
}

流动池

DEX 资金池余额

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

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

参数说明

string

必填

区块链名称，例如：sol

string

必填

资金池地址

响应数据格式

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

WebSocket API
SDK

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

{
  "poolAddress": string,           // 资金池地址
  "tokenAAddress": string,         // 代币A地址
  "tokenALiquidityInUsd": number,  // 代币A流动性（美元）
  "tokenBAddress": string,         // 代币B地址
  "tokenBLiquidityInUsd": number   // 代币B流动性（美元）
}

使用示例

import { ChainStreamClient } from '@chainstream-io/sdk';
import { Resolution } from '@chainstream-io/sdk/openapi';

const client = new ChainStreamClient('YOUR_ACCESS_TOKEN');

// 直接订阅即可，SDK 会自动检测连接状态并建立连接
client.stream.subscribeTokenCandles({
  chain: 'sol',
  tokenAddress: '6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN',
  resolution: Resolution._1m,
  callback: (data) => {
    console.log('K线数据:', data);
  }
});

// 订阅钱包余额
client.stream.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连接
- 实现自动重连机制
- 定期发送心跳
错误处理
- 实现完整的错误处理流程
- 记录详细的错误日志
- 使用指数退避重连
性能优化
- 合理控制订阅数量
- 实现消息队列机制
- 及时清理无用订阅

完整示例

使用 SDK（推荐）
原生 WebSocket

import { ChainStreamClient } from '@chainstream-io/sdk';
import { Resolution } from '@chainstream-io/sdk/openapi';

const client = new ChainStreamClient('YOUR_ACCESS_TOKEN');

// 直接订阅即可，SDK 会自动检测连接状态并建立连接
const subscription = client.stream.subscribeTokenCandles({
  chain: 'sol',
  tokenAddress: '6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN',
  resolution: Resolution._1m,
  callback: (data) => {
    console.log('K线数据:', data);
  }
});

// 取消订阅
subscription.unsubscribe();

使用 SDK 时，认证、重连、心跳等都已自动处理，推荐在生产环境中使用。

TypeScript/JavaScript SDK: @chainstream-io/sdk
Python SDK: chainstream-sdk
Go SDK: chainstream-go-sdk
Rust SDK: chainstream-sdk

class DexWebSocket {
  private ws: WebSocket;
  private reconnectAttempts = 0;
  private maxReconnectAttempts = 5;
  private subscriptions = new Set<string>();

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

  private connect() {
    // 在 URL 中拼接 token 参数进行认证
    const url = `${this.baseUrl}?token=${this.accessToken}`;
    this.ws = new WebSocket(url);
    
    this.ws.onopen = () => {
      console.log('WebSocket 连接成功');
      this.reconnectAttempts = 0;
      // 重新订阅之前的频道
      this.resubscribe();
    };

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

    this.ws.onclose = () => {
      console.log('WebSocket 连接关闭');
      this.reconnect();
    };

    this.ws.onerror = (error) => {
      console.error('WebSocket 错误:', error);
    };
  }

  private reconnect() {
    if (this.reconnectAttempts < this.maxReconnectAttempts) {
      const delay = Math.min(1000 * Math.pow(2, this.reconnectAttempts), 10000);
      this.reconnectAttempts++;
      console.log(`${delay}ms 后尝试重连...`);
      setTimeout(() => this.connect(), delay);
    }
  }

  private resubscribe() {
    this.subscriptions.forEach(channel => {
      this.send({ type: "subscribe", channel });
    });
  }

  private handleMessage(data: any) {
    // 处理消息
  }

  private send(data: any) {
    if (this.ws.readyState === WebSocket.OPEN) {
      this.ws.send(JSON.stringify(data));
    }
  }

  public subscribe(channel: string) {
    this.subscriptions.add(channel);
    this.send({ type: "subscribe", channel });
  }

  public unsubscribe(channel: string) {
    this.subscriptions.delete(channel);
    this.send({ type: "unsubscribe", channel });
  }
}

// 使用示例
const client = new DexWebSocket(
  "wss://realtime-dex.chainstream.io/connection/websocket",
  "YOUR_ACCESS_TOKEN"
);

​概述

​快速开始

​1. 建立连接

​2. 订阅数据

​3. 处理数据

​数据订阅

​K线

​K线数据

​代币

​代币统计

​代币持有者统计

​新代币元数据

​新代币信息

​代币供应量

​代币流动性

​代币最大流动性

​代币总流动性

​排名

​排名的代币统计数据

​排名的代币持有者统计

​排名的代币供应量数据

​排名的代币流动性数据

​排名的代币列表

​排名代币绑定曲线

​钱包

​钱包余额

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

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

​交易

​代币交易

​钱包交易

​流动池

​DEX 资金池余额

​使用示例

​重连策略

​使用限制

​最佳实践

​完整示例

概述

快速开始

1. 建立连接

2. 订阅数据

3. 处理数据

数据订阅

K线

K线数据

代币

代币统计

代币持有者统计

新代币元数据

新代币信息

代币供应量

代币流动性

代币最大流动性

代币总流动性

排名

排名的代币统计数据

排名的代币持有者统计

排名的代币供应量数据

排名的代币流动性数据

排名的代币列表

排名代币绑定曲线

钱包

钱包余额

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

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

交易

代币交易

钱包交易

流动池

DEX 资金池余额

使用示例

重连策略

使用限制

最佳实践

完整示例