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

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

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

查询当前所有块的信息

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

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

Timestamp int64 //区块时间戳
+ W+ ^0 i0 P X6 T0 o
PrevBlockHash string //上一个区块的hash值
( L0 c# N! c, c2 U* f. p! _: J0 m
Hash string //当前区块哈希值
0 {8 C6 Y$ \; D2 z& r' x8 f* u
Data string //区块数据
3 ^: b- I/ n4 `. k$ b
}8 r& N: m9 c y3 N
//计算Hash; ?" ?6 Q' X5 I+ Z6 U8 P/ d0 M
func calculateHash(b *Block) string {
% U8 N6 o9 h8 e
blockData := string(b.Index) + string(b.Timestamp) + b.PrevBlockHash
4 g% b4 M; ^3 P" U! D
hashInBytes := sha256.Sum256([]byte(blockData))) y' i; ^0 e0 S1 F) M
return hex.EncodeToString(hashInBytes[:])$ a# s! v% v7 Q' C4 B4 W/ C
}

复制代码

//生成新的区块
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
/ M3 S/ @) |6 t" Q
3 ~" s6 o% M7 h5 S: _) F
import (
! l5 Q- b1 `/ R& y- f/ q, H2 h
"encoding/json"
7 i. Z! n: Z& D, M5 |; h
"BlockChain/core" w! \) c- ]% K4 K0 g& a2 V
"io"
0 W$ w7 H; h* H9 k- n
"net/http"
2 r9 g0 B$ k- L ]/ W8 r
)
9 C& X; T. ?* J7 H
! O2 V4 M# a" \3 Z
var blockChain *core.BlockChain. p( }' ?2 }; _& e/ E
" U! \+ p+ Y2 M% E a8 \
func run() {
" z* g3 Q: [$ ^
http.HandleFunc("/block_chain/get", blockChainGetHandle)4 [4 m |# s" V$ j
http.HandleFunc("/block_chain/write", blockChainWriteHandle)
% L0 H, Z% ]+ N! ?7 I8 f
http.ListenAndServe(":8332", nil), T8 j8 v. z- `, _
}" o( c3 V* T+ J* v8 Q( U9 L
2 d @# L5 u, d: X; d
func blockChainGetHandle(w http.ResponseWriter, r *http.Request) {1 N& x* o# d7 n" P% z( f# @7 [
bytes, err := json.Marshal(blockChain)
, p2 \( m0 `, e
if err != nil { O& y0 J1 A. W+ U
http.Error(w, err.Error(), http.StatusInternalServerError)/ m2 N$ Q2 Q0 m( y
return
# x' p) |2 |0 G) s1 |0 e& U8 J
}3 Y/ `+ H, M" L( A4 P
io.WriteString(w, string(bytes))/ _0 P1 P$ w- n5 P" T. a# P
}
/ \* ^% n+ ?4 u4 h+ J" A. }- H
3 F" C1 e, R! y/ A, ]
func blockChainWriteHandle(w http.ResponseWriter, r *http.Request) {" W8 x3 I( J; Q9 n- ~, ?) P! p
blockData := r.URL.Query().Get("data")# L1 u1 Z# H: i, M2 x8 O
blockChain.SendData(blockData)
2 z0 n$ n5 _) d) | e$ @( T
blockChainGetHandle(w, r)" @# W0 I3 {: l w6 k$ g6 S- P
}4 C$ G. p) Z2 ^. I
: T" c' U& Q6 N' D$ i& R
func main() {; n/ a5 E7 r) A1 f/ k
blockChain = core.NewBlockChain()
- Q* W) |, |( I, a0 ?- P1 w8 P
run()
1 H4 |8 Z2 O8 o/ K& q7 N9 N
}

复制代码

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