subscribe gRPC Method - Solana gRPC

Solana gRPC is included with Scale and Business plans. On Build and Accelerate plans, it remains available via the Solana gRPC add-on.

参数

该方法不接受任何参数

退货

结果

对象

正在加载...

请求

1
包 main
2

3
导入 (
4
	"上下文"
5
	"crypto/tls"
6
	"fmt"
7
	"日志"
8
	"time"
9
	"github.com/mr-tron/base58"
10
	"encoding/json"
11

12
	pb "yellowstone/proto"
13

14
	"google.golang.org/grpc"
15
	"google.golang.org/grpc/credentials"
16
	"google.golang.org/grpc/encoding/gzip"
17
	"google.golang.org/grpc/keepalive"
18
)
19

20
// Quicknode endpoints consist of two crucial components: the endpoint name and the corresponding token
21
// For eg: QN Endpoint: https://docs-demo.solana-mainnet.quiknode.pro/abcde123456789
22
// endpoint will be: docs-demo.solana-mainnet.quiknode.pro:10000  {10000 is the port number for gRPC}
23
// token will be : abcde123456789
24

25
var (
26
	endpoint = "YOUR_QN_ENDPOINT:10000"
27
	token    = "YOUR_TOKEN_NUMBER"
28
)
29

30
func main() {
31
	opts := []grpc.DialOption{
32
		grpc.WithTransportCredentials(凭证.NewTLS(&tls.配置{})),
33
		grpc.WithKeepaliveParams(kacp),
34
		grpc.WithDefaultCallOptions(grpc.MaxCallRecvMsgSize(1024*1024*1024), grpc.UseCompressor(gzip.Name)),
35
		grpc.WithPerRPCCredentials(tokenAuth{token: token}),
36
	}
37

38
	conn, err := grpc.NewClient(endpoint, opts...)
39
	如果 err != nil {
40
		log.Fatalf("Failed to connect: %v", err)
41
	}
42
	defer conn.Close()
43

44
	client := pb.NewGeyserClient(conn)
45

46
    commitment := pb.CommitmentLevel_FINALIZED
47
    subReq := &pb.SubscribeRequest{
48
        Commitment: &commitment,
49
        BlocksMeta: map[string]*pb.SubscribeRequestFilterBlocksMeta{
50
            "blocks": {},
51
        },
52
        Slots: map[string]*pb.SubscribeRequestFilterSlots{
53
            "slots": {},
54
        },
55
    }
56

57
    d, _ := json.Marshal(subReq)
58
    fmt.Printf("Subscription request: %s\n", string(d))
59

60
    stream, err := client.Subscribe(context.Background())
61
    if err != nil {
62
        fmt.Printf("Failed to subscribe to yellowstone: %v\n", err)
63
        返回
64
    }
65

66
    if err = stream.Send(subReq); err != nil {
67
        fmt.Printf("Failed to send subscription request: %v\n", err)
68
        返回
69
    }
70

71
    for {
72
        m, err := stream.Recv()
73
        if err != nil {
74
            fmt.Printf("Failed to receive yellowstone message: %v\n", err)
75
            返回
76
        }
77

78
        switch {
79
        case m.GetBlock() != nil:
80
            fmt.Printf("Block: %d\n", m.GetBlock().GetBlockHeight())
81
        case m.GetBlockMeta() != nil:
82
            fmt.Printf("BlockMeta: %d\n", m.GetBlockMeta().GetBlockHeight())
83
        case m.GetTransaction() != nil:
84
            fmt.Printf("Transaction: %s\n", base58.Encode(m.GetTransaction().GetTransaction().GetSignature()))
85
        case m.GetSlot() != nil:
86
            fmt.Printf("Slot: %d\n", m.GetSlot().GetSlot())
87
        }
88
    }
89
}

1
包 main
2

3
导入 (
4
	"上下文"
5
	"crypto/tls"
6
	"fmt"
7
	"日志"
8
	"time"
9
	"github.com/mr-tron/base58"
10
	"encoding/json"
11

12
	pb "yellowstone/proto"
13

14
	"google.golang.org/grpc"
15
	"google.golang.org/grpc/credentials"
16
	"google.golang.org/grpc/encoding/gzip"
17
	"google.golang.org/grpc/keepalive"
18
)
19

20
// Quicknode endpoints consist of two crucial components: the endpoint name and the corresponding token
21
// For eg: QN Endpoint: https://docs-demo.solana-mainnet.quiknode.pro/abcde123456789
22
// endpoint will be: docs-demo.solana-mainnet.quiknode.pro:10000  {10000 is the port number for gRPC}
23
// token will be : abcde123456789
24

25
var (
26
	endpoint = "YOUR_QN_ENDPOINT:10000"
27
	token    = "YOUR_TOKEN_NUMBER"
28
)
29

30
func main() {
31
	opts := []grpc.DialOption{
32
		grpc.WithTransportCredentials(凭证.NewTLS(&tls.配置{})),
33
		grpc.WithKeepaliveParams(kacp),
34
		grpc.WithDefaultCallOptions(grpc.MaxCallRecvMsgSize(1024*1024*1024), grpc.UseCompressor(gzip.Name)),
35
		grpc.WithPerRPCCredentials(tokenAuth{token: token}),
36
	}
37

38
	conn, err := grpc.NewClient(endpoint, opts...)
39
	如果 err != nil {
40
		log.Fatalf("Failed to connect: %v", err)
41
	}
42
	defer conn.Close()
43

44
	client := pb.NewGeyserClient(conn)
45

46
    commitment := pb.CommitmentLevel_FINALIZED
47
    subReq := &pb.SubscribeRequest{
48
        Commitment: &commitment,
49
        BlocksMeta: map[string]*pb.SubscribeRequestFilterBlocksMeta{
50
            "blocks": {},
51
        },
52
        Slots: map[string]*pb.SubscribeRequestFilterSlots{
53
            "slots": {},
54
        },
55
    }
56

57
    d, _ := json.Marshal(subReq)
58
    fmt.Printf("Subscription request: %s\n", string(d))
59

60
    stream, err := client.Subscribe(context.Background())
61
    if err != nil {
62
        fmt.Printf("Failed to subscribe to yellowstone: %v\n", err)
63
        返回
64
    }
65

66
    if err = stream.Send(subReq); err != nil {
67
        fmt.Printf("Failed to send subscription request: %v\n", err)
68
        返回
69
    }
70

71
    for {
72
        m, err := stream.Recv()
73
        if err != nil {
74
            fmt.Printf("Failed to receive yellowstone message: %v\n", err)
75
            返回
76
        }
77

78
        switch {
79
        case m.GetBlock() != nil:
80
            fmt.Printf("Block: %d\n", m.GetBlock().GetBlockHeight())
81
        case m.GetBlockMeta() != nil:
82
            fmt.Printf("BlockMeta: %d\n", m.GetBlockMeta().GetBlockHeight())
83
        case m.GetTransaction() != nil:
84
            fmt.Printf("Transaction: %s\n", base58.Encode(m.GetTransaction().GetTransaction().GetSignature()))
85
        case m.GetSlot() != nil:
86
            fmt.Printf("Slot: %d\n", m.GetSlot().GetSlot())
87
        }
88
    }
89
}

1
import Client, { CommitmentLevel, SubscribeRequest, SubscribeUpdate, SubscribeUpdateTransaction } from "@triton-one/yellowstone-grpc";
2

3
// Quicknode endpoints consist of two crucial components: the endpoint name and the corresponding token
4
// For eg: QN Endpoint: https://docs-demo.solana-mainnet.quiknode.pro/abcde123456789
5
// endpoint will be: docs-demo.solana-mainnet.quiknode.pro:10000  {10000 is the port number for gRPC}
6
// token will be : abcde123456789
7

8
const ENDPOINT = "YOUR_QN_ENDPOINT:10000";
9
const TOKEN = "YOUR_TOKEN_NUMBER";
10

11
async 函数 main() {
12
    const client = new Client(ENDPOINT, TOKEN, {});
13

14
    const commitment = CommitmentLevel.CONFIRMED;
15

16
    try {
17
        const stream = await client.subscribe();
18

19
        // Set up error and end handlers
20
        stream.on("error", (error) => {
21
            console.error("Stream error:", error);
22
            stream.end();
23
        });
24

25
        stream.on("end", () => {
26
            console.log("Stream ended");
27
        });
28

29
        // Handle incoming data
30
        stream.on("data", (data: SubscribeUpdate) => {
31
            handleSubscribeUpdate(data);
32
        });
33

34
        // Create subscription request
35
        const request: SubscribeRequest = {
36
            slots: { client: { filterByCommitment: true } },
37
            transactions: {
38
                client: {
39
                    vote: false,
40
                    failed: false,
41
                    signature: undefined,
42
                    accountInclude: [],
43
                    accountExclude: [],
44
                    accountRequired: [],
45
                },
46
            },
47
            commitment: commitment,
48
            accounts: {},
49
            transactionsStatus: {},
50
            entry: {},
51
            blocks: {},
52
            blocksMeta: {},
53
            accountsDataSlice: [],
54
            ping: undefined,
55
        };
56

57
        // Send subscription request
58
        await new Promise<void>((resolve, reject) => {
59
            stream.write(request, (err: Error | null | undefined) => {
60
                if (err) {
61
                    reject(err);
62
                } else {
63
                    resolve();
64
                }
65
            });
66
        });
67

68
        console.log("Subscription started. Waiting for events...");
69

70
        // Keep the script running
71
        await new Promise(() => {});
72

73
    } catch (error) {
74
        console.error("Error in subscription process:", error);
75
    }
76
}
77

78
function handleSubscribeUpdate(data: SubscribeUpdate) {
79
    if ("slot" in data) {
80
        console.log("Slot update:", data.slot);
81
    } else if ("transaction" in data) {
82
        const transaction = data.transaction as SubscribeUpdateTransaction;
83
        if (transaction && transaction.transaction) {
84
            console.log("Transaction update:", {
85
                signature: Buffer.from(transaction.transaction.signature).toString('base64'),
86
                slot: transaction.slot,
87
            });
88
        }
89
    } else {
90
        console.log("Other update:", data);
91
    }
92
}
93

94
main()
95
    .catch((err) => {
96
        console.error("Unhandled error:", err);
97
        process.exit(1);
98
    });

1
import Client, { CommitmentLevel, SubscribeRequest, SubscribeUpdate, SubscribeUpdateTransaction } from "@triton-one/yellowstone-grpc";
2

3
// Quicknode endpoints consist of two crucial components: the endpoint name and the corresponding token
4
// For eg: QN Endpoint: https://docs-demo.solana-mainnet.quiknode.pro/abcde123456789
5
// endpoint will be: docs-demo.solana-mainnet.quiknode.pro:10000  {10000 is the port number for gRPC}
6
// token will be : abcde123456789
7

8
const ENDPOINT = "YOUR_QN_ENDPOINT:10000";
9
const TOKEN = "YOUR_TOKEN_NUMBER";
10

11
async 函数 main() {
12
    const client = new Client(ENDPOINT, TOKEN, {});
13

14
    const commitment = CommitmentLevel.CONFIRMED;
15

16
    try {
17
        const stream = await client.subscribe();
18

19
        // Set up error and end handlers
20
        stream.on("error", (error) => {
21
            console.error("Stream error:", error);
22
            stream.end();
23
        });
24

25
        stream.on("end", () => {
26
            console.log("Stream ended");
27
        });
28

29
        // Handle incoming data
30
        stream.on("data", (data: SubscribeUpdate) => {
31
            handleSubscribeUpdate(data);
32
        });
33

34
        // Create subscription request
35
        const request: SubscribeRequest = {
36
            slots: { client: { filterByCommitment: true } },
37
            transactions: {
38
                client: {
39
                    vote: false,
40
                    failed: false,
41
                    signature: undefined,
42
                    accountInclude: [],
43
                    accountExclude: [],
44
                    accountRequired: [],
45
                },
46
            },
47
            commitment: commitment,
48
            accounts: {},
49
            transactionsStatus: {},
50
            entry: {},
51
            blocks: {},
52
            blocksMeta: {},
53
            accountsDataSlice: [],
54
            ping: undefined,
55
        };
56

57
        // Send subscription request
58
        await new Promise<void>((resolve, reject) => {
59
            stream.write(request, (err: Error | null | undefined) => {
60
                if (err) {
61
                    reject(err);
62
                } else {
63
                    resolve();
64
                }
65
            });
66
        });
67

68
        console.log("Subscription started. Waiting for events...");
69

70
        // Keep the script running
71
        await new Promise(() => {});
72

73
    } catch (error) {
74
        console.error("Error in subscription process:", error);
75
    }
76
}
77

78
function handleSubscribeUpdate(data: SubscribeUpdate) {
79
    if ("slot" in data) {
80
        console.log("Slot update:", data.slot);
81
    } else if ("transaction" in data) {
82
        const transaction = data.transaction as SubscribeUpdateTransaction;
83
        if (transaction && transaction.transaction) {
84
            console.log("Transaction update:", {
85
                signature: Buffer.from(transaction.transaction.signature).toString('base64'),
86
                slot: transaction.slot,
87
            });
88
        }
89
    } else {
90
        console.log("Other update:", data);
91
    }
92
}
93

94
main()
95
    .catch((err) => {
96
        console.error("Unhandled error:", err);
97
        process.exit(1);
98
    });

还没有账号吗？

endpoint 几秒钟endpoint 创建您的Quicknode endpoint ，并开始构建

免费开始使用