观察者模式，我们有很多其他的方式来称呼它。比如熟悉的发布/订阅模式，回调方式，Listen监听等。 我们看到很多源码中有Observer，Listen，Hook，Callback，基本用到了观察者模式； 话不多说，直接来点代码说明下 首先定义被观察者（抽象的，公有的） public interfac ...
分类：
其他好文 时间：
2020-03-27 13:13:46
阅读次数：
111
有这么一段代码经常会出现在代码中 1 var pubsub = (()=>{ 2 var topics = {}; 3 function subscribe(topic,fn){ 4 if(!topics[topic]){ 5 topics[topic] = []; 6 } 7 topics[top ...
分类：
其他好文 时间：
2020-03-24 16:03:57
阅读次数：
74
前言 事件总线模式（Event Bus Pattern）是发布/订阅模式的一种实现。它是一种集中式的事件处理机制，允许不同组件彼此通信，但又不相互依赖，实现松耦合。Grafana 开源项目的软件架构就采用了事件总线模式。 事件总线模式 事件总线模式包含如下组件： Event：不同组件间传递的数据。可 ...
分类：
其他好文 时间：
2020-03-23 11:26:04
阅读次数：
117
发布-订阅模式是什么？ 发布-订阅模式又叫做观察者模式，它定义对象间的一种一对多的依赖关系，当一个对象的状态发生改变的时候，所有依赖于它的对象都将得到通知。 作为一名JavaScript开发者，我100%相信你已经使用过了这个模式，不信你看如下代码： document.body.addEventLi ...
分类：
编程语言 时间：
2020-03-22 19:54:29
阅读次数：
70
记录下和kafka相关的概念原理以及常用工具，文中很多理解参考文末博文、书籍还有前辈。 kafka特性 kafka是由领英(LinkedIn)提供给Apache，是一个消息引擎，现在发展成为还可以进行流处理（kafka streams）的一个平台，以下是它的架构图。 （1）用的是发布 订阅模式，多个 ...
分类：
其他好文 时间：
2020-03-21 00:00:40
阅读次数：
74
1.服务端： io.on('connection',function(socket)); 监听客户端连接,回调函数会传递本次连接的socket，一般的代码就写在这个回调里 io.sockets.emit('String',data); 给所有客户端广播消息，String就是自定义的事件名称，data ...
分类：
其他好文 时间：
2020-03-15 00:10:30
阅读次数：
83
1.redis消息模式 发布消息通常有两种模式分为：队列模式（queuing）和发布订阅模式（publish-subscribe）。 队列模式中，consumers可以同时从服务端读取消息，每个消息只被其中一个consumer读到。 发布订阅模式中消息被广播到所有的consumer中，topic中的 ...
分类：
其他好文 时间：
2020-03-06 01:19:35
阅读次数：
100
一、Kafka概述1）消息队列1）点对点模式（一对一，消费者主动拉取数据，消息收到后消息清除）点对点模型通常是一个基于拉取或者轮询的消息传送模型，这种模型从队列中请求信息，而不是将消息推送到客户端。这个模型的特点是发送到队列的消息被一个且只有一个接收者接收处理，即使有多个消息监听者也是如此；2）发布/订阅模式（一对多，数据生产后，推送给所有订阅者）发布订阅模型则是一个基于推送的消息传送模型。发布订
分类：
其他好文 时间：
2020-02-28 09:13:22
阅读次数：
80
一、简介 RabbitMQ是实现了高级消息队列协议（AMQP）的开源消息代理软件（亦称面向消息的中间件）。 消息队列都涉及的生产者消费者模型，不做详解，本文只作为快速使用的参考文档。 消息队列主要有点对点和发布订阅模式。 其主要用途是异步、削峰，充当一个缓存的作用。只有可以异步处理时才可以使用消息队 ...
分类：
编程语言 时间：
2020-02-27 20:37:55
阅读次数：
67
JAVA开发MQTT总结 MQTT 介绍 它是一种 机器之间通讯 machine to machine (M2M)、物联网 Internet of Things （IoT）常用的一种轻量级消息传输协议 适用于网络带宽较低的场合 包含发布、订阅模式，通过一个代理服务器（broker），任何一个客户端（ ...
分类：
编程语言 时间：
2020-02-24 18:28:35
阅读次数：
64
