WebSocketを利用する

Alchemy

WebSockets

クエリ

JavaScript

初級

Elan Halpern

Alchemy docs

2020年12月1日

10 分の読書

ページを編集

このガイドでは、初級者向けに、WebSocketとAlchemyを使ってイーサリアムブロックチェーンにリクエストを送信する方法を学びます。

(opens in a new tab)WebSocketとHTTPの比較

HTTPとは異なり、WebSocketでは特定の情報が必要な場合にリクエストを継続的に実行する必要はありません。 WebSocketでは、正しく設定されていれば、ネットワーク接続が継続され、変更をリッスンすることができます。

どのネットワーク接続でも同様ですが、WebSocketが中断なしに永続的にオープンであると想定すべきではありませんが、手動で切断された接続に適切に対処し、再接続するのは手間がかかる場合があります。 WebSocketのもう一つの欠点は、応答にはエラーメッセージのみが含まれ、HTTPステータスコードを取得できないという点です。

Alchemy Web3 (opens in a new tab)は、WebSocketの障害と再試行の処理を、設定不要で自動的に追加します。

試してみる

WebSocketをテストする最も簡単な方法は、wscat (opens in a new tab)のようなWebSocketリクエストを行うためのコマンドラインツールをインストールすることです。 wscatを使って、次のようにリクエストを送ります：

注：Alchemyアカウントをお持ちの場合は、demoをご自身のAPIキーに置き換えることができます。こちらで無料のAlchemyアカウントにサインアップしてください！ (opens in a new tab)

wscat -c wss://eth-mainnet.ws.alchemyapi.io/ws/demo

>  {"jsonrpc":  "2.0", "id": 0, "method":  "eth_gasPrice"}

<  {"jsonrpc":  "2.0", "result":  "0xb2d05e00", "id": 0}

WebSocketの使用方法

まず、アプリにWebSocketのURLを入力してWebSocketを開きます。アプリのWebSocket URLは、ダッシュボード (opens in a new tab)でアプリのページを開き、「View Key」をクリックして確認できます。アプリのWebSocket用URLはHTTPリクエスト用のURLとは異なっており、両方とも「View Key」で確認できる点に注意してください。

Alchemy APIリファレンス (opens in a new tab)に記載されているAPIはすべて、WebSocket経由で使用できます。これには、HTTP POSTリクエストの本文として送信する場合と同じペイロードを使用しますが、このペイロードをWebSocket経由で送信します。

Web3を使用

Web3のようなクライアント向けライブラリを使用する場合、WebSocketへの移行は簡単です。 Web3クライアントのインスタンスを作成する際に、HTTP URLではなくWebSocket URLを渡すだけでよいです。以下の例をご覧ください：

const web3 = new Web3("wss://eth-mainnet.ws.alchemyapi.io/ws/your-api-key")

web3.eth.getBlockNumber().then(console.log) // -> 7946893

サブスクリプションAPI

WebSocket経由で接続する場合、eth_subscribeとeth_unsubscribeの2つの追加メソッドを使用できます。これらのメソッドを使用することで、特定のイベントをリッスンし、すぐに通知を受け取ることができるようになります。

`eth_subscribe`

特定のイベントを対象とする新規のサブスクリプションを作成しましょう。 eth_subscribeの詳細はこちら (opens in a new tab)。

パラメータ

サブスクリプションのタイプ
オプションのパラメータ

最初の引数では、リッスンするイベントのタイプを指定します。 2番目の引数では、最初の引数に依存したオプションを追加します。以下では、説明タイプ、タイプ別のオプション、およびイベントのペイロードについて説明します。

戻り値

サブスクリプションID：このIDは、受信したすべてのイベントに添付され、eth_unsubscribeを使用してサブスクリプションをキャンセルするためにも使用できます。

サブスクリプションイベント

サブスクリプションが有効である場合、以下のフィールドを含むオブジェクトであるイベントが送信されます：

jsonrpc: 常に「2.0」
method: 常に「eth_subscription」
params: 以下のフィールドを持つオブジェクト：
- subscription: このサブスクリプションを作成したeth_subscribe呼び出しによって返されるサブスクリプションID。
- result: サブスクリプションの種類によって内容が異なるオブジェクト。

サブスクリプションの種類

alchemy_newFullPendingTransactions

保留状態に追加されたすべてのトランザクションにつき、トランザクション情報を返します。このサブスクリプションタイプは、標準のWeb3呼び出しweb3.eth.subscribe(\"pendingTransactions\")と同様に保留中のトランザクションをサブスクライブしますが、トランザクションハッシュだけでなく_完全なトランザクション情報_を発行する点で異なります。

例：

>  {"jsonrpc":  "2.0",  "id":  1,  "method":  "eth_subscribe",  "params":  ["alchemy_newFullPendingTransactions"]}

<  {"id":1,"result":"0x9a52eeddc2b289f985c0e23a7d8427c8","jsonrpc":"2.0"}
<  {
      "jsonrpc":"2.0",
      "method":"eth_subscription",
      "params":{
          "result":{
          "blockHash":null,
          "blockNumber":null,
          "from":"0xa36452fc31f6f482ad823cd1cf5515177d57667f",
          "gas":"0x1adb0",
          "gasPrice":"0x7735c4d40",
          "hash":"0x50bff0736c713458c92dd1848d12f3354149be1363123dae35e94e0f2a9d56bf",
"input":"0xa9059cbb0000000000000000000000000d0707963952f2fba59dd06f2b425ace40b492fe0000000000000000000000000000000000000000000015b1111266cfca100000",
          "nonce":"0x0",
          "to":"0xea38eaa3c86c8f9b751533ba2e562deb9acded40",
          "transactionIndex":null,
          "value":"0x0",
          "v":"0x26",
          "r":"0x195c2c1ed126088e12d290aa93541677d3e3b1d10f137e11f86b1b9227f01e3b",
          "s":"0x60fc4edbf1527832a2a36dbc1e63ed6193a6eee654472fbebbf88ef1750b5344"},
          "subscription":"0x9a52eeddc2b289f985c0e23a7d8427c8"
      }
  }

newHeads

ブロックチェーンの再編成時も含む、ブロックチェーンに新たなヘッダーが追加された際に常にイベントを発行します。

このサブスクリプションでは、ブロックチェーンの再編成が実行された場合に、新たなチェーンに対するすべてのヘッダーを含むイベントが発行されます。特に、同じ高さを持つ複数のヘッダーが発行される場合があるため、このような状況が発生した場合は、より後ろのヘッダーを再編成後の適切なヘッダーと見なす必要があります。

例：

>  {"jsonrpc":  "2.0",  "id":  1,  "method":  "eth_subscribe",  "params":  ["newHeads"]}

<  {"jsonrpc":"2.0","id":2,"result":"0x9ce59a13059e417087c02d3236a0b1cc"}
<  {
  "jsonrpc":  "2.0",
  "method":  "eth_subscription",
  "params":  {
      "result":  {
          "extraData":  "0xd983010305844765746887676f312e342e328777696e646f7773",
          "gasLimit":  "0x47e7c4",
          "gasUsed":  "0x38658",
          "logsBloom":
"0x00000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000",
          "nonce":  "0x084149998194cc5f",
          "number":  "0x1348c9",
          "parentHash":  "0x7736fab79e05dc611604d22470dadad26f56fe494421b5b333de816ce1f25701",
          "receiptRoot":  "0x2fab35823ad00c7bb388595cb46652fe7886e00660a01e867824d3dceb1c8d36",
          "sha3Uncles":  "0x1dcc4de8dec75d7aab85b567b6ccd41ad312451b948a7413f0a142fd40d49347",
          "stateRoot":  "0xb3346685172db67de536d8765c43c31009d0eb3bd9c501c9be3229203f15f378",
          "timestamp":  "0x56ffeff8",
          "transactionsRoot":  "0x0167ffa60e3ebc0b080cdb95f7c0087dd6c0e61413140e39d94d3468d7c9689f"
      },
  "subscription":  "0x9ce59a13059e417087c02d3236a0b1cc"
  }
}

logs

新たに追加されたブロックのうち、指定したフィルター条件に合致した部分のログを発行します。

チェーンの再編成が発生した場合、古いチェーンのブロックの一部であるログは、removedプロパティがtrueに設定されて再度発行されます。さらに新しいチェーン上のブロックに含まれるログも発行されるため、再編成時には、同一のトランザクションのログが複数回表示される場合があります。

パラメータ

以下のフィールドを持つオブジェクトです：
- address (オプション)：アドレスを表す文字列、またはそのような文字列の配列のいずれか。
  - これらのアドレスのいずれかで作成したログのみが発行されます。
- topics: トピック指定子の配列。
  - 各トピック指定子は、null、トピックを表す文字列、または文字列の配列のいずれかです。
  - nullでない配列内の各位置は、発行されるログを、その位置に指定されたトピックのいずれかを持つもののみに制限します。

トピック仕様の例：

[]: すべてのトピックが許可されます。
[A]: 最初の位置にA (以降は任意)。
[null, B]: 最初の位置は任意、2番目の位置にB (以降は任意)。
[A, B]: 最初の位置にA、2番目の位置にB (以降は任意)。
[[A, B], [A, B]]: 最初の位置に(AまたはB)、2番目の位置に(AまたはB) (以降は任意)。

例：

>  {"jsonrpc":  "2.0",  "id":  1,  "method":  "eth_subscribe",  "params":  ["logs",  {"address":  "0x8320fe7702b96808f7bbc0d4a888ed1468216cfd",  "topics":  ["0xd78a0cb8bb633d06981248b816e7bd33c2a35a6089241d099fa519e361cab902"]}]}

<  {"jsonrpc":"2.0","id":2,"result":"0x4a8a4c0517381924f9838102c5a4dcb7"}
<  {
  "jsonrpc":  "2.0",
  "method":  "eth_subscription",
  "params":  {
      "subscription":  "0x4a8a4c0517381924f9838102c5a4dcb7",
      "result":  {
          "address":  "0x8320fe7702b96808f7bbc0d4a888ed1468216cfd",
          "blockHash":  "0x61cdb2a09ab99abf791d474f20c2ea89bf8de2923a2d42bb49944c8c993cbf04",
          "blockNumber":  "0x29e87",
          "data": "0x00000000000000000000000000000000000000000000000000000000000000010000000000000000000000000000000000000000000000000000000000000003",
          "logIndex":"0x0",
          "topics":["0xd78a0cb8bb633d06981248b816e7bd33c2a35a6089241d099fa519e361cab902"],
          "transactionHash":  "0xe044554a0a55067caafd07f8020ab9f2af60bdfe337e395ecd84b4877a3d1ab4",
          "transactionIndex":  "0x0"
      }
  }
}

`eth_unsubscribe`

新たにイベントが送信されないように、既存のサブスクリプションを取り消します。

パラメータ

以前にeth_subscribe呼び出しから返されたサブスクリプションID。

戻り値

サブスクリプションのキャンセルに成功した場合はtrue、指定されたIDを持つサブスクリプションが存在しなかった場合はfalse。

例：

リクエスト

curl https://eth-mainnet.alchemyapi.io/v2/your-api-key
-X POST
-H "Content-Type: application/json"
-d '{"id": 1, "method": "eth_unsubscribe", "params": ["0x9cef478923ff08bf67fde6c64013158d"]}'

結果

{
  "jsonrpc": "2.0",
  "id": 1,
  "result": true
}

Alchemyに無料でサインアップ (opens in a new tab)し、ドキュメント (opens in a new tab)をご覧ください。最新のニュースについては、Twitter (opens in a new tab)でフォローしてください。

ページの最終更新: 2026年3月3日

+10

WebSocketを利用する

(opens in a new tab)WebSocketとHTTPの比較

試してみる

WebSocketの使用方法

Web3を使用

サブスクリプションAPI

eth_subscribe

パラメータ

戻り値

サブスクリプションイベント

サブスクリプションの種類

eth_unsubscribe

このチュートリアルは役に立ちましたか？

`eth_subscribe`

`eth_unsubscribe`