Flutter消息服务插件pip_services3_messaging的使用

Flutter消息服务插件pip_services3_messaging的使用

异步消息传递对于Dart

该模块是Pip.Services多语言微服务工具包的一部分。

消息传递模块包含了一组用于处理消息队列的接口和类，以及一个内存中的消息队列实现。

该模块包含以下包：

• Build - 内存中的消息队列工厂
• Queues - 包含用于处理消息队列的接口、从队列接收消息的订阅以及一个内存中的消息队列实现。

快速链接：

• 配置
• API参考文档
• 变更日志
• 获取帮助
• 贡献

使用

在你的pubspec.yaml文件中添加以下内容：

dependencies:
  pip_services3_messaging: version

然后从命令行安装包：

pub get

开发

开发时你需要安装以下前置条件：

• Dart SDK 2
• Visual Studio Code 或其他你选择的IDE
• Docker

安装依赖项：

pub get

运行自动化测试：

pub run test

生成API文档：

./docgen.ps1

在提交更改之前，运行Docker化的构建和测试：

./build.ps1
./test.ps1
./clear.ps1

联系方式

Dart版本的Pip.Services由以下人员创建和维护：

• Sergey Seroukhov
• Levichev Dmitry

文档由以下人员编写：

• Mark Makarychev
• Levichev Dmitry

完整示例代码

以下是一个完整的示例代码，演示如何在Flutter项目中使用pip_services3_messaging插件。

示例代码

首先，确保在pubspec.yaml文件中添加了依赖项：

dependencies:
  pip_services3_messaging: ^1.0.0

安装依赖项：

flutter pub get

接下来，创建一个简单的Flutter应用来展示消息队列的功能。我们将在一个简单的应用中使用内存中的消息队列。

main.dart

import 'package:flutter/material.dart';
import 'package:pip_services3_messaging/build/MemoryMessageQueueFactory.dart';
import 'package:pip_services3_messaging/queues/MemoryMessageQueue.dart';

void main() {
  runApp(MyApp());
}

class MyApp extends StatelessWidget {
  [@override](/user/override)
  Widget build(BuildContext context) {
    return MaterialApp(
      home: Scaffold(
        appBar: AppBar(title: Text('Pip.Services Messaging Example')),
        body: MessageQueueExample(),
      ),
    );
  }
}

class MessageQueueExample extends StatefulWidget {
  [@override](/user/override)
  _MessageQueueExampleState createState() => _MessageQueueExampleState();
}

class _MessageQueueExampleState extends State<MessageQueueExample> {
  final MemoryMessageQueueFactory _factory = MemoryMessageQueueFactory();
  MemoryMessageQueue _queue;

  [@override](/user/override)
  void initState() {
    super.initState();
    _queue = _factory.create('test_queue');
    _queue.open(null);
  }

  [@override](/user/override)
  Widget build(BuildContext context) {
    return Center(
      child: Column(
        mainAxisAlignment: MainAxisAlignment.center,
        children: <Widget>[
          ElevatedButton(
            onPressed: () {
              _queue.send(null, 'Hello, World!');
            },
            child: Text('Send Message'),
          ),
          ElevatedButton(
            onPressed: () async {
              var message = await _queue.receiveOne(null);
              if (message != null) {
                print('Received message: ${message.message}');
              } else {
                print('No messages available');
              }
            },
            child: Text('Receive Message'),
          ),
        ],
      ),
    );
  }
}