如何使用 geth1.8来监听合约事件
新功能介绍
geth1.8版本带来了新的事件处理方式,使用 abigen 可以自动生成包含合约事件监听以及过滤相关代码.
这样就不用自己去写代码解析 log.
比如:
abigen --sol token.sol --pkg token --out token.go一个例子
通过监听谁给我转账,来说明如何使用新的接口
创建 Filter
只需指定合约地址即可.
filter, err := token.NewTokenFilterer(tokenAddr, c)监听将要发生的事件
这个应该放在过滤历史事件之前,因为有可能在处理历史事件过程中产生了新的事件.如果顺序错了,就会造成事件丢失.
ch := make(chan *token.TokenTransfer, 10)
sub, err := filter.WatchTransfer(nil, ch, nil, []common.Address{toAddr})
if err != nil {
log.Fatalf("watch transfer err %s", err)
}
go func() {
for {
select {
case <-sub.Err():
return
case e := <-ch:
log.Printf("new transfer event from %s to %s value=%s,at %d",
e.From.String(), e.To.String(), e.Value, e.Raw.BlockNumber)
}
}
}()简单直观,不用去关心 log 的细节.
感兴趣的话,可以看一下 TokenTranser 结构
// TokenTransfer represents a Transfer event raised by the Token contract.
type TokenTransfer struct {
From common.Address
To common.Address
Value *big.Int
Raw types.Log // Blockchain specific contextual infos过滤历史事件
也很直观,把你感兴趣的事件范围传递进去,会返回一个 Iterator, 遍历就 ok 了.
history, err := filter.FilterTransfer(&bind.FilterOpts{Start: 480000}, nil, []common.Address{toAddr})
for history.Next() {
e := history.Event
log.Printf("%s transfer to %s value=%s, at %d", e.From.String(), e.To.String(), e.Value, e.Raw.BlockNumber)
}结论
有了这些自动生成的代码以后,我们就不用费劲去理解过滤时候的 Topic 怎么设置,Log怎么解析. 直接关注我们想要的事件本身就可以了.
当然也不是没有问题,如果我关注的不是某个合约上发生了转账事件,而是所有的ERC20token, 那么该怎么写呢?
目前我是没想到怎么实现,要想这么做还是要回到老办法上.
