* 使用 Java 为 MQ Telemetry Transport 创建订户* 在此任务中，您将遵循教程来创建订户应用程序。订户将针对主题创建预订并接收该预订的发布。*提供了一个示例订户应用程序 Subscribe。Subscribe 将创建预订主题 MQTT Examples，并等待获*得该预订...
在MQTT官网（http://mqtt.org/software）中有众多MQTT的实现方式。具体参看官网，Moquette是基于Apache Mina 的模型的一个Java MQTT broker。使用过Mina的同学发现其实broker的启动过程就是一个Mina应用的启动。在MQTT moqu....
分类：
其他好文 时间：
2015-07-01 18:04:41
阅读次数：
143
参看官方文档：http://publib.boulder.ibm.com/infocenter/wmqv7/v7r0/index.jsp?topic=/com.ibm.mq.amqtat.doc/tt00000_.htm* Java 为 MQ Telemetry Transport 创建异步发布程....
HTTP DELETE 订阅主题请求协议和响应协议http://publib.boulder.ibm.com/infocenter/wmqv7/v7r0/topic/com.ibm.mq.csqzau.doc/ts21240_.htm请求响应头各个字段的含义的讲解http://publib.boul...
分类：
Web程序 时间：
2015-07-01 17:52:50
阅读次数：
197
接着上一篇的moquette-mqtt 的使用之broker启动之后，我们需要启动moquette-mqtt 的服务端发布消息。在moquette-mqtt 的mqtt-client中三种方式实现发布消息的方式： 1.采用阻塞式的连接的（BlockingConnection） 2.采用回调式的连接 ...
分类：
其他好文 时间：
2015-07-01 17:52:25
阅读次数：
119
摘要：新版 MQTT 3.1.1 终于在 2014 年 10 月 30 日推出了。尽管大部分改动看着不明显，其实性能已经向前迈进一大步。本文将对比 MQTT 3.1和 3.1.1 的区别并详细介绍。
分类：
其他好文 时间：
2015-06-24 16:15:17
阅读次数：
120
最近学习MQTT协议，选择了当前比较流行的MQTT Broker “mosquitto”，但是在阅读代码过程中发现其网络底层库封装的相当差劲。对于MQTT协议的变长头长度的读取上，基本上采取每次一个byte的方式进行读取判断，对于系统调用read的高代价来讲，真的是相当的浪费，也难怪其不能作为高并发...
分类：
其他好文 时间：
2015-06-18 13:09:01
阅读次数：
512
在上一节中（MQTT消息格式之SUBSCRIBE(消息订阅)消息分析），客户端发送了订阅的消息，这个时候，服务器端收到订阅主题的MQTT消息之后，肯定需要给一个应答，这个应答信息就是SUBACK(消息订阅应答)。消息订阅应答相对来说比较简单。...
分类：
系统相关 时间：
2015-06-17 23:23:07
阅读次数：
1165
我们在上几节的协议分析中，发送连接的请求用的是Eclipse Paho MQTT工具，那么笔者这一次改一下，咱们这次用代码来发送Subscribe的MQTT消息，请注意，下面的代码是基于Eclipse Paho Java API之上的代码，在运行下面的代码前，请先去下载Eclipse Paho Java库，其下载地址为：https://www.eclipse.org/paho/clients/java/. 下面我们正式切入正题。...
分类：
系统相关 时间：
2015-06-16 14:50:09
阅读次数：
279
在上节中（ [6] MQTT,mosquitto,Eclipse Paho---MQTT消息格式之CONNECT消息格式分析）我们分析了CONNECT消息格式，我们知道CONNECT消息是客户端发送出去的，作为对客户端的连接请求，服务器端同样会有一个消息的返回，这个消息就是CONNACK的消息。我们在发出去CONNECT消息后，如果WireShark抓包工具依然开启的话，将会抓到类似于下面的TCP消息，其16进制为：20 02 00 00，那么其代表什么意思呢？...
分类：
系统相关 时间：
2015-06-14 12:30:01
阅读次数：
232
