1. MQTT Message 2. Decode MQTT FixedHeader 3. Decode MQTT VariableHeader 3.1 If Connect Type 3.2 If Publish Type 3.2 If SUBSCRIBE:UNSUBSCRIBE:SUBACK:U ...
分类:
其他好文 时间:
2019-10-31 16:15:08
阅读次数:
97
1、Redius的订阅: 运用关键字subscribe订阅: 关键字publish发布: 发布后,订阅的页面才会出现发布的内容。 2、Redis事务: Redis事务与mysql的事务不同,mysql事务是指在多条sql语句中,只要有一条执行不成功就需要回滚事务。 multi:开启事务。 exec: ...
分类:
其他好文 时间:
2019-10-25 10:04:18
阅读次数:
95
HystrixInvocationHandler.invoke() >HystrixCommand.execute() >queue() >toObservable().toBlocking.toFuture() >toFuture方法中that.single().subscribe()订阅subs ...
分类:
其他好文 时间:
2019-10-19 21:06:46
阅读次数:
91
django的信号 Django中提供了“信号调度”,用于在框架执行操作时解耦。通俗来讲,就是一些动作发生的时候,信号允许特定的发送者去提醒一些接受者。 Django提供一种信号机制。其实就是观察者模式,又叫发布 订阅(Publish/Subscribe) 。当发生一些动作的时候,发出信号,然后监听 ...
分类:
其他好文 时间:
2019-10-12 12:59:13
阅读次数:
70
模式定义 观察者模式(Observer Pattern):定义对象间的一种一对多依赖关系,使得每当一个对象状态发生改变时,其相关依赖对象皆得到通知并被自动更新。观察者模式又叫做发布-订阅(Publish/Subscribe)模式、模型-视图(Model/View)模式、源-监听器(Source/Li ...
分类:
其他好文 时间:
2019-10-07 11:34:12
阅读次数:
97
Redis发布消息模式 生产消费模型 Redis发布消息通常有两种模式: 1:队列模式(queuing) 2:发布-订阅模式(publish-subscribe) 任务队列:顾名思义,就是“传递消息的队列”。与任务队列进行交互的实体有两类,一类是生产者(producer),另一类则是消费者(cons ...
分类:
其他好文 时间:
2019-10-02 14:33:06
阅读次数:
81
1. kafka介绍 1.1. 主要功能 根据官网的介绍,ApacheKafka®是一个分布式流媒体平台,它主要有3种功能: 1:It lets you publish and subscribe to streams of records.发布和订阅消息流,这个功能类似于消息队列,这也是kafka ...
分类:
其他好文 时间:
2019-10-02 00:30:40
阅读次数:
203
Redis 发布/订阅机制原理分析 Redis 通过 PUBLISH 、 SUBSCRIBE 和 PSUBSCRIBE 等命令实现发布和订阅功能。 这些命令被广泛用于构建即时通信应用,比如网络聊天室(chatroom)和实时广播、实时提醒等。 本文通过分析 Redis 源码里的 pubsub.c 文 ...
分类:
其他好文 时间:
2019-10-01 18:03:31
阅读次数:
112
第二个版本: 现在有两个新的问题摆在我们面前 这个状态管理器只能管理 count,不通用 公共的代码要封装起来我们尝试来解决这个问题,把公共的代码封装起来 // 第二个版本redux // createStore,提供了 changeState,getState,subscribe 三个能力。 co ...
分类:
其他好文 时间:
2019-09-25 12:42:40
阅读次数:
66
本文源码: "GitHub·点这里" || "GitEE·点这里" 一、观察者模式 1、概念描述 观察者模式是对象的行为模式,又叫发布 订阅(Publish/Subscribe)模式。观察者模式定义了一种一对多的依赖关系,让多个观察者对象同时监听某一个主题对象,主题对象在状态发生变化时,会通知所有观 ...
分类:
编程语言 时间:
2019-09-15 23:56:34
阅读次数:
179