常见问题 - Geyser gRPC 流

问：你们的节点位于哪些区域？

• 法兰克福（FRA）
• 阿姆斯特丹（AMS）
• 伦敦（LON）
• 纽约（NY）
• 东京（TY）
• 新加坡（SGP）
• 悉尼（SYD）

问：延迟显示 9999ms 且选择了非最优区域。该怎么办？

问：我已经将 IP 加入白名单，但仍然无法连接。应该检查什么？

• HTTPS 端点：使用仪表盘中选择的端点和 443 端口。
• HTTP 端点：使用仪表盘中选择的端点和 80 端口。
• 使用仪表盘中显示的 URL，并采用 https:// 或 http:// 格式。

问：我以前只用过 WebSocket。我可以使用 gRPC 吗？有示例吗？

slv check grpc --endpoint <YOUR_ENDPOINT> --token none

slv check grpc --endpoint <YOUR_ENDPOINT> --token none

问：我可以注册两个 IP 地址吗？

问：过滤器有限制吗？

问：重新连接前应如何收集 gRPC 错误？

问：哪些 gRPC 错误会让我的连接进入暂停，客户端应在何时停止重新连接？

• ERPC 以 ERPC_GRPC_INVALID_ARGUMENT、STREAM_GUARD_SHAPE_BLOCKS 或 STREAM_GUARD_SHAPE_ACCOUNTS_ALL 拒绝的每一个 Subscribe 请求，包括第一个。第一条计入的错误是警告，不会启动暂停。
• STREAM_GUARD_SLOW_READER，但投递滞后发生在 ERPC 一侧时除外：此时 ERPC 会关闭流但不计入，错误中也不带重试时间。

• 警告：不暂停。
• 暂停 60 秒。
• 暂停 300 秒。
• 暂停 1800 秒。
• 暂停 86400 秒（24 小时）。这是最后一个阶段：在此阶段，每一条计入的错误都会再启动一次 86400 秒的暂停。

• 启动暂停的错误会带有 Retry after N seconds. 以及 header x-erpc-retry-after-seconds 和 x-erpc-retry-at（Unix 秒）。警告不带重试时间。
• 当启动暂停的正是一条计入的被拒绝请求时，它返回的是 STREAM_GUARD_SHAPE_REJECT_PENALTY 和 ResourceExhausted (8)，而不是它自己的错误码。
• 在慢速读取暂停或出口流量暂停期间，重新连接会收到 STREAM_GUARD_PENALTY_ACTIVE 和剩余时间。
• 在由被拒绝的请求启动的暂停期间，新的连接会被立即关闭，既没有 gRPC 状态，也没有 ERPC 错误码。在仍处于打开状态的连接上，请求可能在该连接被关闭前再次收到 STREAM_GUARD_SHAPE_REJECT_PENALTY 和剩余时间。客户端可能再也看不到结束时间，因此必须从第一条带有它的错误中保存 x-erpc-retry-at。

问：慢速接收端被断开时，STREAM_GUARD_SLOW_READER 与 ResourceExhausted (8) 表示什么？

问：为什么我的 gRPC 流速度一直停在同一水平，而且越来越落后？

• 16 KiB 的流窗口：稳定在约 2.7 MB/s（16 KiB 除以 6 ms）；投递滞后每秒增长约 0.6 秒，45 秒时达到 26 秒。
• 两个窗口均为 16 MiB：投递滞后最大为 14 ms。

1. 将流的速度和投递滞后与上述模式对比。
2. 测量往返时间。将流的速度乘以往返时间来估算窗口（2.7 MB/s 乘以 6 ms 约为 16 KB）。
3. 检查客户端的两个窗口是否设置了较小的值，或者是否关闭了自动增长（库自动调大窗口）。
4. 检查 TCP 接收缓冲区。在 Linux 上运行 sysctl net.ipv4.tcp_rmem net.core.rmem_max，并查看您的应用是否设置了 SO_RCVBUF；设置它会关闭自动调整大小。
5. 检查中间所有环节的窗口和缓冲区。
6. 如果速度没有上限、只有滞后在增长，说明接收之后的处理较慢。上方的问题“慢速接收端被断开时，STREAM_GUARD_SLOW_READER 与 ResourceExhausted (8) 表示什么？”说明了如何让接收循环只负责读取，并把繁重的工作移到有界队列。

// 两个窗口固定为 16 MiB；保持 http2_adaptive_window 关闭。
let client = GeyserGrpcClient::build_from_shared(endpoint)?
    .tls_config(ClientTlsConfig::new().with_native_roots())?
    .initial_stream_window_size(16 * 1024 * 1024)
    .initial_connection_window_size(16 * 1024 * 1024)
    .connect()
    .await?;

// 两个窗口固定为 16 MiB；保持 http2_adaptive_window 关闭。
let client = GeyserGrpcClient::build_from_shared(endpoint)?
    .tls_config(ClientTlsConfig::new().with_native_roots())?
    .initial_stream_window_size(16 * 1024 * 1024)
    .initial_connection_window_size(16 * 1024 * 1024)
    .connect()
    .await?;

// 已关闭自适应窗口，因此使用这些固定大小。
const client = new Client(endpoint, undefined, {
  grpcInitialStreamWindowSize: 16 * 1024 * 1024,
  grpcInitialConnectionWindowSize: 16 * 1024 * 1024,
  grpcHttp2AdaptiveWindow: false,
})

// 已关闭自适应窗口，因此使用这些固定大小。
const client = new Client(endpoint, undefined, {
  grpcInitialStreamWindowSize: 16 * 1024 * 1024,
  grpcInitialConnectionWindowSize: 16 * 1024 * 1024,
  grpcHttp2AdaptiveWindow: false,
})

// 需要 @grpc/grpc-js 1.14 或更高版本才能同时调大两个窗口。
const client = new Client(endpoint, undefined, {
  'grpc-node.flow_control_window': 16 * 1024 * 1024,
})

// 需要 @grpc/grpc-js 1.14 或更高版本才能同时调大两个窗口。
const client = new Client(endpoint, undefined, {
  'grpc-node.flow_control_window': 16 * 1024 * 1024,
})

// 两个都设置；这样也会关闭窗口的自动增长。
conn, err := grpc.NewClient(target,
	grpc.WithTransportCredentials(creds),
	grpc.WithInitialWindowSize(16<<20),
	grpc.WithInitialConnWindowSize(16<<20),
)

// 两个都设置；这样也会关闭窗口的自动增长。
conn, err := grpc.NewClient(target,
	grpc.WithTransportCredentials(creds),
	grpc.WithInitialWindowSize(16<<20),
	grpc.WithInitialConnWindowSize(16<<20),
)

# 如果 options 中包含 ("grpc.http2.bdp_probe", 0)，请将其移除。
channel = grpc.secure_channel(target, creds, options=[
    ("grpc.http2.lookahead_bytes", 16 * 1024 * 1024),
])

# 如果 options 中包含 ("grpc.http2.bdp_probe", 0)，请将其移除。
channel = grpc.secure_channel(target, creds, options=[
    ("grpc.http2.lookahead_bytes", 16 * 1024 * 1024),
])

问：STREAM_GUARD_EGRESS_BUDGET 与 ResourceExhausted (8) 表示什么？

问：STREAM_GUARD_PENALTY_ACTIVE 与 ResourceExhausted (8) 表示什么？

问：STREAM_GUARD_SHAPE_BLOCKS 与 PermissionDenied (7) 表示什么？

问：STREAM_GUARD_SHAPE_ACCOUNTS_ALL 与 PermissionDenied (7) 表示什么？

问：STREAM_GUARD_SHAPE_REJECT_PENALTY 与 ResourceExhausted (8) 表示什么？

问：STREAM_ADMISSION_LIMIT_REACHED 与 ResourceExhausted (8) 表示什么？

问：STREAM_ADMISSION_IP_NOT_ADMITTED 与 PermissionDenied (7) 表示什么？

问：STREAM_ADMISSION_SOURCE_UNAVAILABLE 与 Unavailable (14) 表示什么？

问：STREAM_ADMISSION_SNAPSHOT_UNAVAILABLE 与 Unavailable (14) 表示什么？

问：ERPC_GRPC_INVALID_ARGUMENT 与 InvalidArgument (3) 表示什么？

问：当 gRPC 返回其他非零状态时，ERPC_GRPC_REQUEST_FAILED 表示什么？

问：推荐哪个区域？

问：我需要约 400ms 或更低的延迟。

• 对 Ping 值的现实理解：Ping 值表示理想条件，不反映流式通信中的实际延迟，后者通常约为 ping 延迟的 5 倍。例如，跨洲 100ms 的 ping 实际上会导致约 500ms 的延迟。因此，必须在同一区域内建立基础设施才能实现约 400ms 的延迟。
  • 典型 Ping 值参考：
    • 同一网络：~0.1ms
    • 私有网络互联（PNI）：~0.2ms
    • 同一数据中心：~0.3ms
    • 同一城市：~1ms
    • 邻国：~5–10ms
    • 跨洲：~100–300ms
• 避免平均延迟的陷阱：Solana 验证者分布在全球各地，且 Leader 调度在每个 epoch 随机变化。依赖平均延迟来实现约 400ms 是不切实际的。相反，您应该精确跟踪特定区域的验证者调度，以识别延迟最低的 slot。要持续实现最小延迟，需要在所有相关区域部署基础设施。在同一区域内，数据获取可以在几十毫秒内完成，传输可以在几毫秒内完成。
• 跟踪 Leader 调度：借助 ERPC Leader Slot API（getLeaderSlots），监控您所在区域的 Leader 验证者调度。 它会返回即将到来的 Leader 调度、当前 epoch 的质押权重、估算的验证者地理位置以及参考 ping 值，让您能赶在延迟最低的 slot 到来之前识别出它们，并将其作为目标。 公共地图型数据源和原生 RPC API 适合了解网络整体分布，但精度不足以用于判断执行时机。Leader Slot API 补足了路由和交易判断所需的粒度。
  • ERPC Leader Slot API 文档
  • ERPC Web Dashboard

问：如何实现零区块（零 slot）交易？

• 识别机会区域：Solana 验证者分布在全球各地，物理上不可能对每个 slot 都实现最优延迟。因此，监控您基础设施所在区域的验证者 Leader 调度，并识别最有利的机会区域。在多个区域部署基础设施也可能有利。例如，法兰克福是关键区域，因为其验证者密度高，Leader 选择更频繁，交易机会更多。
  借助 ERPC Leader Slot API（getLeaderSlots），查询即将到来的 Leader 调度、当前 epoch 的质押权重、估算的验证者地理位置数据以及参考 ping 值，其精度远高于公共地图型数据源或原生 RPC API。这样，您就能在相应 slot 到来之前预先标出机会区域，并执行接近零延迟的交易。
  • ERPC Leader Slot API 文档
  • ERPC Web Dashboard
• 部署专用节点：如果您难以竞争，请考虑部署专用节点。共享节点由于其他用户的流量会产生延迟，因此不推荐使用。此外，将您的专用节点放置在与应用程序相同的网络中可以显著降低网络延迟并优化性能。

问：我可以使用特定端点吗？

问：我收到了 401 错误。为什么？

问：我收到了 429 错误。为什么？

问：为什么专用端点更快？

问：签约后价格会被上调吗？

问：我想用加密货币支付

问：如何实现尽可能低的延迟？

问：延迟是怎样的？

• Solana Stream SDK - ValidatorsDAO GitHub
• SLV（简体中文）

问：这个 RPC（gRPC、Shreds）比其他的快吗？

问：哪个方案提供最快的性能？

问：我遇到了高延迟。我该怎么办？

问：WebSockets、gRPC 和 Shreds 哪个最快？

问：延迟不如预期。