使用go语言编写简易Blockchain实现web调用RPC过程 - 区块链技术 - BitMere

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

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

查询当前所有块的信息

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

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

Timestamp int64 //区块时间戳
" T4 S8 `" G& l% V, J* \4 a1 B
PrevBlockHash string //上一个区块的hash值 H0 \2 p9 H& Q4 D$ p U3 _
Hash string //当前区块哈希值
% C: J4 R L3 W8 [
Data string //区块数据
1 U G9 B, J+ P2 ]0 n4 c" X0 Z
}
! v3 J! c( J7 r% v0 B& i* p( L
//计算Hash
, e: ^5 t- u4 h+ V. P) W
func calculateHash(b *Block) string {+ z1 m. M j. Q, y% \, }
blockData := string(b.Index) + string(b.Timestamp) + b.PrevBlockHash, D2 W% N: y: W0 H
hashInBytes := sha256.Sum256([]byte(blockData))
* H. L8 m a1 U8 _. e: ~
return hex.EncodeToString(hashInBytes[:])
% P& o3 v, p2 G- ~8 J' p
}

复制代码

//生成新的区块
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
0 b/ L6 n% K0 {( |
2 b3 B6 i: V! L& w/ E' w) p
import (
' @! S$ {$ @5 J' @; N5 a
"encoding/json"9 Z" a- d1 d9 j; v8 I7 B* H
"BlockChain/core"
2 `: G9 u, ?/ b4 r7 Z, |
"io"
0 s( g: y2 S' ^3 b3 h
"net/http"( O% E* i' M E$ u1 y+ C3 R
)
9 ]; d( L0 ?% l9 I
2 Q6 q/ {% L! H- d/ h( r
var blockChain *core.BlockChain
( q) P% C; S- c" ?& p
' e- N* ^' s% L. s3 s: V+ i- T; J
func run() {2 p7 x3 w$ l6 f+ {
http.HandleFunc("/block_chain/get", blockChainGetHandle)! ?; o0 }1 {9 y- t) F7 P" @# r4 h, P
http.HandleFunc("/block_chain/write", blockChainWriteHandle), Y* R" m1 G/ i3 u( I
http.ListenAndServe(":8332", nil)
1 R' Q0 D9 p; d. l9 P. N
}
Z* E9 ~% W- j3 _- X
6 {: ~4 S/ p; @0 s3 C6 d
func blockChainGetHandle(w http.ResponseWriter, r *http.Request) {/ G* L* ^' n, T+ \/ i! N, v
bytes, err := json.Marshal(blockChain)
7 [0 ~' _. b0 {1 H5 n
if err != nil {
4 h# M4 s% a: {( o" \
http.Error(w, err.Error(), http.StatusInternalServerError)
& I6 [8 _- N$ @; D) d
return
* p8 L s9 F3 o0 @6 Q
}
) x6 w2 l, \3 _3 v
io.WriteString(w, string(bytes))
9 z# Q3 c& i; v0 B1 G9 r8 @
}5 e3 C- y( [3 b, @: A
* S1 O$ d1 e) n) S
func blockChainWriteHandle(w http.ResponseWriter, r *http.Request) {" C0 m- ]. ]# t/ g( A) P
blockData := r.URL.Query().Get("data")
' t! t7 ~5 Y% y
blockChain.SendData(blockData)
; b8 r n3 _# A9 S: a. ~
blockChainGetHandle(w, r)0 h9 U6 j3 p5 M9 E$ m' b
}
% o# L) |2 x0 _9 i5 W8 @2 \
9 U# P/ K& y2 [7 Q: v# i' {- }1 W! G
func main() {
/ N8 ?# l. [. u [# P: ?& {, r/ h
blockChain = core.NewBlockChain() @4 F4 q2 [! y6 U& N" J: O
run()
6 @) E; o) i0 W) d& Z% Q
}

复制代码

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