accountSubscribe RPC Method

As of May 1, 2026, this WebSocket method is billed based on metered data usage: 0.1 MB = 15 API credits. Learn more about WebSocket billing.

参数

Pubkey

字符串

正在加载...

对象

对象

正在加载...

承诺

字符串

正在加载...

已最终确定

字符串

正在加载...

已确认

字符串

正在加载...

已处理

字符串

正在加载...

encoding

字符串

正在加载...

退货

结果

整数

正在加载...

Notification Format:

正在加载...

请求

1
import { address, createSolanaRpcSubscriptions } from '@solana/kit';
2

3
const rpcSubscriptions = createSolanaRpcSubscriptions('');
4

5
async 函数 main() {
6
    const abortController = new AbortController();
7
    const accountNotifications = await rpcSubscriptions
8
        .accountNotifications(address('9kwU8PYhsmRfgS3nwnzT3TvnDeuvdbMAXqWsri2X8rAU'), { commitment: 'confirmed' })
9
        .subscribe({ abortSignal: abortController.signal });
10

11
    try {
12
        for await (const notification of accountNotifications) {
13
            console.log('New balance', notification.value.lamports);
14
        }
15
    } catch (e) {
16
        console.error(e);
17
    }
18

19
}
20

21
主();

1
import { address, createSolanaRpcSubscriptions } from '@solana/kit';
2

3
const rpcSubscriptions = createSolanaRpcSubscriptions('');
4

5
async 函数 main() {
6
    const abortController = new AbortController();
7
    const accountNotifications = await rpcSubscriptions
8
        .accountNotifications(address('9kwU8PYhsmRfgS3nwnzT3TvnDeuvdbMAXqWsri2X8rAU'), { commitment: 'confirmed' })
9
        .subscribe({ abortSignal: abortController.signal });
10

11
    try {
12
        for await (const notification of accountNotifications) {
13
            console.log('New balance', notification.value.lamports);
14
        }
15
    } catch (e) {
16
        console.error(e);
17
    }
18

19
}
20

21
主();

1
const web3 = require("@solana/web3.js");
2
(async () => {
3
  const publicKey = new web3.PublicKey(
4
    "E645TckHQnDcavVv92Etc6xSWQaq8zzPtPRGBheviRAk"
5
  );
6
  const solanaConnection = new web3.Connection("https://docs-demo.solana-mainnet.quiknode.pro/", {
7
    wsEndpoint: "",
8
  });
9
  solanaConnection.onAccountChange(
10
    publicKey,
11
    (updatedAccountInfo, context) =>
12
      console.log("Updated account info: ", updatedAccountInfo),
13
    "confirmed"
14
  );
15
})();
16

1
const web3 = require("@solana/web3.js");
2
(async () => {
3
  const publicKey = new web3.PublicKey(
4
    "E645TckHQnDcavVv92Etc6xSWQaq8zzPtPRGBheviRAk"
5
  );
6
  const solanaConnection = new web3.Connection("https://docs-demo.solana-mainnet.quiknode.pro/", {
7
    wsEndpoint: "",
8
  });
9
  solanaConnection.onAccountChange(
10
    publicKey,
11
    (updatedAccountInfo, context) =>
12
      console.log("Updated account info: ", updatedAccountInfo),
13
    "confirmed"
14
  );
15
})();
16

1
import solana
2
import asyncio
3
from asyncstdlib import enumerate
4
from solana.rpc.websocket_api import connect
5
from solana.publickey import PublicKey
6

7
async def main():
8
    async with connect("") as websocket:
9
        await websocket.account_subscribe(PublicKey('E645TckHQnDcavVv92Etc6xSWQaq8zzPtPRGBheviRAk'))
10
        first_resp = await websocket.recv()
11
        subscription_id = first_resp.result
12
        async for idx, msg in enumerate(websocket):
13
            print(msg)
14

15
asyncio.run(main())

1
import solana
2
import asyncio
3
from asyncstdlib import enumerate
4
from solana.rpc.websocket_api import connect
5
from solana.publickey import PublicKey
6

7
async def main():
8
    async with connect("") as websocket:
9
        await websocket.account_subscribe(PublicKey('E645TckHQnDcavVv92Etc6xSWQaq8zzPtPRGBheviRAk'))
10
        first_resp = await websocket.recv()
11
        subscription_id = first_resp.result
12
        async for idx, msg in enumerate(websocket):
13
            print(msg)
14

15
asyncio.run(main())

1
wscat -c  \ 
2
# 等待连接 
3
{"id":1,"jsonrpc":"2.0","method":"accountSubscribe","params":["E645TckHQnDcavVv92Etc6xSWQaq8zzPtPRGBheviRAk",{"encoding": "jsonParsed"}]}
4

1
wscat -c  \ 
2
# 等待连接 
3
{"id":1,"jsonrpc":"2.0","method":"accountSubscribe","params":["E645TckHQnDcavVv92Etc6xSWQaq8zzPtPRGBheviRAk",{"encoding": "jsonParsed"}]}
4

回复

1
{
2
  “jsonrpc”: "2.0",
3
  "result": 23784,
4
  "id": 1
5
}

1
{
2
  “jsonrpc”: "2.0",
3
  "result": 23784,
4
  "id": 1
5
}

还没有账号吗？

只需几秒钟即可创建您的 Quicknode 端点，并开始构建

免费开始使用