以太坊实战【地址监控一】

chaimyu (58)in #ethereum • 6 years ago (edited)

概述

很多时候需要实现地址监控，例如钱包充值后需要及时通知用户，那怎么来实现呢？

因为对一块没具体了解过，初步想有两种方法：

以太坊提供了API，可以直接对地址监控
直接去下载区块，解析区块信息看有没有要监控的地址的记录

实现

ethereum有rpc函数eth_getBlockByNumber，是不是这个能达到要求呢？

大概思路：

监控服务第一次启动，从以太坊上取最新块数据
解析新块上是否有监控地址的交易，有则通知，处理完成保存块号到本地
继续取下一块数据，并执行2，只到最新块取完，进行延时
取最新块号，不等于保存的最新块号则取新块数据，执行2

RPC调用

用python简单写个http调用试试，返回错误

  File "/opt/local/Library/Frameworks/Python.framework/Versions/2.7/lib/python2.7/urllib2.py", line 556, in http_error_default
    raise HTTPError(req.get_full_url(), code, msg, hdrs, fp)
urllib2.HTTPError: HTTP Error 415: Unsupported Media Type

不支持类型，官方有个说明没注意看

The curl options below might return a response where the node complains about the content type, this is because the --data option sets the content type to application/x-www-form-urlencoded . 
If your node does complain, manually set the header by placing -H "Content-Type: application/json" at the start of the call.

在HTTP头里加上

{"Content-type":"application/json"}

再次调用，正确返回数据了！

POST:http://localhost:8545,data:{"jsonrpc":"2.0","method":"eth_mining","params":[],"id":71}
{"jsonrpc":"2.0","id":71,"result":false}

主要就是通过eth_getBlockByNumber和eth_blockNumber这两个接口循环监控是否有新块，有新块再解析新块数据了！

    def run(self):
        while True:
            r = self.eth_blockNumber()
            d = json.loads(r)
            if d.has_key("result"):
                lastBlockNo = d["result"]
                if lastBlockNo != self.lastBlockNo:
                    print("New block no: " + lastBlockNo)

                    r = self.eth_getBlockByNumber(lastBlockNo)
                    d = json.loads(r)
                    print(d)

                    self.lastBlockNo = lastBlockNo
            else:
                print("eth_blockNumber fail!")
            time.sleep(1)