ERC20合约交易监听的PHP实现代码
EthMon开发包用于监听以太坊ERC20代币合约的转账交易,官方下载地址:
http://sc.hubwiz.com/codebag/ethmon-php/。
1、开发包概述
EthMon代币交易监听开发包特点如下:
- 监听以太坊合约日志中指定地址发生的代币转入/转出交易
- 自定义代币交易发生时的业务逻辑
- 即支持标准的Web3接口(例如Infura),也支持Etherscan非标接口
EthMon运行于PHP 7.1+环境下,主要类以及其关系如下图所示:
EthMon的主要代码文件清单如下:
文件路径 | 说明 |
---|---|
ethtool/src/ | EthMon源代码目录 |
ethtool/src/EthMon.php | EthMon入口类 |
ethtool/src/EthApi.php | 以太坊API基类 |
ethtool/src/EthApiEtherscan.php | EthApi的Etherscan继承类 |
ethtool/src/EthApiWeb3.php | EthApi的Web3继承类 |
ethtool/src/LogParser.php | 以太坊日志解析类 |
ethtool/src/IEventListener.php | EthMon事件监听器接口 |
demo/ | EthMon演示代码目录 |
demo/EthMon-es-demo.php | 使用Etherscan接口的EthMon演示 |
demo/EthMon-web3-demo.php | 使用Web3/Infura接口的EthMon演示 |
demo/getLogs-es-demo.php | 使用Etherscan接口的getLogs演示 |
demo/getLogs-web3-demo.php | 使用Web3/Infura接口的getLogs演示 |
demo/LogParser-demp.php | LogParser演示 |
demo/etherscan-key | 演示代码用的api key - etherscan |
demo/infura-key | 演示代码用的api key - infura |
vendor/ | 第三方依赖包 |
composer.json | composer配置文件 |
EthMon官方下载地址:http://sc.hubwiz.com/codebag/ethmon-php/
2、使用说明
在开始之前,请使用自己的API KEY替换以下文件的内容
- demo/etherscan-key
- demo/infura-key
EthMon是开发包的入口类,调用其scanBlocks()
方法可以扫描指定区间的以太坊区块,提取并解析其中的合约日志,当匹配监听的地址后,调用事件监听器(IEventListener接口实现对象)的handleEvent()
方法并传入解析后的事件对象。
2.1 IEventListener
调用者的程序需要在IeventListener接口的实现类中封装自己的业务逻辑,例如写入数据库等等。下面的代码实现了一个基本的事件监听器 —— 只是简单地在屏幕显示输出事件对象的内容:
class EzListener implements IEventListener{ function handleEvent($event){ var_dump($event); } }
handleEvent()
方法的参数是一个StdClass对象,结构如下:
- block:交易所在区块号
- txhash:交易哈希
- contract:触发事件的合约地址
- name:事件名称,例如:Transfer
- flow:资金流向,可能值:inbound - 转入 , outbound - 转出
-
params:事件参数数组,成员依次为:
- 转出地址,字符串
- 转入地址,字符串
- 代币数量,BigInteger,可以调用
toString()
方法将其转换为字符串
一旦定义好事件监听器,就可以按如下步骤设置并启动监听:
2.2 创建EthMon对象
创建EthMon实例需要传入一个EthApi对象,例如使用EthApiWeb3对象:
$ethApi = new EthApiWeb3('https://mainnet.infura.io/v3/<your-api-key>'); $em = new EthMon($ethApi);
2.3 设置要监听的代币合约
创建了EthMon实例后,需要调用watchToken()
方法设置要监听的代币合约,例如监听BNB代币合约:
$em->watchToken('0xb8c77482e45f1f44de1745f52c74426c631bdd52');
2.4 添加要监听的代币交易相关地址
使用EthMon实例的watchAddress()
方法添加要监听的代币交易相关地址。例如下面的代码监听地址0xd3705916ce7e2c43806e0e0707c4b9d6f27e9ab2
收到代币
的事件:
$em->watchAddress('0xd3705916ce7e2c43806e0e0707c4b9d6f27e9ab2',EthMon::FLOW_IN);
而下面的代码监听地址0x6c6cbbb3ef3d690de7aa0525b5e6c2ffe7aed6a5
转出代币的事件:
$em->watchAddress('0x6c6cbbb3ef3d690de7aa0525b5e6c2ffe7aed6a5',EthMon::FLOW_OUT);
当希望监听一个地址的转入/转出代币事件时,使用EthMon::FLOW_INOUT
标志:
$em->watchAddress('0xd3705916ce7e2c43806e0e0707c4b9d6f27e9ab2',EthMon::FLOW_INOUT);
2.5 添加事件监听器
调用EthMon实例的addEventListener()
方法添加一个事件监听器对象,当EthMon的scanBlocks()
扫描区块时,将在满足条件时调用这些事件监听器。
例如,下面的代码添加我们之前定义的EzListener类的实例对象:
$em->addEventListener(new EzListener);
2.6 扫描区块链
需要周期性地调用EthMon的scanBlocks()
方法来扫描区块链以便跟踪新的代币交易日志,scanBlocks()
的两个参数分别用来指定扫描的起始区块号和结束区块号,当使用特殊的latest
字符串时,表示使用最新的区块。
例如,下面的代码每隔5秒钟扫描一次最新的区块:
while(true){ $em->scanBlocks('latest','latest'); sleep(5); }
虽然起止区块号都可以使用任意整数值,但由于Etherscan和Web3的返回记录数量都有限制,因此不建议一次扫描多个区块。例如下面的代码试图扫描从8500000到8500404的405个区块:
$em->scanBlocks(8500000,8500404); //不建议,可能失败
建议逐块扫描,同时考虑到第三方服务的访问频次限制,在两次扫描期间进行适当的延时处理。
EthMon官方下载地址:http://sc.hubwiz.com/codebag/ethmon-php/
低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
Jvm-Sandbox源码分析--增强目标类
前言 在前两篇文章Jvm-Sandbox源码分析--启动简析和Jvm-Sandbox源码分析--启动时加载模块中我们分析了jvm-sandbox启动及启动时加载模块的过程,这一篇我们来看一下如何使用模块增强目标类的流程。 执行脚本 在启动沙箱流程之后,执行如下命令。sh sandbox/bin/sandbox.sh -p pid -d "broken-clock-tinker/repairCheckState" # -d debug if [[ ! -z ${OP_DEBUG} ]]; then sandbox_debug_curl "module/http/${ARG_DEBUG}" exit fi 通过ModuleHttpServlet doMethod方法进行http路由 ModuleHttpServlet是在启动流程中提到的 JettyCoreServer 类中通过 initJettyContextHandler 操作加入到jetty上下文的。 // module-http-servlet final String pathSpec = "/module/http/*"; lo...
- 下一篇
Golang 基准测试(Benchmark)
Benchmark ? 基准测试是对计算机系统的性能的测试。 在程序中,基准测试,是一种测试代码性能的方法;比如有一个问题你有多种不同的方案,你想选择一种性能最好的方案,那么你就需要基准测试。 基准测试主要是通过测试 CPU 和内存的效率问题,来评估被测试代码的性能,进而找到更好的解决方案。比如链接池的数量不是越多越好,那么哪个值才是最优值呢,这就需要配合基准测试不断调优了。 工程意图 仓库: https://github.com/guzhongren/TDD/tree/master/09.benchmar 根据输入的字符串和重复次数,输出重复次数后的字符串。 初始化工程 go mod init benchmark 测试的函数需要以 Test 开头,参数为 *testing.T 类型 Test 测试先行 # 测试 Repeat 函数 func TestRepeat(t *testing.T) { actual := Repeat(`a`, 6) expect := `aaaaaa` if actual != expect { t.Errorf(`expect %s, but got ...
相关文章
文章评论
共有0条评论来说两句吧...
文章二维码
点击排行
推荐阅读
最新文章
- Red5直播服务器,属于Java语言的直播服务器
- Docker使用Oracle官方镜像安装(12C,18C,19C)
- Springboot2将连接池hikari替换为druid,体验最强大的数据库连接池
- Docker安装Oracle12C,快速搭建Oracle学习环境
- CentOS6,CentOS7官方镜像安装Oracle11G
- Jdk安装(Linux,MacOS,Windows),包含三大操作系统的最全安装
- CentOS关闭SELinux安全模块
- CentOS7编译安装Gcc9.2.0,解决mysql等软件编译问题
- Windows10,CentOS7,CentOS8安装MongoDB4.0.16
- Hadoop3单机部署,实现最简伪集群