Flutter CQRS架构实现插件cqrs_mediator的使用

什么是CQRS？

CQRS（Command and Query Responsibility Segregation）是一种设计模式，它将读取和更新操作分离到不同的接口中。这种模式可以最大化应用程序的性能、可扩展性和安全性，并允许系统随着时间的推移更好地演进。

什么是Mediator？

Mediator（中介者模式）是一种行为设计模式，它减少了对象之间的混乱依赖关系。该模式限制了对象之间的直接通信，并强制它们仅通过中介对象进行协作。

cqrs_mediator插件介绍

cqrs_mediator是一个用于Flutter的插件，它结合了CQRS和Mediator模式的优点，提供了一种简单的方式来编写命令和查询处理逻辑。

如何使用cqrs_mediator

ICommand

同步命令

1. 创建你的命令和命令处理器：

class MyCommand extends ICommand {}

class CommandHandler extends ICommandHandler<MyCommand> {
  [@override](/user/override)
  void call(MyCommand command) {
    // your code here
  }
}

1. 使用它：

void main() {
  Mediator.instance.registerHandler(() => CommandHandler());
}

/// 在代码中的其他地方使用
TextButton(
  onPressed: () {
    Mediator.instance.run(MyCommand());
  },
  child: const Text("Call command handler"),
)

异步命令

1. 创建你的异步命令和异步命令处理器：

class MyAsyncCommand extends IAsyncCommand {}

class MyAsyncCommandHandler extends IAsyncCommandHandler<MyAsyncCommand> {
  [@override](/user/override)
  Future<void> call(MyAsyncCommand command) async {
    // your code here
  }
}

1. 使用它：

void main() {
  Mediator.instance.registerHandler(() => MyAsyncCommandHandler());
}

/// 在代码中的其他地方使用
TextButton(
  onPressed: () async {
    await Mediator.instance.run(MyAsyncCommand());
  },
  child: const Text("Call async command handler"),
)

IQuery

同步查询

1. 创建你的查询和查询处理器：

class MyQuery extends IQuery<String> {}

class QueryHandler extends IQueryHandler<String, MyQuery> {
  [@override](/user/override)
  String call(MyQuery query) {
    return 'Your result';
  }
}

1. 使用它：

void main() {
  Mediator.instance.registerHandler(() => QueryHandler());
}

/// 在代码中的其他地方使用
TextButton(
  onPressed: () {
    var result = Mediator.instance.run(MyQuery());
    print(result);
  },
  child: const Text("Call query handler"),
)

异步查询

1. 创建你的异步查询和异步查询处理器：

class MyAsyncQuery extends IAsyncQuery<String> {}

class AsyncQueryHandler extends IAsyncQueryHandler<String, MyAsyncQuery> {
  [@override](/user/override)
  Future<String> call(MyAsyncQuery query) async {
    return 'Your result';
  }
}

1. 使用它：

void main() {
  Mediator.instance.registerHandler(() => AsyncQueryHandler());
}

/// 在代码中的其他地方使用
TextButton(
  onPressed: () async {
    var result = await Mediator.instance.run(MyAsyncQuery());
    print(result);
  },
  child: const Text("Call async query handler"),
)

示例Demo

以下是一个完整的示例，展示了如何在Flutter应用中使用cqrs_mediator插件：

import 'package:cqrs_mediator/cqrs_mediator.dart';
import 'package:flutter/material.dart';

// 定义同步命令
class MyCommand extends ICommand {}

class MyCommandHandler extends ICommandHandler<MyCommand> {
  [@override](/user/override)
  void call(MyCommand command) {
    print('MyCommand executed');
  }
}

// 定义异步命令
class MyAsyncCommand extends IAsyncCommand {}

class MyAsyncCommandHandler extends IAsyncCommandHandler<MyAsyncCommand> {
  [@override](/user/override)
  Future<void> call(MyAsyncCommand command) async {
    await Future.delayed(Duration(seconds: 1));
    print('MyAsyncCommand executed');
  }
}

// 定义同步查询
class MyQuery extends IQuery<String> {}

class MyQueryHandler extends IQueryHandler<String, MyQuery> {
  [@override](/user/override)
  String call(MyQuery query) {
    return 'Result from MyQuery';
  }
}

// 定义异步查询
class MyAsyncQuery extends IAsyncQuery<String> {}

class MyAsyncQueryHandler extends IAsyncQueryHandler<String, MyAsyncQuery> {
  [@override](/user/override)
  Future<String> call(MyAsyncQuery query) async {
    await Future.delayed(Duration(seconds: 1));
    return 'Result from MyAsyncQuery';
  }
}

void main() {
  // 注册处理器
  Mediator.instance.registerHandler(() => MyCommandHandler());
  Mediator.instance.registerHandler(() => MyAsyncCommandHandler());
  Mediator.instance.registerHandler(() => MyQueryHandler());
  Mediator.instance.registerHandler(() => MyAsyncQueryHandler());

  runApp(MyApp());
}

class MyApp extends StatelessWidget {
  [@override](/user/override)
  Widget build(BuildContext context) {
    return MaterialApp(
      title: 'CQRS Mediator Demo',
      theme: ThemeData(
        primarySwatch: Colors.blue,
      ),
      home: MyHomePage(),
    );
  }
}

class MyHomePage extends StatelessWidget {
  [@override](/user/override)
  Widget build(BuildContext context) {
    return Scaffold(
      appBar: AppBar(
        title: Text('CQRS Mediator Demo'),
      ),
      body: Center(
        child: Column(
          mainAxisAlignment: MainAxisAlignment.center,
          children: <Widget>[
            TextButton(
              onPressed: () {
                Mediator.instance.run(MyCommand());
              },
              child: Text("Call command handler"),
            ),
            TextButton(
              onPressed: () async {
                await Mediator.instance.run(MyAsyncCommand());
              },
              child: Text("Call async command handler"),
            ),
            TextButton(
              onPressed: () {
                var result = Mediator.instance.run(MyQuery());
                print(result);
              },
              child: Text("Call query handler"),
            ),
            TextButton(
              onPressed: () async {
                var result = await Mediator.instance.run(MyAsyncQuery());
                print(result);
              },
              child: Text("Call async query handler"),
            ),
          ],
        ),
      ),
    );
  }
}