programSubscribe 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.

參數

program_id

字串

載入中...

物件

物件

載入中...

commitment

字串

載入中...

finalized

載入中...

confirmed

載入中...

processed

載入中...

encoding

字串

載入中...

filters

字串

載入中...

退貨

結果

整數

載入中...

Notification Format:

載入中...

請求

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

1
const web3 = require("@solana/web3.js");
2
(async () => {
3
  const publicKey = new web3.PublicKey(
4
    "22Y43yTVxuUkoRKdm9thyRhQ3SdgQS7c7kB6UNCiaczD"
5
  );
6
  const solanaConnection = new web3.Connection("https://docs-demo.solana-mainnet.quiknode.pro/", {
7
    wsEndpoint: "",
8
  });
9
  solanaConnection.onProgramAccountChange(
10
    publicKey,
11
    (updatedProgramInfo, context) =>
12
      console.log("Updated program info: ", updatedProgramInfo),
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.program_subscribe(PublicKey('22Y43yTVxuUkoRKdm9thyRhQ3SdgQS7c7kB6UNCiaczD'))
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.program_subscribe(PublicKey('22Y43yTVxuUkoRKdm9thyRhQ3SdgQS7c7kB6UNCiaczD'))
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
{
4
  "jsonrpc": "2.0",
5
  "id": 1,
6
  "method": "programSubscribe",
7
  "params": [
8
    "11111111111111111111111111111111",
9
    {
10
      "encoding": "base64",
11
      "commitment": "finalized"
12
    }
13
  ]
14
}

1
wscat -c  \ 
2
# 等待連線 
3
{
4
  "jsonrpc": "2.0",
5
  "id": 1,
6
  "method": "programSubscribe",
7
  "params": [
8
    "11111111111111111111111111111111",
9
    {
10
      "encoding": "base64",
11
      "commitment": "finalized"
12
    }
13
  ]
14
}

回應

1
{
2
  "jsonrpc": "2.0",
3
  "result": 24040,
4
  "id": 1
5
}

1
{
2
  "jsonrpc": "2.0",
3
  "result": 24040,
4
  "id": 1
5
}

還沒有帳號嗎？

只需幾秒鐘即可建立您的 Quicknode 端點，並開始建置

立即免費開始使用