从零开发区块链应用--以太坊余额查询

Posted 2022-02-12 杰哥的技术杂货铺

文章目录

• 一、账户状态stateTrie
• • 1.2 查询余额代码思路
  • 1.3 余额查询流程
• 二、获取账户余额
• • 2.1 代码解析
  • 2.2 完整代码
• 三、获取账户代币余额

一、账户状态stateTrie

Block.Header.Root 就是stateRoot，是一棵PMT树，存储了所有账户的当前最新的状态信息，比如账户余额。

a path is always: sha3(ethereumAddress) and a value is always: rlp(ethereumAccount)
Root是一个hash值，通过Root去数据库中可以找到 stateTrie的根节点，然后通过sha3(ethereumAddress)得出要最终查找的path，再根据path可以一步步的找到每个账户rlp(ethereumAccount)

Account账户余额分为账户余额和账户代币余额两种类型

type Account struct 
    Nonce    uint64   //Nonce：账户发起交易的次数
    Balance  *big.Int //该账户的余额
    Root     common.Hash //存储树MPT，它是所有合约数据存储的地方
    CodeHash []byte  //合约代码的Hash值 注：[合约]表示该项仅对合约账户有效

每个用户都对应一个StateObject，StateObject对应就是在stateTrie中的位置，表示一个账户的动态变化结果值

type stateObject struct 
    address  common.Address
    addrHash common.Hash // hash of ethereum address of the account
    data     Account
    db       *StateDB

1.2 查询余额代码思路

• 先获取当前的区块高度，并从创世区块开始遍历所有区块。getBlockNumber()

• 获取某一区块的相关信息，得到该区块中的所有交易TxHash，并遍历。getBlock()

• 获取某一交易的详细信息，得到转账地址from和接收地址to。getTransaction()

• 判断该地址是合约地址还是账号地址。getCode()

• 获取地址对应的余额。getBalance()

• 1.3 余额查询流程

• 查询获取当前最新的区块，然后获取到lastBlock.header.Root

• 先从本地缓存中查找是否有stateObject的热点数据，没有的话则,根据Root找到数据库中对应的根节点，然后按照Address在MPT树中的排列，找到对应的stateObject

• 通过stateObject找到对应的Account

• 获取到该Account里面的余额

二、获取账户余额

2.1 代码解析

读取一个账户的余额相当简单。调用客户端的BalanceAt方法，给它传递账户地址和可选的区块号。将区块号设置为nil将返回最新的余额。

account := common.HexToAddress("0x71c7656ec7ab88b098defb751b7401b5f6d8976f")
balance, err := client.BalanceAt(context.Background(), account, nil)
if err != nil 
  log.Fatal(err)


fmt.Println(balance) // 25893180161173005034

传区块号能让您读取该区块时的账户余额。区块号必须是big.Int类型。

blockNumber := big.NewInt(5532993)
balance, err := client.BalanceAt(context.Background(), account, blockNumber)
if err != nil 
  log.Fatal(err)


fmt.Println(balance) // 25729324269165216042

以太坊中的数字是使用尽可能小的单位来处理的，因为它们是定点精度，在ETH中它是wei。要读取ETH值，您必须做计算wei/10^18。因为我们正在处理大数，我们得导入原生的Gomath和math/big包。这是您做的转换。

fbalance := new(big.Float)
fbalance.SetString(balance.String())
ethValue := new(big.Float).Quo(fbalance, big.NewFloat(math.Pow10(18)))

fmt.Println(ethValue) // 25.729324269165216041

待处理的余额

有时您想知道待处理的账户余额是多少，例如，在提交或等待交易确认后。客户端提供了类似BalanceAt的方法，名为PendingBalanceAt，它接收账户地址作为参数。

pendingBalance, err := client.PendingBalanceAt(context.Background(), account)
fmt.Println(pendingBalance) // 25729324269165216042

2.2 完整代码

package main

import (
    "context"
    "fmt"
    "log"
    "math"
    "math/big"

    "github.com/ethereum/go-ethereum/common"
    "github.com/ethereum/go-ethereum/ethclient"
)

func main() 
    client, err := ethclient.Dial("https://mainnet.infura.io")
    if err != nil 
        log.Fatal(err)
    

    account := common.HexToAddress("0x71c7656ec7ab88b098defb751b7401b5f6d8976f")
    balance, err := client.BalanceAt(context.Background(), account, nil)
    if err != nil 
        log.Fatal(err)
    
    fmt.Println(balance) // 25893180161173005034

    blockNumber := big.NewInt(5532993)
    balanceAt, err := client.BalanceAt(context.Background(), account, blockNumber)
    if err != nil 
        log.Fatal(err)
    
    fmt.Println(balanceAt) // 25729324269165216042

    fbalance := new(big.Float)
    fbalance.SetString(balanceAt.String())
    ethValue := new(big.Float).Quo(fbalance, big.NewFloat(math.Pow10(18)))
    fmt.Println(ethValue) // 25.729324269165216041

    pendingBalance, err := client.PendingBalanceAt(context.Background(), account)
    fmt.Println(pendingBalance) // 25729324269165216042

三、获取账户代币余额

• 获取from、to、data参数

func (rc *RequestChain) GetCallContractInfo(from, to, data string) (string, error) 
	info, err := rc.Client.CallContract(from, to, data)
	if err != nil 
		logger.Error("GetCallContractInfo", "step", "CallContract", "err", err.Error())
		return "", err
	
	res, err := common.HexToString(info.(string))
	if err != nil 
		logger.Error("GetCallContractInfo", "step", "HexToString", "err", err.Error())
		return "", err
	
	resByte, err := hex.DecodeString(res)
	return string(resByte), nil

• 调用以太坊rpc，获取余额

// CallContract 查询合约
func (eth *Http) CallContract(from, to, data string) (interface, error) 
	tag := "latest"
	args = []interfaceCallMsg
		From: from,
		To:   to,
		Data: data,
	, tag
	params := NewHttpParams("eth_call", args)
	resBody, err := eth.rpc.HttpRequest(params)
	if err != nil 
		return nil, err
	
	return eth.ParseJsonRPCResponse(resBody)