基于区块链和Springboot的网上书店交易系统(源码+文档+部署讲解等)

🔥【Java 圈顶流大神！】CSDN 博客专家 + 阿里云专家双 buff 叠满！公司资深架构师亲驻！全网狂揽 5 万 + 死忠粉！专注 Java 技术深耕 + 毕业设计实战落地，高校老师 / 讲师 / 同行看过来 —— 这波合作绝对让你直呼 “捡到宝”！​

💥【毕设救星！告别烂大街模板！】​

不管你是卡壳的 Javaweb 项目、难啃的小程序开发，还是 Python 数据可视化、SSM/SpringBoot 框架搭建，甚至 Vue/HTML/Jsp/PHP 全栈需求，咱全是纯手写高含金量代码！拒绝千篇一律的 “僵尸模板”，每一行代码都适配学生学习逻辑，二次开发轻松上手，答辩时导师都得夸你 “功底扎实”！​

📚【学习 & 求职硬核资源库炸了！】​

简历模板直接给你 “面试加分款”！学习资料覆盖从入门到精通全阶段，面试题库更是刷完就能 “手撕面试官”！技术咨询秒回不拖沓，文档编写 / 论文降重直接给你 “学术级优化”，长期答辩答疑辅导更是全程护航 —— 哪怕你是 “答辩小白”，经咱腾讯会议一对一精讲，也能变身 “答辩王者”，轻松 hold 住全场！​

⚠️ 别划走！文末联系方式赶紧存！​

这波资源错过绝对拍大腿！先收藏！先收藏！先收藏！（重要的事说三遍）不管是毕设选题卡壳、文档写不下去，还是代码 bug 卡到崩溃，随时来问！​

🌟 想瞅更多神仙案例？翻主页！​

项目全是 “定制级水准”，不管是学习提升还是毕设通关，跟着李小陆工作室，绝对让你在同学里 “卷” 出重围，求职时 “赢在起跑线”！​

获取项目源码，请关注❤点赞收藏并私信博主，谢谢-

核心代码

@Service
public class BlockchainService {
private static final Logger logger = LoggerFactory.getLogger(BlockchainService.class);

@Autowired
private BlockchainConfigReader configReader;

private BcosSDK bcosSDK;
private Client client;
private CryptoKeyPair keyPair;
private ProductMarket productMarket;

@PostConstruct
public void init() {
try {
logger.info("开始初始化区块链服务…");

// 初始化FISCO BCOS SDK – 从classpath加载config.toml配置文件
String configFile = getConfigFilePath();
if (configFile == null) {
logger.warn("未找到config.toml配置文件，区块链功能将不可用");
logger.warn("请确保config.toml文件存在于src/main/resources目录中");
return;
}

logger.info("使用配置文件: {}", configFile);
bcosSDK = BcosSDK.build(configFile);
client = bcosSDK.getClient(1); // 默认使用群组1
keyPair = client.getCryptoSuite().createKeyPair();

// 从配置文件获取合约地址
String contractAddress = configReader.getProductMarketAddress();
if (contractAddress == null || contractAddress.isEmpty() || contractAddress.equals("0x0000000000000000000000000000000000000000")) {
logger.warn("ProductMarket合约地址未配置或无效，请在config.toml文件中设置正确的合约地址");
logger.warn("区块链查询功能将不可用，但不影响基本的图书管理功能");
return;
}

productMarket = ProductMarket.load(contractAddress, client, keyPair);

logger.info("BlockchainService初始化成功, 合约地址: {}", contractAddress);
} catch (Exception e) {
logger.error("BlockchainService初始化失败", e);
logger.warn("区块链功能不可用，但不影响基本的图书管理功能");
// 清理可能不完整的初始化状态
client = null;
bcosSDK = null;
productMarket = null;
}
}

@PreDestroy
public void destroy() {
if (bcosSDK != null) {
bcosSDK.stopAll();
logger.info("BlockchainService已关闭");
}
}

/**
* 检查合约是否已正确初始化
* @return 是否已初始化
*/
private boolean isContractInitialized() {
if (productMarket == null) {
logger.debug("ProductMarket合约未初始化，区块链功能不可用");
return false;
}
return true;
}

/**
* 获取配置文件的绝对路径
* @return 配置文件路径，如果文件不存在返回null
*/
private String getConfigFilePath() {
try {
ClassPathResource resource = new ClassPathResource("config.toml");
if (!resource.exists()) {
logger.error("config.toml文件不存在于classpath中，请确保文件位于src/main/resources目录下");
return null;
}

// 如果是在开发环境中，直接使用文件路径
try {
File file = resource.getFile();
return file.getAbsolutePath();
} catch (IOException e) {
// 如果是在JAR中，需要复制到临时文件
logger.info("配置文件在JAR中，复制到临时位置");

File tempFile = File.createTempFile("config", ".toml");
tempFile.deleteOnExit();

try (InputStream inputStream = resource.getInputStream();
FileOutputStream outputStream = new FileOutputStream(tempFile)) {
byte[] buffer = new byte[1024];
int bytesRead;
while ((bytesRead = inputStream.read(buffer)) != -1) {
outputStream.write(buffer, 0, bytesRead);
}
}

return tempFile.getAbsolutePath();
}
} catch (IOException e) {
logger.error("无法获取config.toml文件路径: {}", e.getMessage());
return null;
}
}

/**
* 上架新商品
* @param name 商品名称
* @param description 商品描述
* @param price 价格
* @param inventory 库存
* @return 商品ID
*/
public BigInteger listProduct(String name, String description, BigInteger price, BigInteger inventory) {
if (!isContractInitialized()) {
return BigInteger.ZERO;
}

try {
TransactionReceipt receipt = productMarket.listProduct(name, description, price, inventory);
List<ProductMarket.ProductListedEventResponse> events = productMarket.getProductListedEvents(receipt);
if (!events.isEmpty()) {
return events.get(0).productId;
}
return BigInteger.ZERO;
} catch (Exception e) {
logger.error("上架商品到区块链失败", e);
return BigInteger.ZERO;
}
}

/**
* 更新商品信息
* @param productId 商品ID
* @param name 商品名称
* @param description 商品描述
* @param price 价格
* @param inventory 库存
* @return 是否成功
*/
public boolean updateProduct(BigInteger productId, String name, String description, BigInteger price, BigInteger inventory) {
if (!isContractInitialized()) {
return false;
}

try {
TransactionReceipt receipt = productMarket.updateProduct(productId, name, description, price, inventory);
return receipt.isStatusOK();
} catch (Exception e) {
logger.error("更新区块链商品信息失败", e);
return false;
}
}

/**
* 下架商品
* @param productId 商品ID
* @return 是否成功
*/
public boolean removeProduct(BigInteger productId) {
if (!isContractInitialized()) {
return false;
}

try {
TransactionReceipt receipt = productMarket.removeProduct(productId);
return receipt.isStatusOK();
} catch (Exception e) {
logger.error("从区块链下架商品失败", e);
return false;
}
}

/**
* 创建订单
* @param productId 商品ID
* @param quantity 数量
* @return 订单ID
*/
public BigInteger createOrder(BigInteger productId, BigInteger quantity) {
try {
TransactionReceipt receipt = productMarket.createOrder(productId, quantity);
List<ProductMarket.OrderCreatedEventResponse> events = productMarket.getOrderCreatedEvents(receipt);
if (!events.isEmpty()) {
return events.get(0).orderId;
}
return BigInteger.ZERO;
} catch (Exception e) {
logger.error("在区块链创建订单失败", e);
return BigInteger.ZERO;
}
}

/**
* 支付订单
* @param orderId 订单ID
* @return 是否成功
*/
public boolean payOrder(BigInteger orderId) {
try {
TransactionReceipt receipt = productMarket.payOrder(orderId);
List<ProductMarket.OrderPaidEventResponse> events = productMarket.getOrderPaidEvents(receipt);
return !events.isEmpty();
} catch (Exception e) {
logger.error("区块链支付订单失败", e);
return false;
}
}

/**
* 查询商品信息
* @param productId 商品ID
* @return 商品信息数组
*/
public Tuple9<BigInteger, String, String, BigInteger, BigInteger, String, Boolean, BigInteger, BigInteger> getProduct(BigInteger productId) {
if (!isContractInitialized()) {
return null;
}

try {
return productMarket.getProduct(productId);
} catch (Exception e) {
logger.error("从区块链查询商品信息失败", e);
return null;
}
}

/**
* 查询订单信息
* @param orderId 订单ID
* @return 订单信息数组
*/
public Tuple7<BigInteger, BigInteger, String, BigInteger, BigInteger, BigInteger, Boolean> getOrder(BigInteger orderId) {
try {
return productMarket.getOrder(orderId);
} catch (Exception e) {
logger.error("从区块链查询订单信息失败", e);
return null;
}
}

/**
* 获取格式化的区块链商品信息
* @param productId 商品ID
* @return 格式化的商品信息字符串，如果不存在返回null
*/
public String getFormattedProductInfo(BigInteger productId) {
try {
Tuple9<BigInteger, String, String, BigInteger, BigInteger, String, Boolean, BigInteger, BigInteger> product =
getProduct(productId);

if (product == null || product.getValue1().equals(BigInteger.ZERO)) {
return null;
}

StringBuilder sb = new StringBuilder();
sb.append("区块链ID: ").append(product.getValue1()).append("\\n");
sb.append("名称: ").append(product.getValue2()).append("\\n");
sb.append("描述: ").append(product.getValue3()).append("\\n");
sb.append("价格: ").append(product.getValue4()).append("\\n");
sb.append("库存: ").append(product.getValue5()).append("\\n");
sb.append("卖家: ").append(product.getValue6()).append("\\n");
sb.append("上架状态: ").append(product.getValue7() ? "已上架" : "已下架").append("\\n");
sb.append("创建时间: ").append(product.getValue8()).append("\\n");
sb.append("更新时间: ").append(product.getValue9());

return sb.toString();
} catch (Exception e) {
logger.error("获取格式化区块链商品信息失败", e);
return null;
}
}
}

视频详细讲解

👇👇👇

基于区块链和Springboot的网上书店交易系统https://www.bilibili.com/video/BV1eCn9zLEWq/?vd_source=03bdbe4c11e488e8655a6a1c6dcd16d2

系统展示

获取项目源码，请关注❤点赞收藏并私信博主，谢谢-