EOS:dfuse stream 保证不会错过一个心跳

强大的 dfuse history API 给咱们带来了高效的链数据获取途径，让咱们的 dapp 在用户体验上了一个台阶。

官方示例

不会错过一个心跳

代码分析

函数

pendingActions 待处理的action。
ensureStream 返回steam实例。
commit 处理pendingActions中的action，并告诉dfuse server 当前处理的blockid，下次dfuse server推送的action就是基于你告诉dfuseserver的lastCommittedBlockNum，其中steam.mark()就是告诉dfuseserver的lastCommittedBlockNum的函数。

步骤

1.建立一个dfuse client
2.将Engine类托管dfuse client
3.调用streamActionTraces，接收ActionTraces流，于此同时接管dfuse的listening、action_trace、progress事件
4.当触发action_trace事件当时候，会调用commit方法(不会错过心跳在该方法里实现，请看函数里commit的解释)，而后循环处理pendingActions中等待的action。等处理完以后，向pendingActions数组传入当前接收action，进入排队

总结

若是这个服务想要从头同步的话，个人理解应该是在listening事件的时候就告诉dfuseserver 当前同步的blockId，这样就会从你想要开始的地方推送数据流。

若是这个服务想要从头同步的话，streamActionTraces 里有个stream option 里有个start block，这样就会从你想要开始的地方推送数据流。

刚接触dfuse，若是有不对的地方请指出，谢谢。

相关资料

不会错过一个心跳
如何保证dfuse流持续链接
其余
Javascript例子
Javascript例子_live
Go例子
node.js例子
GraphQL API react demo
GraphQL API react live
查询语言规范
github
graphql编辑器和api文档浏览器_live