使用 Pub/Sub 模型在 Flutter 中进行实时通信

在 Flutter 开发中，管理应用程序各个组件之间的通信是一项挑战，尤其是当您需要发送实时更新时。这正是 pub/sub（发布-订阅）模型的优势所在。在发布/订阅模型中，组件（订阅者）监听来自其他组件（发布者）的事件或数据，而彼此不直接依赖。当事件发生时，发布者会发出 “广播”，订阅者会接收到，从而根据需要做出反应。这种架构促进了解耦，使应用程序更具可扩展性，也更易于维护。

例如，在银行应用程序中，必须有效地管理实时通知和更新，包括余额变化、交易提醒或账户状态更新等功能。使用 Flutter 中的 fbroadcast 包的 pub/sub 模型，您可以广播这些更新，让应用程序的各个部分做出相应的反应，而无需创建一个紧密耦合的架构。

为何将 Pub/Sub 用于金融应用程序？

Pub/Sub 模型非常适合金融应用程序，其中多个动态组件需要根据外部事件进行通信或更新：

• 交易提醒：即时通知用户最近的交易。
• 余额更新：在不同屏幕上随时查看最新账户余额。
• 账户状态更改：在账户冻结或激活等重要变更发生时通知用户。

使用 Flutter 中的 fbroadcast，您可以轻松管理不同屏幕或组件上的实时数据，支持持续广播，甚至实现双向通信。

让我们通过几个关键用例来探讨如何在类似金融应用程序中实现 fbroadcast。

设置 fbroadcast

首先，在 pubspec.yaml 文件中添加 fbroadcast：

dependencies:
  fbroadcast: ^2.0.0

运行 flutter pub get 安装软件包。

金融应用程序用例

以下是在金融应用程序中使用 fbroadcast 的一些关键场景和代码示例。

1. 广播交易警报

假设您想在发生新交易时提醒用户，并在相关屏幕上显示详细信息。

代码示例：

import 'package:fbroadcast/fbroadcast.dart';

void main() {
  // 广播新的交易警报
  FBroadcast.instance().broadcast(
    "transaction_alert",
    value: {"type": "debit", "amount": 200, "account": "Checking"},
  );
  // 注册以监听交易警报（例如，在 HomeScreen 中）
  FBroadcast.instance().register("transaction_alert", (value, callback) {
    print("Transaction Alert: $value");
    // 输出: {type: "debit", amount: 200, account: "Checking"}
  });
}

每个注册了 transaction_alert 的屏幕都会收到交易详情，从而可以显示警报或更新交易历史记录。

2. 持续广播实时更新余额

要在全局范围内管理和更新最新余额，可以使用持续广播。这样，任何屏幕都可以获得最新余额，而无需重复调用后台。

代码示例：

// 广播并保存最新的余额更新
FBroadcast.instance().broadcast( 
  "balance_update" , 
  value: { "checking" : 8000 , "savings" : 15000 }, 
  persistence: true , 
); 

// 在任何屏幕上访问最新余额
var latestBalance = FBroadcast.value( "balance_update" ); 
print ( "Current Account Balances: $latestBalance " ); 
// 输出：{checking: 8000, savings: 15000} 
// 如果需要，清除余额数据（例如，在用户注销时）
 FBroadcast.instance().clear( "balance_update" );

通过此设置，任何显示余额的屏幕（例如仪表板或帐户概览）都可以直接访问最新值，从而提供无缝的用户体验。

3. 重要账户通知的粘性广播

粘性广播对于用户在访问应用程序时可能需要立即看到的紧急通知很有帮助，即使他们在初始广播期间不活跃。

代码示例：

// 发送粘性广播以更改帐户状态
FBroadcast.instance().stickyBroadcast(
  "account_status_notification",
  value: {"account": "Checking", "status": "Frozen"},
);

// 注册以监听帐户状态通知（例如，在 NotificationsScreen 中）
FBroadcast.instance().register("account_status_notification", (value, callback) {
  print("Account Status Notification: $value");
  // 输出: {account: "Checking", status: "Frozen"}
});

在此示例中，粘性广播可确保有关帐户冻结的通知保持可用，直到侦听器（例如特定屏幕或应用程序的通知中心）访问它。

4. 交易批准的双向沟通

有时，您的应用可能需要验证或确认某项操作才能继续。例如，让我们根据账户余额检查是否能够批准交易。

代码示例：

// 广播消息以检查交易是否可以获得批准
FBroadcast.instance().broadcast(
  "transaction_approval_check",
  value: {"amount": 300, "account": "Checking"},
  callback: (approvalStatus) {
    print("Transaction Approval Status: $approvalStatus");
    // 输出: "Approved" or "Declined"
  },
);

// 注册监听器以响应交易批准检查（例如，在 TransactionService 中）
FBroadcast.instance().register("transaction_approval_check", (value, callback) {
  // 检查批准状态的逻辑
  var approvalStatus = "Approved";  
  callback(approvalStatus);  // 将批准状态返回给发送者
});

这种双向通信使应用程序能够检查交易资格并向用户提供即时反馈，从而改善整体体验。

5. 绑定上下文以实现接收器的有效注销

假设您需要在一个屏幕（如 AccountDetailsScreen）中注册多个接收器。将它们绑定到上下文可确保它们在屏幕关闭时自动移除。

代码示例：

// 在 AccountDetailsS​​creen 中注册多个接收器
FBroadcast.instance().register(
  "balance_update",
  (value, callback) => print("Balance Updated: $value"),
  more: {
    "transaction_alert": (value, callback) => print("Transaction Alert: $value"),
    "account_status_notification": (value, callback) => print("Account Status Notification: $value"),
  },
  context: this,  // 绑定到 AccountDetailsS​​creen 上下文
);

// 在 AccountDetailsS​​creen 被处置时取消注册所有接收器
FBroadcast.instance().unregister(this);

通过将这些接收器绑定到屏幕的上下文，您可以确保它们在屏幕关闭时自动取消注册，从而控制内存使用情况并避免不必要的监听器。

总之，在类金融应用中使用 pub/sub 模型和 fbroadcast 可帮助您无缝管理实时通知和更新。借助简洁高效的架构，您可以在应用中广播数据而无需直接依赖，从而使应用响应更快、更可扩展。