与常规的可观察类不同，LiveData 具有生命周期感知能力，这意味着它具有感知应用组件（如 Activity、Fragment 或 Service）的生命周期的能力，并且LiveData仅更新处于活跃生命周期状态的应用组件观察者...LiveData是一个持有数据的容器类，它持有的数据是可以被观察者订阅的，当数据发生变化时会通知观察者，观察者可以是 Activity、Fragment、Service 等对象。...从上述步骤可以看出，LiveData使用了观察者模式，观察者通常是UI控制器，如Activity或Fragment，而被观察者则是LiveData包谷的数据对象， 当LiveData对象持有数据发生变化...，会通知对它订阅的所有处于活跃状态的订阅者。...同时，LiveData仅更新处于活跃生命周期状态的应用组件观察者，也即是说LiveData并不会通知所有的观察者，它只会通知处于活跃状态的观察者，那么它是如何做到这一点的呢？
6.适应屏幕旋转的数据保存 像屏幕旋转导致的 activity 或 fragment重创建之后，Livedata 会立即通知一下相应的观察者。保证了数据不会丢失。...LiveData允许UI控制器Observer订阅更新。 当LiveData对象所保存的数据发生变化时，UI会在响应中自动更新。...所以我们需要在一开始就设置好观察。 通常情况下，LiveData只在数据有变化时，给活跃的Observer进行通知。 此行为的一个例外是，Observer在从非活跃状态变为活跃状态时也会收到通知。...在建立观察者关系之后，可以更新LiveData对象的值，如以下示例所示，当用户点击按钮时向所有观察者发出通知： mButton.setOnClickListener(new OnClickListener...)都会触发观察者并更新UI。
这种感知能力可确保 LiveData 仅更新处于活跃生命周期状态的应用组件观察者。...当我们的观察者生命周期处于 STARTD 或者 RESUMED 状态，LiveData 就会认为当前观察者处于活跃状态，此时就会触发相应的更新通知，而非活跃的观察者自然不会收到通知。...，我们一般会先初始化一个 MutableLiveData 对象,然后对外暴漏 LiveData 对象，从而遵循开闭原则，外部调用者只允许订阅观察者，观察数据更新，而不允许主动通知数据更新，当然这也是 LiveData...的生命周期观察数组里，从而便于收到生命周期更新通知； 上述的实现看似简单，但仔细思考就有个问题，如果观察者此时处于不活跃状态呢？...，并将新的版本号赋值给这个观察者； 相应的，因为我们的观察者订阅了 lifecycle 生命周期更新，所以当生命周期由非活跃转为活跃状态时，我们就再去对比一下当前观察者的最新数据版本号与我们当前最新的版本号是否一致
三个步骤就定义了使用LiveData的方式，从步骤可以看出，使用了观察者模式，当LiveData对象持有数据发生变化，会通知对它订阅的所有处于活跃状态的订阅者。...而这些订阅者通常是UI控制器，如Activity或Fragment，以能在被通知时，自动去更新Views。 创建LiveData对象 LiveData可以包装任何数据，包括集合对象。...onActivite() 当有活跃状态的订阅者订阅LiveData时会回调该方法。意味着需要在这里监听数据的变化。...setValue() 注意到value=price这里是调用了setValue(price)方法，通过该方法更新LiveData的值，进而通知处于活跃状态的订阅者。...LiveData会认为订阅者的生命周期处于STARTED或RESUMED状态时，该订阅者是活跃的。 那么如何使用StockLiveData呢？
❝老实说，LiveData是一个可观察的数据持有者。它让你的应用程序中的组件，通常是UI，能够观察LiveData对象的变化。...❞ 关于这个LiveData的新概念是，它具有生命周期意识，这意味着它尊重应用程序组件（Activity、Fragment）的生命周期状态，并确保LiveData只在组件（观察者）处于活跃的生命周期状态时更新它...为了更好地理解何时使用这个新的可观察的数据持有者以及使用它的优势，在这篇文章的其余部分，我将回顾一些替代方案，以面对根据数据变化更新UI这一基本任务。...#3 — Using an event bus 另一种方法是，当我们必须根据数据变化更新用户界面时，使用基于事件的机制（发布者/订阅者）（使用greenrobot EventBus演示）。...此外，实现基于事件机制的库通常支持高级功能，如交付线程和订阅者的优先级（人们也可以使用Android LocalBroadcast，而不需要第三方库）。
LiveData需要一个观察者对象，一般是Observer类的具体实现。当观察者的生命周期处于STARTED或RESUMED状态时，LiveData会通知观察者数据变化。...自动解除数据订阅 要想使用LiveData（或者这种有可被观察数据能力的类）就必须配合实现了LifecycleOwner的对象使用。在这种情况下，当对应的生命周期对象DESTORY时，才能移除观察者。...通过 observe()方法连接观察者和LiveData。observe()方法需要携带一个LifecycleOwner类。这样就可以让观察者订阅LiveData中的数据，实现实时更新。...observe()，当数据更新后，LiveData 会通知它的所有活跃的观察者。...与 RxJava 不同的，LiveData 只会通知活跃的观察者，例如 Activity 位于 Destroyed 状态时是不活跃的，因此不会收到通知。
这种感知能力可确保 LiveData 仅更新处于活跃生命周期状态的应用组件观察者。 官方介绍如下，其实说的比较清楚了，主要作用在两点： 数据存储器类。也就是一个用来存储数据的类。 可观察。...主要思想就是用到了观察者模式思想，让观察者和被观察者解耦，同时还能感知到数据的变化，所以一般被用到ViewModel中，ViewModel负责触发数据的更新，更新会通知到LiveData，然后LiveData...不会因 Activity 停止而导致崩溃 如果观察者的生命周期处于非活跃状态（如返回栈中的 Activity），则它不会接收任何 LiveData 事件。...对象没有任何活跃观察者时，会调用 onInactive()方法。...说到原理，其实就是两个方法： 订阅方法，也就是observe方法。通过该方法把订阅者和被观察者关联起来，形成观察者模式。
这种感知能力可确保LiveData 仅更新处于活跃生命周期状态的应用组件观察者。 应用组件观察者可以很安全的观察数据变化（绑定声明周期，自动绑定和移除），不用担心内存泄漏等问题。...当观察的数据发生变化时，LiveData 会通知 [Observer]对象，实现被动更新，不需要主动去调用viewmodel获取数据。...不会发生内存泄漏 观察者会绑定到 [Lifecycle]，可以获取到应用组件的声明周期，当销毁时自动取消订阅。...不会因 Activity 停止而导致崩溃 如果观察者的生命周期处于非活跃状态（如返回栈中的 Activity），则它不会接收任何 LiveData 事件（也是通过LifecycleOwner实现的）...LiveData 对象连接到系统服务一次，然后需要相应资源的任何观察者只需观察 LiveData 对象。
在这些情况下，我们通常会使用设计模式来实现这种机制，其中订阅发布模式就是其中之一。订阅发布模式（Publish-Subscribe Pattern）是一种软件设计模式，用于实现对象间的松耦合。...本文将详细介绍订阅发布模式的原理、应用场景、优缺点以及如何在程序中实现订阅发布模式。原理订阅发布模式的本质是一种消息传递机制，也就是所谓的“事件驱动”，它包括三个主要的组成部分：发布者、订阅者和消息。...其中，发布者负责发布消息，订阅者负责订阅感兴趣的消息，而消息则是传递信息的工具。在订阅发布模式中，发布者和订阅者之间不直接产生耦合关系，它们之间通过消息进行交互。...例如，一个网站可能需要发送新闻通知给所有订阅者。观察者模式：订阅者需要观察一个特定的对象，以便当该对象发生变化时能够及时得到通知。例如，当数据模型发生变化时，视图层需要进行更新。...通过使用订阅发布模式，我们可以实现对象间的松耦合，并且提高代码的可扩展性和可重用性。在程序中实现订阅发布模式的方法有很多种，开发者可以根据自己的需求来选择合适的实现方式。
观察者模式：实现对象间的松耦合通知机制 引言 在当今的软件开发领域，设计模式已成为创建可维护、可扩展和可重用代码的基石。在众多设计模式中，观察者模式以其独特的能力，实现对象间的松耦合通信而脱颖而出。...本文将深入探讨观察者模式，一种允许对象状态变更自动通知依赖对象的行为型设计模式。我们将从其基本定义入手，阐释为何在现代软件架构中观察者模式至关重要，包括它如何实现解耦、动态交互和广播通信。...UI与业务逻辑分离：在图形用户界面编程中，界面组件（观察者）需要根据业务逻辑的变化（主题）更新显示，而不直接依赖于业务逻辑的具体实现。...应用实例： 股票市场监控：在股票市场监控系统中，股票价格的变化（主题）需要实时更新所有监控器（观察者），如交易界面、数据分析工具等。...消息传递：发布-订阅模式可以处理更复杂的通信场景，如消息过滤、异步消息传递等，而观察者模式通常用于同步更新。 使用场景：发布-订阅模式适用于大规模的分布式系统，观察者模式适用于对象间相对简单的通信。
等），此感知能力确保了 LiveData 只更新处于生命周期活跃状态的组件的观察者 生命周期活跃状态的定义是这些组件正处于 STARTED 或 RESUMED 状态，LiveData 只会更新活跃状态的观察者...，而已注册但处于非活跃状态的观察者不会被更新 我们可以在实现了 LifecycleOwner 的接口的对象中注册 observer，这种关联允许 observer 在与之相关的 Lifecycle 对象处于...在生命周期销毁时会立即取消数据观察订阅 LiveData 的优势 确保 UI 和数据状态同步 LiveData 遵循观察者模式。...每次应用程序数据更改时，你的观察者都可以在每次更改时更新 UI，而不是更新 UI 没有内存泄露 观察者绑定到 Lifecycle 对象，并在其相关生命周期被破坏后自行清理 不会因为活动停止而崩溃 如果观察者的生命周期处于非活动状态...在这种情况下，观察者被认为始终处于活动状态，因此始终会收到有关修改的通知。
---- eProsima 快速 RTPS eprosima Fast RTPS 是 RTPS（实时发布订阅）协议的 C++ 实现，它通过对象管理组 (OMG) 联盟定义和维护的不可靠传输（如 UDP）...可以为发布者、订阅者、服务服务器和客户端指定 QoS 配置文件。QoS 配置文件可以独立应用于上述实体的每个实例，但如果使用不同的配置文件，它们可能会不兼容，从而阻止消息的传递。...可靠性 尽力而为：尝试提供样本，但如果网络不健壮，可能会丢失它们。 可靠：保证样品送达，可多次重试。...耐用性 Transient local：发布者负责为“后期加入”订阅保存样本。 Volatile：不尝试保留样本。...为了让订阅者收听发布者的主题，他们请求的活跃度跟踪级别必须等于或低于发布者提供的跟踪级别，并且订阅者设置的直到被认为不活跃的时间必须大于时间由发布者设置。 生命周期策略为消息保持有效的时间建立了合同。
的时候执行这个扩展函数；但是这两个Flow不一样他们不依赖于外部调用（可配置稍后说明），他们是热流，他们发出的数据会缓存起来当有订阅者的时候再通知订阅者 StateFlow 和 SharedFlow是发出状态更新并向多个使用方发出值并且可以通过...api去开启： 1.viewModelScope：跟随ViewModel的生命周期变化，当ViewModel观察的组件销毁调用onClear的时候自动取消协程，生命周期过长不采取一般在对数据进行处理的时候会使用...1.WhileSubscribed()当存在活跃订阅者（观察flow的协程域没有被取消）时flow函数也会活跃（执行flow函数），可配置最后一个订阅者取消订阅的超时时间进行取消flow函数运行也可以配置数据过期时间...（超过一段时间将会从缓冲中移除） 2.SharingStarted.Eagerly 可立即启动提供方（flow函数立马运行），使用 SharingStarted.Lazily 可在第一个订阅者出现后开始共享数据...通过 subscriptionCount 属性，获取活跃状态的收集器的数量。 通过 resetReplayCache 函数清空数据缓存，供您在不想回放已向数据流发送的最新信息的情况下使用。
的时候执行这个扩展函数；但是这两个Flow不一样他们不依赖于外部调用（可配置稍后说明），他们是热流，他们发出的数据会缓存起来当有订阅者的时候再通知订阅者StateFlow 和 SharedFlow是发出状态更新并向多个使用方发出值并且可以通过...：跟随ViewModel的生命周期变化，当ViewModel观察的组件销毁调用onClear的时候自动取消协程，生命周期过长不采取一般在对数据进行处理的时候会使用2.lifecycleScope： 此范围内启动的协程会在...1.WhileSubscribed()当存在活跃订阅者（观察flow的协程域没有被取消）时flow函数也会活跃（执行flow函数），可配置最后一个订阅者取消订阅的超时时间进行取消flow函数运行也可以配置数据过期时间...（超过一段时间将会从缓冲中移除）2.SharingStarted.Eagerly 可立即启动提供方（flow函数立马运行），使用 SharingStarted.Lazily 可在第一个订阅者出现后开始共享数据...通过 subscriptionCount 属性，获取活跃状态的收集器的数量。通过 resetReplayCache 函数清空数据缓存，供您在不想回放已向数据流发送的最新信息的情况下使用。
我们将深入研究简单工厂、工厂方法和抽象工厂模式，并讨论它们的适用场景。 3. 观察者模式 (Observer Pattern) 观察者模式建立了对象之间的松耦合关系，用于事件处理和消息传递。...我们将探讨观察者模式的实现方式以及如何应用于实际场景，如 GUI 开发和发布-订阅系统。 4....适配器模式 (Adapter Pattern) 适配器模式用于解决接口不兼容的问题，它允许不同接口的对象协同工作。我们将讨论对象适配器和类适配器的区别，并示例说明如何在代码中应用适配器模式。 5....观察者模式 (Observer Pattern) 观察者模式建立了对象之间的一对多依赖关系，当一个对象的状态发生变化时，所有依赖它的对象都会得到通知并自动更新。...这在以下情况下非常有用： GUI 开发：用于处理用户界面组件的事件和交互。 发布-订阅系统：用于实现消息传递和事件处理。 股票市场报价：多个观察者关注股票价格的变化。
具体如下： 对于异步订阅关系，存在 被观察者发送事件速度 与观察者接收事件速度 不匹配的情况 发送 & 接收事件速度 = 单位时间内 发送&接收事件的数量 大多数情况，主要是 被观察者发送事件速度 ＞...观察者接收事件速度 1.2 问题 被观察者 发送事件速度太快，而观察者 来不及接收所有事件，从而导致观察者无法及时响应 / 处理所有发送过来事件的问题，最终导致缓存区溢出、事件丢失 & OOM 如，...与 观察者接收事件速度 不匹配的场景 具体场景就取决于 该事件的类型，如：网络请求，那么具体场景：有很多网络请求需要执行，但执行者的执行速度没那么快，此时就需要使用背压策略来进行控制。...，所以下文中讲解的主要是异步订阅关系场景，即 被观察者 & 观察者 工作在不同线程中 但由于在同步订阅关系的场景也可能出现流速不匹配的问题，所以在讲解异步情况后，会稍微讲解一下同步情况，以方便对比 5.1...下图 = 当缓存区存满时（128个事件）溢出报错的原理图 代码演示1：观察者不接收事件的情况下，被观察者继续发送事件 & 存放到缓存区；再按需取出 /** * 步骤1：设置变量 *
这个主题对象在自身状态变化时，会通知所有订阅者对象，使它们能够自动更新自己的状态。 ? RxBus的出现 RxBus不是一个库，而是一个文件，实现只有短短30行代码。...来创建一个Subject对象（PublishSubject只有被订阅后才会把接收到的事件立刻发送给订阅者），在需要接收事件的地方，订阅该Subject对象，之后如果Subject对象接收到事件，则会发射给该订阅者...完成了订阅，在需要发送事件的地方将事件发送给之前被订阅的Subject对象，则此时Subject对象作为订阅者接收事件，然后会立刻将事件转发给订阅该Subject对象的订阅者，以便订阅者处理相应事件，到这里就完成了事件的发送与处理...正是由于LiveData对组件生命周期可感知特点，因此可以做到仅在组件处于生命周期的激活状态时才更新UI数据。 LiveData需要一个观察者对象，一般是Observer类的具体实现。...LiveData的优点 UI和实时数据保持一致，因为LiveData采用的是观察者模式，这样一来就可以在数据发生改变时获得通知，更新UI。
对于异步订阅关系，存在 被观察者发送事件速度 与观察者接收事件速度 不匹配的情况 发送 & 接收事件速度 = 单位时间内 发送&接收事件的数量 大多数情况，主要是 被观察者发送事件速度 ＞...与 观察者接收事件速度 不匹配的场景 具体场景就取决于 该事件的类型，如：网络请求，那么具体场景：有很多网络请求需要执行，但执行者的执行速度没那么快，此时就需要使用背压策略来进行控制。...代码演示1：观察者不接收事件的情况下，被观察者继续发送事件 & 存放到缓存区；再按需取出 /** * 步骤1：设置变量 */ private static final String...代码演示2：观察者不接收事件的情况下，被观察者继续发送事件至超出缓存区大小（128） Flowable.create(new FlowableOnSubscribe() {...面向对象：针对缓存区 作用：当缓存区大小存满、被观察者仍然继续发送下1个事件时，该如何处理的策略方式 缓存区大小存满、溢出 = 发送事件速度 ＞ 接收事件速度 的结果 = 发送 & 接收事件不匹配的结果
而 ToB 场景下：聊天记录是非常重要的内容，钉钉为保证用户消息不丢失，提供了多端同步和消息云端存储的能力，用户任意换端都能查看完整的聊天记录。...对于第 3）点：要求消息队列的高可用性方面不仅包括系统可用性，也包括数据可用性，要求写入消息队列时消息不丢失（钉钉 IM 对消息的保证级别是一条都不丢）。...此外，如何在系统异常的情况下做到消息最终一致？Processor 收到上游投递的消息时，会尝试对消息做入库处理。即使入库失败，依然会将消息投给同步服务，将消息下发，保证实时消息收发正常。...钉钉能够支持十几万人的超大群，超大群的活跃对服务端和客户端都会带来很大冲击，而实际上用户的需求只需实现秒级更新。针对以上场景：可以利用 RocketMQ 的定时消息能力实现分布式定时任务。...▲ 用 RocketMQ 实现分布式定时任务的流程原理我们抽象了一个分布式定时任务的组件，提供了很多其他实时性可达秒级的功能，如万人群的群状态更新、消息扩展更新都接入了此组件。
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
对象存储
腾讯会议
云直播
