跳转到主要内容

​
什么是 accountSubscribe？

Solana 的 WebSockets 支持一种方法，可以让您订阅一个账户，并在与匹配的账户公钥相关的 lamports 或数据发生变化时，通过 WebSocket 连接接收通知。 此方法直接符合 Solana WSS API 规范。

​
参数

  • string：账户公钥，以 base58 格式发送（必需）
  • object：一个可选对象，用于传递其他参数
  • encoding：指定在 AccountNotification 中返回数据的格式。支持的值：base58（默认），base64，base64+zstd，jsonParsed
  • commitment：定义交易的承诺级别。支持的值：finalized（默认），confirmed，processed

​
账户订阅示例

在此示例中，我们正在订阅账户 SysvarC1ock11111111111111111111111111111111 的更改。 每当该账户的数据或 lamports 发生变化时，我们将看到更新。 对于这个特定账户，更新频繁发生，因为 slot 和 unixTimestamp 都是返回账户数据的一部分。
增强型 WebSockets 现在在主 wss://mainnet.helius-rpc.com 和 wss://devnet.helius-rpc.com 端点 上得到支持。切换旧的 wss://atlas-mainnet.helius-rpc.com 和 wss://atlas-devnet.helius-rpc.com 端点以获得统一的开发者体验。
const WebSocket = require('ws');

// Create a WebSocket connection
const ws = new WebSocket('wss://mainnet.helius-rpc.com?api-key=<API_KEY>');

// Function to send a request to the WebSocket server
function sendRequest(ws) {
    const request = {
        jsonrpc: "2.0",
        id: 420,
        method: "accountSubscribe",
        params: [
            "SysvarC1ock11111111111111111111111111111111", // pubkey of account we want to subscribe to
            {
                encoding: "jsonParsed", // base58, base64, base65+zstd, jsonParsed
                commitment: "confirmed", // defaults to finalized if unset
            }
        ]
    };
    ws.send(JSON.stringify(request));
}

// Function to send a ping to the WebSocket server
function startPing(ws) {
    setInterval(() => {
        if (ws.readyState === WebSocket.OPEN) {
            ws.ping();
            console.log('Ping sent');
        }
    }, 30000); // Ping every 30 seconds
}

// Define WebSocket event handlers

ws.on('open', function open() {
    console.log('WebSocket is open');
    sendRequest(ws);  // Send a request once the WebSocket is open
    startPing(ws);    // Start sending pings
});

ws.on('message', function incoming(data) {
    const messageStr = data.toString('utf8');
    try {
        const messageObj = JSON.parse(messageStr);
        console.log('Received:', messageObj);
    } catch (e) {
        console.error('Failed to parse JSON:', e);
    }
});

ws.on('error', function error(err) {
    console.error('WebSocket error:', err);
});

ws.on('close', function close() {
    console.log('WebSocket is closed');
});

​
示例通知

{
    'jsonrpc': '2.0', 
    'method': 'accountNotification', 
    'params': 
        {
          'subscription': 237508762798666, 
          'result': 
           {
            'context': {'slot': 235781083}, 
            'value': 
             {
             'lamports': 1169280, 
             'data': 'BvEhEb6hixL3QPn41gHcyi2CDGKt381jbNKFFCQr6XDTzCTXCuSUG9D', 
             'owner': 'Sysvar1111111111111111111111111111111111111', 
             'executable': False, 
             'rentEpoch': 361, 
             'space': 40
             }
           }
        }
}