【SpringBoot】SpringBoot实现基本的区块链的步骤与代码
以下是Spring Boot实现基本的区块链代码的步骤:
-
创建一个Block类,它表示一个区块,包含一个区块头和一个区块体。区块头包括版本号、时间戳、前一个区块的哈希值和当前区块的哈希值。区块体包含交易数据。
-
创建一个Blockchain类,它表示整个区块链,包含一个链列表和一个未确认交易列表。添加一个Genesis区块(创世区块)。
-
实现哈希函数,可以使用SHA256算法对数据进行哈希。
-
实现一个简单的工作量证明算法,目的是确保新区块的生成需要付出一定的计算力。可以使用计算拼图的方式来实现工作量证明算法。
-
实现一个简单的交易系统,包括交易数据的创建和验证。可以将交易数据保存在未确认交易列表中,然后在新区块生成后将其加入到区块链中。
-
实现一个简单的P2P网络,让不同的节点之间可以互相通信。可以使用websocket协议来实现P2P网络。
-
实现一个简单的共识协议,让不同的节点之间可以达成共识,确保区块链的一致性。可以使用最长链原则来实现共识协议。
-
创建一个Spring Boot应用程序,将以上所有代码整合起来,并提供简单的REST接口,让外部应用程序可以调用区块链的各种功能。
下面是一个简单实现的代码示例:
- Block类
public class Block {private int version;private long timeStamp;private String previousHash;private String hash;private List<Transaction> transactions;// getters and setters
}
2.Blockchain类
public class Blockchain {private List<Block> chain = new ArrayList<>();private List<Transaction> currentTransactions = new ArrayList<>();public Blockchain() {// create genesis blockBlock genesisBlock = new Block(1, System.currentTimeMillis(), "", "");chain.add(genesisBlock);}public void addBlock(Block block) {String previousHash = getLastBlock().getHash();String hash = calculateHash(block.getVersion(), block.getTimeStamp(), previousHash, block.getTransactions());block.setHash(hash);chain.add(block);currentTransactions.clear();}public Block getLastBlock() {return chain.get(chain.size() - 1);}public void addTransaction(Transaction transaction) {currentTransactions.add(transaction);}// getters and setters
}
3.哈希函数
public static String calculateHash(int version, long timeStamp, String previousHash, List<Transaction> transactions) {String data = version + timeStamp + previousHash + transactions.toString();MessageDigest digest = MessageDigest.getInstance("SHA-256");byte[] hash = digest.digest(data.getBytes(StandardCharsets.UTF_8));return bytesToHex(hash);
}private static String bytesToHex(byte[] hash) {StringBuffer hexString = new StringBuffer();for (int i = 0; i < hash.length; i++) {String hex = Integer.toHexString(0xff & hash[i]);if(hex.length() == 1) hexString.append('0');hexString.append(hex);}return hexString.toString();
}
4.工作量证明算法
public static Block mineBlock(Block block, int difficulty) {String target = new String(new char[difficulty]).replace('\0', '0');while (!block.getHash().substring(0, difficulty).equals(target)) {block.setNonce(block.getNonce() + 1);block.setHash(calculateHash(block.getVersion(), block.getTimeStamp(), block.getPreviousHash(), block.getTransactions(), block.getNonce()));}return block;
}public static String calculateHash(int version, long timeStamp, String previousHash, List<Transaction> transactions, int nonce) {String data = version + timeStamp + previousHash + transactions.toString() + nonce;MessageDigest digest = MessageDigest.getInstance("SHA-256");byte[] hash = digest.digest(data.getBytes(StandardCharsets.UTF_8));return bytesToHex(hash);
}
5.交易系统
public class Transaction {private String sender;private String recipient;private int amount;// getters and setters
}@RestController
public class TransactionController {@Autowiredprivate Blockchain blockchain;@PostMapping("/transactions/new")public ResponseEntity<String> addTransaction(@RequestBody Transaction transaction) {blockchain.addTransaction(transaction);return ResponseEntity.ok("Transaction added");}
}
6.P2P网络
@Component
public class P2PClient {@Autowiredprivate Blockchain blockchain;@Autowiredprivate P2PServer p2pServer;private WebSocketSession session;private String address;@EventListenerpublic void handleWebSocketConnectListener(SessionConnectedEvent event) {session = event.getSession();address = session.getRemoteAddress().getHostName();p2pServer.addClient(this);}@EventListenerpublic void handleWebSocketCloseListener(SessionDisconnectEvent event) {p2pServer.removeClient(this);}public void sendMessage(String message) throws IOException {session.sendMessage(new TextMessage(message));}public void broadcast(String message) throws IOException {for (P2PClient client : p2pServer.getClients()) {if (!client.getAddress().equals(address)) {client.sendMessage(message);}}}// getters and setters
}@Component
public class P2PServer {@Autowiredprivate Blockchain blockchain;private List<P2PClient> clients = new ArrayList<>();public void addClient(P2PClient client) {clients.add(client);}public void removeClient(P2PClient client) {clients.remove(client);}public List<P2PClient> getClients() {return clients;}@Scheduled(fixedDelay = 1000)public void broadcastBlockchain() throws IOException {ObjectMapper objectMapper = new ObjectMapper();String blockchainJson = objectMapper.writeValueAsString(blockchain);for (P2PClient client : clients) {client.sendMessage(blockchainJson);}}
}
7.共识协议
public class Consensus {public static boolean resolveConflicts(List<Blockchain> blockchains) {int maxLength = blockchains.size();Blockchain longestBlockchain = null;for (Blockchain blockchain : blockchains) {if (blockchain.getChain().size() > maxLength && isValidChain(blockchain.getChain())) {maxLength = blockchain.getChain().size();longestBlockchain = blockchain;}}if (longestBlockchain != null) {blockchain.setChain(longestBlockchain.getChain());blockchain.setCurrentTransactions(longestBlockchain.getCurrentTransactions());return true;} else {return false;}}private static boolean isValidChain(List<Block> chain) {Block lastBlock = chain.get(0);int currentIndex = 1;while (currentIndex < chain.size()) {Block block = chain.get(currentIndex);if (!block.getPreviousHash().equals(lastBlock.getHash())) {return false;}currentIndex++;}return true;}
}@RestController
public class ConsensusController {@Autowiredprivate List<P2PClient> peers;@GetMapping("/nodes/resolve")public ResponseEntity<String> resolveConflicts() throws IOException {List<Blockchain> blockchains = new ArrayList<>();blockchains.add(blockchain);for (P2PClient peer : peers) {RestTemplate restTemplate = new RestTemplate();ResponseEntity<String> response = restTemplate.getForEntity(peer.getUrl() + "/chain", String.class);if (response.getStatusCode() == HttpStatus.OK) {Blockchain remoteBlockchain = objectMapper.readValue(response.getBody(), Blockchain.class);blockchains.add(remoteBlockchain);}}if (Consensus.resolveConflicts(blockchains)) {return ResponseEntity.ok("Conflict resolved. Blockchain updated.");} else {return ResponseEntity.ok("No conflicts found.");}}
}
8.Spring Boot应用程序
@SpringBootApplication
public class Application {public static void main(String[] args) {SpringApplication.run(Application.class, args);}
}
这只是一个简单的实现示例,实际上要实现一个完整的区块链系统需要更多的功能和细节。此外,还需要处理各种安全问题,例如拒绝服务攻击、双重支付等。因此,建议在实际应用中使用成熟的区块链框架,而不是从头开始编写自己的区块链代码。
相关文章:
【SpringBoot】SpringBoot实现基本的区块链的步骤与代码
以下是Spring Boot实现基本的区块链代码的步骤: 创建一个Block类,它表示一个区块,包含一个区块头和一个区块体。区块头包括版本号、时间戳、前一个区块的哈希值和当前区块的哈希值。区块体包含交易数据。 创建一个Blockchain类,它…...

Photoscan/Metashape 2.0.0中的地面激光扫描处理
在Metashape(原Photoscan)2.0.0, 结构化地面激光扫描和非结构化航空激光扫描都可以使用导入点云(文件>导入>导入点云)命令导入。导入时会保留所有点属性(包括结构化信息)。 本文讨论以下主题 如何将激光扫描数据导入项目&am…...

git快速使用
1、下载git 设置签名 2、基本概念 工作区:写代码的地方。 暂存区:.git的.index 工作区:.git 3、常用操作 本地codinggit init, 初始化一个本地仓库,项目根目录下会出现个.gitgit remote add origin gitgithub.com…...
java 实现代理模式
代理模式(Proxy Pattern)是一种结构型设计模式,它允许一个对象(代理对象)充当另一个对象(被代理对象)的接口,以控制对该对象的访问。代理模式通常用于以下情况: 远程代理…...
【每日一题】力扣1768. 交替合并字符串
题目以及链接: 1768. 交替合并字符串 给你两个字符串 word1 和 word2 。请你从 word1 开始,通过交替添加字母来合并字符串。如果一个字符串比另一个字符串长,就将多出来的字母追加到合并后字符串的末尾。 返回 合并后的字符串 。 示例 1&…...

vscode新建vue3文件模板
输入快捷新建的名字 enter 确认后在文件中输入以下内容 {// Place your snippets for vue here. Each snippet is defined under a snippet name and has a prefix, body and// description. The prefix is what is used to trigger the snippet and the body will be expand…...
MySql学习笔记02——MySql的简单介绍
MySQL 常用命令 注意在mysql中使用的命令需要用英文分号结尾(启动/关闭mysql服务不需要带分号) net start mysql 启动mysql服务(需要管理员启动cmd) net stop mysql关闭mysql服务(需要管理员启动cmd) m…...

mysql-1:认识mysql
文章目录 数据库概述什么是数据库什么是关系型数据库 MySQL的概述MySQL是什么MySQL发展历程 SQL的概述什么是SQLSQL发展的简要历史:SQL语言分类 数据库概述 什么是数据库 数据库就是[存储数据的仓库],其本质是一个[文件系统],数据按照特定的…...
算法通关村-----堆在查找和排序中的应用
数组中的第K个最大元素 问题描述 给定整数数组 nums 和整数 k,请返回数组中第 k 个最大的元素。请注意,你需要找的是数组排序后的第 k 个最大的元素,而不是第 k 个不同的元素。你必须设计并实现时间复杂度为 O(n) 的算法解决此问题。详见le…...
直方图统计增强方法
直方图统计增强方法的原理: 直方图统计增强是一种基于像素值分布的图像增强技术,通过调整像素值的分布来增强图像的对比度和细节。其原理是根据图像的直方图信息,将原始像素值映射到一个新的像素值域,从而改变图像的亮度和对比…...

字节二面:如果高性能渲染十万条数据?
前言 最近博主在字节面试中遇到这样一个面试题,这个问题也是前端面试的高频问题,作为一名前端开发工程师,我们虽然可能很少会遇到后端返回十万条数据的情况,但是了解掌握如何处理这种情况,能让你对前端性能优化有更深的…...

Mysql高阶语句(二)
一、设置别名(alias ——>as) 在 MySQL 查询时,当表的名字比较长或者表内某些字段比较长时,为了方便书写或者 多次使用相同的表,可以给字段列或表设置别名。使用的时候直接使用别名,简洁明了࿰…...

算法笔记 二叉搜索树
二叉搜索树(Binary Search Tree,简称 BST)是一种数据结构,用于存储具有可比较键(通常是数字或字符串)的元素 1 结构特点 节点结构:每个节点都有一个键和两个子节点(左子节点和右子…...
微软牵手Linux:Ubuntu“系统”上架win10应用商店啦
导读继SUSE Linux登陆之后,Ubuntu今天正式以UWP应用的身份上架Win10应用商店。Windows Insider用户升级到Win10秋季创意者更新预览版Build 16190及以上就可以下载和安装Ubuntu系统应用。一旦下载和安装完Ubuntu应用后,它将开始在你的Windows10 PC上安装U…...
leetcode做题笔记126. 单词接龙 II
按字典 wordList 完成从单词 beginWord 到单词 endWord 转化,一个表示此过程的 转换序列 是形式上像 beginWord -> s1 -> s2 -> ... -> sk 这样的单词序列,并满足: 每对相邻的单词之间仅有单个字母不同。转换过程中的每个单词 s…...
windows下运行springboot的jar包,修改替换class文件,修改配置文件application,打包
在windows下跑springboot的jar包,经常会用到一些命令行和操作。 1、修改配置文件(以application.yml为例) #提取文件 jar xvf mqtt-10.1.0.jar BOOT-INF/classes/application.yml#将文件装回jar包 jar uvf mqtt-10.1.0.jar BOOT-INF/classe…...
PMD 检查java代码:可以去掉无用的括号(UselessParentheses)
这个规则的优先级比较低。 https://docs.pmd-code.org/pmd-doc-6.55.0/pmd_rules_java_codestyle.html#uselessparentheses 无用的括号可以去掉。当然,有时候为了避免理解起来困难,加上括号反而更加清晰。 例如: public static short calc…...

【数据结构练习】栈的面试题集锦
目录 前言: 1.进栈过程中可以出栈的选择题 2.将递归转化为循环 3.逆波兰表达式求值 4.有效的括号 5. 栈的压入、弹出序列 6. 最小栈 前言: 数据结构想要学的好,刷题少不了,我们不仅要多刷题,还要刷好题&#x…...

简单工厂模式概述和使用
目录 一、简单工厂模式简介1. 定义2. 使用动机 二、简单工厂模式结构1.模式结构2. 时序图 三、简单工厂的使用实例四、简单工厂模式优缺点五、简单工厂模式在Java中的应用 一、简单工厂模式简介 原文链接 1. 定义 简单工厂模式(Simple Factory Pattern):又称为静…...

软件工程概述
软件工程概述 软件工程指的是应用计算机科学、数学及管理科学等原理,以工程化的原则和方法来解决软件问题的工程,目的是提高软件生产效率、提高软件质量、降低软件成本。 1. 计算机软件 计算机软件指的是计算机系统中的程序及其文档。程序是计算任务的…...
KubeSphere 容器平台高可用:环境搭建与可视化操作指南
Linux_k8s篇 欢迎来到Linux的世界,看笔记好好学多敲多打,每个人都是大神! 题目:KubeSphere 容器平台高可用:环境搭建与可视化操作指南 版本号: 1.0,0 作者: 老王要学习 日期: 2025.06.05 适用环境: Ubuntu22 文档说…...
谷歌浏览器插件
项目中有时候会用到插件 sync-cookie-extension1.0.0:开发环境同步测试 cookie 至 localhost,便于本地请求服务携带 cookie 参考地址:https://juejin.cn/post/7139354571712757767 里面有源码下载下来,加在到扩展即可使用FeHelp…...
椭圆曲线密码学(ECC)
一、ECC算法概述 椭圆曲线密码学(Elliptic Curve Cryptography)是基于椭圆曲线数学理论的公钥密码系统,由Neal Koblitz和Victor Miller在1985年独立提出。相比RSA,ECC在相同安全强度下密钥更短(256位ECC ≈ 3072位RSA…...

【WiFi帧结构】
文章目录 帧结构MAC头部管理帧 帧结构 Wi-Fi的帧分为三部分组成:MAC头部frame bodyFCS,其中MAC是固定格式的,frame body是可变长度。 MAC头部有frame control,duration,address1,address2,addre…...

从零开始打造 OpenSTLinux 6.6 Yocto 系统(基于STM32CubeMX)(九)
设备树移植 和uboot设备树修改的内容同步到kernel将设备树stm32mp157d-stm32mp157daa1-mx.dts复制到内核源码目录下 源码修改及编译 修改arch/arm/boot/dts/st/Makefile,新增设备树编译 stm32mp157f-ev1-m4-examples.dtb \stm32mp157d-stm32mp157daa1-mx.dtb修改…...
【Web 进阶篇】优雅的接口设计:统一响应、全局异常处理与参数校验
系列回顾: 在上一篇中,我们成功地为应用集成了数据库,并使用 Spring Data JPA 实现了基本的 CRUD API。我们的应用现在能“记忆”数据了!但是,如果你仔细审视那些 API,会发现它们还很“粗糙”:有…...

【开发技术】.Net使用FFmpeg视频特定帧上绘制内容
目录 一、目的 二、解决方案 2.1 什么是FFmpeg 2.2 FFmpeg主要功能 2.3 使用Xabe.FFmpeg调用FFmpeg功能 2.4 使用 FFmpeg 的 drawbox 滤镜来绘制 ROI 三、总结 一、目的 当前市场上有很多目标检测智能识别的相关算法,当前调用一个医疗行业的AI识别算法后返回…...

零基础在实践中学习网络安全-皮卡丘靶场(第九期-Unsafe Fileupload模块)(yakit方式)
本期内容并不是很难,相信大家会学的很愉快,当然对于有后端基础的朋友来说,本期内容更加容易了解,当然没有基础的也别担心,本期内容会详细解释有关内容 本期用到的软件:yakit(因为经过之前好多期…...
CSS设置元素的宽度根据其内容自动调整
width: fit-content 是 CSS 中的一个属性值,用于设置元素的宽度根据其内容自动调整,确保宽度刚好容纳内容而不会超出。 效果对比 默认情况(width: auto): 块级元素(如 <div>)会占满父容器…...

JVM虚拟机:内存结构、垃圾回收、性能优化
1、JVM虚拟机的简介 Java 虚拟机(Java Virtual Machine 简称:JVM)是运行所有 Java 程序的抽象计算机,是 Java 语言的运行环境,实现了 Java 程序的跨平台特性。JVM 屏蔽了与具体操作系统平台相关的信息,使得 Java 程序只需生成在 JVM 上运行的目标代码(字节码),就可以…...