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

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

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

查询当前所有块的信息

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

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

Timestamp int64 //区块时间戳
5 L" Y* |, P* c G# N
PrevBlockHash string //上一个区块的hash值
# R+ ^7 V) g1 T
Hash string //当前区块哈希值* g! F, f* k3 L' T3 S* F# i' X
Data string //区块数据- O3 B! _- @% w! J, C5 J
}
* g2 E0 _6 [7 u$ o2 l' b3 b
//计算Hash
' `. R& s$ }: D2 o
func calculateHash(b *Block) string {
' k# z/ c1 E. e+ T7 D
blockData := string(b.Index) + string(b.Timestamp) + b.PrevBlockHash
Q' W, G8 p) r% {& E+ l( |! w
hashInBytes := sha256.Sum256([]byte(blockData))5 M* ~% J1 T8 s+ Z& w( W7 n% w
return hex.EncodeToString(hashInBytes[:])
2 D, _7 i W* e8 X
}

复制代码

//生成新的区块
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 main2 a7 q# o2 l/ ]* ~% r4 @& T
" Z8 ^ i0 v9 m( s0 k1 D9 g3 W% ?
import (5 S5 J- ]7 W# z; p' B2 b
"encoding/json"
: x- W) `2 L' f
"BlockChain/core"& o) C7 j. q6 R
"io", `9 u& Y r2 |. N; n
"net/http"
( z; C) v# q0 i' P
)+ q5 y- t( R$ m& f% {8 _1 J
% E2 P( `/ A: [$ @: Y+ S
var blockChain *core.BlockChain' B! o) O% W# Z
! M& o) X! s* I! Y
func run() { e* t7 ^& S: C/ M
http.HandleFunc("/block_chain/get", blockChainGetHandle)
4 F0 z% F2 ~5 O; I d; U' F
http.HandleFunc("/block_chain/write", blockChainWriteHandle)1 `1 ?2 X8 v$ |/ Y- k
http.ListenAndServe(":8332", nil)
$ s% J6 P* C; J- c9 W
}8 G) e3 V! A" m
1 t% @# |6 p% M8 _8 l! ]2 \6 _
func blockChainGetHandle(w http.ResponseWriter, r *http.Request) {
+ K! b6 s+ v: q/ o3 X! `
bytes, err := json.Marshal(blockChain)
4 m" S. J5 l! _8 _- Y
if err != nil {
/ L; ?2 G1 X8 W
http.Error(w, err.Error(), http.StatusInternalServerError)
3 O+ \" i% u8 o5 s7 p p' \7 A
return
/ o# Q- @. i/ R4 I' |- |! X" E
}9 K9 ^, { n% _) D# ~
io.WriteString(w, string(bytes)); H) n/ Z3 z) a9 ~3 R4 C: b4 M+ J
}3 n+ l( |% B% s! s3 B
- y K$ W8 J3 N" d
func blockChainWriteHandle(w http.ResponseWriter, r *http.Request) {
# v7 `3 ?5 i2 k+ o3 W
blockData := r.URL.Query().Get("data")
8 r: O( Q" [: ^
blockChain.SendData(blockData)- e3 q8 }4 {: S- q
blockChainGetHandle(w, r): z7 G4 i/ \/ D) @9 L) d# b
}
% i/ V* e: t# v% j
! V5 K) Z" W) {- }6 Z- s. r
func main() {
2 a& A1 o2 i+ [9 E' E- k# H
blockChain = core.NewBlockChain()0 f% ]& I- n( v
run()0 e+ b/ i# D7 o/ ^
}

复制代码

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