背景介绍 分布式，实时性 在前面一章，我简单地介绍了我们的智能家居大数据基础平台架构，我们知道对于一些实时性要求比较高的数据，比如一些控制命令（传感器的开关状态、智能小车的速度）等信息需要实时地传送到数据中心，并且数据中心需要将这些数据实时推送给其他子系统，包括计算服务平台，智
在学习webflux 之前我们先要了解一个概念 什么是背压(back press) 对我们以前使用的发布订阅模式来说.我们的以前的模式是 消费只能通过提供者提供的数据来持续消费 如果一直发送消息,那么就只能一直消费 我们对背压做一个详细的比喻 比如我们每家每户,都有一个水龙头.自来水公司相
mqtt 实时可靠的消息服务，也有基于UDP的 可以以极少的代码和有限的带宽 客户端-服务器的消息发布/订阅传输协议 可接受不可知数据格式 Mqtt是三端协议 发布者（Publish）、代理（Broker）（服务器）、订阅者（Subscribe）。其中，消息的发布者和订阅者都是客户端，消息代理是服务器，消息发布者可
1、观察者模式 观察者模式定义了对象间的一种一对多的依赖关系，当一个对象的状态发生改变时，所有依赖于它的对象都将得到通知，并自动更新。观察者模式属于行为型模式，行为型模式关注的是对象之间的通讯，观察者模式就是观察者和被观察者之间的通讯。 观察者模式有一个别名叫“发布-订阅模
#仅简单描述，稍后会新增具体内容： 发布者-订阅者模式又称观察者模式：当一个对象（发布者）状态发生改变时，所有依赖它的对象（订阅者）都会得到通知。 该模式广泛应用在异步编程中：我们无需关注对象在异步运行期间的内部状态，只需要订阅感兴趣的事件发生点。 简单说就是该模式让发布者和订阅
文章目录一、DDS体系结构1.1 DLRL层1.2 DCPS层二、DDS通信过程三、DDS通信特点四、DDS标准实现4.1 RTI DDS软件4.2 OpenSplice DDS软件4.3 OpenDDS软件 一、DDS体系结构 DDS采用DCPS通信机制，提供一个与平台无关的数据模型。它允许应用程序实时发布拥有的信息，并订阅需要的信息
