flutter中EventBus的实现原理

行业 归档:201905
普通
浏览:129
2019-05-05 19:36:10
文章转载自:https://cloud.tencent.com/developer/article/1338289

Event Bus可以说是在客户端界公认的最好的全局通信解决方案了,他的出现简化了应用程序内各组件间、组件与后台线程间的通信。

Event Bus可以说在各大端都有过实现:

Android端的Event Bus

compile 'de.greenrobot:eventbus:3.0.0-beta1'

Ios端的Event Bus

github "cesarferreira/SwiftEventBus" == 3.0.0

Vue更是直接就自带一个EventBus,简直不能再凶残了。那么,既然Event Bus这么不可或缺,Flutter平台肯定也有Event Bus了,对,绝逼是有的。

dependencies:
  event_bus: ^1.0.1

Flutter中EventBus的实现原理

class EventBus {
  StreamController _streamController;

  /// Controller for the event bus stream.
  StreamController get streamController => _streamController;

  /// new event bus
  EventBus({bool sync: false}) {
    _streamController = new StreamController.broadcast(sync: sync);
  }
  ///Listener
  Stream<T> on<T>() {
    if (T == dynamic) {
      return streamController.stream;
    } else {
      return streamController.stream.where((event) => event is T).cast<T>();
    }
  }
  /// Fires a new event on the event bus with the specified [event].
  void fire(event) {
    streamController.add(event);
  }
  /// Destroy this [EventBus]. This is generally only in a testing context.
  void destroy() {
    _streamController.close();
  }

很显然,你没有看错,源码就是这么少,相信之前用Rxjava做过RxBus这种风骚操作的你对这么几行代码实现一个Event Bus的你一点都不会觉得惊讶。

而Dart上可以凭借这么几行代码就实现一个Event Bus,同样的道理,背后有着一个分非常有气场的男人在支持,这个男人就是Stream。首先来看一看Event bus的创建。

Event bus的创建
EventBus({bool sync: false}) {
    _streamController = new StreamController.broadcast(sync: sync);
  }

创建的过程丢在了构造函数中,使用了broadcast方式,那么什么是broadcast方式呢?要了解这个,还需要知道StreamController的其他方式:

Single subscription streams
broadcast stream
所谓的single方式,是指这种stream流只能被一个人订阅,适用场景是http请求这种。

所谓的broadcast方式,是指这种stream流可以被多个人订阅,but,在你订阅之前的stream已经发送过得事件,你将错过了,只能收到你订阅开始之后发送的事件了。

streamController是dart的内置的一个类,可以理解为给stream制造数据的控制器,公开的方法add(Event)就是干这个的。

当然,这里提到了订阅,那么什么事订阅是怎么做的。

订阅
///Listener
  Stream<T> on<T>() {
    if (T == dynamic) {
      return streamController.stream;
    } else {
      return streamController.stream.where((event) => event is T).cast<T>();
    }
  }

这里使用泛型T来过滤自己想关心的事件类型,streamController成员stream中holder住了streamContorller制造出来的数据,一定订阅发送,这些数据将一个个的被发送出去,✔️的,每个订阅者都能得到这份数据流。

发送事件

发送事件很简单,就是使用streamController.add方法往stream中塞事件。

以上就是整个dart实现的event_bus的原理了,用一幅图来解释就是:

fires表示通过StreamController向Streams 中add Event,一旦有了event,subScriptor就嗅到了有货了,于是就取到了fires发送出来的event了。

关于Stream

Stream实际上类比Rxjava的话,就有点类似于Rxjava被订阅之前的那一段。是一个可以被订阅的流,因此,它也有一些比较风骚的操作,比如:

map

Stream<S> map<S>(S Function(T event) convert);

asyncMap

Stream<E> asyncMap<E>(FutureOr<E> Function(T event) convert);

当然,实际上用的最多还是

listen,实际上就是订阅,看其返回值就知道,是StreamSubsciption

StreamSubscription<T> listen(void Function(T event) onData,

因此,如果想取消订阅的话,可以通过StreamSubsciption.cancel来做。这点都是可以我们熟悉的Rxjava类似。

事实上,stream在platform_channel中也有着其举足轻重的地位,做过的同学应该知道EventChannel实际上就是通过stream来实现的。

注意事项
  • 本文地址:https://22v.net/article/3244/
  • 转载本文时,请注明转载自“SamBlog”的字样。
  • 如此文章有损您的合法权益,请使用页面底部的邮箱与我取得联系。
分类目录
文章归档
友情站点