用 Python 构建一个极小的区块链

Posted 2021-02-05 派森学python

虽然有些人认为区块链是一个早晚会出现问题的解决方案，但是毫无疑问，这个创新技术是一个计算机技术上的奇迹。那么，究竟什么是区块链呢？

区块链

以比特币Bitcoin或其它加密货币按时间顺序公开地记录交易的数字账本。

更通俗的说，它是一个公开的数据库，新的数据存储在被称之为区块block的容器中，并被添加到一个不可变的链chain中（因此被称为区块链blockchain），之前添加的数据也在该链中。对于比特币或其它加密货币来说，这些数据就是一组组交易，不过，也可以是其它任何类型的数据。

区块链技术带来了全新的、完全数字化的货币，如比特币和莱特币Litecoin，它们并不由任何中心机构管理。这给那些认为当今的银行系统是骗局并将最终走向失败的人带来了自由。区块链也革命性地改变了分布式计算的技术形式，如以太坊Ethereum就引入了一种有趣的概念：智能合约smart contract。

在这篇文章中，我将用不到 50 行的 Python 2.x 代码实现一个简单的区块链，我把它叫做 SnakeCoin。

欢迎加入我的QQ群`923414804`与我一起学习，群里有我学习过程中整理的大量学习资料。加群即可免费获取

不到 50 行代码的区块链

我们首先将从定义我们的区块是什么开始。在区块链中，每个区块随同时间戳及可选的索引一同存储。在 SnakeCoin 中，我们会存储这两者。为了确保整个区块链的完整性，每个区块都会有一个自识别的哈希值。如在比特币中，每个区块的哈希是该块的索引、时间戳、数据和前一个区块的哈希值等数据的加密哈希值。这里提及的“数据”可以是任何你想要的数据。

1. import hashlib as hasher
3. class Block:
4. def __init__(self, index, timestamp, data, previous_hash):
5. self.index = index
6. self.timestamp = timestamp
7. self.data = data
8. self.previous_hash = previous_hash
9. self.hash = self.hash_block()
11. def hash_block(self):
12. sha = hasher.sha256()
13. sha.update(str(self.index) +
14. str(self.timestamp) +
15. str(self.data) +
16. str(self.previous_hash))
17. return sha.hexdigest()

真棒，现在我们有了区块的结构了，不过我们需要创建的是一个区块链。我们需要把区块添加到一个实际的链中。如我们之前提到过的，每个区块都需要前一个区块的信息。但问题是，该区块链中的第一个区块在哪里？好吧，这个第一个区块，也称之为创世区块，是一个特别的区块。在很多情况下，它是手工添加的，或通过独特的逻辑添加的。

我们将创建一个函数来简单地返回一个创世区块解决这个问题。这个区块的索引为 0 ，其包含一些任意的数据值，其“前一哈希值”参数也是任意值。

1. import datetime as date
3. def create_genesis_block():
4. # Manually construct a block with
5. # index zero and arbitrary previous hash
6. return Block(0, date.datetime.now(), "Genesis Block", "0")

现在我们可以创建创世区块了，我们需要一个函数来生成该区块链中的后继区块。该函数将获取链中的前一个区块作为参数，为要生成的区块创建数据，并用相应的数据返回新的区块。新的区块的哈希值来自于之前的区块，这样每个新的区块都提升了该区块链的完整性。如果我们不这样做，外部参与者就很容易“改变过去”，把我们的链替换为他们的新链了。这个哈希链起到了加密的证明作用，并有助于确保一旦一个区块被添加到链中，就不能被替换或移除。

1. def next_block(last_block):
2. this_index = last_block.index + 1
3. this_timestamp = date.datetime.now()
4. this_data = "Hey! I‘m block " + str(this_index)
5. this_hash = last_block.hash
6. return Block(this_index, this_timestamp, this_data, this_hash)

这就是主要的部分。

现在我们能创建自己的区块链了！在这里，这个区块链是一个简单的 Python 列表。其第一个的元素是我们的创世区块，我们会添加后继区块。因为 SnakeCoin 是一个极小的区块链，我们仅仅添加了 20 个区块。我们通过循环来完成它。

1. # Create the blockchain and add the genesis block
2. blockchain = [create_genesis_block()]
3. previous_block = blockchain[0]
5. # How many blocks should we add to the chain
6. # after the genesis block
7. num_of_blocks_to_add = 20
9. # Add blocks to the chain
10. for i in range(0, num_of_blocks_to_add):
11. block_to_add = next_block(previous_block)
12. blockchain.append(block_to_add)
13. previous_block = block_to_add
14. # Tell everyone about it!
15. print "Block #{} has been added to the blockchain!".format(block_to_add.index)
16. print "Hash: {} ".format(block_to_add.hash)

让我们看看我们的成果：

别担心，它将一直添加到 20 个区块

很好，我们的区块链可以工作了。如果你想要在主控台查看更多的信息，你可以编辑其完整的源代码并输出每个区块的时间戳或数据。

这就是 SnakeCoin 所具有的功能。要使 SnakeCoin 达到现今的产品级的区块链的高度，我们需要添加更多的功能，如服务器层，以在多台机器上跟踪链的改变，并通过工作量证明算法（POW）来限制给定时间周期内可以添加的区块数量。

如果你想了解更多技术细节，你可以在这里查看最初的比特币白皮书。

让这个极小区块链稍微变大些

这个极小的区块链及其简单，自然也相对容易完成。但是因其简单也带来了一些缺陷。首先，SnakeCoin 仅能运行在单一的一台机器上，所以它相距分布式甚远，更别提去中心化了。其次，区块添加到区块链中的速度同在主机上创建一个 Python 对象并添加到列表中一样快。在我们的这个简单的区块链中，这不是问题，但是如果我们想让 SnakeCoin 成为一个实际的加密货币，我们就需要控制在给定时间内能创建的区块（和币）的数量。

从现在开始，SnakeCoin 中的“数据”将是交易数据，每个区块的“数据”字段都将是一些交易信息的列表。接着我们来定义“交易”。每个“交易”是一个 JSON 对象，其记录了币的发送者、接收者和转移的 SnakeCoin 数量。注：交易信息是 JSON 格式，原因我很快就会说明。

1. {
2. "from": "71238uqirbfh894-random-public-key-a-alkjdflakjfewn204ij",
3. "to": "93j4ivnqiopvh43-random-public-key-b-qjrgvnoeirbnferinfo",
4. "amount": 3
5. }

现在我们知道了交易信息看起来的样子了，我们需要一个办法来将其加到我们的区块链网络中的一台计算机（称之为节点）中。要做这个事情，我们会创建一个简单的 HTTP 服务器，以便每个用户都可以让我们的节点知道发生了新的交易。节点可以接受  POST 请求，请求数据为如上的交易信息。这就是为什么交易信息是 JSON 格式的：我们需要它们可以放在请求信息中传递给服务器。

$ pip install flask # 首先安装 Web 服务器框架

1. from flask import Flask
2. from flask import request
3. node = Flask(__name__)
5. # Store the transactions that
6. # this node has in a list
7. this_nodes_transactions = []
9. @node.route(‘/txion‘, methods=[‘POST‘])
10. def transaction():
11. if request.method == ‘POST‘:
12. # On each new POST request,
13. # we extract the transaction data
14. new_txion = request.get_json()
15. # Then we add the transaction to our list
16. this_nodes_transactions.append(new_txion)
17. # Because the transaction was successfully
18. # submitted, we log it to our console
19. print "New transaction"
20. print "FROM: {}".format(new_txion[‘from‘])
21. print "TO: {}".format(new_txion[‘to‘])
22. print "AMOUNT: {} ".format(new_txion[‘amount‘])
23. # Then we let the client know it worked out
24. return "Transaction submission successful "
26. node.run()

真棒！现在我们有了一种保存用户彼此发送 SnakeCoin 的记录的方式。这就是为什么人们将区块链称之为公共的、分布式账本：所有的交易信息存储给所有人看，并被存储在该网络的每个节点上。

但是，有个问题：人们从哪里得到 SnakeCoin 呢？现在还没有办法得到，还没有一个称之为 SnakeCoin 这样的东西，因为我们还没有创建和分发任何一个币。要创建新的币，人们需要“挖”一个新的 SnakeCoin 区块。当他们成功地挖到了新区块，就会创建出一个新的 SnakeCoin ，并奖励给挖出该区块的人（矿工）。一旦挖矿的矿工将 SnakeCoin 发送给别人，这个币就流通起来了。

我们不想让挖新的 SnakeCoin 区块太容易，因为这将导致 SnakeCoin 太多了，其价值就变低了；同样，我们也不想让它变得太难，因为如果没有足够的币供每个人使用，它们对于我们来说就太昂贵了。为了控制挖新的 SnakeCoin 区块的难度，我们会实现一个工作量证明Proof-of-Work（PoW）算法。工作量证明基本上就是一个生成某个项目比较难，但是容易验证（其正确性）的算法。这个项目被称之为“证明”，听起来就像是它证明了计算机执行了特定的工作量。

在 SnakeCoin 中，我们创建了一个简单的 PoW 算法。要创建一个新区块，矿工的计算机需要递增一个数字，当该数字能被 9 （“SnakeCoin” 这个单词的字母数）整除时，这就是最后这个区块的证明数字，就会挖出一个新的 SnakeCoin 区块，而该矿工就会得到一个新的 SnakeCoin。

1. # ...blockchain
2. # ...Block class definition
4. miner_address = "q3nf394hjg-random-miner-address-34nf3i4nflkn3oi"
6. def proof_of_work(last_proof):
7. # Create a variable that we will use to find
8. # our next proof of work
9. incrementor = last_proof + 1
10. # Keep incrementing the incrementor until
11. # it‘s equal to a number divisible by 9
12. # and the proof of work of the previous
13. # block in the chain
14. while not (incrementor % 9 == 0 and incrementor % last_proof == 0):
15. incrementor += 1
16. # Once that number is found,
17. # we can return it as a proof
18. # of our work
19. return incrementor
21. @node.route(‘/mine‘, methods = [‘GET‘])
22. def mine():
23. # Get the last proof of work
24. last_block = blockchain[len(blockchain) - 1]
25. last_proof = last_block.data[‘proof-of-work‘]
26. # Find the proof of work for
27. # the current block being mined
28. # Note: The program will hang here until a new
29. # proof of work is found
30. proof = proof_of_work(last_proof)
31. # Once we find a valid proof of work,
32. # we know we can mine a block so
33. # we reward the miner by adding a transaction
34. this_nodes_transactions.append(
35. { "from": "network", "to": miner_address, "amount": 1 }
36. )
37. # Now we can gather the data needed
38. # to create the new block
39. new_block_data = {
40. "proof-of-work": proof,
41. "transactions": list(this_nodes_transactions)
42. }
43. new_block_index = last_block.index + 1
44. new_block_timestamp = this_timestamp = date.datetime.now()
45. last_block_hash = last_block.hash
46. # Empty transaction list
47. this_nodes_transactions[:] = []
48. # Now create the
49. # new block!
50. mined_block = Block(
51. new_block_index,
52. new_block_timestamp,
53. new_block_data,
54. last_block_hash
55. )
56. blockchain.append(mined_block)
57. # Let the client know we mined a block
58. return json.dumps({
59. "index": new_block_index,
60. "timestamp": str(new_block_timestamp),
61. "data": new_block_data,
62. "hash": last_block_hash
63. }) + " "

现在，我们能控制特定的时间段内挖到的区块数量，并且我们给了网络中的人新的币，让他们彼此发送。但是如我们说的，我们只是在一台计算机上做的。如果区块链是去中心化的，我们怎样才能确保每个节点都有相同的链呢？要做到这一点，我们会使每个节点都广播其（保存的）链的版本，并允许它们接受其它节点的链。然后，每个节点会校验其它节点的链，以便网络中每个节点都能够达成最终的链的共识。这称之为共识算法consensus algorithm。

我们的共识算法很简单：如果一个节点的链与其它的节点的不同（例如有冲突），那么最长的链保留，更短的链会被删除。如果我们网络上的链没有了冲突，那么就可以继续了。

1. @node.route(‘/blocks‘, methods=[‘GET‘])
2. def get_blocks():
3. chain_to_send = blockchain
4. # Convert our blocks into dictionaries
5. # so we can send them as json objects later
6. for block in chain_to_send:
7. block_index = str(block.index)
8. block_timestamp = str(block.timestamp)
9. block_data = str(block.data)
10. block_hash = block.hash
11. block = {
12. "index": block_index,
13. "timestamp": block_timestamp,
14. "data": block_data,
15. "hash": block_hash
16. }
17. # Send our chain to whomever requested it
18. chain_to_send = json.dumps(chain_to_send)
19. return chain_to_send
21. def find_new_chains():
22. # Get the blockchains of every
23. # other node
24. other_chains = []
25. for node_url in peer_nodes:
26. # Get their chains using a GET request
27. block = requests.get(node_url + "/blocks").content
28. # Convert the JSON object to a Python dictionary
29. block = json.loads(block)
30. # Add it to our list
31. other_chains.append(block)
32. return other_chains
34. def consensus():
35. # Get the blocks from other nodes
36. other_chains = find_new_chains()
37. # If our chain isn‘t longest,
38. # then we store the longest chain
39. longest_chain = blockchain
40. for chain in other_chains:
41. if len(longest_chain) < len(chain):
42. longest_chain = chain
43. # If the longest chain wasn‘t ours,
44. # then we set our chain to the longest
45. blockchain = longest_chain

我们差不多就要完成了。在运行了完整的 SnakeCoin 服务器代码之后，在你的终端可以运行如下代码。（假设你已经安装了 cCUL）。

1、创建交易

curl "localhost:5000/txion" 
     -H "Content-Type: application/json" 
     -d ‘{"from": "akjflw", "to":"fjlakdj", "amount": 3}‘

2、挖一个新区块

curl localhost:5000/mine

3、 查看结果。从客户端窗口，我们可以看到。

对代码做下美化处理，我们看到挖矿后我们得到的新区块的信息：

{
  "index": 2,
  "data": {
    "transactions": [
      {
        "to": "fjlakdj",
        "amount": 3,
        "from": "akjflw"
      },
      {
        "to": "q3nf394hjg-random-miner-address-34nf3i4nflkn3oi",
        "amount": 1,
        "from": "network"
      }
    ],
    "proof-of-work": 36
  },
  "hash": "151edd3ef6af2e7eb8272245cb8ea91b4ecfc3e60af22d8518ef0bba8b4a6b18",
  "timestamp": "2017-07-23 11:23:10.140996"
}

大功告成！现在 SnakeCoin 可以运行在多个机器上，从而创建了一个网络，而且真实的 SnakeCoin 也能被挖到了。

你可以根据你的喜好去修改 SnakeCoin 服务器代码，并问各种问题了。