时间戳

首页 > 解决方案 > 飞镖中的未来队列

asynchronous - 飞镖中的未来队列

问题描述

我想实现一个聊天系统。

我被困在用户非常快速地发送多个消息的地步。尽管所有消息都到达服务器，但以任何顺序。

所以我想实现一个队列，每条消息都应该

  1. 首先被放入队列

  2. 等待轮到

  3. 轮到发帖请求

  4. 等待服务器响应大约 5 秒

  5. 如果响应在时间范围内到达并且状态正常，则消息发送，否则消息发送失败。

  6. 在第 5 点的任何情况下，消息都应出队，并且应给下一条消息机会。

现在，主要问题是，每个聊天头或我们正在与之交谈的用户可能有多个队列。我将如何实施？我对飞镖和颤振真的很陌生。请帮忙。谢谢！

标签： asynchronousdartqueueflutterchat

解决方案

听起来您正在描述一个Stream- 一系列有序的异步事件。

https://www.dartlang.org/guides/language/language-tour#handling-streams https://www.dartlang.org/guides/libraries/library-tour#stream

创建一个StreamController，并在消息进入时向其中添加消息：

var controller = StreamController<String>();
// whenever you have a message
controller.add(message);

收听该流并上传消息：

await for(var messsage in controller.messages) {
  await uploadMessage(message);
}

推荐阅读