使用go语言编写简易Blockchain实现web调用RPC过程

在本机端口进行查询由于是第一次运行该链生成创世区块

通过http实现RPC命令的调用  实现添加块

查询当前所有块的信息

这里只做了两个命令分别是get和write
源代码如下
基础功能的实现

package core
import (
      "crypto/sha256"
      "encoding/hex"
      "time"
)
//定义区块
type Block struct {
      Index       int64  //区块编号

Timestamp int64 //区块时间戳6 Q6 v. A9 O) W6 {* L2 @0 v) o
PrevBlockHash string //上一个区块的hash值
) f+ n- @* c/ g, S
Hash string //当前区块哈希值
' F& ]/ I4 ^6 N7 ~* j" u5 F
Data string //区块数据
. t) J7 Y2 _1 U* ]- x
}
* v; y7 K! p4 I1 r; s1 d' ] E2 m
//计算Hash
3 @( S: y- @. k
func calculateHash(b *Block) string {- W+ l8 M% f3 m, ]3 Y T6 i
blockData := string(b.Index) + string(b.Timestamp) + b.PrevBlockHash7 \3 S2 X( w5 ^1 y' v2 v
hashInBytes := sha256.Sum256([]byte(blockData))8 l5 N3 \5 ~% D. ?
return hex.EncodeToString(hashInBytes[:])
) l; J. b' l# h# O6 F5 o+ g
}

复制代码

//生成新的区块
func GenerateNewBlock(preBlock *Block, data string) *Block {
      newBlock := &Block{}
      newBlock.Index = preBlock.Index + 1
      newBlock.PrevBlockHash = preBlock.Hash
      newBlock.Timestamp = time.Now().Unix()
      newBlock.Hash = calculateHash(newBlock)
      newBlock.Data = data
      return newBlock
}

//生成创始区块
func GenerateGenesisBlock() *Block {
      preBlock := &Block{}
      preBlock.Index = -1
      preBlock.Hash = ""
      return GenerateNewBlock(preBlock, "Genesis Block")
}
将基础功能实现的块进行链接实现blockchain
package core

import (
      "fmt"
      "log"
)

//定义区块链
type BlockChain struct {
      Blocks []*Block
}

//创建一个区块链
func NewBlockChain() *BlockChain {
      genesisBlock := GenerateGenesisBlock()
      blockChain := &BlockChain{}
      blockChain.AppendBlock(genesisBlock)
      return blockChain
}

//记录区块数据
func (bc *BlockChain) SendData(data string) {
      preBlock := bc.Blocks[len(bc.Blocks)-1]
      newBlock := GenerateNewBlock(preBlock, data)
      bc.AppendBlock(newBlock)
}

//往区块链添加区块
func (bc *BlockChain) AppendBlock(newBlock *Block) {
      if len(bc.Blocks) == 0 {
            bc.Blocks = append(bc.Blocks, newBlock)
            return
      }
      if isValid(newBlock, bc.Blocks[len(bc.Blocks)-1]) {
            bc.Blocks = append(bc.Blocks, newBlock)
      } else {
            log.Fatal("invalid block")
      }
      return
}

//输出区块链信息
func (bc *BlockChain) Print() {
      for _, block := range bc.Blocks {
            fmt.Printf("Index : %d\n", block.Index)
            fmt.Printf("Prev.Hash : %s\n", block.PrevBlockHash)
            fmt.Printf("Curr.Hash : %s\n", block.Hash)
            fmt.Printf("Curr.Data : %s\n", block.Data)
            fmt.Printf("Curr.Timestamp : %d\n", block.Timestamp)
            fmt.Println("==========================================")
      }
}

//验证区块
func isValid(newBlock *Block, oldBlock *Block) bool {
      if newBlock.Index-1 != oldBlock.Index {
            return false
      }
      if newBlock.PrevBlockHash != oldBlock.Hash {
            return false
      }
      if calculateHash(newBlock) != newBlock.Hash {
            return false
      }
      return true
}
实现RPC接口的交互

package main3 F, g$ W: D. B" c6 G S6 g" s
4 p( M* V# \ ?- v
import (
_. L9 I: L9 e
"encoding/json"" l2 Q8 J, D8 z: {
"BlockChain/core"& w ^' Z/ O. d) h
"io"
% h; X0 n6 G6 q* Z
"net/http"
# R$ U7 y6 B; z* r! {, ~; c/ k
)
; T l2 L2 g% L, T2 h
- w, ~% ~7 ~' l2 ^3 @
var blockChain *core.BlockChain$ u' J: a9 @. L( b( }
' U4 m2 Z3 U0 @
func run() {
1 |5 i/ U& U/ R
http.HandleFunc("/block_chain/get", blockChainGetHandle), D4 [8 i. _: o g
http.HandleFunc("/block_chain/write", blockChainWriteHandle)
5 @% R! S- K' I5 \4 l- a$ a# ]
http.ListenAndServe(":8332", nil)3 C( P/ x0 t: W; k( z: T
}
/ j4 j! z' e- T z4 W0 V
3 e ]; p N1 \2 m( @1 M
func blockChainGetHandle(w http.ResponseWriter, r *http.Request) {
- g' h* n" h' l; q* I8 I+ x
bytes, err := json.Marshal(blockChain)8 j! k2 T! f& Z* K! }
if err != nil {( n& j4 K" n# v1 F3 @5 Z, e
http.Error(w, err.Error(), http.StatusInternalServerError)2 ^6 h% G; x" Y/ J; ^5 e
return' Y S$ h! q" F0 o
}
( s7 s, k+ q. @$ b; G4 z
io.WriteString(w, string(bytes))
# g* z6 b8 a3 E% V) j& }8 l7 w4 a
}
- p5 O1 l3 W7 f* x/ s3 k' C
' b: `4 t& @* l* M4 p
func blockChainWriteHandle(w http.ResponseWriter, r *http.Request) {
/ R3 `! k+ @! C# e: Q4 u' \) p
blockData := r.URL.Query().Get("data")
1 ^6 ]6 J. M M# @6 w
blockChain.SendData(blockData)
l) H* Q5 B) W4 \3 {3 K' S
blockChainGetHandle(w, r)0 H' V' H% b; |- o
}5 v1 L% J0 y+ t6 g
. V& M" J$ I0 d0 n( s
func main() {
/ O5 N8 i, r: Q0 n, M/ A$ v- |
blockChain = core.NewBlockChain()
/ a2 S+ H$ Q. K' P
run()% J$ i, ?! w; n- r( g1 |7 o
}

复制代码

通过两部分代码实现简易区块链的RPC调用

浏览过的版块