Web3以太坊架构

以太坊后端架构设计：从索引到实时监听

EasyGo2025-11-2015 分钟

架构概览

构建以太坊后端服务需要考虑以下核心模块：

**区块同步器** - 实时同步区块数据

2. **事件监听器** - 监听智能合约事件

3. **交易追踪器** - 追踪交易状态

4. **数据索引器** - 建立高效的查询索引

5. **API 服务** - 提供数据查询接口

区块同步

使用 go-ethereum 连接节点

1package main
2
3import (
4    "context"
5    "log"
6    "github.com/ethereum/go-ethereum/ethclient"
7)
8
9func main() {
10    client, err := ethclient.Dial("wss://mainnet.infura.io/ws/v3/YOUR_KEY")
11    if err != nil {
12        log.Fatal(err)
13    }
14    
15    // 订阅新区块
16    headers := make(chan *types.Header)
17    sub, err := client.SubscribeNewHead(context.Background(), headers)
18    if err != nil {
19        log.Fatal(err)
20    }
21    
22    for {
23        select {
24        case err := <-sub.Err():
25            log.Fatal(err)
26        case header := <-headers:
27            log.Println("New block:", header.Number.Uint64())
28        }
29    }
30}

事件监听

监听 ERC20 Transfer 事件

1// Transfer 事件签名
2transferSig := crypto.Keccak256Hash([]byte("Transfer(address,address,uint256)"))
3
4query := ethereum.FilterQuery{
5    Addresses: []common.Address{tokenAddress},
6    Topics:    [][]common.Hash{{transferSig}},
7}
8
9logs := make(chan types.Log)
10sub, err := client.SubscribeFilterLogs(context.Background(), query, logs)

数据存储设计

推荐使用 PostgreSQL + TimescaleDB 存储区块链数据：

**blocks** - 区块信息

**transactions** - 交易记录

**logs** - 事件日志

**token_transfers** - 代币转账

高可用设计

使用多个 RPC 节点做负载均衡

2. 实现断点续传机制

3. 使用消息队列解耦组件

4. 建立完善的监控告警

总结

构建生产级别的以太坊后端需要综合考虑数据一致性、实时性和可扩展性。

区块同步

使用 go-ethereum 连接节点

1package main
2
3import (
4    "context"
5    "log"
6    "github.com/ethereum/go-ethereum/ethclient"
7)
8
9func main() {
10    client, err := ethclient.Dial("wss://mainnet.infura.io/ws/v3/YOUR_KEY")
11    if err != nil {
12        log.Fatal(err)
13    }
14    
15    // 订阅新区块
16    headers := make(chan *types.Header)
17    sub, err := client.SubscribeNewHead(context.Background(), headers)
18    if err != nil {
19        log.Fatal(err)
20    }
21    
22    for {
23        select {
24        case err := <-sub.Err():
25            log.Fatal(err)
26        case header := <-headers:
27            log.Println("New block:", header.Number.Uint64())
28        }
29    }
30}

事件监听

监听 ERC20 Transfer 事件

1// Transfer 事件签名
2transferSig := crypto.Keccak256Hash([]byte("Transfer(address,address,uint256)"))
3
4query := ethereum.FilterQuery{
5    Addresses: []common.Address{tokenAddress},
6    Topics:    [][]common.Hash{{transferSig}},
7}
8
9logs := make(chan types.Log)
10sub, err := client.SubscribeFilterLogs(context.Background(), query, logs)