電子發燒友App
Chainlink基本原理
本文我們來從技術上簡述一下Chainlink的基本原理。如果用最短的一句話解釋什么是Chainlink，可以說Chainlink一個去中心化的預言機項目，所以為了理解Chainlink的工作原理，我們首先要明白什么是預言機。
預言機
預言機的英文為Oracle，和著名的數據庫服務提供商Oracle（甲骨文）重名，但是兩者除了名字相同以為并沒有任何關系。Oracle這個單詞是什么意思，下面是我在vocabulary.com上查到的Oracle的含義：
Back in ancient times， an oracle was someone who offered advice or a prophecy thought to have come directly from a divine source. In modern usage， any good source of information can be called an oracle.
中文的大概意思是：在古代，oracle是一個提出建議或預言的人，他的建議或預言被認為是直接來自于神。在現代用法中，任何好的信息來源都可以稱為oracle。
這樣就不難理解了，Oracle傳達了萬能全知的神的旨意，而甲骨文最初就是用來占卜吉兇時的記錄，也在當時也被認為是神諭，傳達了神的意思。所以不管是“預言機”還是“甲骨文”都表達了“信息源”的意思。
計算機領域內的預言機一詞，最早是圖靈提出的。圖靈在圖靈機（Turing Machine）的基礎上，加入了一個稱為預言者（oracle）的黑盒，組成了預言機（Oracle Machine）。所謂預言者，是一個可以回答特定問題集合的實體。即它可以向圖靈機系統內部輸入信息，幫助圖靈機完成運算。以太坊的智能合約是“圖靈完備（Turing Complete）”的，某種意義上可以看做一個圖靈機，所以以太坊的設計者借鑒這個概念，把向“圖靈完備的智能合約”這個圖靈機輸入信息的也被稱為預言機oracle。所以說“預言機”這個名字并不是區塊鏈技術領域內的獨創概念，它來源于非常早期的計算機抽象設計，在密碼學等領域內也都有類似的概念。
而在區塊鏈領域，預言機被認為是可以為智能合約提供外部數據源的系統。從傳統技術架構方面來看，預言機是連接智能合約與區塊鏈外部世界的中間件（middleware），是區塊鏈重要的基礎設施，它的作用是為區塊鏈上的智能合約（Smart Contract）提供數據信息的。
正如以太坊的定義，區塊鏈是一個交易驅動的狀態機（a transaction-based state machine），它能做的事情非常簡單，就是通過向區塊鏈提交事務/交易（transaction），來將區塊鏈從一個狀態轉變成另一個狀態。為了保持共識，EVM的執行過程必須完全確定，并且僅基于以太坊狀態和簽名交易的共享上下文。這產生了兩個特別重要的后果：一個是EVM和智能合約沒有內在的隨機性來源；另一個是外部數據只能作為交易的數據載荷引入。用通俗的話講，區塊鏈沒有主動獲取數據的能力，它能用的只有區塊鏈自己本身的數據。數據的缺失導致智能合約的應用范圍非常少，目前大部分的應用都是圍繞著token來展開的。
區塊鏈的確定性的意思是，在任何節點上，只要連入到區塊鏈的分布式網絡中，它就可以同步所有的歷史區塊，回放出一套完全相同的賬本。換句話說：在沒有互聯網連接的情況下，給定完整的塊，節點必須能夠從頭開始重新創建區塊鏈的最終狀態。如果賬本在形成過程中，依賴于某個外部的API調用結果，那在不同時間不同環境下回放的結果就會不一樣。這種情況是區塊鏈所不允許的，所以區塊鏈在設計之初就沒有網絡調用。
那么要實現向區塊鏈提供數據，應該怎么做呢？區塊鏈能留下的只有賬本，而區塊鏈所能輸入的只有交易。我們就從這兩個方面入手。
幾乎每一個合約系統，都會有事件記錄的功能，比如以太坊中的EventLog功能。
下面我們通過一個例子，來介紹一下預言機的基本原理。我們在以太坊鏈上建立一個用戶合約，它需要獲取到某個城市的氣溫數據。當然，智能合約自己是無法獲取到這個發生于鏈下真實世界中的數據信息的，需要借助預言機來實現。智能合約將需要獲取天氣溫度的的城市寫入到EventLog中，鏈下我們會啟動一個進程，監聽并訂閱這個事件日志，獲取到智能合約的請求之后，將指定城市的溫度，通過提交transaction的方式，調用合約中的回填方法，提交到智能合約中。
聲明：以下代碼僅供演示預言機原理，沒有做參數檢測和錯誤處理，請不要在生產環境中使用。
消費者合約：
contract WeatherOracle {
// 用戶存儲預言機提交的天氣數值
// 定義事件
event RequestTemperature （bytes city）;
// 發出獲取請求，即發出一個事件日志
function requestTemperature （string memory _city） public {
emit RequestTemperature（bytes（_city））;
}
// 預言機回調方法，預言機獲取到數據后通過這個方法將數據提交到鏈上
function updateWeather （uint256 _temperature） public {
temperature = _temperature;
}
}
上面的代碼非常簡單，定義了一個變量用來存儲結果，一個方法用于發出請求，一個方法用于接收結果。
鏈下，我們啟動一個進程，以訂閱topic的方式獲取日志信息，之后通過構建一個transaction，提交一個結果到合約中。
func SubscribeEventLog（） {
topic ：= crypto.Keccak256（［］byte（“RequestTemperature（bytes）”））
query ：= ethereum.FilterQuery{
Topics： ［］［］common.Hash{
{
common.BytesToHash（topic），
}，
}，
}
// 訂閱相關主題的日志事件
events ：= make（chan types.Log）
sub， err ：= EthClient.SubscribeFilterLogs（ctx， query， events）
// 加載合約的ABI文件
ta， err ：= abi.JSON（strings.NewReader（AbiJsonStr））
// 監聽事件訂閱
for {
select {
case err ：= 《-sub.Err（）：
log.Error（err）
break
case ev ：= 《-events：
// 獲取到訂閱的消息
ej， _ ：= ev.MarshalJSON（）
log.Info（string（ej））
// 解析數據
var sampleEvent struct {
City ［］byte
}
err = ta.Unpack（&sampleEvent， “RequestTemperature”， ev.Data）
log.Info（string（sampleEvent.City））
// 構建交易提交結果，需要提供私鑰用于簽署交易
CallContract（“b7b502b.。.164b42c”）
}
}
}
func CallContract（keyStr string） {
addr ：= PrivateKeyToAddress（keyStr）
nonce， err ：= EthClient.PendingNonceAt（ctx， addr）
gasPrice， err ：= EthClient.SuggestGasPrice（ctx）
privateKey， err ：= crypto.HexToECDSA（keyStr）
auth ：= bind.NewKeyedTransactor（privateKey）
auth.Nonce = big.NewInt（int64（nonce））
auth.Value = big.NewInt（0）
auth.GasLimit = uint64（300000）
auth.GasPrice = gasPrice
instance， err ：= event.NewEvent（common.HexToAddress（“0x8A421906e9562AA1c71e5a32De1cf75161C5A463”）， EthClient）
// 調用合約中的updateWeather方法，回填數據“29”
tx， err ：= instance.UpdateWeather（auth， big.NewInt（29））
log.Info（tx.Hash（）.Hex（））
}
用一個圖來展示這個過程：
Chainlink
Chainlink是一個去中心化的預言機項目，它的作用就是以最安全的方式向區塊鏈提供現實世界中產生的數據。Chainlink在基本的預言機原理的實現方式之上，圍繞LINK token通過經濟激勵建立了一個良性循環的生態系統。Chainlink預言機需要通過LINK token的轉賬來實現觸發。
LINK是以太坊網絡上的ERC677合約，關于各類ERC token的區別，請參考這篇文章。
在《精通以太坊（Matering Ethereum）》一書中，提出了三種預言機的設計模式，分別是
· 立即讀取（immediate-read）
· 發布/訂閱（publish–subscribe）
· 請求/響應（request–response）
而基于LINK ERC677 token完成的預言機功能，就屬于其中的請求/響應模式。這是一種較為復雜的模式，上圖中展示的是一個不含有聚合過程的簡單請求/相應流程。
我們以Chainlink提供的TestnetConsumer合約中的一個requestEthereumPrice 方法為例來簡單講一下請求響應的流程。這個函數定義如下：
function requestEthereumPrice（address _oracle， string _jobId）
public
onlyOwner
{
Chainlink.Request memory req = buildChainlinkRequest（stringToBytes32（_jobId）， this， this.fulfillEthereumPrice.selector）;
req.add（“get”， “https://min-api.cryptocompare.com/data/price？fsym=ETH&tsyms=USD”）;
req.add（“path”， “USD”）;
req.addInt（“times”， 100）;
sendChainlinkRequestTo（_oracle， req， ORACLE_PAYMENT）;
}
它所實現的功能就是從指定的API（cryptocompare）獲取ETH/USD的交易價格。函數傳入的參數是指定的oracle地址和jobId。
將一些列的請求參數組好后，調用sendChainlinkRequestTo 方法將請求發出。sendChainlinkRequestTo是定義在Chainlink提供的庫中的一個接口方法，定義如下：
/**
* @notice 向指定的oracle地址創建一個請求
* @dev 創建并存儲一個請求ID， 增加本地的nonce值， 并使用`transferAndCall` 方法發送LINK，
* 創建到目標oracle合約地址的請求
* 發出 ChainlinkRequested 事件。
* @param _oracle 發送請求至的oracle地址
* @param _req 完成初始化的Chainlink請求
* @param _payment 請求發送的LINK數量
* @return 請求 ID
*/
function sendChainlinkRequestTo（address _oracle， Chainlink.Request memory _req， uint256 _payment）
internal
returns （bytes32 requestId）
{
requestId = keccak256（abi.encodePacked（this， requests））;
_req.nonce = requests;
pendingRequests［requestId］ = _oracle;
emit ChainlinkRequested（requestId）;
require（link.transferAndCall（_oracle， _payment， encodeRequest（_req））， “unable to transferAndCall to oracle”）;
requests += 1;
return requestId;
}
其中link.transferAndCall方法即是ERC677定義的token轉賬方法，與ERC20的transfer方法相比，它多了一個data字段，可以在轉賬的同時攜帶數據。這里就將之前打包好的請求數據放在了data字段，跟隨轉賬一起發送到了oracle合約。transferAndCall 方法定義如下：
/**
* @dev 將token和額外數據一起轉移給一個合約地址
* @param _to 轉移到的目的地址
* @param _value 轉移數量
* @param _data 傳遞給接收合約的額外數據
*/
function transferAndCall（address _to， uint _value， bytes _data）
public
returns （bool success）
{
super.transfer（_to， _value）;
Transfer（msg.sender， _to， _value， _data）;
if （isContract（_to）） {
contractFallback（_to， _value， _data）;
}
return true;
}
其中的Transfer（msg.sender， _to， _value， _data）;是發出一個事件日志：
event Transfer（address indexed from， address indexed to， uint value， bytes data）;
將這次轉賬的詳細信息（發送方、接收方、金額、數據）記錄到日志中。
Oracle合約在收到轉賬之后，會觸發onTokenTransfer方法，該方法會檢查轉賬的有效性，并通過發出OracleRequest事件記錄更為詳細的數據信息：
event OracleRequest（
bytes32 indexed specId，
address requester，
bytes32 requestId，
uint256 payment，
address callbackAddr，
bytes4 callbackFunctionId，
uint256 cancelExpiration，
uint256 dataVersion，
bytes data
）;
這個日志會在oracle合約的日志中找到，如圖中下方所示。鏈下的節點會訂閱該主題的日志，在獲取到記錄的日志信息之后，節點會解析出請求的具體信息，通過網絡的API調用，獲取到請求的結果。之后通過提交事務的方式，調用Oracle合約中的fulfillOracleRequest方法，將數據提交到鏈上。fulfillOracleRequest定義如下：
/**
* @notice 由Chainlink節點調用來完成請求
* @dev 提交的參數必須是`oracleRequest`方法所記錄的哈希參數
* 將會調用回調地址的回調函數，`require`檢查時不會報錯，以便節點可以獲得報酬
* @param _requestId 請求ID必須與請求者所匹配
* @param _payment 為Oracle發放付款金額 （以wei為單位）
* @param _callbackAddress 完成方法的回調地址
* @param _callbackFunctionId 完成方法的回調函數
* @param _expiration 請求者可以取消之前節點應響應的到期時間
* @param _data 返回給消費者合約的數據
* @return 外部調用成功的狀態值
*/
function fulfillOracleRequest（
bytes32 _requestId，
uint256 _payment，
address _callbackAddress，
bytes4 _callbackFunctionId，
uint256 _expiration，
bytes32 _data
）
external
onlyAuthorizedNode
isValidRequest（_requestId）
returns （bool）
{
bytes32 paramsHash = keccak256（
abi.encodePacked（
_payment，
_callbackAddress，
_callbackFunctionId，
_expiration
）
）;
require（commitments［_requestId］ == paramsHash， “Params do not match request ID”）;
withdrawableTokens = withdrawableTokens.add（_payment）;
delete commitments［_requestId］;
require（gasleft（） 》= MINIMUM_CONSUMER_GAS_LIMIT， “Must provide consumer enough gas”）;
// All updates to the oracle‘s fulfillment should come before calling the
// callback（addr+functionId） as it is untrusted.
// See： https://solidity.readthedocs.io/en/develop/security-considerations.html#use-the-checks-effects-interactions-pattern
return _callbackAddress.call（_callbackFunctionId， _requestId， _data）; // solhint-disable-line avoid-low-level-calls
}
這個方法會在進行一系列的檢驗之后，會將結果通過之前記錄的回調地址與回調函數，返回給消費者合約：
_callbackAddress.call（_callbackFunctionId， _requestId， _data）;
這樣一次請求就全部完成了。
總結
本文從預言機的概念開始，通過一個簡單的獲取ETH價格的例子，講解了請求/響應模式的Chainlink預言機的基本過程，希望對你理解預言機與Chainlink的運行原理有所幫助。
責任編輯；zl
工商網監
評論