구독

별도의 서버

On a deployment behind a reverse proxy, both /ws and /ws/ are served as two separate locations with no redirect between them: a WebSocket client mostly does not follow a 301 on its handshake, so whichever spelling was redirected would simply fail to connect.

핸드셰이크

eth_subscribe와 pickle_subscribe는 서로 바꿔 쓸 수 있게 받아들여지며 똑같이 동작합니다.

// ->
{"jsonrpc":"2.0","id":1,"method":"pickle_subscribe","params":["miniBlocks"]}

// <-
{"jsonrpc":"2.0","id":1,"result":"0x1"}

// <- then, per event
{"jsonrpc":"2.0","method":"eth_subscription","params":{"subscription":"0x1","result":{…}}}

• Subscription ids come from a per-connection counter starting at 1, so two connections both see 0x1. Do not treat an id as globally unique.
• Notifications always arrive under the method name eth_subscription, even for a subscription opened as pickle_subscribe. Unwrap the payload at params.result.
• eth_unsubscribe and pickle_unsubscribe both return a boolean: true if the id was found on this connection, false otherwise.

네 가지 종류

실제 예제

미니블록 스트림이며, 퍼스트파티 피드가 쓰는 폴백까지 함께 보입니다. 폴백은 중요합니다. 소켓이 끊기는 것은 정상이고, 폴링 경로가 빈틈 없이 따라잡는 방법입니다.

// WS_URL: wss://rpc.picklechain.xyz/ws/ on the public testnet, or a node of your own.
// The /ws path is required - an upgrade at the bare origin answers 405.
const socket = new WebSocket(WS_URL);

socket.addEventListener("open", () => {
  socket.send(JSON.stringify({
    jsonrpc: "2.0", id: 1, method: "pickle_subscribe", params: ["miniBlocks"],
  }));
});

socket.addEventListener("message", (event) => {
  const message = JSON.parse(event.data);
  // The subscribe reply carries an id; notifications carry params.result.
  if (!message.params) return;
  const mini = message.params.result;

  // Decimal numbers, not hex quantities - and microseconds, not seconds.
  console.log(mini.number, mini.transactions.length, mini.timestampUs);
});

// A slow handler is DROPPED from the stream rather than buffered, so do the
// work elsewhere and keep this callback cheap.

소켓이 닫히면 마지막으로 본 높이부터 pickle_miniBlockNumber를 폴링한 다음 pickle_getMiniBlockByNumber를 부르십시오. 따라잡기에는 상한을 두십시오 - 레퍼런스 클라이언트는 한 번에 최대 100개를 가져옵니다 - 그러지 않으면 긴 단절이 공유된 무거운 읽기 예산을 상대로 한 요청 폭주로 바뀝니다.

한도와 드롭 정책

이 한도들 중 환경 변수로 조정할 수 있는 것은 없으며, 연결 상한은 accept 시점에 강제됩니다. 257번째 연결은 오류 프레임 없이 닫히므로, 거부가 아니라 네트워크 장애처럼 보입니다.

소켓 위의 일반 호출

Any frame that is not a subscribe or unsubscribe is forwarded to the same handler the HTTP port uses, so every method in the reference is callable over the socket.