我们如何处理web3js中的区块链重新连接
在本文中，我们将学习如何使用Web3JS在生产环境中自动处理区块链断开连接。 下述方法适用于Web3JS 1.0.0-beta.35版本，但对于稳定的1.2。*版本也应适用。
问题描述 如果您的团队在生产中使用Web3JS，那么您必须意识到Web3JS中没有内置的重新连接功能来处理区块链断开或重新启动。 因此，通常，当连接断开时，NodeJS服务也需要重新启动才能再次连接到区块链。 这不是一个非常实用的方法。
解 让我们看看如何在NodeJS中优雅地处理区块链断开连接。 在Web3JS库中， Provider对象为我们提供了以下事件
- 连接 -建立连接
- 错误 -提供程序错误
- 结束 -提供程序连接已结束。
文件connection.js 在此文件中，我们将处理NodeJS和区块链之间的连接。 我们将有一个newBlockchainconnection方法，该方法将返回Web3活动连接对象。
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?
}档案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?
}摘要 关于区块链断开连接，当提供商触发“结束”事件时，我们将在超时后触发回调。 然后，该事件依次调用该函数以创建新的区块链连接。
需要注意的几点：
- 有时，Web3JS为同一连接断开向您发送多个“结束”事件，因此我们必须检查是否已经处理了一次断开连接事件。
- 使用“ setProvider”在web3实例对象中设置新提供者，而不是创建新的web3实例
- 重置提供程序并删除活动的侦听器
- 重新连接间隔通常必须至少为5秒，重新启动区块链大约需要5秒。
https://skeps.com/blog/how-we-handle-blockchain-reconnects-in-web3js
From: https://hackernoon.com/how-we-handle-blockchain-reconnects-in-web3js-t5fu37ik
推荐阅读
- 第三节|第三节 快乐和幸福（12）
- 这辈子我们都不要再联系了
- 考研英语阅读终极解决方案——阅读理解如何巧拿高分
- 如何寻找情感问答App的分析切入点
- 诗歌:|诗歌: 《让我们举起世界杯，干了！》
- 我们重新了解付费。
- 那件我们忽略的小事叫感恩
- mybatisplus如何在xml的连表查询中使用queryWrapper
- MybatisPlus使用queryWrapper如何实现复杂查询
- 我们应该和什么样的人交朋友