Повторяющиеся события, запускаемые в прослушивателе Web3

У меня была та же проблема, и приведенное выше решение не сработало в случае, если testrpc запущен и уже запустил некоторые события, а затем при запуске кода Web3 часы возвращают последнее инициированное событие. Что решило проблему и получило только новые события:

var latestBlock = web3.eth.blockNumber; //get the latest blocknumber
contractInstance.MyEvent({fromBlock: latestBlock}, (error, event) => { 
    if (error) {
     console.log(error); return; 
    } else {
        if(event.blockNumber != latestBlock) {   //accept only new events
        console.log(event);
        latestBlock = latestBlock + 1;   //update the latest blockNumber
        }
    }

Надеюсь, это поможет!

это сработало для меня

MyTokenContract.allEvents({fromBlock:'latest'}, (ошибка, событие) => { if (ошибка) { console.log( Event error: ${error}); return; }

Несмотря на то, что в документах указано, что «последний» используется по умолчанию, это исправило мои повторяющиеся события. Я не использовал allEvents. Я смотрел только одно мероприятие по контракту.

Надеюсь, поможет.

У меня все еще было это в марте 2019 года, я решил это, создав Setв своем javascript и добавив к нему blockNumbers в своем обратном вызове, чтобы гарантировать отсутствие дубликатов.

var eventBlocks = new Set()

listenCallback = async (error, event, type) => {
  if (error) { console.log(error); }
  else {
    let blockNumber = event.blockNumber;
    if (eventBlocks.has(blockNumber)) return;
    eventBlocks.add(blockNumber);
    //do everything else you want to do
  }
}

Я сделал именно то, что было сделано выше. Я ловил свое исходное событие следующим образом:

  this.buyEvent = this.$store.state.web3contract.BuyTransaction({},{fromBlock: 0, toBlock: 'latest'});
          this.buyEvent.watch(function(err,res){
console.log(res);
console.log(err);
})

Чтобы исправить двойное срабатывание, я добавил этот дополнительный фрагмент кода, и он решил мою проблему.

  this.$store.state.web3contract.allEvents({fromBlock:'latest'}, function (error,event){
    if (error) {
      console.log(error)
    } else {
      console.log("All Events")
      console.log(event);
    }
  })

Это должно быть какая-то ошибка в web3, или я не знаю, что это такое. Я уверен, что не зарегистрирую функцию часов дважды. Было бы здорово, если бы кто-нибудь мог подтвердить, является ли это ошибкой web3.

Наконец-то я понял это, братья по блокчейну.

Я создавал бота, чтобы наблюдать за покупками/продажами на Uniswap, и продолжал получать повторяющиеся события Transfer для одного и того же Tx Hash. Не уверен, что это связано с web3 или с моим локальным узлом Eth, но это сводило меня с ума. Я пытался ограничиться блоками (например, если был найден следующий блок, игнорировать), но я получал несколько событий с одним и тем же хэшем в одном блоке, так что это не сработало.

Наконец, я нашел способ сравнить последний Tx Hash с текущим и, если они совпадают, игнорировать остальную часть процесса; если не продолжить обработку транзакции:

    async function savetxhash(lasthash) {   //async function to save last tx
        return new Promise((resolve) => {

        resolve(lasthash)

       });
      }

      var lasthash = ""                     //declare empty at first

     //Here you will have your web3.eth.Transfer() or .allEvents() listener code
     //Then below that you will compare saved hash to new one

       console.log('This hash is '+event.transactionHash+'')
       console.log('Last hash was '+lasthash+'')
                      
       if (lasthash.toLowerCase() == event.transactionHash.toLowerCase()) {
           console.log('Found duplicate tx hash, skipping...')
           } else {
           console.log('No duplicate tx hash found, doing something important...')
           }
                      
       lasthash = await savetxhash(event.transactionHash)   //lastly call the function

Я столкнулся с той же проблемой здесь, используя web3 ^1.3.6.

Судя по этой проблеме в репозитории web3.js , это похоже на проблему с самой библиотекой.

Мое решение заключалось в том, чтобы хранить хэш транзакции каждого события и сравнивать его перед выполнением какой-либо логики.