Publish/Subscribe(发布订阅模式) 发布订阅模式其实就是生产者将数据发送到交换机,交换机将所有的消息发送到每个绑定的队列中,因此 在发布消息时可以只先指定交换机的名称,交换机的声明的代码可以放到消费者端进行声明,队列的声明也放在消费者端来声明 Exchange类型 fanout fa ...
分类:
其他好文 时间:
2020-02-12 23:57:04
阅读次数:
126
将redis发布订阅模式用做消息队列和rabbitmq的区别: 1.可靠性 1.1:redis :没有相应的机制保证消息的可靠消费,如果发布者发布一条消息,而没有对应的订阅者的话,这条消息将丢失,不会存在内存中; 1.2:rabbitmq:具有消息消费确认机制,如果发布一条消息,还没有消费者消费该队 ...
分类:
其他好文 时间:
2020-02-09 10:04:47
阅读次数:
76
一、kafka概述 1.1、定义 Kakfa是一个分布式的基于发布/订阅模式的消息队列(message queue),主要应用于大数据的实时处理领域 1.2、消息队列 1.2.1、传统的消息队列&新式的消息队列的模式 上面是传统的消息队列,比如一个用户要注册信息,当用户信息写入数据库后,后面还有一些 ...
分类:
其他好文 时间:
2020-02-01 00:54:38
阅读次数:
84
一、kafka的基础架构 kafka是一个分布式的基于发布/订阅模式的消息队列,主要应用于大数据实时处理领域。 kafka的具体架构如图: 学习kafka的架构前,我们需要了解图中的每个角色: (1)consumer group 消费者组:这是kafka消息队列特有的角色,它是一堆消费组组合成的。消 ...
分类:
其他好文 时间:
2020-01-28 20:47:17
阅读次数:
139
一、定义: 观察者模式(Observer)又叫做发布 订阅模式(Publish/Subscribe),定义了一种一对多的依赖模式,让多个观察者对象同时监听某一个主题对象,这个主题对象在状态发生变化时,会通知所有观察者对象,使他们能够自动更新自己。 二、示例代码: 三、利用委托类实现 上述例子的问题在 ...
分类:
其他好文 时间:
2020-01-06 19:34:46
阅读次数:
62
原理讲解 原理简述 :利用发布订阅模式。第一步,先ESP8266获取各种传感器数值,第二步,新建主题,然后esp8266往这个主题发送消息,第三步。app inventor 订阅这个主题,因为app inventor 制作的app 订阅了这个主题,就可以收到来自这个主题的消息,也就是可以收到各种传感 ...
分类:
移动开发 时间:
2020-01-03 14:01:04
阅读次数:
247
html 1 <body> 2 <script src="./Dvue.js"></script> 3 <script> 4 const app = new DVue({ 5 data: { 6 test: "I am test", 7 foo: { 8 bar: "bar" 9 } 10 } 11 ...
分类:
其他好文 时间:
2020-01-02 14:12:09
阅读次数:
100
总是把这两个当作同一个模式,但其实是不太一样的,现在重温一下。 观察者模式 观察者直接订阅目标,当目标触发事件时,通知观察者进行更新 简单实现 js class Observer { constructor(name) { this.name = name; } update() { console ...
分类:
Web程序 时间:
2019-12-28 15:53:18
阅读次数:
104
当node中异步读取文件(在所有的同步任务执行完成之后执行的任务)操作,需要并行执行完成后调用某函数: 1. 自定义函数after 2. 发布订阅模式 发布订阅模式的本质是,订阅的函数存入队列,每次发布的时候全部执行。 ...
分类:
其他好文 时间:
2019-12-25 15:42:35
阅读次数:
101
1)观察者模式 观察者模式通俗的讲就是我们平事件调用(click/change等等) 大家先看这个图片。我们被观察者Subject(监听某个事件)发生改变时,观察者Observer监听到没改变做出调整。最大的特点是实现了松耦合(如何理解松耦合呢?个人认为就是当Subject 发生给变时,我们有一套对 ...
分类:
其他好文 时间:
2019-12-22 12:33:25
阅读次数:
80