在介绍事件前,我们先明确事件,日志这两个概念。事件发生后被记录到区块链上成为了日志。总的来说,事件强调功能,一种行为;日志强调存储,内容。
事件是以太坊EVM提供的一种日志基础设施。事件可以用来做操作记录,存储为日志。也可以用来实现一些交互功能,比如通知UI,返回函数调用结果等1。
事件
当定义的事件触发时,我们可以将事件存储到EVM的交易日志中,日志是区块链中的一种特殊数据结构。日志与合约关联,与合约的存储合并存入区块链中。只要某个区块可以访问,其相关的日志就可以访问。但在合约中,我们不能直接访问日志和事件数据(即便是创建日志的合约)。下面我们来看看,如何在Solidity中实现一个事件:
pragma solidity ^0.4.0;
contract Transfer{
event transfer(address indexed _from, address indexed _to, uint indexed value);
function deposit() payable {
address current = this;
uint value = msg.value;
transfer(msg.sender, current, value);
}
function getBanlance() constant returns(uint) {
return this.balance;
}
/* fallback function */
function(){}
}
从上面的例子中,我们使用event
关键字定义一个事件,参数列表中为要记录的日志参数的名称及类型。
监听事件
在web3.js中,提供了响应事件的方法,如下2:
var event = myContract.transfer();
// 监听
event.watch(function(error, result){
console.log("Event are as following:-------");
for(let key in result){
console.log(key + " : " + result[key]);
}
console.log("Event ending-------");
});
另外一种简便写法是直接加入事件回调,这样就不用再写watch
的部分:
var event = myContract.transfer(function(error, result){
console.log("Event are as following:-------");
for(let key in result){
console.log(key + " : " + result[key]);
}
console.log("Event ending-------");
});
注意:在操作执行完成后,我们要记得调用event.stopWatching();
来终止监听。
检索日志
Indexed属性
可以在事件参数上增加indexed
属性,最多可以对三个参数增加这样的属性。加上这个属性,可以允许你在web3.js中通过对加了这个属性的参数进行值过滤,方式如下[event]:
var event = myContract.transfer({value: "100"});
上面实现的是对value
值为100
的日志,过滤后的返回。
如果你想同时匹配多个值,还可以传入一个要匹配的数组。
var event = myContract.transfer({value: ["99","100","101"]});
增加了indexed
的参数值会存到日志结构的Topic
部分,便于快速查找。而未加indexed
的参数值会存在data
部分,成为原始日志。需要注意的是,如果增加indexed
属性的是数组类型(包括string
和bytes
),那么只会在Topic
存储对应的数据的web3.sha3
哈希值,将不会再存原始数据。因为Topic是用于快速查找的,不能存任意长度的数据,所以通过Topic实际存的是数组这种非固定长度数据哈希结果。要查找时,是将要查找内容哈希后与Topic内容进行匹配,但我们不能反推哈希结果,从而得不到原始值3。
其它过滤参数
事件还支持传入其它参数对象来限定可检索的范围,支持fromBlock
,toBlock
等过滤条件,详见https://github.com/ethereum/wiki/wiki/JavaScript-API#contract-events,链接的第二个参数[^filter]。
var event = myContract.transfer({value: "100"}, {fromBlock: 0, toBlock: 'latest'});
上面的代码实现了从第一块开始搜索日志。
Topic
日志中存储的不同的索引事件就叫不同的主题。比如,事件定义,event transfer(address indexed _from, address indexed _to, uint value)
有三个主题,第一个主题为默认主题,即事件签名transfer(address,address,uint256)
,但如果是声明为anonymous
的事件,则没有这个主题;另外两个indexed
的参数也会分别形成两个主题,可以分别通过_from
,_to
主题来进行过滤。如果数组,包括字符串,字节数据做为索引参数,实际主题是对应值的Keccak-256哈希值。
var defaultTopic = web3.sha3("transfer(address,address,uint256)1");
var event = myContract.transfer({value: "100"}, {fromBlock: 0, toBlock: 'latest', topics:[ defaultTopic]});
备注:Topic过滤似乎没有生效,待研究
其它
事件可以被继承。
日志的Merkle证明是可能的,所以在区块链外,如果能提供这样一种证明,可以证明日志确实存在于区块链上。
底层的日志接口
可以通过底层的日志接口来访问底层的日志机制。通过函数log0
,log1
,log2
,log3
,log4
。logi
支持i + 1
个类型为bytes32
的参数。其中第一个参数是日志的data
部分,其它参数为topic
。所以下述事件:
event Deposit(
address indexed _from,
bytes32 indexed _id,
uint _value
);
使用API的等同写法为:
log3(
msg.value,
0x50cb9fe53daa9737b786ab3646f04d0150dc50ef4e75f59509d83667ad5adb20,
msg.sender,
_id
);
第一个参数为非indexed
的data
部分值。第二个参数为默认主题,即事件签名的哈希值keccak256("Deposit(address,hash256,uint256)")
,后面两个是按顺序的indexed
的主题。
使用web3.js读取事件的完整例子
下面是一个使用以太坊提供的工具包web3.js访问事件的完整例子:
let Web3 = require('web3');
let web3;
if (typeof web3 !== 'undefined') {
web3 = new Web3(web3.currentProvider);
} else {
// set the provider you want from Web3.providers
web3 = new Web3(new Web3.providers.HttpProvider("http://localhost:8545"));
}
let from = web3.eth.accounts[0];
//编译合约
let source = "pragma solidity ^0.4.0;contract Transfer{ event transfer(address indexed _from, address indexed _to, uint indexed value); function deposit() payable { address current = this; uint value = msg.value; transfer(msg.sender, current, value); } function getBanlance() constant returns(uint) { return this.balance; } /* fallback function */ function(){}}";
let transferCompiled = web3.eth.compile.solidity(source);
console.log(transferCompiled);
console.log("ABI definition:");
console.log(transferCompiled["info"]["abiDefinition"]);
//得到合约对象
let abiDefinition = transferCompiled["info"]["abiDefinition"];
let transferContract = web3.eth.contract(abiDefinition);
//2. 部署合约
//2.1 获取合约的代码,部署时传递的就是合约编译后的二进制码
let deployCode = transferCompiled["code"];
//2.2 部署者的地址,当前取默认账户的第一个地址。
let deployeAddr = web3.eth.accounts[0];
//2.3 异步方式,部署合约
//警告,你不应该每次都部署合约,这里只是为了提供一个可以完全跑通的例子!!!
transferContract.new({
data: deployCode,
from: deployeAddr,
gas: 1000000
}, function(err, myContract) {
if (!err) {
// 注意:这个回调会触发两次
//一次是合约的交易哈希属性完成
//另一次是在某个地址上完成部署
// 通过判断是否有地址,来确认是第一次调用,还是第二次调用。
if (!myContract.address) {
console.log("contract deploy transaction hash: " + myContract.transactionHash) //部署合约的交易哈希值
// 合约发布成功后,才能调用后续的方法
} else {
console.log("contract deploy address: " + myContract.address) // 合约的部署地址
console.log("Current balance: " + myContract.getBanlance());
var event = myContract.transfer();
// 监听
event.watch(function(error, result){
console.log("Event are as following:-------");
for(let key in result){
console.log(key + " : " + result[key]);
}
console.log("Event ending-------");
});
//使用transaction方式调用,写入到区块链上
myContract.deposit.sendTransaction({
from: deployeAddr,
value: 100,
gas: 1000000
}, function(err, result){
console.log("Deposit status: " + err + " result: " + result);
console.log("After deposit balance: " + myContract.getBanlance());
//终止监听,注意这里要在回调里面,因为是异步执行的。
event.stopWatching();
});
}
}
});
关于作者
专注基于以太坊(Ethereum)的相关区块链(Blockchain)技术,了解以太坊,Solidity,Truffle,web3.js。
个人博客: http://tryblockchain.org
版权所有,转载注明出处
参考资料
处于某些特定的环境下,可以看到评论框,欢迎留言交流^_^。