将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
一、项目结构 项目结构如何 两个模块，一个为消费方，一个为提供方，也可将两个模块合一，配置文件合一。 二、整合步骤 一、pom.xml 生产方、消费方一致 二、Producer模块 测试代码： 三、Consumer模块 1.配置文件 2.监听器 分别监听提供方queue和topic的消息 启动消费方 ...
分类：
编程语言 时间：
2020-01-30 20:54:55
阅读次数：
101
一、kafka的基础架构 kafka是一个分布式的基于发布/订阅模式的消息队列，主要应用于大数据实时处理领域。 kafka的具体架构如图： 学习kafka的架构前，我们需要了解图中的每个角色： （1）consumer group 消费者组：这是kafka消息队列特有的角色，它是一堆消费组组合成的。消 ...
分类：
其他好文 时间：
2020-01-28 20:47:17
阅读次数：
139
在之前的文章 "RabbitMQ入门（二）工作队列" 中，我们创建了一个工作队列。工作队列背后的假设是每一项任务都被准确地传送至一个worker。在本文中，我们将会做一些不同的事情——我们将会把一个消息发送至许多消费者中。这种模式被称为 。 为了解释这种模式，我们将会构建一个简单的日志系统。它包含两 ...
分类：
其他好文 时间：
2020-01-28 16:00:48
阅读次数：
77
一、定义： 观察者模式（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
