处事开启后，首先会通过ws协议的jsonrpc，在上注册事件订阅，订阅乐成后开启一个for轮回，吸收并处理惩罚事件动静。
三、事件订阅
        stateCode,
    case “uint256”:
        return nil, fmt.Errorf(“[sendQueryRequest] NewRequest failed: %v”, err)

Oracle后端处事整体包括事件订阅模块、查询模块和回调模块，架构如下图所示。

一、文章布局
        case vLog := <-e.EventChan:
    e.Subscription = sub
    }
            resValue = big.NewInt(int64(resUint64Value))
// sendQueryRequest 按照客户端指定的查询地点发送请求
type OracleQueryInfo struct {
        return nil, fmt.Errorf(“[ParseResponeData] unmarshal response data failed:%v”, err)
    return nil
    Requester    common.Address
    }
有的网络节点没有开启ws处事，而利用http协议的网络jsonrpc又无法直接订阅事件。这时可以采纳迂回计策，模仿事件订阅，详细思路如下：
    switch resParamType {
这里我的思路是可以从以下几个方面优化：
}
•在缓存（内存或redis等）中维护账号对应的Nonce•每次提倡生意业务时，从缓存中获取，每获取一次，缓存中的Nonce累加1•缓存中的Nonce按期和链长举办校对和同步•对付大概呈现的空洞环境，利用空生意业务填补
        return nil, err
    }
文中的Oracle处事完整代码地点：https://github.com/six-days/ethereum-oracle-service
    }
func (e *EventWatch) dealEvent() {
    transaction, err := e.BoundContract.Transact(e.TransactOpts, responseName, in…)
    if err != nil {
        responseName = OracelResponseUint256Name
    }
        return fmt.Errorf(“[dealQuery] unmarshal query data failed:%v”, err)
}
事件订阅必需利用ws协议的jsonrpc，http协议的jsonprc无法订阅事件。
    case “uint256”:
    in := []interface{}{
Transact要领源码详见：https://github.com/six-days/go-ethereum/blob/master/accounts/abi/bind/base.go
        queryInfo.CallbackAddr,
    return resValue, nil
这里利用go-simplejson库将查询功效举办json理会，而且提取用户指定所需要的字段，将字段转换为用户合约中回调要领吸收的数据范例。
1、日志理会
        }
1、Nonce托管
References
    reqData := &QueryRequest{}
    }
        if coverErr == nil {
    e.dealEvent()
    Fee          *big.Int
各人对付优化有其他思路或疑问，接待留言探讨。
    }
}
    }
查询请求较量简朴，就是按照用户提供的url发送请求。代码如下所示。
在TransactOpts工具中可以设置nonce、gasLimit、gasPrice等值，假如不指定，Transact要了解本身增补上。除此之外，Transact要领也会挪用TransactOpts工具的Signer要领对动静举办签名。
2、Gas优化
事件日志理会我们用go-ethereum的abi模块的Unpack要领，将日志理会为我们界说好的布局体。
代码如下所示。
        return err
    switch resParamType {
    URL            string   `json:”url,omitempty”`
    if err != nil {
    queryRes, err := ParseResponeData(body, reqData.ResponseParams, resParamType)
        },
    }
•上篇：Oracle简介及合约实现[1]•中篇：利用go语言开拓Oracle处事•下篇：抽奖合约挪用Oracle处事示例
    }
    }
    Raw          types.Log // Blockchain specific contextual infos
    CallbackFUN  string
    }
    logs.Trace(“[sendQueryRequest] get “, reqData.URL, ” response is: “, string(body))
}
func (e *EventWatch) sendQueryResponse(res interface{}, stateCode uint64, queryInfo *OracleQueryInfo, resParamType string) error {
}
    if err = json.Unmarshal(queryInfo.QueryData, reqData); err != nil {
    case “bytes”:
        }
            {e.OracleABI.Events[OracelEventName].ID()},
        return nil, fmt.Errorf(“[ParseResponeData] response data type %s error:%v”, resParamType, err)
        return fmt.Errorf(“[dealQuery] unpack event log failed:%v”, err)
在高并发的环境下，必定会呈现多笔生意业务Nonce值沟通的环境，后提倡生意业务包围前生意业务，造成前生意业务失败。
        return nil, fmt.Errorf(“[sendQueryRequest] http get request failed: %v”, err)
本文将通过上、中、下三篇文章教育各人一步步开拓实现一其中心化的Oracle处事，并通过一个抽奖合约演示如何利用我们的Oracle处事。文章内容布置如下：
func (e *EventWatch) subscribeEvent() error {
    if coverErr != nil {
    res, err := http.DefaultClient.Do(req)
在回调模块中，挪用合约时，我们并没有指定提倡生意业务账号的Nonce值，而是由Transact要领在每次提倡生意业务时，动态计较。这就会限制我们生意业务的并发。
六、可以优化的处所
在上篇中，，我们实现了一个通用的Oracle合约，其主要有一个吸收用户请求的Query要领；回挪用户合约的Response要领和一个供Oracle后端处事订阅的QueryInfo事件。
•开启网络区块监控•监控到有新区块发生，查询区块中的日志•假如有我们Oracle合约发生的查询日志，则进入后续的查询和回调流程
•Addresses是Oracle合约地点；•Topics参数是过滤主题，是一个二维数组，这里我们的主题只指定了事件的名称。
    err := e.OracleABI.Unpack(queryInfo, OracelEventName, vLog.Data)
    var coverErr error
    default:
    return nil
    req, err := http.NewRequest(“GET”, reqData.URL, nil)
二、处事架构

郑重声明：本文版权归原作者所有，转载文章仅为传播更多信息之目的，如作者信息标记有误，请第一时间联系我们修改或删除，多谢。