QT采用MQTT协议远程控制LED灯测试环境:mqtt_client(Publish) QT 5.6.0 win10mqtt_client(Subscribe) ubuntu 12.04mqtt_broker mosquitto ubuntu 12.0.4开发QT程序使用了QMQTT library 下载地址效果:QT Client代码:mainwindow.h#ifndef MAINWIND...
分类:
其他好文 时间:
2016-05-12 21:39:32
阅读次数:
329
这一次,主要分析client subscribe 某个topic 的处理流程。 由protocol开始 是的,还是要从protocol开始,至于为什么,之前就说过了。 subscribe 类型的packet的处理是: 1、过滤掉topictable 为空的情况 2、组装必要的client 信息,完成 ...
分类:
其他好文 时间:
2016-05-09 14:24:18
阅读次数:
178
这次,分析处理publish msg的流程。 由protocol开始 publish 类型的packet的处理是: 1、ACL 检查 2、处理packet 获得msg 3、调用session module进行处理 emqttd_session 模块处理 和subscribe的处理流程类似,emqtt ...
分类:
其他好文 时间:
2016-05-09 14:15:35
阅读次数:
202
初步认识观察者模式 观察者模式又称为发布/订阅(Publish/Subscribe)模式,因此我们可以用报纸期刊的订阅来形象的说明: 报社方负责出版报纸. 你订阅了该报社的报纸,那么只要报社发布了新报纸,就会通知你,或发到你手上. 如果你不想再读报纸,可以取消订阅,这样,报社发布了新报纸就不会再通知 ...
bbs.chinaacc.com/forum-2-3/topic-5704679.htm...
分类:
编程语言 时间:
2016-05-09 07:09:25
阅读次数:
220
Divide two integers without using multiplication, division and mod operator. If it is overflow, return MAX_INT. Subscribe to see which companies asked ...
分类:
其他好文 时间:
2016-05-08 10:15:41
阅读次数:
165
前言
在默认情况下,即在不指定线程的情况下,RxJava 遵循的是线程不变的原则,即:在哪个线程调用 subscribe(),就在哪个线程生产事件;在哪个线程生产事件,就在哪个线程消费事件。
如果需要切换线程,就需要用到 Scheduler (调度器)。
Schedulers部分主要来自《给Android 开发者的 RxJava 详解》
Sche...
分类:
编程语言 时间:
2016-05-07 11:08:07
阅读次数:
150
Write a function that takes a string as input and returns the string reversed. Example: Given s = "hello", return "olleh". Subscribe to see which comp ...
分类:
编程语言 时间:
2016-05-01 17:40:03
阅读次数:
248
基本概念Observer
观察者模式(Observer Pattern)又称为发布订阅模式(Publish/subscribe)
定义对象间的一种一对多的依赖关系,使得每当一个对象改变状态,则所有依赖于它的对象都会得到通知并且自动更新
根据单一职责原则,每个类的职责是单一的,我们可以通过触发机制,形成一个触发链,把各个单一的职责串联成真实世界中的复杂的逻辑关系。
观察者模式的角色分工(JDK中提供了...
分类:
编程语言 时间:
2016-04-29 18:02:58
阅读次数:
220
count
count 函数和 Java 集合中的 size 或者 length 一样。用来统计源 Observable 完成的时候一共发射了多少个数据。 Observable values = Observable.range(0, 3);
values.subscribe(new Observer() {...
分类:
编程语言 时间:
2016-04-29 16:28:45
阅读次数:
264
综述
观察者模式(Observer Pattern)也叫做发布-订阅(Publish/Subscribe)模式、模型-视图(Model/View)模式。这个模式的一个最重要的作用就是解耦。也就是将被观察者和观察者进行解耦,使得他们之间的依赖性更小,甚至做到毫无依赖。在观察者模式中它定义了一种一对多的依赖关系,使得当每一个对象改变状态,则所有依赖于它的对象都会得到通知并被自动更新。...
分类:
编程语言 时间:
2016-04-27 22:46:44
阅读次数:
350