在這一系列的文章中,我將向你展示如何使用 Rust 語言從零開始編寫一個(gè)區(qū)塊鏈。這些文章并不是為了想學(xué)習(xí)智能合約編程的人,而是為了理解區(qū)塊鏈的底層知識(shí) - 區(qū)塊、鏈、鍵值數(shù)據(jù)庫(kù)、網(wǎng)絡(luò)、共識(shí)機(jī)制等的人而準(zhǔn)備的。如果你想學(xué)習(xí)區(qū)塊鏈的底層知識(shí),這就是你要找的地方。
我已經(jīng)在區(qū)塊鏈領(lǐng)域工作了幾年,從一開始就計(jì)劃寫這一系列的文章來學(xué)習(xí)區(qū)塊鏈。但直到現(xiàn)在,我才有足夠的時(shí)間來做這件事。我主要熟悉 Substrate 框架,從其文檔站點(diǎn)學(xué)到了很多知識(shí),從核心概念到如何使用它來開發(fā)應(yīng)用。所以我建議你如果有時(shí)間的話,去閱讀那些文檔,他們官方還有關(guān)于它的課程,你可以在這里找到信息:Polkadot Academy。國(guó)內(nèi)的話,OneBlock+社區(qū)在做免費(fèi)的Substrate培訓(xùn)課程,你可以在這里找到最新一期(2023.12)報(bào)名鏈接。
Substrate 是一個(gè)功能齊全的區(qū)塊鏈框架,它非常強(qiáng)大。但它也很復(fù)雜,難以深入理解,所以我開設(shè)這個(gè)系列,幫助那些想要深入了解區(qū)塊鏈內(nèi)部的開發(fā)者。
Rust 無疑是編寫區(qū)塊鏈的首選,它也是我最喜歡的編程語言。如果你還沒有接觸過它,你應(yīng)該去試試。
好的,讓我們開始吧。
塊
什么是區(qū)塊?它是區(qū)塊鏈的基本單位。在我們的例子中,它只是一個(gè) Rust 結(jié)構(gòu)體。我們可以這樣定義它:
structBlock{ header:BlockHeader, body:BlockBody, }
區(qū)塊由兩部分組成:BlockHeader 和 BlockBody。每種類型的定義如下:
BlockHeader
structBlockHeader{ hash:String, height:u64, prev_hash:String, timestamp:u64, }
BlockBody
typeBlockBody=Vec
區(qū)塊的Body部分是一個(gè)普通的字符串向量,而頭部看起來更有趣。在所有的字段中,prev_hash 是最有趣的,它存儲(chǔ)了前一個(gè)區(qū)塊的哈希字段值,我們將在這篇文章后面的鏈部分討論它。
height 字段表示這個(gè)區(qū)塊的序列號(hào),新的區(qū)塊被添加到區(qū)塊鏈中時(shí),高度會(huì)遞增。
timestamp 字段表示創(chuàng)建這個(gè)區(qū)塊時(shí)的 Unix 時(shí)間戳。所以它與你正在使用的本地機(jī)器有關(guān)。
而 hash 字段存儲(chǔ)了這個(gè)區(qū)塊的哈希值。我們會(huì)問:如何計(jì)算這個(gè)區(qū)塊的哈希值?因?yàn)楣W侄问沁@個(gè)結(jié)構(gòu)體的一部分,所以簡(jiǎn)單地序列化這個(gè)結(jié)構(gòu)體是行不通的。我們需要在做計(jì)算時(shí)從其他字段中排除這個(gè)字段。所以算法看起來像這樣:
fncalc_block_hash(height:u64,prev_hash:&str,timestamp:u64,body:&Vec
letconcated_str=vec![ height.to_string(), prev_hash.to_string(), timestamp.to_string(), body.concat(), ] .concat(); letmuthasher=Sha256::new(); hasher.update(concated_str.as_bytes()); hex::encode(hasher.finalize().as_slice()) }
我們不會(huì)教授如何編寫 Rust 代碼的細(xì)節(jié),相反,我們主要會(huì)描述如何設(shè)計(jì)它的思路流程。
在這里,我們按照 height, prev_hash, timestamp, body 的順序連接這個(gè)區(qū)塊的元素。由于 body 是一個(gè)向量,我們應(yīng)該首先連接它。一旦字符串連接完成,我們使用 Sha256 對(duì)其進(jìn)行哈希計(jì)算。這一步創(chuàng)建了一個(gè) 32 字節(jié)的 u8 數(shù)組:[u8; 32]。然后我們使用 hex 將其編碼為長(zhǎng)度為 64 的字符串,這代表了這個(gè)區(qū)塊的哈希。
你會(huì)注意到,我們將 prev_hash 值作為這個(gè)區(qū)塊的哈希的來源之一。這非常重要,你可能會(huì)想知道我們?yōu)槭裁匆@么做。
我們可以按照以下方式測(cè)試這個(gè)算法:
#[test] fntest_block_hash(){ letblock1=Block::new(10,"aaabbbcccdddeeefff".to_string(),vec![]); letblock2=Block::new(10,"aaabbbcccdddeeefff".to_string(),vec![]); assert_eq!(block1.header.height,block2.header.height); assert_eq!(block1.header.prev_hash,block2.header.prev_hash); //XXX:havelittleprobabilitytofail assert_eq!(block1.header.timestamp,block2.header.timestamp); //XXX:havelittleprobabilitytofail assert_eq!(block1.header.hash,block2.header.hash); assert_eq!(block1.body,block2.body); }
鏈
什么是鏈?你可以想象一條項(xiàng)鏈或者一條鐵鏈。在我們的例子中,鏈?zhǔn)且粋€(gè)抽象的概念,每個(gè)區(qū)塊都存儲(chǔ)了前一個(gè)區(qū)塊的哈希字段值。就這樣,你看,沒有復(fù)雜的地方。
在這個(gè)鏈中,每個(gè)區(qū)塊只關(guān)心前一個(gè)區(qū)塊,而不關(guān)心其他區(qū)塊。所以它是一個(gè)相對(duì)簡(jiǎn)單的結(jié)構(gòu)。
但我們即將遇到一個(gè)問題:第一個(gè)區(qū)塊怎么辦?它之前沒有區(qū)塊。
是的,對(duì)于這個(gè)邊緣情況,我們需要為 hash 字段設(shè)置一個(gè)預(yù)定義的值。由于這個(gè)特殊情況,區(qū)塊鏈的第一個(gè)區(qū)塊通常被稱為 創(chuàng)世(Genesis) 區(qū)塊。
這就是整個(gè)區(qū)塊鏈的樣子:
隨著時(shí)間的推移,這個(gè)結(jié)構(gòu)將無限擴(kuò)展(或增長(zhǎng))。
區(qū)塊鏈管理器
我們需要一個(gè)管理器來管理區(qū)塊鏈。現(xiàn)在它非常簡(jiǎn)單,只包含一個(gè)區(qū)塊的向量。
#[derive(Debug)] structBlockChain{ blocks:Vec, }
并在其上實(shí)現(xiàn)一些方法:
implBlockChain{ fnnew()->Self{ BlockChain{blocks:vec![]} } fngenesis()->Block{ lettxs=vec!["Thebigbrotheriswatchingyou.".to_string()]; Block::new(0,"1984,GeorgeOrwell".to_string(),txs) } fnadd_block(&mutself,block:Block){ self.blocks.push(block); } }
現(xiàn)在我們可以使用這個(gè)管理器來構(gòu)建一個(gè)區(qū)塊鏈:
fnmain(){
letmutblockchain=BlockChain::new(); letgenesis_block=BlockChain::genesis(); letprev_hash=genesis_block.header.hash.clone(); blockchain.add_block(genesis_block); letb1=Block::new(1,prev_hash,vec![]); letprev_hash=b1.header.hash.clone(); blockchain.add_block(b1); letb2=Block::new(2,prev_hash,vec![]); letprev_hash=b2.header.hash.clone(); blockchain.add_block(b2); letb3=Block::new(3,prev_hash,vec![]); letprev_hash=b3.header.hash.clone(); blockchain.add_block(b3); letb4=Block::new(4,prev_hash,vec![]); letprev_hash=b4.header.hash.clone(); blockchain.add_block(b4); letb5=Block::new(5,prev_hash,vec![]); //letprev_hash=b5.header.hash.clone(); blockchain.add_block(b5); println!("{:#?}",blockchain); }
它將打印出來類似下面的東西:
mike@alberta:~/works/blockchainworks/vintage$cargorun Compilingvintagev0.1.0(/home/mike/works/blockchainworks/vintage) Finisheddev[unoptimized+debuginfo]target(s)in0.22s Running`target/debug/vintage` BlockChain{ blocks:[ Block{ header:BlockHeader{ hash:"96cf34aa91e070ddf95eb9e0e8616b24e2f326c80d5fa9746e8dd8f0bec730d6", height:0, prev_hash:"1984,GeorgeOrwell", timestamp:1705649594, }, body:[ "Thebigbrotheriswatchingyou.", ], }, Block{ header:BlockHeader{ hash:"0dd52ac54a9d621c47688f7920cd9eaee18ffe0cca3c83e124b8f78cef8999e5", height:1, prev_hash:"96cf34aa91e070ddf95eb9e0e8616b24e2f326c80d5fa9746e8dd8f0bec730d6", timestamp:1705649594, }, body:[], }, Block{ header:BlockHeader{ hash:"61e95ab151cfa41c2a74cb076c33511ddf71f45dab0571f5f2db89df7ebc64cf", height:2, prev_hash:"0dd52ac54a9d621c47688f7920cd9eaee18ffe0cca3c83e124b8f78cef8999e5", timestamp:1705649594, }, body:[], }, Block{ header:BlockHeader{ hash:"dde009c56c1b02d41fec8271e5f990e9b33c84a2cf044de6fc33e96605f90458", height:3, prev_hash:"61e95ab151cfa41c2a74cb076c33511ddf71f45dab0571f5f2db89df7ebc64cf", timestamp:1705649594, }, body:[], }, Block{ header:BlockHeader{ hash:"f8cd3ab5f6ccc864515635878498e2e26b63b4fbf4dbc60ea3649e859b4a7d27", height:4, prev_hash:"dde009c56c1b02d41fec8271e5f990e9b33c84a2cf044de6fc33e96605f90458", timestamp:1705649594, }, body:[], }, Block{ header:BlockHeader{ hash:"4415f4993729459f5ff07c7c963890f1d9210d5241f5203b9179c8d3db6e9dac", height:5, prev_hash:"f8cd3ab5f6ccc864515635878498e2e26b63b4fbf4dbc60ea3649e859b4a7d27", timestamp:1705649594, }, body:[], }, ], }
我們做到了,它已經(jīng)是一個(gè)區(qū)塊鏈了。
如何持久化
到目前為止,我們只是將區(qū)塊鏈保存在計(jì)算機(jī)的內(nèi)存中,所以如果我們現(xiàn)在關(guān)閉計(jì)算機(jī),區(qū)塊鏈將一無所有。我們最好將整個(gè)鏈存儲(chǔ)在我們的計(jì)算機(jī)上。
一般來說,人們會(huì)使用鍵值數(shù)據(jù)庫(kù)(kv db)來存儲(chǔ)區(qū)塊鏈。為什么使用 kv db 而不是文件或 SQL db 呢?因?yàn)樗?jiǎn)單且高效。
在我們的例子中,我們將使用 redb 作為我們的存儲(chǔ)后端。根據(jù)其官方網(wǎng)站,Redb 是一個(gè)簡(jiǎn)單、便攜、高性能、ACID、嵌入式鍵值存儲(chǔ),完全用 Rust 編寫,并受到 lmdb 的啟發(fā)。
接下來,我們需要設(shè)計(jì)一個(gè)存儲(chǔ)模式。有以下幾點(diǎn):
使用兩個(gè)表:blocks 表用于開發(fā)/生產(chǎn)模式,blocks_fortest 表用于測(cè)試模式;
每個(gè)區(qū)塊都作為 redb 中的一個(gè)鍵值元素存儲(chǔ),其中鍵是區(qū)塊的哈希字段值,值是區(qū)塊的完全序列化字符串。
我們需要一個(gè)指針指向最后一個(gè)區(qū)塊。'指向'實(shí)際上意味著持有區(qū)塊的哈希值。我們可以使用這個(gè)指針從數(shù)據(jù)庫(kù)中重構(gòu)整個(gè)鏈(內(nèi)存表示)。
我們還保持了 height 和區(qū)塊的 hash 之間的映射關(guān)系。
然后我們需要將一個(gè) db 實(shí)例注入到 BlockChain 管理器結(jié)構(gòu)中。
#[derive(Debug)] structBlockChain{ blocks:Vec, db:Db, }
基于這個(gè)管理器實(shí)例,我們可以按照以下方式實(shí)現(xiàn)一個(gè)持久化方法:
fnpersist_block_to_table(
&mutself, table:TableDefinition<&str,?&str>, block:&Block, )->Result<()>{ letheight=&block.header.height; lethash=&block.header.hash; letcontent=serde_json::to_string(&block)?; //storehash->blockpair self.db.write_block_table(table,&hash,&content)?; //storeheight->hashpair self.db .write_block_table(table,&height.to_string(),&hash)?; //storethelbp->hashpair(lastblockpointertohash) self.db .write_block_table(table,LAST_BLOCK_POINTER,&hash)?; Ok(()) }
其中,我們使用 serde 框架并使用 serde_json 將整個(gè) block 結(jié)構(gòu)體序列化為字符串(json 格式)。如你所見,我們存儲(chǔ)了 3 對(duì)鍵值對(duì):
hash -> 序列化的區(qū)塊字符串
height -> 區(qū)塊哈希
lbp (最后一個(gè)區(qū)塊的指針) -> 區(qū)塊哈希
我們可以像這樣從數(shù)據(jù)庫(kù)中檢索一個(gè) Block:
fnretrieve_block_by_hash_from_table(
&self, table:TableDefinition<&str,?&str>, hash:&str, )->Result
我們使用 serde_json::from_str() 來反序列化原始字符串。
接下來,我們需要弄清楚如何從數(shù)據(jù)庫(kù)中重新構(gòu)建一個(gè)正確的區(qū)塊鏈。我們可以使用一個(gè)迭代來做這個(gè),首先獲取最后一個(gè)區(qū)塊,然后獲取最后一個(gè)區(qū)塊的前一個(gè)區(qū)塊,依此類推。我們可以看看代碼:
fnpopulate_from_db_table(&mutself,table:TableDefinition<&str,?&str>)->Result<()>{
//findlastblockhashfromdb letlast_block_hash=self.db.read_block_table(table,LAST_BLOCK_POINTER)?; iflast_block_hash.is_none(){ returnOk(()); } letlast_block_hash=last_block_hash.unwrap(); //retrievelastblock letblock=self.retrieve_block_by_hash_from_table(table,&last_block_hash)?; ifblock.is_none(){ returnOk(()); } letblock=block.unwrap(); letmutprev_hash=block.header.prev_hash.clone(); letmutblocks:Vec=vec![block]; //iteratetooldblockesbyprev_hash whileprev_hash!=GENESIS_PREV_HASH{ letblock=self.retrieve_block_by_hash_from_table(table,&prev_hash)?; ifblock.is_none(){ returnOk(()); } letblock=block.unwrap(); prev_hash=block.header.prev_hash.clone(); blocks.insert(0,block); } //contructaninstanceofblockchain self.blocks=blocks; Ok(()) }
我們可以像這樣使用這個(gè) API:
letmutblockchain=BlockChain::new();
blockchain .populate_from_db() .expect("errorwhenpopulatefromdb");
然后可以測(cè)試它:
#[test] fntest_store_block_and_restore_block(){ letmutblockchain=BlockChain::new_to_table(TABLE_BLOCKS_FORTEST); //initialization letgenesis_block=BlockChain::genesis(); letprev_hash=genesis_block.header.hash.clone(); blockchain.add_block_to_table(TABLE_BLOCKS_FORTEST,genesis_block); letb1=Block::new(1,prev_hash,vec![]); letprev_hash=b1.header.hash.clone(); blockchain.add_block_to_table(TABLE_BLOCKS_FORTEST,b1); letb2=Block::new(2,prev_hash,vec![]); blockchain.add_block_to_table(TABLE_BLOCKS_FORTEST,b2); letblock_vec=blockchain.blocks.clone(); blockchain .populate_from_db_table(TABLE_BLOCKS_FORTEST) .expect("errorwhenpopulatefromdb"); _=blockchain.db.drop_table(TABLE_BLOCKS_FORTEST); for(i,block)inblock_vec.into_iter().enumerate(){ letblock_tmp=blockchain.blocks[i].clone(); assert_eq!(block,block_tmp); } }
在我們的代碼中,使用 anyhow 來幫助管理各種錯(cuò)誤,感謝這個(gè)漂亮的 crate,它使我們的生活更加輕松。
到目前為止,我們的區(qū)塊鏈已經(jīng)具有了持久化的能力,不再擔(dān)心會(huì)丟失數(shù)據(jù)。我們已經(jīng)到達(dá)了偉大征程的第一個(gè)里程碑。
審核編輯:黃飛
-
源代碼
+關(guān)注
關(guān)注
96文章
2945瀏覽量
66747 -
區(qū)塊鏈
+關(guān)注
關(guān)注
111文章
15562瀏覽量
106045 -
Rust
+關(guān)注
關(guān)注
1文章
228瀏覽量
6610
原文標(biāo)題:使用Rust從零開發(fā)區(qū)塊鏈 01
文章出處:【微信號(hào):Rust語言中文社區(qū),微信公眾號(hào):Rust語言中文社區(qū)】歡迎添加關(guān)注!文章轉(zhuǎn)載請(qǐng)注明出處。
發(fā)布評(píng)論請(qǐng)先 登錄
相關(guān)推薦
評(píng)論