تخطٍ إلى المحتوى الرئيسي

استخدام WebSockets

Alchemy
websockets
الاستعلام
JavaScript
المستوى المبتدئ
Elan Halpern
1 ديسمبر 2020
5 دقيقة قراءة

هذا دليل للمبتدئين حول استخدام WebSockets و Alchemy لإجراء طلبات إلى البلوك تشين الخاص بإيثريوم.

 (opens in a new tab)WebSockets مقابل HTTP

على عكس HTTP، مع WebSockets، لا تحتاج إلى إجراء طلبات مستمرة عندما تريد معلومات محددة. تحافظ WebSockets على اتصال شبكة لك (إذا تم إجراؤه بشكل صحيح) وتستمع إلى التغييرات.

كما هو الحال مع أي اتصال شبكة، يجب ألا تفترض أن WebSocket سيظل مفتوحًا إلى الأبد دون انقطاع، ولكن التعامل الصحيح مع الاتصالات المقطوعة وإعادة الاتصال يدويًا قد يكون من الصعب إجراؤه بشكل صحيح. عيب آخر لـ WebSockets هو أنك لا تحصل على رموز حالة HTTP في الاستجابة، بل تحصل فقط على رسالة الخطأ.

يضيف Alchemy Web3 (opens in a new tab) تلقائيًا معالجة لفشل WebSocket وإعادة المحاولة دون الحاجة إلى أي تكوين.

جربه بنفسك

أسهل طريقة لاختبار WebSockets هي تثبيت أداة سطر أوامر لإجراء طلبات WebSocket مثل wscat (opens in a new tab). باستخدام wscat، يمكنك إرسال الطلبات على النحو التالي:

ملاحظة: إذا كان لديك حساب Alchemy، يمكنك استبدال demo بمفتاح API الخاص بك. سجل للحصول على حساب Alchemy مجاني هنا! (opens in a new tab)

1wscat -c wss://eth-mainnet.ws.alchemyapi.io/ws/demo
2
3>  {"jsonrpc":  "2.0", "id": 0, "method":  "eth_gasPrice"}
4
5<  {"jsonrpc":  "2.0", "result":  "0xb2d05e00", "id": 0}
6

كيفية استخدام WebSockets

للبدء، افتح WebSocket باستخدام عنوان URL الخاص بـ WebSocket لتطبيقك. يمكنك العثور على عنوان URL الخاص بـ WebSocket لتطبيقك عن طريق فتح صفحة التطبيق في لوحة التحكم الخاصة بك (opens in a new tab) والنقر على "View Key". لاحظ أن عنوان URL لتطبيقك الخاص بـ WebSockets يختلف عن عنوان URL الخاص بطلبات HTTP، ولكن يمكن العثور على كليهما بالنقر على "View Key".

أين تجد عنوان URL الخاص بـ WebSocket في لوحة تحكم Alchemy

يمكن استخدام أي من واجهات برمجة التطبيقات (APIs) المدرجة في مرجع Alchemy API (opens in a new tab) عبر WebSocket. للقيام بذلك، استخدم نفس الحمولة التي سيتم إرسالها كجسم لطلب HTTP POST، ولكن بدلاً من ذلك أرسل تلك الحمولة عبر WebSocket.

مع Web3

الانتقال إلى WebSockets أثناء استخدام مكتبة عميل مثل Web3 أمر بسيط. ما عليك سوى تمرير عنوان URL الخاص بـ WebSocket بدلاً من عنوان HTTP عند إنشاء عميل Web3 الخاص بك. على سبيل المثال:

1const web3 = new Web3("wss://eth-mainnet.ws.alchemyapi.io/ws/your-api-key")
2
3web3.eth.getBlockNumber().then(console.log) // -> 7946893 // -> 7946893

واجهة برمجة تطبيقات الاشتراك (Subscription API)

عند الاتصال عبر WebSocket، يمكنك استخدام طريقتين إضافيتين: eth_subscribe و eth_unsubscribe. ستسمح لك هذه الطرق بالاستماع إلى أحداث معينة وتلقي إشعارات فورية.

eth_subscribe

ينشئ اشتراكًا جديدًا لأحداث محددة. تعرف على المزيد حول eth_subscribe (opens in a new tab).

المعلمات

  1. أنواع الاشتراك
  2. معلمات اختيارية

تحدد الوسيطة الأولى نوع الحدث الذي يجب الاستماع إليه. تحتوي الوسيطة الثانية على خيارات إضافية تعتمد على الوسيطة الأولى. يتم وصف أنواع الوصف المختلفة وخياراتها وحمولات الأحداث الخاصة بها أدناه.

المخرجات

معرف الاشتراك: سيتم إرفاق هذا المعرف بأي أحداث مستلمة، ويمكن استخدامه أيضًا لإلغاء الاشتراك باستخدام eth_unsubscribe.

أحداث الاشتراك

أثناء تنشيط الاشتراك، ستتلقى أحداثًا عبارة عن كائنات تحتوي على الحقول التالية:

  • jsonrpc: دائمًا "2.0"
  • method: دائمًا "eth_subscription"
  • params: كائن يحتوي على الحقول التالية:
    • subscription: معرف الاشتراك الذي تم إرجاعه بواسطة استدعاء eth_subscribe الذي أنشأ هذا الاشتراك.
    • result: كائن تختلف محتوياته بناءً على نوع الاشتراك.

أنواع الاشتراك

  1. alchemy_newFullPendingTransactions

يُرجع معلومات المعاملة لجميع المعاملات التي تمت إضافتها إلى حالة الانتظار. يشترك هذا النوع من الاشتراك في المعاملات المعلقة، على غرار استدعاء Web3 القياسي web3.eth.subscribe("pendingTransactions")، ولكنه يختلف في أنه يُصدر معلومات المعاملة الكاملة بدلاً من مجرد التجزئة (هاش) الخاصة بالمعاملة.

مثال:

1>  {"jsonrpc":  "2.0",  "id":  1,  "method":  "eth_subscribe",  "params":  ["alchemy_newFullPendingTransactions"]}
2
3<  {"id":1,"result":"0x9a52eeddc2b289f985c0e23a7d8427c8","jsonrpc":"2.0"}
4<  {
5      "jsonrpc":"2.0",
6      "method":"eth_subscription",
7      "params":{
8          "result":{
9          "blockHash":null,
10          "blockNumber":null,
11          "from":"0xa36452fc31f6f482ad823cd1cf5515177d57667f",
12          "gas":"0x1adb0",
13          "gasPrice":"0x7735c4d40",
14          "hash":"0x50bff0736c713458c92dd1848d12f3354149be1363123dae35e94e0f2a9d56bf",
15"input":"0xa9059cbb0000000000000000000000000d0707963952f2fba59dd06f2b425ace40b492fe0000000000000000000000000000000000000000000015b1111266cfca100000",
16          "nonce":"0x0",
17          "to":"0xea38eaa3c86c8f9b751533ba2e562deb9acded40",
18          "transactionIndex":null,
19          "value":"0x0",
20          "v":"0x26",
21          "r":"0x195c2c1ed126088e12d290aa93541677d3e3b1d10f137e11f86b1b9227f01e3b",
22          "s":"0x60fc4edbf1527832a2a36dbc1e63ed6193a6eee654472fbebbf88ef1750b5344"},
23          "subscription":"0x9a52eeddc2b289f985c0e23a7d8427c8"
24      }
25  }
26
إظهار الكل
  1. newHeads

يُصدر حدثًا في أي وقت تتم فيه إضافة ترويسة جديدة إلى السلسلة، بما في ذلك أثناء إعادة تنظيم السلسلة.

عند حدوث إعادة تنظيم للسلسلة، سيُصدر هذا الاشتراك حدثًا يحتوي على جميع الترويسات الجديدة للسلسلة الجديدة. على وجه الخصوص، هذا يعني أنك قد ترى ترويسات متعددة مُصدرة بنفس الارتفاع، وعندما يحدث هذا، يجب اعتبار الترويسة اللاحقة هي الترويسة الصحيحة بعد إعادة التنظيم.

مثال:

1>  {"jsonrpc":  "2.0",  "id":  1,  "method":  "eth_subscribe",  "params":  ["newHeads"]}
2
3<  {"jsonrpc":"2.0","id":2,"result":"0x9ce59a13059e417087c02d3236a0b1cc"}
4<  {
5  "jsonrpc":  "2.0",
6  "method":  "eth_subscription",
7  "params":  {
8      "result":  {
9          "extraData":  "0xd983010305844765746887676f312e342e328777696e646f7773",
10          "gasLimit":  "0x47e7c4",
11          "gasUsed":  "0x38658",
12          "logsBloom":
13"0x00000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000",
14          "nonce":  "0x084149998194cc5f",
15          "number":  "0x1348c9",
16          "parentHash":  "0x7736fab79e05dc611604d22470dadad26f56fe494421b5b333de816ce1f25701",
17          "receiptRoot":  "0x2fab35823ad00c7bb388595cb46652fe7886e00660a01e867824d3dceb1c8d36",
18          "sha3Uncles":  "0x1dcc4de8dec75d7aab85b567b6ccd41ad312451b948a7413f0a142fd40d49347",
19          "stateRoot":  "0xb3346685172db67de536d8765c43c31009d0eb3bd9c501c9be3229203f15f378",
20          "timestamp":  "0x56ffeff8",
21          "transactionsRoot":  "0x0167ffa60e3ebc0b080cdb95f7c0087dd6c0e61413140e39d94d3468d7c9689f"
22      },
23  "subscription":  "0x9ce59a13059e417087c02d3236a0b1cc"
24  }
25}
26
إظهار الكل
  1. logs

يُصدر السجلات التي تعد جزءًا من الكتل المضافة حديثًا والتي تتطابق مع معايير التصفية المحددة.

عند حدوث إعادة تنظيم للسلسلة، سيتم إصدار السجلات التي تعد جزءًا من الكتل الموجودة على السلسلة القديمة مرة أخرى مع تعيين الخاصية removed إلى true. علاوة على ذلك، يتم إصدار السجلات التي تعد جزءًا من الكتل الموجودة على السلسلة الجديدة، مما يعني أنه من الممكن رؤية السجلات لنفس المعاملة عدة مرات في حالة إعادة التنظيم.

المعلمات

  1. كائن يحتوي على الحقول التالية:
    • address (اختياري): إما سلسلة نصية تمثل عنوان أو مصفوفة من هذه السلاسل النصية.
      • سيتم إصدار السجلات التي تم إنشاؤها من أحد هذه العناوين فقط.
    • topics: مصفوفة من محددات المواضيع.
      • كل محدد موضوع إما أن يكون null، أو سلسلة نصية تمثل موضوعًا، أو مصفوفة من السلاسل النصية.
      • كل موضع في المصفوفة ليس null يقيد السجلات المُصدرة بتلك التي تحتوي على أحد المواضيع المحددة في ذلك الموضع فقط.

بعض الأمثلة على مواصفات المواضيع:

  • []: يُسمح بأي مواضيع.
  • [A]: A في الموضع الأول (وأي شيء بعده).
  • [null, B]: أي شيء في الموضع الأول و B في الموضع الثاني (وأي شيء بعده).
  • [A, B]: A في الموضع الأول و B في الموضع الثاني (وأي شيء بعده).
  • [[A, B], [A, B]]: (A أو B) في الموضع الأول و (A أو B) في الموضع الثاني (وأي شيء بعده).

مثال:

1>  {"jsonrpc":  "2.0",  "id":  1,  "method":  "eth_subscribe",  "params":  ["logs",  {"address":  "0x8320fe7702b96808f7bbc0d4a888ed1468216cfd",  "topics":  ["0xd78a0cb8bb633d06981248b816e7bd33c2a35a6089241d099fa519e361cab902"]}]}
2
3<  {"jsonrpc":"2.0","id":2,"result":"0x4a8a4c0517381924f9838102c5a4dcb7"}
4<  {
5  "jsonrpc":  "2.0",
6  "method":  "eth_subscription",
7  "params":  {
8      "subscription":  "0x4a8a4c0517381924f9838102c5a4dcb7",
9      "result":  {
10          "address":  "0x8320fe7702b96808f7bbc0d4a888ed1468216cfd",
11          "blockHash":  "0x61cdb2a09ab99abf791d474f20c2ea89bf8de2923a2d42bb49944c8c993cbf04",
12          "blockNumber":  "0x29e87",
13          "data": "0x00000000000000000000000000000000000000000000000000000000000000010000000000000000000000000000000000000000000000000000000000000003",
14          "logIndex":"0x0",
15          "topics":["0xd78a0cb8bb633d06981248b816e7bd33c2a35a6089241d099fa519e361cab902"],
16          "transactionHash":  "0xe044554a0a55067caafd07f8020ab9f2af60bdfe337e395ecd84b4877a3d1ab4",
17          "transactionIndex":  "0x0"
18      }
19  }
20}
21
إظهار الكل

eth_unsubscribe

يُلغي اشتراكًا حاليًا بحيث لا يتم إرسال أي أحداث أخرى.

المعلمات

  1. معرف الاشتراك، كما تم إرجاعه مسبقًا من استدعاء eth_subscribe.

المخرجات

true إذا تم إلغاء الاشتراك بنجاح، أو false إذا لم يكن هناك اشتراك بالمعرف المحدد.

مثال:

الطلب

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

النتيجة

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

سجل مع Alchemy (opens in a new tab) مجانًا، واطلع على مستنداتنا (opens in a new tab)، وللحصول على أحدث الأخبار، تابعنا على Twitter (opens in a new tab).

آخر تحديث للصفحة: 1 أكتوبر 2025

wackeroww (opens in a new tab)
mdqstm (opens in a new tab)
pettinaripp (opens in a new tab)
+10

هل كانت تعليمات الاستخدام هذه مفيدة؟