智能合约¶
自研并实现了一套智能合约虚拟机XVM。特点如下:
合约状态数据与合约代码运行环境分离,从而能够支持多语言虚拟机且各种合约虚拟机只需要做纯粹的无状态合约代码执行;
支持执行消耗资源,避免恶意攻击;
支持丰富的智能合约开发语言,比如go,Solitidy,C/C++,Java等;
利用读写集确保普通合约调用支持并发执行,充分利用计算机多核特性;
事件机制 在使用超级链的过程中,可能会遇到一些异步的情况:比如执行合约的时候,构造的交易是否合法我们可以实时获知,但具体什么时候真正的被节点打包上链就不一样了。当然还有其他类似的场景,针对这种问题,我们引入了事件订阅机制。
合约事件¶
订阅的接口十分简单,只有Subscribe一个
1 2 3 | service EventService {
rpc Subscribe (SubscribeRequest) returns (stream Event);
}
|
其中订阅接口的SubscribeRequest格式如下:
1 2 3 4 5 6 7 8 9 | message SubscribeRequest {
SubscribeType type = 1;
bytes filter = 2;
}
enum SubscribeType {
// 区块事件,payload为BlockFilter
BLOCK = 0;
}
|
请求里的filter用来设置事件过滤参数,是一段序列化的proto对象,因为订阅不同内容需要的参数不尽相同
BLOCK 事件的过滤参数如下:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 | message BlockFilter {
string bcname = 1;
BlockRange range = 2;
bool exclude_tx = 3;
bool exclude_tx_event = 4;
string contract = 10;
string event_name = 11;
string initiator = 12;
string auth_require = 13;
string from_addr = 14;
string to_addr = 15;
}
message BlockRange {
string start = 1;
string end = 2;
}
|
其中各个字段的说明如下:
bcname链名,必填字段range指定起始订阅位置和结束位置,如果没有指定则默认从当前最新区块开始,持续订阅。exclude_tx是否去掉FilteredTransaction数据exclude_tx_event是否去掉ContractEvent数据contract匹配合约名字,为空的话匹配所有合约event_name匹配合约事件名字,为空的话匹配所有合约事件nameinitiator匹配交易发起者地址,为空的话匹配所有交易发起者auth_require匹配交易的auth_require中的任何一个地址,为空匹配所有from_addr匹配转账发起者地址,为空的话匹配所有转账发起者to_addr匹配转账接受者地址,为空的匹配所有转账接受者
BlockRange 字段意义:
如果
start_num和end_num都为空,则表示从当前最新区块开始,持续订阅最新区块。如果
start_num为空,end_num不为空,则表示从当前最新区块开始,订阅到指定区块,如果``end_num``小与当前区块则什么也不做。如果
start_num不为空,end_num为空,则从start_num开始持续订阅。如果
start_num和end_num都不为空,按照指定区块范围订阅,左闭右开。
注解
需要注意的是过滤字段都是正则表达式,如果需要全匹配名字为 counter 的合约,contract 字段需要为 ^counter$ ,
不能为 counter ,这么写会匹配到名为 counter1 的合约。
订阅返回的内容格式均为Event,事件的详细内容会放在payload里
1 2 3 | message Event {
bytes payload = 1;
}
|
订阅 BLOCK 事件时,填充如下内容:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 | message ContractEvent {
string contract = 1;
string name = 2;
bytes body = 3;
}
message FilteredTransaction {
string txid = 1;
repeated ContractEvent events = 2;
}
message FilteredBlock {
string bcname = 1;
string blockid = 2;
int64 block_height = 3;
repeated FilteredTransaction txs = 4;
}
|
当然,订阅RPC接口断开的时候,订阅行为也会停止