Flutter消息通信插件flueco_messaging的使用

flueco_messaging 是一个用于在 Flutter 应用中实现消息通信的插件。它可以帮助你在不同的组件、页面或模块之间传递消息，从而实现解耦和高效的通信。以下是如何使用 flueco_messaging 插件的步骤和示例。

1. 添加依赖

首先，你需要在 pubspec.yaml 文件中添加 flueco_messaging 依赖：

dependencies:
  flutter:
    sdk: flutter
  flueco_messaging: ^1.0.0 # 确保使用最新版本

然后运行 flutter pub get 来安装依赖。

2. 初始化消息总线

在你的应用启动时，初始化消息总线。通常可以在 main.dart 文件中进行初始化。

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

void main() {
  // 初始化消息总线
  final messaging = MessagingBus();

  runApp(MyApp(messaging: messaging));
}

class MyApp extends StatelessWidget {
  final MessagingBus messaging;

  MyApp({required this.messaging});

  @override
  Widget build(BuildContext context) {
    return MaterialApp(
      title: 'Flutter Messaging Demo',
      home: HomePage(messaging: messaging),
    );
  }
}

3. 发送和接收消息

在需要发送和接收消息的地方，你可以使用 MessagingBus 实例来发送和订阅消息。

发送消息

class HomePage extends StatelessWidget {
  final MessagingBus messaging;

  HomePage({required this.messaging});

  void _sendMessage() {
    // 发送一个简单的字符串消息
    messaging.publish('my_message', 'Hello, Flueco Messaging!');
  }

  @override
  Widget build(BuildContext context) {
    return Scaffold(
      appBar: AppBar(
        title: Text('Home Page'),
      ),
      body: Center(
        child: ElevatedButton(
          onPressed: _sendMessage,
          child: Text('Send Message'),
        ),
      ),
    );
  }
}

接收消息

class AnotherPage extends StatefulWidget {
  final MessagingBus messaging;

  AnotherPage({required this.messaging});

  @override
  _AnotherPageState createState() => _AnotherPageState();
}

class _AnotherPageState extends State<AnotherPage> {
  String? _message;

  @override
  void initState() {
    super.initState();

    // 订阅消息
    widget.messaging.subscribe<String>('my_message').listen((message) {
      setState(() {
        _message = message;
      });
    });
  }

  @override
  Widget build(BuildContext context) {
    return Scaffold(
      appBar: AppBar(
        title: Text('Another Page'),
      ),
      body: Center(
        child: Text(_message ?? 'No message received yet'),
      ),
    );
  }
}

4. 取消订阅

当你不再需要接收消息时，记得取消订阅以避免内存泄漏。

class _AnotherPageState extends State<AnotherPage> {
  String? _message;
  late StreamSubscription<String> _subscription;

  @override
  void initState() {
    super.initState();

    _subscription = widget.messaging.subscribe<String>('my_message').listen((message) {
      setState(() {
        _message = message;
      });
    });
  }

  @override
  void dispose() {
    _subscription.cancel(); // 取消订阅
    super.dispose();
  }

  @override
  Widget build(BuildContext context) {
    return Scaffold(
      appBar: AppBar(
        title: Text('Another Page'),
      ),
      body: Center(
        child: Text(_message ?? 'No message received yet'),
      ),
    );
  }
}

5. 使用自定义消息类型

你不仅可以发送和接收基本类型（如 String），还可以发送和接收自定义对象。

class MyCustomMessage {
  final String content;
  final DateTime timestamp;

  MyCustomMessage(this.content, this.timestamp);
}

// 发送自定义消息
messaging.publish('custom_message', MyCustomMessage('Custom content', DateTime.now()));

// 接收自定义消息
widget.messaging.subscribe<MyCustomMessage>('custom_message').listen((message) {
  print('Received custom message: ${message.content} at ${message.timestamp}');
});