Flutter插件quasar的使用_Quasar 是一个轻量级且高性能的 Dart 包，它实现了 JSON-RPC 2 规范，并通过 NATS 发布/订阅架构进行通信

Flutter插件quasar的使用_Quasar 是一个轻量级且高性能的 Dart 包，它实现了 JSON-RPC 2 规范，并通过 NATS 发布/订阅架构进行通信

概述

Quasar 是一个轻量级且高性能的 Dart 包，它实现了 JSON-RPC 2 规范，并通过 NATS 发布/订阅架构进行通信。以下是 Quasar 的详细使用指南。

支持平台

• Android
• iOS
• Linux
• MacOS
• Web
• Windows

特性

• 实现了完整的 JSON-RPC 2 规范。
• 使用 NATS 进行通信。
• 可以作为服务器、客户端或对等方使用。
• 自动发现对等方。
• 使用主题传递参数。

安装

要运行 Quasar，你需要 Dart v2.0 或更高版本。

安装包并启动 NATS 服务器：

pub add quasar

使用

服务器端

import 'package:pedantic/pedantic.dart';
import 'package:quasar/quasar.dart';

void main(List<String> arguments) async {
  // 启动服务器，并传递 NATS 服务器地址和唯一名称或主题前缀用于订阅。
  var server = QuasarServer('nats://127.0.0.1:4222', 'my-unique-server-name-1');

  var i = 5;
  // 任何字符串都可以用作方法名。方法名区分大小写。
  server.registerMethod('count', () {
    // 返回要发送给客户端的值。这可以是任何 JSON-可序列化的对象。
    return i++;
  });

  // 方法可以接受参数。它们被呈现为 Map<String, dynamic> 对象，这使得验证预期参数的存在变得容易。
  server.registerMethod('echo', (Parameters params) {
    // 如果请求没有 "message" 参数，这将自动向客户端发送响应，通知请求无效。
    return params.data!['message'];
  });

  // 方法可以通过抛出任何 Exception 来发送错误响应。任何正数都可以用作应用程序定义的错误代码。
  const divideByZero = 1;
  server.registerMethod('divide', (Parameters params) {
    var divisor = params.data!['divisor'];
    if (divisor == 0) {
      throw JSON_RPC_Err('Cannot divide by zero.', divideByZero);
    }

    return int.parse(params.data!['dividend']) / divisor;
  });

  // 启动客户端并传递 NATS 服务器地址和要发布到的服务器或主题（服务器前缀）的名称。
  var client = QuasarClient('nats://127.0.0.1:4222', 'my-test-server-1');

  // 客户端不会订阅输入流，直到你调用 `listen`。返回的 Future 不会完成，直到连接关闭。
  await client.listen();

  // 通知是一种调用方法的方式，告诉服务器不期望结果。它的返回类型是 `void`；即使它导致错误，你也听不到回音。
  client.sendNotification('count');

  // 调用服务器上的 "count" 方法。返回一个 Future，该 Future 将完成于包含服务器响应的值。
  var count = await client.sendRequest('count');
  print('Count is $count');

  // 参数作为简单的 Map 传递。确保它们是 JSON-可序列化的！
  var echo = await client.sendRequest('echo', {'message': 'hello'});
  print('Echo says $echo');

  // 如果服务器发送错误响应，返回的 Future 将完成于 RpcException。你可以捕获此错误并检查其错误代码、消息以及服务器随附的任何数据。
  try {
    await client.sendRequest('divide', {'dividend': 2, 'divisor': 0});
  } on JSON_RPC_Err catch (error) {
    print('JSON RPC error ${error.code}: ${error.message}');
  }

  // 关闭服务器和客户端
  await server.close();
  await client.close();
}

作为对等方使用

import 'package:pedantic/pedantic.dart';
import 'package:quasar/quasar.dart';

void main(List<String> arguments) async {
  // 创建具有唯一名称和 rendezvous 点的对等方。
  var peer1 = QuasarPeer('i-am-peer-1', 'place', 'nats://127.0.0.1:4222');
  var peer2 = QuasarPeer('i-am-peer-2', 'place', 'nats://127.0.0.1:4222');

  // 等待对等方相互发现。
  unawaited(peer1.listen());
  await peer2.listen();

  peer1.registerMethod('name', () => 'peer 1');

  peer2.registerMethod('time', () => DateTime.now().toString());

  var time = await peer1.sendRequest('time');
  print('Peer 2 - time $time');

  var name = await peer2.sendRequest('name');
  print('Peer 1 - name $name');

  // 关闭对等方
  await peer1.close();
  await peer2.close();
}