第五篇 设计模式的选择和应用 - 智慧选择与合理实践

// Spring BeanFactory 实现了工厂方法模式
public interface BeanFactory {
    Object getBean(String name) throws BeansException;
    // ... 其他获取bean的方法
}

// 通常我们使用 ApplicationContext 来获取 bean
public class ClassPathXmlApplicationContext implements ApplicationContext {
    public Object getBean(String name) throws BeansException {
        // ...
    }
}

@Configuration
public class DataSourceConfig {

    @Autowired
    private Environment env;

    @Bean
    @Primary
    public DataSource primaryDataSource() {
        return DataSourceBuilder.create()
                .url(env.getProperty("primary.datasource.url"))
                .username(env.getProperty("primary.datasource.username"))
                .password(env.getProperty("primary.datasource.password"))
                .build();
    }

    @Bean
    public DataSource secondaryDataSource() {
        return DataSourceBuilder.create()
                .url(env.getProperty("secondary.datasource.url"))
                .username(env.getProperty("secondary.datasource.username"))
                .password(env.getProperty("secondary.datasource.password"))
                .build();
    }

    // 在其他类中注入时可以按需选择数据源策略
    @Service
    public class SomeService {
    
        @Autowired
        private DataSource dataSource; // 这里注入的数据源可能是primaryDataSource也可能是secondaryDataSource
        
        // 根据业务需求决定使用哪个数据源
        // ...
    }
}

@Aspect
@Component
public class TransactionalAdvice {

    @Before("execution(* com.example.service.*.*(..))")
    public void before(JoinPoint joinPoint) {
        // 开启事务的逻辑
    }

    @AfterReturning(pointcut = "execution(* com.example.service.*.*(..))", returning = "result")
    public void afterReturning(Object result) {
        // 提交事务的逻辑
    }
    
    // 其他通知...
}

@Service
public class UserServiceImpl implements UserService {

    // 这个UserService的实例在Spring IoC容器中实际上是被代理的对象
    @Override
    public void addUser(User user) {
        // 添加用户逻辑
    }
}

// 商品抽象类或接口
public abstract class Product {
    protected double price;
    
    public abstract void add(Product product);
    public abstract void remove(Product product);
    // ... 其他如获取价格、名称等方法
}

// 单品商品
public class SingleProduct extends Product {
    private String name;
    
    public SingleProduct(String name, double price) {
        this.name = name;
        this.price = price;
    }
    
    @Override
    public void add(Product product) {
        throw new UnsupportedOperationException("单个商品不能添加子商品");
    }

    @Override
    public void remove(Product product) {
        throw new UnsupportedOperationException("单个商品没有子商品可移除");
    }
    // ...
}

// 套装商品，内部维护一个产品列表
public class BundleProduct extends Product {
    private List<Product> productList = new ArrayList<>();
    
    public void add(Product product) {
        productList.add(product);
    }

    public void remove(Product product) {
        productList.remove(product);
    }

    @Override
    public double getPrice() {
        double totalPrice = 0;
        for (Product item : productList) {
            totalPrice += item.getPrice();
        }
        return totalPrice;
    }
    // ...
}

import java.util.ArrayList;
import java.util.List;

// 购物车接口，同时作为观察目标（Observable）
public interface Cart extends ObserverTarget {
    void addItem(Product product);
    void removeItem(Product product);
    double getTotalPrice();
    // 注册和删除观察者的方法由ObserverTarget提供
}

// 购物车实现
public class ShoppingCart implements Cart {
    private List<Product> cartItems = new ArrayList<>();
    private List<Observer> observers = new ArrayList<>();

    @Override
    public void addItem(Product product) {
        cartItems.add(product);
        notifyObservers(); // 添加商品后通知所有观察者
    }

    @Override
    public void removeItem(Product product) {
        cartItems.remove(product);
        notifyObservers(); // 移除商品后通知所有观察者
    }

    @Override
    public double getTotalPrice() {
        double totalPrice = 0;
        for (Product item : cartItems) {
            totalPrice += item.getPrice();
        }
        return totalPrice;
    }

    // 实现ObserverTarget接口中的注册与通知方法
    @Override
    public void addObserver(Observer observer) {
        observers.add(observer);
    }

    @Override
    public void removeObserver(Observer observer) {
        observers.remove(observer);
    }

    @Override
    public void notifyObservers() {
        for (Observer observer : observers) {
            observer.update(this); // 更新观察者（例如总价显示组件）
        }
    }
}

// 观察者接口
public interface Observer {
    void update(Cart cart);
}

// 总价显示组件作为观察者
public class TotalPriceDisplay implements Observer {
    @Override
    public void update(Cart cart) {
        double totalPrice = cart.getTotalPrice();
        // 更新UI或其他操作，显示最新的总价
    }
}