### 创建简易区块链 为了构建一个基于Python的简易区块链，可以按照如下方式组织代码结构。该实现不仅涵盖了基础的数据存储机制还引入了简单的共识算法以确保数据的一致性和不可篡改性。 #### 导入必要的库 首先导入所需的第三方模块，这些模块用于处理时间戳、哈希运算以及HTTP请求响应等操作。 ```python import datetime import hashlib import json from flask import Flask, jsonify, request import requests ``` #### 定义Block类 每一个区块(Block)由索引(index)，时间戳(timestamp)，交易列表(transactions)，前一区块的工作量证明(proof)，以及前一区块的哈希值(previous_hash)组成。 ```python class Block: def __init__(self, index, timestamp, transactions, proof, previous_hash): self.index = index self.timestamp = str(datetime.datetime.now()) self.transactions = transactions self.proof = proof self.previous_hash = previous_hash or self.hash_block() def hash_block(self): """ 使用SHA-256算法计算当前区块的哈希值 :return: 当前区块的哈希字符串表示形式 """ block_string = "{}{}{}{}".format( self.index, self.timestamp, ''.join([str(t) for t in self.transactions]), self.proof ) return hashlib.sha256(block_string.encode()).hexdigest() ``` #### 构建Blockchain类 `Blockchain` 类负责管理整个链表式的数据库，并提供接口函数供外部调用，比如挖矿(mining)、添加新区块(add_new_block)等功能。 ```python class Blockchain(object): def __init__(self): # 初始化创世区块 genesis_block = Block(0, datetime.datetime.now(), [], 100, "0") self.chain = [genesis_block] @property def last_block(self): """获取最新的区块""" return self.chain[-1] def add_transaction(self, sender, recipient, amount): """ 添加新的交易记录至待打包池 :param sender: 发送方地址 :param recipient: 接收方地址 :param amount: 数额 :return: 将要被打包进的那个区块的编号 """ transaction_data = { 'sender': sender, 'recipient': recipient, 'amount': amount } next_index = len(self.chain) response = {'message': f'Transaction will be added to Block {next_index}'} return jsonify(response), 201 def mine_block(self): """ 挖掘新块并加入到链条上 :return: 新挖掘出来的区块的信息字典 """ last_proof = self.last_block.proof new_proof = self._proof_of_work(last_proof) previous_hash = self.last_block.hash_block() new_block = Block(len(self.chain), datetime.datetime.now(), [], new_proof, previous_hash) self.chain.append(new_block) response = { 'message': 'New Block Forged', 'index': new_block.index, 'transactions': [], 'proof': new_block.proof, 'previous_hash': previous_hash, } return jsonify(response), 200 def _proof_of_work(self, last_proof): """ 工作量证明 (Proof of Work): 找到一个数 p' 使得其与最后一个工作量证明相乘的结果含有四个前置零. :param last_proof: 上一次的工作量证明 :type last_proof: int :return: 新的工作量证明 :rtype: int """ proof = 0 while not self.valid_proof(last_proof, proof): proof += 1 return proof @staticmethod def valid_proof(last_proof, proof): """ 验证给定的工作量证明是否有效——即检查两个连续整数之积是否有四位以上的二进制位全为零的情况发生 :param last_proof: 上次的工作量证明 :type last_proof: int :param proof: 待验证的工作量证明 :type proof: int :return: 如果满足条件则返回True；否则False :rtype: bool """ guess = f'{last_proof}{proof}'.encode() guess_hash = hashlib.sha256(guess).hexdigest() return guess_hash[:4] == "0000" ``` #### 设置Flask Web服务端口 利用Flask框架搭建RESTful API服务器以便于客户端能够发送POST/GET请求来进行交互。 ```python app = Flask(__name__) blockchain = Blockchain() @app.route('/mine', methods=['GET']) def mine(): global blockchain result = blockchain.mine_block() return result @app.route('/transactions/new', methods=['POST']) def new_transaction(): values = request.get_json() required_fields = ['sender', 'recipient', 'amount'] if not all(k in values for k in required_fields): return 'Missing fields', 400 index = blockchain.add_transaction(values['sender'], values['recipient'], values['amount']) response = {'message': f'Transaction will be added to Block'} return jsonify(response), 201 if __name__ == '__main__': app.run(host='localhost', port=5000) ``` 上述代码展示了如何使用Python建立一个简易版的区块链系统[^1]。通过定义相应的类和方法来模拟真实的区块链运作流程，包括但不限于创建交易、生成新区块以及执行工作量证明(PoW)[^4]。