如何在Java中实现商品库存管理_技术教程

设计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. 使用示例

演示如何添加商品并进行库存操作。

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());
    }
}