设计Product类包含id、name、price、stock属性及对应getter/setter；2. 使用ConcurrentHashMap存储商品实现线程安全的增删改查；3. 扣减库存时加锁防止超卖，确保操作原子性。
在Java中实现商品库存管理，核心是设计清晰的数据结构和操作逻辑，确保增删改查高效且线程安全。以下是一个简单但实用的实现方式，适用于中小型系统或学习场景。
1. 定义商品实体类
每个商品需要有基本信息，如ID、名称、价格和当前库存数量。
public class Product {
private String id;
private String name;
private double price;
private int stock;
public Product(String id, String name, double price, int stock) {
this.id = id;
this.name = name;
this.price = price;
this.stock = stock;
}
// Getter 和 Setter 方法
public String getId() { return id; }
public String getName() { return name; }
public double getPrice() { return price; }
public int getStock() { return stock; }
public void setStock(int stock) {
if (stock < 0) {
throw new IllegalArgumentException("库存不能为负数");
}
this.stock = stock;
}
public void increaseStock(int amount) {
if (amount <= 0) {
throw new IllegalArgumentException("增加库存数量必须大于0");
}
this.stock += amount;
}
public boolean decreaseStock(int amount) {
if (amount <= 0) {
throw new IllegalArgumentException("减少库存数量必须大于0");
}
if (stock >= amount) {
stock -= amount;
return true;
}
return false; // 库存不足
}
}
2. 创建库存管理服务类
使用一个Map来存储商品，以商品ID为键，便于快速查找。所有修改操作加锁保证线程安全。
import java.util.HashMap;
import java.util.Map;
public class InventoryManager {
private final Map inventory = new HashMap<>();
// 添加商品（通常用于初始化或新增）
public synchronized void addProduct(Product product) {
if (product == null || product.getId() == null) {
throw new IllegalArgumentException("商品信息不完整");
}
inventory.put(product.getId(), product);
}
// 根据ID获取商品
public synchronized Product getProduct(String productId) {
return inventory.get(productId);
}
// 增加库存
public synchronized boolean increaseStock(String productId, int amount) {
Product product = inventory.get(productId);
if (product != null) {
product.increaseStock(amount);
return true;
}
return false;
}
// 减少库存（例如下单时调用）
public synchronized boolean decreaseStock(String productId, int amount) {
Product product = inventory.get(productId);
if (product != null) {
return product.decreaseStock(amount);
}
return false;
}
// 检查库存是否足够
public synchronized boolean hasEnoughStock(String productId, int amount) {
Product product = inventory.get(productId);
return product != null && product.getStock() >= amount;
}
// 获取当前库存总量（可用于监控）
public synchronized int getTotalStock() {
return inventory.values().stream().mapToInt(Product::getStock).sum();
}
}
3. 使用示例
演示如何添加商品并进行库存操作。
立即学习“Java免费学习笔记（深入）”；
public class Main {
public static void main(String[] args) {
InventoryManager manager = new InventoryManager();
// 添加商品
Product p1 = new Product("P001", "iPhone 15", 5999.0, 50);
manager.addProduct(p1);
// 查询库存
System.out.println("当前库存: " + manager.getProduct("P001").getStock());
// 减少库存（模拟下单）
if (manager.hasEnoughStock("P001", 5)) {
boolean success = manager.decreaseStock("P001", 5);
if (success) {
System.out.println("下单成功，剩余库存: " + manager.getProduct("P001").getStock());
}
} else {
System.out.println("库存不足！");
}
// 补货
manager.increaseStock("P001", 20);
System.out.println("补货后库存: " + manager.getProduct("P001").getStock());
}
}
4. 可扩展建议
实际项目中可根据需求增强功能：
- 持久化：将库存数据保存到数据库（如MySQL），使用JDBC或Spring Data JPA。
-
并发控制：高并发场景可用
ConcurrentHashMap配合CAS或分布式锁（如Redis）。 - 日志记录：记录库存变动流水，便于追踪。
- 库存预警：设置阈值，自动提醒补货。
- 事务支持：在订单系统中与支付、订单创建保持一致性。
