一、什么是消息队列？1、消息就是数据。2、队列有队尾和队头，队列有入队和出队，队列先进先出。3、生产者存数据入口4、消费者取数据入口 二、推模型--发布订阅模型--阻塞 主动把消息推给订阅者。数据实时要求高，用推。 三、拉模型--生产者消费者模型--非阻塞消费者自己去拉取数据。数据实时要求不高，用拉 ...
分类：
其他好文 时间：
2020-05-25 22:13:36
阅读次数：
55
1 ActiveMq JMS --> java Message 2 ActiveMQ的消息形式 有2种类型： 2.1 一种是点对点的，一个生产者和一个消费者一一对应 多个生产者 Queue 多个消费者 2.2 另一种是发布、订阅模式，一个生产者产生消息并进行发送后，可以由多个消费者进行接收 多个生产 ...
分类：
其他好文 时间：
2020-05-15 09:35:18
阅读次数：
52
个人在学习Kafka ， 这两天在看官方文档。看完了简介部分，看完做个小总结。看看官方是怎么夸Kafka的。## 三大特性- 发布-订阅- 持久化存储- 低延迟的实时处理## 特性梳理- Topic ： 逻辑概念，承载数据的实体- 数据的保存期限可以设置- 磁盘是顺序读写，IO不是瓶颈- 可以处理大... ...
分类：
其他好文 时间：
2020-05-11 21:42:33
阅读次数：
50
@ "TOC" 第一 接线 ESP8266 01 arduino 3.3v 3.3V GND GND EN 3.3V TX pin13 RX pin12 第二 原理讲解 原理简述 ：利用发布订阅模式。第一步，先arduino获取各种传感器数值，第二步，新建主题，然后arduino往这个主题发送消息， ...
分类：
移动开发 时间：
2020-05-11 00:42:14
阅读次数：
107
一。rabbitmq基本知识 exchange: 交换器，接收生产者发送的消息并路由给对应的队列。三种常用的交换器类型：1.direct(发布订阅，完全匹配) 2。广播型 3.topic（主题，规则匹配） queue: 消息队列，用来保存消息直到发送给消费者。消息一直在队列中，知道消费者链接到队列将 ...
分类：
编程语言 时间：
2020-05-10 23:03:39
阅读次数：
91
promise规范 1、当实例化Promise时会立即执行 2、已经是成功态或是失败态不可再更新状态 3、让Promise支持异步 我们可以参照发布订阅模式，在执行then方法时如果还在等待态（pending），就把回调函数临时寄存到一个数组里，当状态发生改变时依次从数组中取出执行就好了。 4、链式 ...
分类：
其他好文 时间：
2020-05-10 13:05:17
阅读次数：
63
一、简介EventBus是由greenrobot 组织贡献的一个Android事件发布/订阅轻量级框架。EventBus是一个Android端优化的publish/subscribe消息总线，简化了应用程序内各组件间、组件与后台线程间的通信。比如请求网络，等网络返回时通过Handler或Broadc ...
分类：
移动开发 时间：
2020-05-07 15:14:23
阅读次数：
84
Spring Cloud Stream介绍 Spring Cloud Stream，官方定义Spring Cloud Stream是一个构建消息驱动微服务的框架 应用程序通过 inputs 或者 outputs 来与 Spring Cloud Stream 中的binder对象交互，通过配置bind ...
分类：
编程语言 时间：
2020-05-07 00:25:01
阅读次数：
104
1.pulsar概述 Apache Pulsar 是灵活的发布-订阅消息系统（Flexible Pub/Sub messaging），采用分层分片架构（backed by durable log/stream storage）。 Apache Pulsar 是一个开源的分布式pub-sub消息系统， ...
分类：
其他好文 时间：
2020-05-06 17:53:05
阅读次数：
75
监听触发事件： js class EventEmeitter { constructor(){ this._events = this._events || new Map(); this._maxLength = this._maxLength || 10; } } EventEmeitter.p ...
分类：
其他好文 时间：
2020-05-05 18:09:53
阅读次数：
47
