一、Kafka介绍 Kafka是一个开源的分布式消息引擎/消息中间件，同时Kafka也是一个流处理平台。Kakfa支持以发布/订阅的方式在应用间传递消息，同时并基于消息功能添加了Kafka Connect、Kafka Streams以支持连接其他系统的数据(Elasticsearch、Hadoop等 ...
分类：
系统相关 时间：
2020-04-23 12:02:24
阅读次数：
86
简单来说，就是服务端不断发布消息，客户端订阅了就会收到消息。 下面我们看个简单的实力： Server: #include <stdlib.h> #include <zmq.h> #include <string.h> #include <unistd.h> #include <time.h> #de ...
分类：
其他好文 时间：
2020-04-22 13:35:29
阅读次数：
102
前提准备四个文件，两个子组件：List、List2和一个events.js文件以及一个App.js父组件; 在src目录下创建events.js,里面的内容如下： // events.js（以常用的发布/订阅模式举例,借用Node.js Events模块的浏览器版实现） import { Event ...
分类：
其他好文 时间：
2020-04-20 13:39:52
阅读次数：
76
前言 上一章的工作队列模式中，生产者发布的一堆消息进入队列，消费者接收队列中的消息，每条消息只能发给一个消费者。 本章要做的是吧一条消息发送给多个消费者，这种模式就是Fanout Exchange（扇形交换机）“发布/订阅模式”，它会将消息路由给绑定到它身上的所有队列。 注意：该模式没有存储消息功能 ...
分类：
其他好文 时间：
2020-04-20 12:03:48
阅读次数：
80
Redis命令中的Pub/Sub Redis在 2.0之后的版本中 实现了 事件推送的 发布订阅命令 以下是Redis关于发布和订阅提供的相关命令 SUBSCRIBE channel [channel ...] 订阅给定的一个或多个频道的信息。 PSUBSCRIBE pattern [pattern ...
分类：
其他好文 时间：
2020-04-19 00:53:35
阅读次数：
58
js异步解决方案：回调函数、事件监听、发布订阅、promise、generator、async/await 回调函数引起的问题是回调地狱、使代码可读性和可维护性被破坏 async/await是generator方案的语法糖async/await和generator方案，相较于Promise而言，有一 ...
分类：
Web程序 时间：
2020-04-16 16:49:32
阅读次数：
86
一.MQTT介绍 1.简介 MQTT（message queuing telemetry transport）是IBM开发的即时通讯协议，是一种发布/订阅极其轻量级的消息传输协议，专门为网络受限设备、低宽带以及高延迟和不可靠的网络而设计的。由于以上轻量级的特点，是实现智能家居的首选传输协议，相比于X ...
分类：
其他好文 时间：
2020-04-15 23:09:07
阅读次数：
178
python中使用redis发布订阅者模型 redis发布订阅者模型： Redis提供了发布订阅功能，可以用于消息的传输，Redis的发布订阅机制包括三个部分，发布者，订阅者和Channel。发布者和订阅者都是Redis客户端，Channel则为Redis服务器端，发布者将消息发送到某个的频道，订阅 ...
分类：
编程语言 时间：
2020-04-13 14:12:27
阅读次数：
85
ZooKeeper 是一个开放源码的分布式协调服务，它是集群的管理者，监视着集群 中各个节点的状态根据节点提交的反馈进行下一步合理操作。最终，将简单易用 的接口和性能高效、功能稳定的系统提供给用户。 分布式应用程序可以基于 Zookeeper 实现诸如数据发布/订阅、负载均衡、命名 服务、分布式协调 ...
分类：
其他好文 时间：
2020-04-12 20:34:02
阅读次数：
70
[toc] 一、kafka简介 Kafka是一个开源的分布式消息引擎/消息中间件，同时Kafka也是一个流处理平台。Kakfa支持以发布/订阅的方式在应用间传递消息，同时并基于消息功能添加了Kafka Connect、Kafka Streams以支持连接其他系统的数据(Elasticsearch、H ...
分类：
系统相关 时间：
2020-04-12 14:23:35
阅读次数：
109
