在现代软件开发中，实时数据处理和响应式编程变得越来越重要。库存管理系统是一个典型的需要实时更新的应用场景，当库存发生变化时，系统应该能够立即通知所有相关的组件或服务。在这个实战教程中，我们将展示如何使用Spring Boot结合观察者模式来构建一个简单的实时库存管理系统。

技术栈

• Java 11
• Spring Boot 2.x
• Maven

步骤一：创建Spring Boot项目

首先，你需要创建一个新的Spring Boot项目。你可以通过Spring Initializr网站或者IDEA等工具快速生成一个基础的Spring Boot项目。

步骤二：定义库存实体类

我们需要定义一个库存实体类Inventory，它将存储商品的基本信息和库存数量。

java

深色版本

1public class Inventory {
2    private String productId;
3    private int quantity;
4
5    public Inventory(String productId, int quantity) {
6        this.productId = productId;
7        this.quantity = quantity;
8    }
9
10    // getters and setters
11}

步骤三：实现观察者模式

接下来，我们需要实现观察者模式。这里我们定义一个InventoryObserver接口，以及一个具体的实现类InventoryUpdateNotifier。

java

深色版本

1// 观察者接口
2public interface InventoryObserver {
3    void update(Inventory inventory);
4}
5
6// 具体的观察者实现
7public class InventoryUpdateNotifier {
8    private List<InventoryObserver> observers = new ArrayList<>();
9
10    public void addObserver(InventoryObserver observer) {
11        synchronized (observers) {
12            if (!observers.contains(observer)) {
13                observers.add(observer);
14            }
15        }
16    }
17
18    public void removeObserver(InventoryObserver observer) {
19        synchronized (observers) {
20            observers.remove(observer);
21        }
22    }
23
24    public void notifyObservers(Inventory inventory) {
25        for (InventoryObserver observer : observers) {
26            observer.update(inventory);
27        }
28    }
29}

步骤四：集成到Spring框架

为了让这些类能够被Spring容器管理，我们需要将它们声明为Bean，并且在配置文件中设置相应的依赖关系。

java

深色版本

1@Configuration
2public class AppConfig {
3
4    @Bean
5    public InventoryUpdateNotifier inventoryUpdateNotifier() {
6        return new InventoryUpdateNotifier();
7    }
8}

步骤五：创建服务端点来更新库存

现在我们需要创建一个RESTful API端点，当调用该端点时，会触发库存的变化，并通知所有的观察者。

java

深色版本

1@RestController
2@RequestMapping("/inventory")
3public class InventoryController {
4
5    @Autowired
6    private InventoryUpdateNotifier notifier;
7
8    @PostMapping("/update")
9    public ResponseEntity<String> update(@RequestBody Inventory inventory) {
10        // 更新库存逻辑...
11        notifier.notifyObservers(inventory);
12        return ResponseEntity.ok("Inventory updated successfully");
13    }
14}

步骤六：实现观察者

最后，我们需要创建一个或多个观察者，它们将订阅库存更新事件。

java

深色版本

1@Component
2public class StockMonitor implements InventoryObserver {
3
4    @Override
5    public void update(Inventory inventory) {
6        System.out.println("Stock Monitor: Inventory of product " + inventory.getProductId() + " has been updated to " + inventory.getQuantity());
7    }
8}

步骤七：测试应用

启动你的Spring Boot应用，并使用Postman或者curl命令来触发库存更新API，观察控制台输出，确认是否正确地通知了观察者。

shell

深色版本

1curl -X POST http://localhost:8080/inventory/update -H 'Content-Type: application/json' -d '{"productId":"123", "quantity":5}'

以上就是使用Spring Boot结合观察者模式实现的一个简单实时库存管理系统的实现过程。当然，在实际生产环境中，还需要考虑更多的细节，比如事务管理、并发处理等。