let fs = require('fs'); // 发布订阅 发布和订阅没关系 中间通过数组进行关联 function Events() { this.callbacks = []; this.results = []; } // 订阅 Events.prototype.on = function ...
分类:
其他好文 时间:
2020-06-27 11:28:26
阅读次数:
48
0MQ (ZeroMQ) 是一个轻量级消息内核。它可用于C、C++、Python、.NET /Mono、Fortran 和 Java 语言。它运行在AIX ,FreeBSD的,基于HP - UX , Linux和MacOS下, OpenBSD系统, OpenVMS , QNX Neutrino,So ...
分类:
其他好文 时间:
2020-06-27 11:18:51
阅读次数:
398
kafka是什么Kafka最初由Linkedin公司开发,是一个分布式、分区的、多副本的、多订阅者,基于zookeeper协调的,发布/订阅模式的消息队列(Message Queue),Linkedin于2010年贡献给了Apache基金会并成为顶级开源项目。经过多年发展,Kafka已经由最初的日志 ...
分类:
其他好文 时间:
2020-06-25 10:16:04
阅读次数:
74
装饰模式核心内容: 观察者模式又称为发布订阅模式,定义了对象间的一对多依赖关系,当一个对象状态发生改变时,其相关依赖的其他对象都能接收到通知; 观察者模式的核心在于目标(Subject)和观察者(Observer)接口,目标有一个状态属性,观察者“订阅”这个目标,当目标的状态属性发生改变时,通知所有 ...
分类:
其他好文 时间:
2020-06-23 17:06:41
阅读次数:
50
Zookeeper 是一个典型的发布/订阅模式的分布式数据管理与协调框架,开发人员 可以使用它来进行分布式数据的发布和订阅。 通过对 Zookeeper 中丰富的数据节点进行交叉使用,配合 Watcher 事件通知机 制,可以非常方便的构建一系列分布式应用中年都会涉及的核心功能,如: 1、数据发布/ ...
分类:
其他好文 时间:
2020-06-20 18:56:45
阅读次数:
70
发布订阅和观察者模式 曾经我一直以为发布订阅和观察者是一回事,而且有些书和博客里面也是这样说的,直到我看到了这篇剖析 Vue 原理&实现双向绑定 MVVM的文章,作者很细致的解读了 vue 的双向绑定实现原理,并用简约的代码实现了一个简化版的 vue,包括了解析器 Compile ,监听器 Obse ...
分类:
其他好文 时间:
2020-06-17 18:20:06
阅读次数:
56
定义 Kafka 是一个分布式的基于发布/订阅模式的消息队列(Message Queue),主要应用与大数据实时处理领域。 消息队列 Kafka 本质上是一个 MQ(Message Queue),使用消息队列的好处?(面试会问) 解耦:允许我们独立的扩展或修改队列两边的处理过程。 可恢复性:即使一个 ...
分类:
其他好文 时间:
2020-06-15 16:11:29
阅读次数:
53
随着微服务的火热,DDD(领域驱动设计模式)思想风起云涌,冲击着整个软件生态系统。其中,事件总线那是必须知道的了,于是我便抱着一个学习DDD的心态搭建了一个博客网站,目前该网站正在建设阶段,后续会不断完善,这里我只是讲一下我里面所用到的事件总线。 事件总线,我的理解就是发布订阅模式,这里有一篇文章写 ...
分类:
Web程序 时间:
2020-06-09 17:03:38
阅读次数:
92
ActiveMQ作为消息队列Queue以及Topic主题订阅模式的Broker,在我们使用Windows开发环境时,需要如下配置 1 下载Jdk 略 此处作为开发人员jdk环境是比不可好的,所以jdk配置不再赘述,运行ActiveMQ是需要jdk支持的 2 下载ActiveMQ,地址如下: http ...
kafka特点: 1.高吞吐量,支持高并发。支持消息分区,和分布式系统。同时保证每个partition内的消息顺序传输。提供消息持久化能力。 2.Kafka就是一种发布-订阅模式。 消费者可以订阅一个或多个topic,消费者可以消费该topic中所有的数据,同一条数据可以被多个消费者消费,数据被消费 ...
分类:
其他好文 时间:
2020-06-09 12:32:50
阅读次数:
64