1. 命令模式的核心思想与应用场景命令模式Command Pattern是一种行为型设计模式它将请求封装成独立的对象使你可以参数化客户端对象将请求排队或记录请求日志以及支持可撤销的操作。我第一次在电商系统开发中应用这个模式时它完美解决了订单操作的可撤销问题。这个模式的本质是把做什么具体操作和谁来做调用者解耦。想象餐厅点餐的场景顾客Client不需要知道厨师Receiver如何烹饪只需把订单Command交给服务员Invoker由服务员统一调度执行。这种间接调用的方式带来了极大的灵活性。2. 模式结构与组件解析2.1 经典UML类图实现标准的命令模式包含以下核心角色Command抽象命令声明执行操作的接口通常包含execute()方法可能包含undo()方法支持撤销public interface Command { void execute(); void undo(); }ConcreteCommand具体命令绑定接收者与动作实现execute()方法调用接收者的操作示例开灯命令public class LightOnCommand implements Command { private Light light; public LightOnCommand(Light light) { this.light light; } Override public void execute() { light.on(); } Override public void undo() { light.off(); } }Invoker调用者持有命令对象在适当时机调用命令的execute()示例遥控器按钮public class RemoteControl { private Command command; public void setCommand(Command command) { this.command command; } public void pressButton() { command.execute(); } }Receiver接收者知道如何执行操作实际执行业务逻辑的对象示例电灯设备public class Light { public void on() { System.out.println(Light is on); } public void off() { System.out.println(Light is off); } }2.2 线程安全实现要点在多线程环境下使用命令模式时需要注意命令对象应当是无状态的或者状态是线程隔离的如果命令包含共享资源需要同步控制考虑使用线程池来执行命令队列// 线程安全的命令队列示例 public class CommandQueue { private final QueueCommand queue new ConcurrentLinkedQueue(); private final Executor executor Executors.newFixedThreadPool(4); public void addCommand(Command command) { queue.offer(command); } public void executeAll() { while (!queue.isEmpty()) { Command cmd queue.poll(); executor.execute(cmd::execute); } } }3. 实战应用支持撤销的文本编辑器3.1 编辑器核心功能设计我们实现一个支持无限撤销的文本编辑器// 接收者文档类 public class Document { private StringBuilder content new StringBuilder(); public void insert(int pos, String text) { content.insert(pos, text); } public void delete(int pos, int length) { content.delete(pos, pos length); } public String getContent() { return content.toString(); } }3.2 命令类实现// 抽象命令 public interface TextCommand extends Command { void setDocument(Document doc); } // 插入命令 public class InsertCommand implements TextCommand { private Document document; private int position; private String text; Override public void setDocument(Document doc) { this.document doc; } public InsertCommand(int pos, String text) { this.position pos; this.text text; } Override public void execute() { document.insert(position, text); } Override public void undo() { document.delete(position, text.length()); } } // 删除命令 public class DeleteCommand implements TextCommand { private Document document; private int position; private int length; private String deletedText; // ...setDocument实现... public DeleteCommand(int pos, int len) { this.position pos; this.length len; } Override public void execute() { deletedText document.getContent().substring(position, position length); document.delete(position, length); } Override public void undo() { document.insert(position, deletedText); } }3.3 历史管理类public class CommandHistory { private StackCommand history new Stack(); private StackCommand redoStack new Stack(); public void execute(Command cmd) { cmd.execute(); history.push(cmd); redoStack.clear(); } public void undo() { if (!history.isEmpty()) { Command cmd history.pop(); cmd.undo(); redoStack.push(cmd); } } public void redo() { if (!redoStack.isEmpty()) { Command cmd redoStack.pop(); cmd.execute(); history.push(cmd); } } }4. 高级应用与性能优化4.1 宏命令模式宏命令是命令模式的扩展允许将多个命令组合成一个命令public class MacroCommand implements Command { private ListCommand commands new ArrayList(); public void add(Command cmd) { commands.add(cmd); } Override public void execute() { commands.forEach(Command::execute); } Override public void undo() { // 需要反向执行undo for (int i commands.size() - 1; i 0; i--) { commands.get(i).undo(); } } }4.2 命令模式与内存优化当命令对象过多时可以考虑享元模式共享可复用的命令对象对象池重用命令对象实例延迟加载只在需要时创建命令// 命令对象池示例 public class CommandPool { private static final int MAX_POOL_SIZE 100; private static MapClass?, QueueCommand pool new HashMap(); public static Command get(Class? extends Command clazz) { QueueCommand queue pool.computeIfAbsent(clazz, k - new LinkedList()); Command cmd queue.poll(); if (cmd null) { try { cmd (Command) clazz.newInstance(); } catch (Exception e) { throw new RuntimeException(e); } } return cmd; } public static void release(Command cmd) { if (pool.size() MAX_POOL_SIZE) { QueueCommand queue pool.computeIfAbsent(cmd.getClass(), k - new LinkedList()); queue.offer(cmd); } } }5. 常见问题与调试技巧5.1 命令模式常见陷阱过度设计简单场景不要滥用命令模式适用场景需要撤销/重做、需要排队执行、需要记录日志不适用场景简单的一次性操作内存泄漏长时间运行的命令队列可能积累大量对象解决方案定期清理或使用弱引用线程安全问题多个线程访问同一命令对象解决方案使用线程局部变量或创建命令副本5.2 调试命令模式系统日志记录public class LoggingCommand implements Command { private Command realCommand; public LoggingCommand(Command cmd) { this.realCommand cmd; } Override public void execute() { System.out.println(Executing: realCommand.getClass().getSimpleName()); realCommand.execute(); } Override public void undo() { System.out.println(Undoing: realCommand.getClass().getSimpleName()); realCommand.undo(); } }空命令模式public class NoCommand implements Command { Override public void execute() {} Override public void undo() {} }用于避免null检查符合Null Object模式性能监控public class ProfilingCommand implements Command { private Command realCommand; public ProfilingCommand(Command cmd) { this.realCommand cmd; } Override public void execute() { long start System.nanoTime(); realCommand.execute(); long duration System.nanoTime() - start; System.out.println(Execution took: duration ns); } // ...类似实现undo... }6. 命令模式在框架中的应用6.1 Java Swing中的ActionSwing中的Action接口就是命令模式的典型实现// 创建命令 Action saveAction new AbstractAction(Save) { Override public void actionPerformed(ActionEvent e) { // 保存逻辑 } }; // 绑定到多个UI组件 JButton saveButton new JButton(saveAction); JMenuItem saveMenuItem new JMenuItem(saveAction);6.2 Spring的CommandLineRunnerSpring Boot中的CommandLineRunner也是命令模式的应用Component public class MyRunner implements CommandLineRunner { Override public void run(String... args) { // 应用启动后执行的命令 } }6.3 事务处理中的命令模式数据库事务可以看作是一个宏命令public class TransactionCommand implements Command { private ListCommand commands new ArrayList(); public void add(Command cmd) { commands.add(cmd); } Override public void execute() { try { commands.forEach(Command::execute); // 提交事务 } catch (Exception e) { // 回滚所有命令 for (int i commands.size() - 1; i 0; i--) { commands.get(i).undo(); } throw e; } } Override public void undo() { // 事务级别的undo就是执行回滚 for (int i commands.size() - 1; i 0; i--) { commands.get(i).undo(); } } }7. 命令模式与其他模式的结合7.1 命令责任链模式实现可扩展的命令处理管道public abstract class ChainableCommand implements Command { private ChainableCommand next; public void setNext(ChainableCommand next) { this.next next; } Override public void execute() { doExecute(); if (next ! null) { next.execute(); } } protected abstract void doExecute(); Override public void undo() { if (next ! null) { next.undo(); } doUndo(); } protected abstract void doUndo(); }7.2 命令备忘录模式增强撤销功能保存完整状态public interface StatefulCommand extends Command { Object getState(); void restoreState(Object state); } public class Memento { private MapStatefulCommand, Object states new HashMap(); public void saveState(StatefulCommand cmd) { states.put(cmd, cmd.getState()); } public void restoreAll() { states.forEach(StatefulCommand::restoreState); } }7.3 命令观察者模式实现命令执行通知public class ObservableCommand implements Command { private Command realCommand; private ListCommandListener listeners new ArrayList(); public void addListener(CommandListener l) { listeners.add(l); } Override public void execute() { listeners.forEach(l - l.beforeExecute(this)); realCommand.execute(); listeners.forEach(l - l.afterExecute(this)); } // ...类似实现undo... } public interface CommandListener { void beforeExecute(Command cmd); void afterExecute(Command cmd); }8. 测试命令模式的最佳实践8.1 单元测试策略测试命令对象Test public void testInsertCommand() { Document doc new Document(); Command cmd new InsertCommand(0, Hello); ((TextCommand)cmd).setDocument(doc); cmd.execute(); assertEquals(Hello, doc.getContent()); cmd.undo(); assertEquals(, doc.getContent()); }测试命令历史Test public void testCommandHistory() { CommandHistory history new CommandHistory(); Document doc new Document(); Command cmd1 new InsertCommand(0, A); ((TextCommand)cmd1).setDocument(doc); history.execute(cmd1); Command cmd2 new InsertCommand(1, B); ((TextCommand)cmd2).setDocument(doc); history.execute(cmd2); assertEquals(AB, doc.getContent()); history.undo(); assertEquals(A, doc.getContent()); history.redo(); assertEquals(AB, doc.getContent()); }8.2 集成测试要点测试命令队列的执行顺序测试宏命令的原子性测试长时间运行的命令稳定性测试内存使用情况避免命令积累导致OOM8.3 性能测试建议测量单个命令执行时间测试命令队列的吞吐量评估撤销/重做功能的内存占用压力测试命令历史管理Test public void performanceTest() { int count 10000; Document doc new Document(); CommandHistory history new CommandHistory(); long start System.currentTimeMillis(); for (int i 0; i count; i) { Command cmd new InsertCommand(i, a); ((TextCommand)cmd).setDocument(doc); history.execute(cmd); } long duration System.currentTimeMillis() - start; System.out.println(Insert count chars took: duration ms); start System.currentTimeMillis(); for (int i 0; i count; i) { history.undo(); } duration System.currentTimeMillis() - start; System.out.println(Undo count times took: duration ms); }9. 命令模式的变体与扩展9.1 异步命令模式public interface AsyncCommand { CompletableFutureVoid executeAsync(); CompletableFutureVoid undoAsync(); } public class AsyncFileDownloadCommand implements AsyncCommand { private String url; private String savePath; Override public CompletableFutureVoid executeAsync() { return CompletableFuture.runAsync(() - { // 实现下载逻辑 }); } Override public CompletableFutureVoid undoAsync() { return CompletableFuture.runAsync(() - { // 删除下载的文件 new File(savePath).delete(); }); } }9.2 持久化命令模式public interface PersistentCommand extends Serializable, Command { default void saveTo(Path path) throws IOException { try (ObjectOutputStream out new ObjectOutputStream( Files.newOutputStream(path))) { out.writeObject(this); } } static PersistentCommand loadFrom(Path path) throws IOException, ClassNotFoundException { try (ObjectInputStream in new ObjectInputStream( Files.newInputStream(path))) { return (PersistentCommand) in.readObject(); } } }9.3 反应式命令模式public interface ReactiveCommand { MonoVoid executeReactive(); MonoVoid undoReactive(); } public class ReactiveDatabaseCommand implements ReactiveCommand { private DatabaseClient dbClient; private String query; Override public MonoVoid executeReactive() { return dbClient.sql(query) .fetch() .rowsUpdated() .then(); } Override public MonoVoid undoReactive() { // 实现逆向操作 return Mono.empty(); } }10. 命令模式在分布式系统中的应用10.1 分布式命令模式public interface DistributedCommand extends Command { String getTargetNode(); byte[] serialize(); void deserialize(byte[] data); } public class DistributedCommandExecutor { private MapString, NodeConnection nodeConnections; public void executeOnNode(DistributedCommand cmd) { NodeConnection conn nodeConnections.get(cmd.getTargetNode()); conn.sendCommand(cmd.serialize()); } }10.2 CQRS模式中的命令CQRSCommand Query Responsibility Segregation模式中命令端专门处理状态变更public interface CqrsCommand { void validate(); void executeOn(AggregateRoot aggregate); } public class ChangePasswordCommand implements CqrsCommand { private String userId; private String newPassword; Override public void validate() { if (newPassword.length() 8) { throw new IllegalArgumentException(Password too short); } } Override public void executeOn(AggregateRoot aggregate) { User user (User) aggregate; user.setPassword(hashPassword(newPassword)); } }10.3 事件溯源中的命令事件溯源Event Sourcing系统中命令产生事件public abstract class EsCommand { public abstract ListEvent executeOn(Aggregate aggregate); } public class CreateOrderCommand extends EsCommand { private String customerId; private ListOrderItem items; Override public ListEvent executeOn(Aggregate aggregate) { Order order (Order) aggregate; if (order.isCreated()) { return List.of(); } return List.of( new OrderCreatedEvent(customerId, items), new OrderStatusChangedEvent(CREATED) ); } }11. 命令模式在游戏开发中的应用11.1 游戏控制命令public interface GameCommand extends Command { void setGameCharacter(GameCharacter character); } public class MoveCommand implements GameCommand { private GameCharacter character; private Direction direction; private int distance; Override public void setGameCharacter(GameCharacter character) { this.character character; } Override public void execute() { character.move(direction, distance); } Override public void undo() { character.move(direction.opposite(), distance); } }11.2 回放系统实现public class GameReplaySystem { private ListGameCommand commands new ArrayList(); private int currentIndex -1; public void record(GameCommand cmd) { // 如果回放中途记录新命令丢弃后面的命令 if (currentIndex commands.size() - 1) { commands commands.subList(0, currentIndex 1); } commands.add(cmd); currentIndex; } public void replay() { for (int i 0; i currentIndex; i) { commands.get(i).execute(); } } public void stepForward() { if (currentIndex commands.size() - 1) { currentIndex; commands.get(currentIndex).execute(); } } public void stepBackward() { if (currentIndex 0) { commands.get(currentIndex).undo(); currentIndex--; } } }11.3 网络游戏中的命令同步public class NetworkCommand implements Serializable { private int frameNumber; private GameCommand command; public void executeOnServer(GameState state) { command.executeOn(state.getCharacter(getPlayerId())); } public void executeOnClient(GameState state) { // 客户端预测执行 command.executeOn(state.getLocalPlayer()); } public void reconcile(GameState state) { // 服务器权威状态修正 if (!state.getCharacter(getPlayerId()) .matchesPredictedState(getPredictedState())) { // 回滚并重新执行命令 } } }12. 命令模式的替代方案12.1 函数式编程替代Java 8可以使用函数接口简化命令模式public class FunctionalCommand { private Runnable execute; private Runnable undo; public FunctionalCommand(Runnable execute, Runnable undo) { this.execute execute; this.undo undo; } public void execute() { execute.run(); } public void undo() { undo.run(); } } // 使用示例 Light light new Light(); Command lightOn new FunctionalCommand( light::on, light::off );12.2 策略模式对比策略模式与命令模式的区别关注点不同策略模式算法替换命令模式动作封装使用场景不同策略模式多种算法实现同一功能命令模式将请求封装为对象典型接口策略模式通常有execute()或calculate()命令模式通常有execute()和undo()12.3 模板方法模式对比模板方法模式与命令模式的区别结构不同模板方法父类定义骨架子类实现步骤命令模式调用者与接收者解耦扩展性不同模板方法通过继承扩展命令模式通过组合扩展适用场景模板方法固定流程可变步骤命令模式需要撤销、排队等操作13. 命令模式的最佳实践13.1 何时使用命令模式需要撤销/重做功能文本编辑器图形绘图工具事务系统需要将操作排队或记录任务调度系统操作日志记录宏命令录制需要支持事务数据库操作多步骤业务流程需要原子性执行的操作集合13.2 实现建议保持命令轻量命令对象应该只包含必要信息复杂逻辑委托给接收者考虑不可变命令一旦创建就不修改内部状态有利于线程安全和撤销实现合理设计命令接口根据需求决定是否需要undo()考虑添加redo()或canExecute()等方法命令生命周期管理明确命令的创建、执行、销毁时机避免内存泄漏13.3 性能优化技巧命令池化重用命令对象减少GC压力特别适用于频繁创建的命令懒加载延迟创建昂贵的资源在execute()时才初始化批量处理合并多个小命令为宏命令减少调用开销异步执行耗时命令使用后台线程注意线程安全问题14. 命令模式的反模式与误用14.1 常见误用场景简单操作过度设计// 反例简单操作不需要命令模式 Command cmd new SimplePrintCommand(Hello); cmd.execute(); // 正例直接调用更简单 System.out.println(Hello);命令类过于庞大单个命令类包含太多逻辑应该将复杂逻辑拆分到接收者中滥用命令历史保存所有命令导致内存膨胀应该设置合理的保存上限14.2 代码异味识别命令类中的条件逻辑// 反例命令中包含条件判断 public void execute() { if (conditionA) { // do A } else { // do B } }命令与接收者紧耦合命令直接操作接收者内部状态应该通过接收者的公共接口交互命令参数过多构造函数或执行方法参数列表过长考虑使用Builder模式或参数对象14.3 重构建议转换为函数式接口简单命令可以用Lambda替代减少类爆炸问题合并相似命令使用参数区分不同行为减少类数量引入命令工厂集中管理命令创建隐藏具体命令类public class CommandFactory { public static Command createSaveCommand(Document doc) { return new SaveCommand(doc); } public static Command createPrintCommand(Document doc) { return new PrintCommand(doc); } }15. 现代编程语言中的命令模式15.1 Kotlin的实现方式利用Kotlin的简洁语法interface Command { fun execute() fun undo() } class LightOnCommand(private val light: Light) : Command { override fun execute() light.on() override fun undo() light.off() } // 使用DSL风格构建命令 fun command(execute: () - Unit, undo: () - Unit) object : Command { override fun execute() execute() override fun undo() undo() } val cmd command( execute { println(Do) }, undo { println(Undo) } )15.2 Swift的实现方式利用Swift的协议扩展protocol Command { func execute() func undo() } extension Command { // 默认实现 func undo() { print(Default undo implementation) } } struct PrintCommand: Command { let message: String func execute() { print(message) } } // 使用闭包构建命令 func makeCommand(execute: escaping () - Void, undo: escaping () - Void) - Command { struct AnonymousCommand: Command { let executeClosure: () - Void let undoClosure: () - Void func execute() { executeClosure() } func undo() { undoClosure() } } return AnonymousCommand(executeClosure: execute, undoClosure: undo) }15.3 TypeScript的实现方式利用TypeScript的类型系统interface CommandT void { execute(): T; undo(): void; } class CalculatorCommand implements Commandnumber { constructor( private receiver: Calculator, private operation: add | subtract, private value: number ) {} execute(): number { return this.receiver[this.operation](this.value); } undo(): void { const oppositeOp this.operation add ? subtract : add; this.receiver[oppositeOp](this.value); } } // 使用高阶函数创建命令 function createCommandT( execute: () T, undo: () void ): CommandT { return { execute, undo }; }16. 命令模式在微服务架构中的应用16.1 跨服务命令模式public class CrossServiceCommand implements Command { private ServiceClient serviceA; private ServiceClient serviceB; private String operationData; Override public void execute() { // 调用服务A String resultA serviceA.call(operationData); // 调用服务B依赖A的结果 serviceB.call(resultA); } Override public void undo() { // 实现补偿事务 serviceB.compensate(); serviceA.compensate(); } }16.2 Saga模式实现Saga模式使用命令模式管理分布式事务public interface SagaCommand extends Command { SagaCommand getCompensationCommand(); } public class CreateOrderSaga { private ListSagaCommand commands new ArrayList(); private ListSagaCommand executed new ArrayList(); public void addCommand(SagaCommand cmd) { commands.add(cmd); } public void execute() { try { for (SagaCommand cmd : commands) { cmd.execute(); executed.add(cmd); } } catch (Exception e) { compensate(); throw e; } } private void compensate() { for (int i executed.size() - 1; i 0; i--) { executed.get(i).getCompensationCommand().execute(); } } }16.3 CQRS与事件溯源结合public abstract class CqrsCommand { public abstract ListEvent executeOn(Aggregate aggregate); public void process(CommandProcessor processor) { processor.process(this); } } public class OrderCommandHandler { private EventStore eventStore; public void handle(CreateOrderCommand cmd) { Order order new Order(); ListEvent events cmd.executeOn(order); eventStore.append(events); } public void handle(CancelOrderCommand cmd) { Order order eventStore.reconstruct(Order.class, cmd.getOrderId()); ListEvent events cmd.executeOn(order); eventStore.append(events); } }17. 命令模式与领域驱动设计17.1 DDD中的命令模式在DDD中命令表示改变系统状态的意图public class PlaceOrderCommand { private String customerId; private ListOrderItem items; private Address shippingAddress; // 验证方法 public void validate() { if (items.isEmpty()) { throw new IllegalArgumentException(Order must have items); } } } public class OrderApplicationService { public void handle(PlaceOrderCommand cmd) { cmd.validate(); Order order new Order( cmd.getCustomerId(), cmd.getItems(), cmd.getShippingAddress() ); orderRepository.save(order); eventPublisher.publish(new OrderPlacedEvent(order.getId())); } }17.2 命令处理器模式public interface CommandHandlerC, R { R handle(C command); } public class PlaceOrderHandler implements CommandHandlerPlaceOrderCommand, OrderId { private OrderRepository repository; Override public OrderId handle(PlaceOrderCommand cmd) { Order order new Order(cmd); repository.save(order); return order.getId(); } } // 使用路由分发命令 public class CommandBus { private MapClass?, CommandHandler?, ? handlers new HashMap(); public C, R void register(ClassC type, CommandHandlerC, R handler) { handlers.put(type, handler); } SuppressWarnings(unchecked) public C, R R dispatch(C command) { CommandHandlerC, R handler (CommandHandlerC, R) handlers.get(command.getClass()); if (handler null) { throw new NoHandlerException(command.getClass()); } return handler.handle(command); } }17.3 命令与领域事件public abstract class DomainCommand { private ListDomainEvent events new ArrayList(); protected void raiseEvent(DomainEvent event) { events.add(event); } public ListDomainEvent getEvents() { return Collections.unmodifiableList(events); } public abstract void executeOn(AggregateRoot aggregate); } public class TransferCommand extends DomainCommand { private String fromAccount; private String toAccount; private BigDecimal amount; Override public void executeOn(AggregateRoot aggregate) { Account account (Account) aggregate; if (account.getId().equals(fromAccount)) { account.debit(amount); raiseEvent(new MoneyDebitedEvent(fromAccount, toAccount, amount)); } else if (account.getId().equals(toAccount)) { account.credit(amount); raiseEvent(new MoneyCreditedEvent(toAccount, fromAccount, amount)); } } }18. 命令模式的未来演进18.1 响应式命令模式结合Reactive Streamspublic interface ReactiveCommand { PublisherVoid execute(); PublisherVoid undo(); } public class ReactiveDatabaseCommand implements ReactiveCommand { private R2dbcEntityTemplate template; private String sql; Override public PublisherVoid execute() { return template.getDatabaseClient() .sql(sql) .then(); } Override public PublisherVoid undo() { return Mono.empty(); } }18.2 基于AI的命令生成public class AiCommandGenerator { private AiModel model; public Command generateFrom(String naturalLanguage) { String json model.generateCommandJson(naturalLanguage); return parseCommand(json); } private Command parseCommand(String json) { // 解析AI生成的JSON命令 // 返回具体命令实例 } } // 使用示例 Command cmd generator.generateFrom( 创建一个新订单客户ID是123包含2件商品A和3件商品B );18.3 量子计算中的命令模式探索量子计算环境下的命令模式public interface QuantumCommand { QuantumState executeOn(QuantumState state); QuantumState undoOn(QuantumState state); } public class HadamardGateCommand implements QuantumCommand { private int qubitIndex; Override public QuantumState executeOn(QuantumState state) { return state.applyHadamard(qubitIndex); } Override public QuantumState undoOn(QuantumState state) { // 哈达玛门是可逆的再次应用即为撤销 return state.applyHadamard(qubitIndex); } }19. 命令模式的学习资源19.1 经典书籍推荐《设计模式可复用面向对象软件的基础》GoF经典著作包含命令模式的原始定义详细讲解模式结构和实现方式《Head First设计模式》图文并茂讲解命令模式包含餐厅点餐等生动示例《实现领域驱动设计》讲解命令模式在DDD中的应用包含CQRS模式的深入讨论19
1. 命令模式的核心思想与应用场景命令模式Command Pattern是一种行为型设计模式它将请求封装成独立的对象使你可以参数化客户端对象将请求排队或记录请求日志以及支持可撤销的操作。我第一次在电商系统开发中应用这个模式时它完美解决了订单操作的可撤销问题。这个模式的本质是把做什么具体操作和谁来做调用者解耦。想象餐厅点餐的场景顾客Client不需要知道厨师Receiver如何烹饪只需把订单Command交给服务员Invoker由服务员统一调度执行。这种间接调用的方式带来了极大的灵活性。2. 模式结构与组件解析2.1 经典UML类图实现标准的命令模式包含以下核心角色Command抽象命令声明执行操作的接口通常包含execute()方法可能包含undo()方法支持撤销public interface Command { void execute(); void undo(); }ConcreteCommand具体命令绑定接收者与动作实现execute()方法调用接收者的操作示例开灯命令public class LightOnCommand implements Command { private Light light; public LightOnCommand(Light light) { this.light light; } Override public void execute() { light.on(); } Override public void undo() { light.off(); } }Invoker调用者持有命令对象在适当时机调用命令的execute()示例遥控器按钮public class RemoteControl { private Command command; public void setCommand(Command command) { this.command command; } public void pressButton() { command.execute(); } }Receiver接收者知道如何执行操作实际执行业务逻辑的对象示例电灯设备public class Light { public void on() { System.out.println(Light is on); } public void off() { System.out.println(Light is off); } }2.2 线程安全实现要点在多线程环境下使用命令模式时需要注意命令对象应当是无状态的或者状态是线程隔离的如果命令包含共享资源需要同步控制考虑使用线程池来执行命令队列// 线程安全的命令队列示例 public class CommandQueue { private final QueueCommand queue new ConcurrentLinkedQueue(); private final Executor executor Executors.newFixedThreadPool(4); public void addCommand(Command command) { queue.offer(command); } public void executeAll() { while (!queue.isEmpty()) { Command cmd queue.poll(); executor.execute(cmd::execute); } } }3. 实战应用支持撤销的文本编辑器3.1 编辑器核心功能设计我们实现一个支持无限撤销的文本编辑器// 接收者文档类 public class Document { private StringBuilder content new StringBuilder(); public void insert(int pos, String text) { content.insert(pos, text); } public void delete(int pos, int length) { content.delete(pos, pos length); } public String getContent() { return content.toString(); } }3.2 命令类实现// 抽象命令 public interface TextCommand extends Command { void setDocument(Document doc); } // 插入命令 public class InsertCommand implements TextCommand { private Document document; private int position; private String text; Override public void setDocument(Document doc) { this.document doc; } public InsertCommand(int pos, String text) { this.position pos; this.text text; } Override public void execute() { document.insert(position, text); } Override public void undo() { document.delete(position, text.length()); } } // 删除命令 public class DeleteCommand implements TextCommand { private Document document; private int position; private int length; private String deletedText; // ...setDocument实现... public DeleteCommand(int pos, int len) { this.position pos; this.length len; } Override public void execute() { deletedText document.getContent().substring(position, position length); document.delete(position, length); } Override public void undo() { document.insert(position, deletedText); } }3.3 历史管理类public class CommandHistory { private StackCommand history new Stack(); private StackCommand redoStack new Stack(); public void execute(Command cmd) { cmd.execute(); history.push(cmd); redoStack.clear(); } public void undo() { if (!history.isEmpty()) { Command cmd history.pop(); cmd.undo(); redoStack.push(cmd); } } public void redo() { if (!redoStack.isEmpty()) { Command cmd redoStack.pop(); cmd.execute(); history.push(cmd); } } }4. 高级应用与性能优化4.1 宏命令模式宏命令是命令模式的扩展允许将多个命令组合成一个命令public class MacroCommand implements Command { private ListCommand commands new ArrayList(); public void add(Command cmd) { commands.add(cmd); } Override public void execute() { commands.forEach(Command::execute); } Override public void undo() { // 需要反向执行undo for (int i commands.size() - 1; i 0; i--) { commands.get(i).undo(); } } }4.2 命令模式与内存优化当命令对象过多时可以考虑享元模式共享可复用的命令对象对象池重用命令对象实例延迟加载只在需要时创建命令// 命令对象池示例 public class CommandPool { private static final int MAX_POOL_SIZE 100; private static MapClass?, QueueCommand pool new HashMap(); public static Command get(Class? extends Command clazz) { QueueCommand queue pool.computeIfAbsent(clazz, k - new LinkedList()); Command cmd queue.poll(); if (cmd null) { try { cmd (Command) clazz.newInstance(); } catch (Exception e) { throw new RuntimeException(e); } } return cmd; } public static void release(Command cmd) { if (pool.size() MAX_POOL_SIZE) { QueueCommand queue pool.computeIfAbsent(cmd.getClass(), k - new LinkedList()); queue.offer(cmd); } } }5. 常见问题与调试技巧5.1 命令模式常见陷阱过度设计简单场景不要滥用命令模式适用场景需要撤销/重做、需要排队执行、需要记录日志不适用场景简单的一次性操作内存泄漏长时间运行的命令队列可能积累大量对象解决方案定期清理或使用弱引用线程安全问题多个线程访问同一命令对象解决方案使用线程局部变量或创建命令副本5.2 调试命令模式系统日志记录public class LoggingCommand implements Command { private Command realCommand; public LoggingCommand(Command cmd) { this.realCommand cmd; } Override public void execute() { System.out.println(Executing: realCommand.getClass().getSimpleName()); realCommand.execute(); } Override public void undo() { System.out.println(Undoing: realCommand.getClass().getSimpleName()); realCommand.undo(); } }空命令模式public class NoCommand implements Command { Override public void execute() {} Override public void undo() {} }用于避免null检查符合Null Object模式性能监控public class ProfilingCommand implements Command { private Command realCommand; public ProfilingCommand(Command cmd) { this.realCommand cmd; } Override public void execute() { long start System.nanoTime(); realCommand.execute(); long duration System.nanoTime() - start; System.out.println(Execution took: duration ns); } // ...类似实现undo... }6. 命令模式在框架中的应用6.1 Java Swing中的ActionSwing中的Action接口就是命令模式的典型实现// 创建命令 Action saveAction new AbstractAction(Save) { Override public void actionPerformed(ActionEvent e) { // 保存逻辑 } }; // 绑定到多个UI组件 JButton saveButton new JButton(saveAction); JMenuItem saveMenuItem new JMenuItem(saveAction);6.2 Spring的CommandLineRunnerSpring Boot中的CommandLineRunner也是命令模式的应用Component public class MyRunner implements CommandLineRunner { Override public void run(String... args) { // 应用启动后执行的命令 } }6.3 事务处理中的命令模式数据库事务可以看作是一个宏命令public class TransactionCommand implements Command { private ListCommand commands new ArrayList(); public void add(Command cmd) { commands.add(cmd); } Override public void execute() { try { commands.forEach(Command::execute); // 提交事务 } catch (Exception e) { // 回滚所有命令 for (int i commands.size() - 1; i 0; i--) { commands.get(i).undo(); } throw e; } } Override public void undo() { // 事务级别的undo就是执行回滚 for (int i commands.size() - 1; i 0; i--) { commands.get(i).undo(); } } }7. 命令模式与其他模式的结合7.1 命令责任链模式实现可扩展的命令处理管道public abstract class ChainableCommand implements Command { private ChainableCommand next; public void setNext(ChainableCommand next) { this.next next; } Override public void execute() { doExecute(); if (next ! null) { next.execute(); } } protected abstract void doExecute(); Override public void undo() { if (next ! null) { next.undo(); } doUndo(); } protected abstract void doUndo(); }7.2 命令备忘录模式增强撤销功能保存完整状态public interface StatefulCommand extends Command { Object getState(); void restoreState(Object state); } public class Memento { private MapStatefulCommand, Object states new HashMap(); public void saveState(StatefulCommand cmd) { states.put(cmd, cmd.getState()); } public void restoreAll() { states.forEach(StatefulCommand::restoreState); } }7.3 命令观察者模式实现命令执行通知public class ObservableCommand implements Command { private Command realCommand; private ListCommandListener listeners new ArrayList(); public void addListener(CommandListener l) { listeners.add(l); } Override public void execute() { listeners.forEach(l - l.beforeExecute(this)); realCommand.execute(); listeners.forEach(l - l.afterExecute(this)); } // ...类似实现undo... } public interface CommandListener { void beforeExecute(Command cmd); void afterExecute(Command cmd); }8. 测试命令模式的最佳实践8.1 单元测试策略测试命令对象Test public void testInsertCommand() { Document doc new Document(); Command cmd new InsertCommand(0, Hello); ((TextCommand)cmd).setDocument(doc); cmd.execute(); assertEquals(Hello, doc.getContent()); cmd.undo(); assertEquals(, doc.getContent()); }测试命令历史Test public void testCommandHistory() { CommandHistory history new CommandHistory(); Document doc new Document(); Command cmd1 new InsertCommand(0, A); ((TextCommand)cmd1).setDocument(doc); history.execute(cmd1); Command cmd2 new InsertCommand(1, B); ((TextCommand)cmd2).setDocument(doc); history.execute(cmd2); assertEquals(AB, doc.getContent()); history.undo(); assertEquals(A, doc.getContent()); history.redo(); assertEquals(AB, doc.getContent()); }8.2 集成测试要点测试命令队列的执行顺序测试宏命令的原子性测试长时间运行的命令稳定性测试内存使用情况避免命令积累导致OOM8.3 性能测试建议测量单个命令执行时间测试命令队列的吞吐量评估撤销/重做功能的内存占用压力测试命令历史管理Test public void performanceTest() { int count 10000; Document doc new Document(); CommandHistory history new CommandHistory(); long start System.currentTimeMillis(); for (int i 0; i count; i) { Command cmd new InsertCommand(i, a); ((TextCommand)cmd).setDocument(doc); history.execute(cmd); } long duration System.currentTimeMillis() - start; System.out.println(Insert count chars took: duration ms); start System.currentTimeMillis(); for (int i 0; i count; i) { history.undo(); } duration System.currentTimeMillis() - start; System.out.println(Undo count times took: duration ms); }9. 命令模式的变体与扩展9.1 异步命令模式public interface AsyncCommand { CompletableFutureVoid executeAsync(); CompletableFutureVoid undoAsync(); } public class AsyncFileDownloadCommand implements AsyncCommand { private String url; private String savePath; Override public CompletableFutureVoid executeAsync() { return CompletableFuture.runAsync(() - { // 实现下载逻辑 }); } Override public CompletableFutureVoid undoAsync() { return CompletableFuture.runAsync(() - { // 删除下载的文件 new File(savePath).delete(); }); } }9.2 持久化命令模式public interface PersistentCommand extends Serializable, Command { default void saveTo(Path path) throws IOException { try (ObjectOutputStream out new ObjectOutputStream( Files.newOutputStream(path))) { out.writeObject(this); } } static PersistentCommand loadFrom(Path path) throws IOException, ClassNotFoundException { try (ObjectInputStream in new ObjectInputStream( Files.newInputStream(path))) { return (PersistentCommand) in.readObject(); } } }9.3 反应式命令模式public interface ReactiveCommand { MonoVoid executeReactive(); MonoVoid undoReactive(); } public class ReactiveDatabaseCommand implements ReactiveCommand { private DatabaseClient dbClient; private String query; Override public MonoVoid executeReactive() { return dbClient.sql(query) .fetch() .rowsUpdated() .then(); } Override public MonoVoid undoReactive() { // 实现逆向操作 return Mono.empty(); } }10. 命令模式在分布式系统中的应用10.1 分布式命令模式public interface DistributedCommand extends Command { String getTargetNode(); byte[] serialize(); void deserialize(byte[] data); } public class DistributedCommandExecutor { private MapString, NodeConnection nodeConnections; public void executeOnNode(DistributedCommand cmd) { NodeConnection conn nodeConnections.get(cmd.getTargetNode()); conn.sendCommand(cmd.serialize()); } }10.2 CQRS模式中的命令CQRSCommand Query Responsibility Segregation模式中命令端专门处理状态变更public interface CqrsCommand { void validate(); void executeOn(AggregateRoot aggregate); } public class ChangePasswordCommand implements CqrsCommand { private String userId; private String newPassword; Override public void validate() { if (newPassword.length() 8) { throw new IllegalArgumentException(Password too short); } } Override public void executeOn(AggregateRoot aggregate) { User user (User) aggregate; user.setPassword(hashPassword(newPassword)); } }10.3 事件溯源中的命令事件溯源Event Sourcing系统中命令产生事件public abstract class EsCommand { public abstract ListEvent executeOn(Aggregate aggregate); } public class CreateOrderCommand extends EsCommand { private String customerId; private ListOrderItem items; Override public ListEvent executeOn(Aggregate aggregate) { Order order (Order) aggregate; if (order.isCreated()) { return List.of(); } return List.of( new OrderCreatedEvent(customerId, items), new OrderStatusChangedEvent(CREATED) ); } }11. 命令模式在游戏开发中的应用11.1 游戏控制命令public interface GameCommand extends Command { void setGameCharacter(GameCharacter character); } public class MoveCommand implements GameCommand { private GameCharacter character; private Direction direction; private int distance; Override public void setGameCharacter(GameCharacter character) { this.character character; } Override public void execute() { character.move(direction, distance); } Override public void undo() { character.move(direction.opposite(), distance); } }11.2 回放系统实现public class GameReplaySystem { private ListGameCommand commands new ArrayList(); private int currentIndex -1; public void record(GameCommand cmd) { // 如果回放中途记录新命令丢弃后面的命令 if (currentIndex commands.size() - 1) { commands commands.subList(0, currentIndex 1); } commands.add(cmd); currentIndex; } public void replay() { for (int i 0; i currentIndex; i) { commands.get(i).execute(); } } public void stepForward() { if (currentIndex commands.size() - 1) { currentIndex; commands.get(currentIndex).execute(); } } public void stepBackward() { if (currentIndex 0) { commands.get(currentIndex).undo(); currentIndex--; } } }11.3 网络游戏中的命令同步public class NetworkCommand implements Serializable { private int frameNumber; private GameCommand command; public void executeOnServer(GameState state) { command.executeOn(state.getCharacter(getPlayerId())); } public void executeOnClient(GameState state) { // 客户端预测执行 command.executeOn(state.getLocalPlayer()); } public void reconcile(GameState state) { // 服务器权威状态修正 if (!state.getCharacter(getPlayerId()) .matchesPredictedState(getPredictedState())) { // 回滚并重新执行命令 } } }12. 命令模式的替代方案12.1 函数式编程替代Java 8可以使用函数接口简化命令模式public class FunctionalCommand { private Runnable execute; private Runnable undo; public FunctionalCommand(Runnable execute, Runnable undo) { this.execute execute; this.undo undo; } public void execute() { execute.run(); } public void undo() { undo.run(); } } // 使用示例 Light light new Light(); Command lightOn new FunctionalCommand( light::on, light::off );12.2 策略模式对比策略模式与命令模式的区别关注点不同策略模式算法替换命令模式动作封装使用场景不同策略模式多种算法实现同一功能命令模式将请求封装为对象典型接口策略模式通常有execute()或calculate()命令模式通常有execute()和undo()12.3 模板方法模式对比模板方法模式与命令模式的区别结构不同模板方法父类定义骨架子类实现步骤命令模式调用者与接收者解耦扩展性不同模板方法通过继承扩展命令模式通过组合扩展适用场景模板方法固定流程可变步骤命令模式需要撤销、排队等操作13. 命令模式的最佳实践13.1 何时使用命令模式需要撤销/重做功能文本编辑器图形绘图工具事务系统需要将操作排队或记录任务调度系统操作日志记录宏命令录制需要支持事务数据库操作多步骤业务流程需要原子性执行的操作集合13.2 实现建议保持命令轻量命令对象应该只包含必要信息复杂逻辑委托给接收者考虑不可变命令一旦创建就不修改内部状态有利于线程安全和撤销实现合理设计命令接口根据需求决定是否需要undo()考虑添加redo()或canExecute()等方法命令生命周期管理明确命令的创建、执行、销毁时机避免内存泄漏13.3 性能优化技巧命令池化重用命令对象减少GC压力特别适用于频繁创建的命令懒加载延迟创建昂贵的资源在execute()时才初始化批量处理合并多个小命令为宏命令减少调用开销异步执行耗时命令使用后台线程注意线程安全问题14. 命令模式的反模式与误用14.1 常见误用场景简单操作过度设计// 反例简单操作不需要命令模式 Command cmd new SimplePrintCommand(Hello); cmd.execute(); // 正例直接调用更简单 System.out.println(Hello);命令类过于庞大单个命令类包含太多逻辑应该将复杂逻辑拆分到接收者中滥用命令历史保存所有命令导致内存膨胀应该设置合理的保存上限14.2 代码异味识别命令类中的条件逻辑// 反例命令中包含条件判断 public void execute() { if (conditionA) { // do A } else { // do B } }命令与接收者紧耦合命令直接操作接收者内部状态应该通过接收者的公共接口交互命令参数过多构造函数或执行方法参数列表过长考虑使用Builder模式或参数对象14.3 重构建议转换为函数式接口简单命令可以用Lambda替代减少类爆炸问题合并相似命令使用参数区分不同行为减少类数量引入命令工厂集中管理命令创建隐藏具体命令类public class CommandFactory { public static Command createSaveCommand(Document doc) { return new SaveCommand(doc); } public static Command createPrintCommand(Document doc) { return new PrintCommand(doc); } }15. 现代编程语言中的命令模式15.1 Kotlin的实现方式利用Kotlin的简洁语法interface Command { fun execute() fun undo() } class LightOnCommand(private val light: Light) : Command { override fun execute() light.on() override fun undo() light.off() } // 使用DSL风格构建命令 fun command(execute: () - Unit, undo: () - Unit) object : Command { override fun execute() execute() override fun undo() undo() } val cmd command( execute { println(Do) }, undo { println(Undo) } )15.2 Swift的实现方式利用Swift的协议扩展protocol Command { func execute() func undo() } extension Command { // 默认实现 func undo() { print(Default undo implementation) } } struct PrintCommand: Command { let message: String func execute() { print(message) } } // 使用闭包构建命令 func makeCommand(execute: escaping () - Void, undo: escaping () - Void) - Command { struct AnonymousCommand: Command { let executeClosure: () - Void let undoClosure: () - Void func execute() { executeClosure() } func undo() { undoClosure() } } return AnonymousCommand(executeClosure: execute, undoClosure: undo) }15.3 TypeScript的实现方式利用TypeScript的类型系统interface CommandT void { execute(): T; undo(): void; } class CalculatorCommand implements Commandnumber { constructor( private receiver: Calculator, private operation: add | subtract, private value: number ) {} execute(): number { return this.receiver[this.operation](this.value); } undo(): void { const oppositeOp this.operation add ? subtract : add; this.receiver[oppositeOp](this.value); } } // 使用高阶函数创建命令 function createCommandT( execute: () T, undo: () void ): CommandT { return { execute, undo }; }16. 命令模式在微服务架构中的应用16.1 跨服务命令模式public class CrossServiceCommand implements Command { private ServiceClient serviceA; private ServiceClient serviceB; private String operationData; Override public void execute() { // 调用服务A String resultA serviceA.call(operationData); // 调用服务B依赖A的结果 serviceB.call(resultA); } Override public void undo() { // 实现补偿事务 serviceB.compensate(); serviceA.compensate(); } }16.2 Saga模式实现Saga模式使用命令模式管理分布式事务public interface SagaCommand extends Command { SagaCommand getCompensationCommand(); } public class CreateOrderSaga { private ListSagaCommand commands new ArrayList(); private ListSagaCommand executed new ArrayList(); public void addCommand(SagaCommand cmd) { commands.add(cmd); } public void execute() { try { for (SagaCommand cmd : commands) { cmd.execute(); executed.add(cmd); } } catch (Exception e) { compensate(); throw e; } } private void compensate() { for (int i executed.size() - 1; i 0; i--) { executed.get(i).getCompensationCommand().execute(); } } }16.3 CQRS与事件溯源结合public abstract class CqrsCommand { public abstract ListEvent executeOn(Aggregate aggregate); public void process(CommandProcessor processor) { processor.process(this); } } public class OrderCommandHandler { private EventStore eventStore; public void handle(CreateOrderCommand cmd) { Order order new Order(); ListEvent events cmd.executeOn(order); eventStore.append(events); } public void handle(CancelOrderCommand cmd) { Order order eventStore.reconstruct(Order.class, cmd.getOrderId()); ListEvent events cmd.executeOn(order); eventStore.append(events); } }17. 命令模式与领域驱动设计17.1 DDD中的命令模式在DDD中命令表示改变系统状态的意图public class PlaceOrderCommand { private String customerId; private ListOrderItem items; private Address shippingAddress; // 验证方法 public void validate() { if (items.isEmpty()) { throw new IllegalArgumentException(Order must have items); } } } public class OrderApplicationService { public void handle(PlaceOrderCommand cmd) { cmd.validate(); Order order new Order( cmd.getCustomerId(), cmd.getItems(), cmd.getShippingAddress() ); orderRepository.save(order); eventPublisher.publish(new OrderPlacedEvent(order.getId())); } }17.2 命令处理器模式public interface CommandHandlerC, R { R handle(C command); } public class PlaceOrderHandler implements CommandHandlerPlaceOrderCommand, OrderId { private OrderRepository repository; Override public OrderId handle(PlaceOrderCommand cmd) { Order order new Order(cmd); repository.save(order); return order.getId(); } } // 使用路由分发命令 public class CommandBus { private MapClass?, CommandHandler?, ? handlers new HashMap(); public C, R void register(ClassC type, CommandHandlerC, R handler) { handlers.put(type, handler); } SuppressWarnings(unchecked) public C, R R dispatch(C command) { CommandHandlerC, R handler (CommandHandlerC, R) handlers.get(command.getClass()); if (handler null) { throw new NoHandlerException(command.getClass()); } return handler.handle(command); } }17.3 命令与领域事件public abstract class DomainCommand { private ListDomainEvent events new ArrayList(); protected void raiseEvent(DomainEvent event) { events.add(event); } public ListDomainEvent getEvents() { return Collections.unmodifiableList(events); } public abstract void executeOn(AggregateRoot aggregate); } public class TransferCommand extends DomainCommand { private String fromAccount; private String toAccount; private BigDecimal amount; Override public void executeOn(AggregateRoot aggregate) { Account account (Account) aggregate; if (account.getId().equals(fromAccount)) { account.debit(amount); raiseEvent(new MoneyDebitedEvent(fromAccount, toAccount, amount)); } else if (account.getId().equals(toAccount)) { account.credit(amount); raiseEvent(new MoneyCreditedEvent(toAccount, fromAccount, amount)); } } }18. 命令模式的未来演进18.1 响应式命令模式结合Reactive Streamspublic interface ReactiveCommand { PublisherVoid execute(); PublisherVoid undo(); } public class ReactiveDatabaseCommand implements ReactiveCommand { private R2dbcEntityTemplate template; private String sql; Override public PublisherVoid execute() { return template.getDatabaseClient() .sql(sql) .then(); } Override public PublisherVoid undo() { return Mono.empty(); } }18.2 基于AI的命令生成public class AiCommandGenerator { private AiModel model; public Command generateFrom(String naturalLanguage) { String json model.generateCommandJson(naturalLanguage); return parseCommand(json); } private Command parseCommand(String json) { // 解析AI生成的JSON命令 // 返回具体命令实例 } } // 使用示例 Command cmd generator.generateFrom( 创建一个新订单客户ID是123包含2件商品A和3件商品B );18.3 量子计算中的命令模式探索量子计算环境下的命令模式public interface QuantumCommand { QuantumState executeOn(QuantumState state); QuantumState undoOn(QuantumState state); } public class HadamardGateCommand implements QuantumCommand { private int qubitIndex; Override public QuantumState executeOn(QuantumState state) { return state.applyHadamard(qubitIndex); } Override public QuantumState undoOn(QuantumState state) { // 哈达玛门是可逆的再次应用即为撤销 return state.applyHadamard(qubitIndex); } }19. 命令模式的学习资源19.1 经典书籍推荐《设计模式可复用面向对象软件的基础》GoF经典著作包含命令模式的原始定义详细讲解模式结构和实现方式《Head First设计模式》图文并茂讲解命令模式包含餐厅点餐等生动示例《实现领域驱动设计》讲解命令模式在DDD中的应用包含CQRS模式的深入讨论19
