flutter 插件Bumblebee 的使用_Bumblebee 是 Dart 和 Flutter 的客户端库，用于与一个名为 Pollen 的 HTTP 发布/订阅和流引擎进行交互

Flutter高效开发辅助插件bumblebee的使用

Bumblebee

Bumblebee 是 Dart 和 Flutter 的客户端库，用于与一个名为 Pollen 的 HTTP 发布/订阅和流引擎进行交互。Pollen 是一个用于 Rails 的 HTTP 发布/订阅和流引擎。

特性

通过 Bumblebee，你可以订阅 Pollen 流，并在接收到消息事件、流完成或失败时获得通知。

开始使用

首先，在你的 Flutter 项目中添加 bumblebee 插件：

flutter pub add bumblebee

使用方法

订阅到一个流

你可以通过以下方式订阅到一个特定的流：

import 'package:bumblebee/bumblebee.dart' as bumblebee;

void subscribe(String streamId) async {
  // 创建客户端实例并连接到服务器
  bumblebee.Client client = bumblebee.Client(server: Uri.parse('https://pollen.server.local'));

  // 订阅到指定的流ID
  bumblebee.Event? event = await client.listen(streamId);

  // 打印流完成信息
  print("Stream completed: ${event?.type}");
}

监听流更新

要开始监听流更新，可以使用 listen 方法并提供流 ID。如果端点受某些认证方案保护，可以在 listen 方法的回调中添加适当的参数或头部信息：

import 'package:bumblebee/bumblebee.dart' as bumblebee;

void subscribe(String streamId) async {
  bumblebee.Client client = bumblebee.Client(server: Uri.parse('https://pollen.server.local'));

  bumblebee.Event? event = await client
    .onHeartbeat(() {
      print('Received an heartbeat');
    })
    .onTerminate(() {
      print('Received the "terminated" event');
    })
    .onMessage((bumblebee.Event event) {
      print('Received an event of type ${event.type}');
      print('Payload: ${event.data()}');
    })
    .listen(streamId, (request) {
      request.headers['authorization'] = "Bearer: <TOKEN>";
    });

  print("Stream completed: ${event?.type}");
  print('Payload: ${event?.data()}');
}

客户端超时

为了确保客户端在服务器关闭流后不会无限期等待，可以设置超时时间。例如，设置 30 秒的超时时间：

import 'package:bumblebee/bumblebee.dart' as bumblebee;

void subscribe(String streamId) async {
  try {
    bumblebee.Client client = bumblebee.Client(server: Uri.parse('https://pollen.server.local'));

    bumblebee.Event? event = await client
      .listen(streamId, (request) {
        request.headers['authorization'] = "Bearer: <TOKEN>";
      })
      .timeout(const Duration(seconds: 30));

    print("Stream completed: ${event?.type}");
    print('Payload: ${event?.data()}');
  } on TimeoutException catch (e) {
    print("Client timeout ${e.message}");
  }
}

处理错误

连接超时和服务器端流失败会分别抛出 StreamTimeoutException 和 FailureException 异常。由于 Bumblebee 使用 http 包，网络连接问题将抛出 http.ClientException 异常。

示例代码

以下是一个完整的示例代码，展示了如何使用 Bumblebee 插件：

import 'dart:async';

import 'package:bumblebee/bumblebee.dart' as bumblebee;

// Usage
// dart run example/bumblebee_example.dart <pollen-server-url> <stream-id>
// dart run example/bumblebee_example.dart https://pollen.server.org b9800156-d4d3-4f89-8c40-292eb01e58b2
void main(List<String> args) async {
  try {
    final client = bumblebee.Client(server: Uri.parse(args[0]));
    bumblebee.Event? event = await client
      .onHeartbeat(() {
        print('Received an heartbeat');
      })
      .onTerminate(() {
        print('Received the "terminated" event');
      })
      .onMessage((bumblebee.Event event) {
        print('Received a message of type ${event.type}');
        print('Payload: ${event.data()}');
      })
      .listen(args[1], (request) {
        request.headers['authorization'] = 'Bearer: <TOKEN>';
      })
      .timeout(const Duration(seconds: 120));

    print('Stream completed with signal "${event?.type}"');
    print("Payload: ${event?.data()}");
  } on bumblebee.BumblebeeException catch (e) {
    print(e.message);
    rethrow;
  } on TimeoutException catch (e) {
    print("Client timeout ${e.message}");
  }
}