> ## Documentation Index
> Fetch the complete documentation index at: https://docs.solanatracker.io/llms.txt
> Use this file to discover all available pages before exploring further.

# 实时代币持有者更新(WebSocket)

> 通过 WebSocket 为任意 Solana 代币实时流式传输持有者数量变化与前 10 钱包集中度更新，是 rug 筛选器与实时看板的理想工具。

Datastream WebSocket 允许您订阅任意代币的实时持有者数据。两个 room 涵盖关键信号:总持有者数量变化和前 10 钱包集中度变化。这些信号帮助您尽早发现风险持有者模式。

<Info>
  **URL:** `wss://datastream.solanatracker.io/{apiKey}`\
  适用于 Premium、Business 和 Enterprise 方案。
</Info>

***

## 实时持有者数量

订阅 `holders:{tokenAddress}`,每当唯一持有者总数变化时即收到一条消息。

**用例:** 追踪持有者动量、在持有者大幅下降时告警,以及显示实时持有者数量徽章。

```javascript theme={null}
const token = "6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN";
const ws = new WebSocket("wss://datastream.solanatracker.io/YOUR_API_KEY");

ws.onopen = () => {
  ws.send(JSON.stringify({ type: "join", room: `holders:${token}` }));
};

ws.onmessage = (event) => {
  const msg = JSON.parse(event.data);
  if (msg.type !== "message") return;

  console.log(`Holders: ${msg.data.total}`);
};
```

**Payload:**

```json theme={null}
{
  "type": "message",
  "room": "holders:6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN",
  "data": {
    "total": 14823
  }
}
```

***

## 前 10 持有者集中度

订阅 `top10:{tokenAddress}` 以在前 10 钱包中任何一个的持仓变化时接收更新。这可以提醒您巨鲸退出或创建者钱包抛售。

**用例:** 当前 10 集中度突破某阈值时告警、追踪个别巨鲸钱包动向以及实时监控创建者钱包抛售。

```javascript theme={null}
const token = "6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN";
const ws = new WebSocket("wss://datastream.solanatracker.io/YOUR_API_KEY");

ws.onopen = () => {
  ws.send(JSON.stringify({ type: "join", room: `top10:${token}` }));
};

ws.onmessage = (event) => {
  const msg = JSON.parse(event.data);
  if (msg.type !== "message") return;

  const { holders } = msg.data;
  const totalConcentration = holders.reduce((sum, h) => sum + h.percentage, 0);

  console.log(`Top 10 hold ${totalConcentration.toFixed(1)}% of supply`);
  holders.forEach((h, i) => {
    console.log(`  #${i + 1} ${h.address}: ${h.percentage.toFixed(2)}%`);
  });

  // Risk warning: top 10 suddenly hold a much larger share
  if (totalConcentration > 50) {
    console.log("🚨 Top 10 concentration above 50% — high risk");
  }
};
```

**Payload:**

```json theme={null}
{
  "type": "message",
  "room": "top10:6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN",
  "data": {
    "holders": [
      { "address": "4Rz5xqikxtZ2s7wE9uQ6n2oLXQi6K65XGoYpKxf24Hqo", "percentage": 12.5 },
      { "address": "FV1r15rbNKkJanXLheoJA7fXEq6NDuMJ3bukXuhJWyV1", "percentage": 8.3 }
    ]
  }
}
```

***

## 同时观察两个信号

在单一连接中同时订阅两个 room 以获得完整图景——持有者数量动量加上集中度风险:

```javascript theme={null}
const token = "6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN";
const ws = new WebSocket("wss://datastream.solanatracker.io/YOUR_API_KEY");

let holderCount = 0;
let top10Pct = 0;

ws.onopen = () => {
  ws.send(JSON.stringify({ type: "join", room: `holders:${token}` }));
  ws.send(JSON.stringify({ type: "join", room: `top10:${token}` }));
};

ws.onmessage = (event) => {
  const msg = JSON.parse(event.data);
  if (msg.type !== "message") return;

  const room = msg.room ?? "";

  if (room.startsWith("holders:")) {
    holderCount = msg.data.total;
    console.log(`[HOLDERS] Total: ${holderCount}`);
  }

  if (room.startsWith("top10:")) {
    top10Pct = msg.data.holders.reduce((sum, h) => sum + h.percentage, 0);
    console.log(`[TOP10] Concentration: ${top10Pct.toFixed(1)}%`);
  }
};
```

***

## 自动重连模式

WebSocket 连接会断开。生产环境中务必实现重连逻辑:

```javascript theme={null}
function connectHolderStream(token, onHolderUpdate, onTop10Update) {
  let ws;
  let reconnectTimeout;

  function connect() {
    ws = new WebSocket("wss://datastream.solanatracker.io/YOUR_API_KEY");

    ws.onopen = () => {
      console.log("Connected — subscribing to holder streams");
      ws.send(JSON.stringify({ type: "join", room: `holders:${token}` }));
      ws.send(JSON.stringify({ type: "join", room: `top10:${token}` }));
    };

    ws.onmessage = (event) => {
      const msg = JSON.parse(event.data);
      if (msg.type !== "message") return;

      if (msg.room?.startsWith("holders:")) onHolderUpdate(msg.data);
      if (msg.room?.startsWith("top10:"))   onTop10Update(msg.data);
    };

    ws.onclose = () => {
      console.log("Disconnected — reconnecting in 3s");
      reconnectTimeout = setTimeout(connect, 3000);
    };

    ws.onerror = (err) => {
      console.error("WebSocket error:", err);
      ws.close();
    };
  }

  connect();

  return () => {
    clearTimeout(reconnectTimeout);
    ws?.close();
  };
}

// Usage
const stopWatching = connectHolderStream(
  "6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN",
  (data) => console.log("Holders:", data.total),
  (data) => {
    const pct = data.holders.reduce((s, h) => s + h.percentage, 0);
    if (pct > 50) console.log("🚨 Risk warning: top 10 hold", pct.toFixed(1) + "%");
  }
);
```

***

## Room 参考

| Room              | 何时更新              |
| ----------------- | ----------------- |
| `holders:{token}` | 总持有者数量变化          |
| `top10:{token}`   | 任何前 10 钱包买入、卖出或退出 |

***

## 相关指南

* [获取所有持有者(REST)](/cn/guides/token-holders) — 获取持有者列表的完整快照
* [安全流](/cn/guides/datastream-safety) — 同时涵盖狙击者、bundler、内部人和开发者持仓变化
* [代币安全与 Rugcheck](/cn/guides/token-safety) — 使用风险评分 API 进行某一时间点的安全检查