如何使用Web3Js來處理區(qū)塊鏈斷開或重新啟動(dòng)

在本文中，我們將學(xué)習(xí)如何使用Web3Js自動(dòng)處理生產(chǎn)環(huán)境中的區(qū)塊鏈斷開。下面描述的方法適用于Web3Js版本1.0.0-beta.35，但是對(duì)于穩(wěn)定的1.2 *版本也適用。

問題描述

如果您的團(tuán)隊(duì)在生產(chǎn)中使用Web3Js，那么您必須意識(shí)到在Web3Js中沒有內(nèi)置的重新連接功能來處理區(qū)塊鏈斷開或重新啟動(dòng)。因此，通常情況下，當(dāng)連接下降時(shí)，需要重新啟動(dòng)NodeJS服務(wù)以便再次連接到區(qū)塊鏈。這不是一個(gè)很實(shí)用的方法。

解決方案

讓我們看看我們?nèi)绾蝺?yōu)雅地處理NodeJS中區(qū)塊鏈斷開的情況。在Web3Js庫中，程序?yàn)槲覀兲峁┝艘韵率录?/p>

連接——建立連接

錯(cuò)誤——程序錯(cuò)誤

結(jié)束——程序連接結(jié)束。

斷開連接后，我們可以利用終止事件重新啟動(dòng)一個(gè)新的Web3Js連接。讓我們來看一個(gè)例子來理解這一點(diǎn)：

File connection.js

在這個(gè)文件中，我們將處理NodeJS和區(qū)塊鏈之間的連接。我們將有一個(gè)新區(qū)塊鏈連接，它將返回一個(gè)Web3活動(dòng)連接對(duì)象。

const web3 = require（“web3”）;

let hasProviderEnded = false， web3Instance， reconnecTInterval = 10000;

async funcTIon newBlockchainConnecTIon（webSocketProvider， endCallback） {

// create new provider

const provider = new web3.providers.WebsocketProvider（webSocketProvider）;

hasProviderEnded = false;

// connect event fires when the connecTIon established successfully.

provider.on（‘connect’， （） =》 console.log（“connected to blockchain”））;

// error event fires whenever there is an error response from blockchain and this event also has an error object and message property of error gives us the specific reason for the error

provider.on（‘error’， （err） =》 console.log（err.message））;

// end event fires whenever the connection end is detected. So Whenever this event fires we will try to reconnect to blockchain

provider.on（‘end’， async （err） =》 {

// handle multiple event calls sent by Web3JS library

if （hasProviderEnded） return;

// setting hashProviderEnded to true as sometimes the end event is fired multiple times by the provider

hasProviderEnded = true;

// reset the current provider

provider.reset（）;

// removing all the listeners of provider.

provider.removeAllListeners（“connect”）;

provider.removeAllListeners（“error”）;

provider.removeAllListeners（“end”）;

setTimeout（（） =》 {

// emitting the restart event after some time to allow blockchain to complete startup

// we are listening to this event in the other file and this callback will initialize a new connection

endCallback（）;

}， reconnectInterval）;

}）;

if （web3Instance == undefined） web3Instance = new web3（provider）;

else web3Instance.setProvider（provider）;

return web3Instance;

}

module.exports = {

newBlockchainConnection

}

File app.js

const connection = require（“connection”）;

const web3JSConnection;

const endCallback = async function （） {

web3JSConnection = await connection.newBlockchainConnection（‘ws://127.0.0.1:8545’， customEvent）;

}）;

async function getWeb3Connection（） {

if （web3JSConnection == undefined） web3JSConnection = await connection.newBlockchainConnection（‘ws://127.0.0.1:8545’， endCallback）;

return web3JSConnection;

}

module.exports = {

getWeb3Connection

}

總結(jié)

在區(qū)塊鏈斷開連接時(shí)，當(dāng)提供程序觸發(fā)“終止”事件時(shí)，我們將在超時(shí)后觸發(fā)回調(diào)。然后，該事件反過來調(diào)用函數(shù)來創(chuàng)建一個(gè)新的區(qū)塊鏈連接。

需要注意的幾點(diǎn)：

· 有時(shí)，Web3Js為同一個(gè)連接點(diǎn)向您發(fā)送多個(gè)“終止”事件，因此我們必須檢查我們是否已經(jīng)處理過一次斷開事件。

· 使用“setProvider”在web3實(shí)例對(duì)象中設(shè)置新的提供程序，而不是創(chuàng)建一個(gè)新的web3實(shí)例。

· 重置提供程序并刪除活動(dòng)偵聽器

· 重新連接的時(shí)間間隔必須至少是5秒，區(qū)塊鏈重啟大約需要5秒。