为了订阅事件日志，我们需要做的第一件事就是拨打启用websocket的以太坊客户端。 幸运的是，Infura支持websockets。

  1. client, err := ethclient.Dial("wss://rinkeby.infura.io/ws")
  2. if err != nil {
  3.   log.Fatal(err)
  4. }

下一步是创建筛选查询。 在这个例子中，我们将阅读来自我们在之前课程中创建的示例合约中的所有事件。

  1. contractAddress := common.HexToAddress("0x147B8eb97fD247D06C4006D269c90C1908Fb5D54")
  2. query := ethereum.FilterQuery{
  3.   Addresses: []common.Address{contractAddress},
  4. }

我们接收事件的方式是通过Go channel。 让我们从go-ethereumcore/types包创建一个类型为Log的channel。

  1. logs := make(chan types.Log)

现在我们所要做的就是通过从客户端调用SubscribeFilterLogs来订阅，它接收查询选项和输出通道。 这将返回包含unsubscribe和error方法的订阅结构。

  1. sub, err := client.SubscribeFilterLogs(context.Background(), query, logs)
  2. if err != nil {
  3.   log.Fatal(err)
  4. }

最后，我们要做的就是使用select语句设置一个连续循环来读入新的日志事件或订阅错误。

  1. for {
  2.   select {
  3.   case err := <-sub.Err():
  4.     log.Fatal(err)
  5.   case vLog := <-logs:
  6.     fmt.Println(vLog) // pointer to event log
  7.   }
  8. }

我们会在下个章节介绍如何解析日志。

完整代码

Commands

  1. solc --abi Store.sol
  2. solc --bin Store.sol
  3. abigen --bin=Store_sol_Store.bin --abi=Store_sol_Store.abi --pkg=store --out=Store.go

Store.sol

  1. pragma solidity ^0.4.24;
  3. contract Store {
  4.   event ItemSet(bytes32 key, bytes32 value);
  6.   string public version;
  7.   mapping (bytes32 => bytes32) public items;
  9.   constructor(string _version) public {
  10.     version = _version;
  11.   }
  13.   function setItem(bytes32 key, bytes32 value) external {
  14.     items[key] = value;
  15.     emit ItemSet(key, value);
  16.   }
  17. }

event_subscribe.go

  1. package main
  3. import (
  4.     "context"
  5.     "fmt"
  6.     "log"
  8.     "github.com/ethereum/go-ethereum"
  9.     "github.com/ethereum/go-ethereum/common"
  10.     "github.com/ethereum/go-ethereum/core/types"
  11.     "github.com/ethereum/go-ethereum/ethclient"
  12. )
  14. func main() {
  15.     client, err := ethclient.Dial("wss://rinkeby.infura.io/ws")
  16.     if err != nil {
  17.         log.Fatal(err)
  18.     }
  20.     contractAddress := common.HexToAddress("0x147B8eb97fD247D06C4006D269c90C1908Fb5D54")
  21.     query := ethereum.FilterQuery{
  22.         Addresses: []common.Address{contractAddress},
  23.     }
  25.     logs := make(chan types.Log)
  26.     sub, err := client.SubscribeFilterLogs(context.Background(), query, logs)
  27.     if err != nil {
  28.         log.Fatal(err)
  29.     }
  31.     for {
  32.         select {
  33.         case err := <-sub.Err():
  34.             log.Fatal(err)
  35.         case vLog := <-logs:
  36.             fmt.Println(vLog) // pointer to event log
  37.         }
  38.     }
  39. }