阅读文档 1.管道 yum install nc 安装netcat 建立socket连接 管道,直接给redis发值 nc localhost 6379 set k1 test (ctrl+c结束)然后在客户端查询 2.发布订阅:help @pubsub 监听之后才能接收到 redis-cli : ...
分类:
其他好文 时间:
2020-08-10 22:10:33
阅读次数:
84
@(arduino和NB-IOT模块M5310-A使用教程,app实时控制) 第一 、先上效果图 第二、原理讲解 原理简述:利用发布订阅模式。第一步,新建主题,第二步,arduino通过nb-iot模块订阅这个主题。第三步、通过app往这个主题发消息。由于单片机订阅了这个主题,所以可以实时收到发往这 ...
分类:
移动开发 时间:
2020-07-30 16:52:54
阅读次数:
120
什么是Kafka?Apache Kafka是一个分布式发布 - 订阅消息系统和一个强大的队列,可以处理大量的数据,并使您能够将消息从一个端点传递到另一个端点。 Kafka适合离线和在线消息消费。 Kafka消息保留在磁盘上,并在群集内复制以防止数据丢失。 Kafka构建在ZooKeeper同步服务之 ...
分类:
其他好文 时间:
2020-07-30 14:47:03
阅读次数:
73
键空间通知(Keyspace Notification)是一个从Redis 2.8.0版本开始可用的功能。 1、简介: 键空间通知基于订阅Pub/Sub(发布/订阅),当库中的key发生改变时,能够对你感兴趣的事件进行通知。 可能接收到的事件示例,如下所示: 所有影响到一个给定键的命令。 所有接收到 ...
分类:
其他好文 时间:
2020-07-28 13:58:08
阅读次数:
106
MQTT简介 MQTT 全称为 Message Queuing Telemetry Transport(消息队列遥测传输)是一种基于发布/订阅范式的“轻量级”消息协议。该协议构建于TCP/IP协议上。 MQTT协议是轻量、简单、开放和易于实现的,这些特点使它适用范围非常广泛。在很多情况下,包括受限的 ...
分类:
编程语言 时间:
2020-07-24 21:10:54
阅读次数:
88
一、Kafka 简介 1.基本概念 Kafka 是一个分布式的基于发布/订阅消息系统,主要应用于大数据实时处理领域,其官网是:http://kafka.apache.org/。Kafka 是一个分布式、支持分区的(Partition)、多副本的(Replica),基于 ZooKeeper 协调的发布 ...
分类:
编程语言 时间:
2020-07-22 15:56:17
阅读次数:
64
有的人把发布 订阅模式又叫观察者模式,它定义对象间的一种一对多的依赖关系,当一个对象的状态发生改变时,所有依赖于它的对象都将得到通知。 其实他们还是有差别的,在发布订阅模式中,组件是松散耦合的,正好和观察者模式相反 发布订阅模式中,发布者和订阅者不知道对方的存在。它们只有通过消息代理进行通信。 在观 ...
分类:
编程语言 时间:
2020-07-21 23:18:26
阅读次数:
137
高级特性 简单消息队列 可以用list的rpush+lpop实现简单的消息队列功能(用blpop可以阻塞连接直到有消息时才返回) 发布订阅模式 消费者通过subscribe订阅一个频道,生产者通过publish发布消息到频道,实现多条发布。 通过unsubscribe取消订阅。 订阅的频道可以用通配 ...
分类:
其他好文 时间:
2020-07-17 22:07:32
阅读次数:
87
第一、原理讲解 原理简述:利用发布订阅模式。第一步,先读取DHT11温湿度数值,第二步,新建主题,然后esp8266往这个主题发送消息,第三步。app inventor 订阅这个主题,因为app inventor 制作的app 订阅了这个主题,就可收到来自这个主题的消息,也就是可以收到温湿度数值。a ...
分类:
微信 时间:
2020-07-16 12:24:01
阅读次数:
155
1:所有的发布订阅就是一个对象。 class Obersve { event={} //等价于下面的constructor // constructor() { // this.event = {} // } subscribe(type, fn) { //订阅 if (Object.keys(th ...
分类:
其他好文 时间:
2020-07-15 15:47:31
阅读次数:
68