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

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

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

查询当前所有块的信息

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

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

Timestamp int64 //区块时间戳
{1 ?" r5 Z- u0 |, H0 `
PrevBlockHash string //上一个区块的hash值
* _) f0 @: _- ^8 H9 v# n7 ~. A( K
Hash string //当前区块哈希值 `; K7 s1 t. i- b
Data string //区块数据
6 {! ^$ @6 H( Q$ x' |4 r
}2 g% B* h! b4 }' S% @
//计算Hash
6 H+ t: @5 b5 ]8 d% E4 Z3 E
func calculateHash(b *Block) string {4 b1 R- `. G+ f! o
blockData := string(b.Index) + string(b.Timestamp) + b.PrevBlockHash
0 ]* Y4 d" C9 P4 c+ G7 U ?8 j/ K
hashInBytes := sha256.Sum256([]byte(blockData))
1 W9 A, @7 X- {+ ~0 ^3 @6 K, w
return hex.EncodeToString(hashInBytes[:])
* C/ P& y; Q; q! |& b
}

复制代码

//生成新的区块
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 main
7 c5 x- h' J" C3 p% B+ D) M
% V& i0 s& c9 J2 m
import (( P$ y. t. Z* b+ o
"encoding/json"
* _- m: N. Q! s4 M& c" \$ x# S3 G
"BlockChain/core"
9 [) `. W3 ]% }! `6 k) A5 W: [+ V
"io"
"net/http"6 I9 q6 A) d* f# j: K- E% q1 t
)" m; S9 s5 K: ]7 e* Z' @
0 O/ v m( {( N) y) i1 f; I( t y
var blockChain *core.BlockChain
& _2 W5 u- s* S7 R/ ` O# X1 F
8 C5 i" o$ ]* M, X
func run() {7 P3 \! J% G4 Z9 J/ ]
http.HandleFunc("/block_chain/get", blockChainGetHandle)5 l$ ~8 f1 u Y" `0 C
http.HandleFunc("/block_chain/write", blockChainWriteHandle)
( y Z. S' ]. \% C, K. ^3 M! A
http.ListenAndServe(":8332", nil)
5 M; ^% V7 T& S1 V$ s) e
}9 X( [" [/ [) `( g
9 ?* L5 r! Q. K# g3 P8 Q5 U# u
func blockChainGetHandle(w http.ResponseWriter, r *http.Request) {; g- @" K- Z5 ^: V* y
bytes, err := json.Marshal(blockChain)
4 R$ m) D( K: F+ v' ]0 Q* h
if err != nil {! {, V; R& k5 B: G } g
http.Error(w, err.Error(), http.StatusInternalServerError)( P# u( K1 Y! R2 P
return9 n0 P% q4 y- ~3 `5 y7 M. L
}
2 u! Z; U- S+ L1 @. q0 j1 q
io.WriteString(w, string(bytes)), l, Z' U, P. v* C+ f
}; a2 Y% L, W) q1 a$ k
" V% O" E- f+ }4 T7 ~3 c/ L
func blockChainWriteHandle(w http.ResponseWriter, r *http.Request) {/ d8 j1 Y- P( N. d' K0 P
blockData := r.URL.Query().Get("data")
) g- ^) [) A1 o& N' [4 X1 g: P
blockChain.SendData(blockData)
- T: I3 } k! }6 j2 V
blockChainGetHandle(w, r)/ S0 N1 n7 h# i+ R* w- O5 G
}) f' ]: ]4 D; O! n4 t1 a( ]2 C7 c
* \* S* y/ F# e+ p0 b' u
func main() {7 D% t6 @/ x; R5 ^
blockChain = core.NewBlockChain()6 i& @& q! I2 L/ K
run()
; [3 x( ^2 n* ?
}

复制代码

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

浏览过的版块