一、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
MQTT是一种轻量级的发布 - 订阅消息传递协议，可能使其最适合各种物联网设备。您可以在此处找到有关MQTT的更多信息。ThingsBoard服务器节点充当MQTT Broker，支持QoS级别0（最多一次）和1（至少一次）以及一组预定义主题。 ...
分类：
其他好文 时间：
2020-02-24 16:54:15
阅读次数：
143
代码如下： 封装自定义：subscribe.js let _subscribe = (function () { // Sub 发布订阅类 class Sub { constructor () { // 创建一个事件池 用来存储后期需要执行的方法 this.$pond = []; } // 向事件池 ...
分类：
其他好文 时间：
2020-02-24 13:30:43
阅读次数：
102
最近项目里，写了一个通知服务，具备处理短信、电邮、站内信的能力。但我做多了一点，就是可以通过配置选择它的能力，比如只具备处理短信或者具备点油、站内信的能力。 我画了一个简单的图 图中的 Dispatcher 是一个Message的中转器，它负责投递给最终的 SMS 、 Email 、 Website ...
分类：
其他好文 时间：
2020-02-23 20:36:41
阅读次数：
74
非父子组件间传值有两种方法，一种是vuex共享数据，另一种是发布订阅模式/观察者模式/总线/Bus。这篇随笔主要总结总线机制的学习心得： 首先通过在Vue.prototype上挂载一个bus属性，指向vue实例；接下来在调用Vue或者创建组件时都会有bus属性。 Vue.prototype.bus= ...
分类：
其他好文 时间：
2020-02-22 15:39:39
阅读次数：
63
观察者模式 定义：指多个对象间存在一对多的依赖关系，当一个对象的状态发生改变时，所有依赖于它的对象都得到通知并被自动更新。这种模式有时又称作发布-订阅模式、模型-视图模式，它是对象行为型模式。 核心：观察者模式主要作用于1：N的通知。当一个对象（目标对象Subject或Objservable）的状态 ...
分类：
其他好文 时间：
2020-02-22 14:13:37
阅读次数：
82
观察者模式（也被称为发布/订阅模式）提供了避免组件之间紧密耦合的另一种方法，它将观察者和被观察的对象分离开。在该模式中，一个对象通过添加一个方法（该方法允许另一个对象，即观察者注册自己）使本身变得可观察。当可观察的对象更改时，它会将消息发送到已注册的观察者。这些观察者收到消息后所执行的操作与可观察的 ...
分类：
编程语言 时间：
2020-02-20 23:42:20
阅读次数：
90
作者：Gundy_链接：https://www.jianshu.com/p/dc94f2099277 生产者消费者模型 并发编程中最常见的例子就是生产者消费者模式，该模式主要通过平衡生产线程和消费线程的工作能力来提高程序的整体处理数据的速度。简单地说，就是生产者生产一些数据，然后放到成果队列中，同时 ...
分类：
其他好文 时间：
2020-02-20 19:56:03
阅读次数：
98
