mqtt底层是socket(mqtt底层原理)

做法是通过socket.io做中转，websocket连接到socekt.io上，后台nodejs再连接到mqtt server上。
现在的activemq已经支持直接用js使用mqtt了，原理就是结合websocket,你下载最新的activemq，里面有个example，超级简单的

启动方式: 解压缩,进入apache-activemq-5.9.0-binapache-activemq-5.9.0bin,双击activemq.bat,即可启动activeMQ服务启动之后: android客户端推送采用mqtt(paho-mqtt-client-1.0.1.jar),
做法是通过socket.io做中转，websocket连接到socekt.io上，后台nodejs再连接到mqtt server上。

MQTT协议是为大量计算能力有限，且工作在低带宽、不可靠的网络的远程传感器和控制设备通讯而设计的协议。 而WebSocket则是浏览器与服务器全双工通信（MQTTMessage Queuing Telemetry Transport，消息队列遥测传输）是IBM开发的一个即时通讯协议，有可能成为物联网的重要组成部分。该协议支持所有平台，几乎可以把所有联网物品和外部连接起来，被用来当做传感器和致动器（比如通过Twitter让房屋联网）的通信协议。 WebSocket protocol 是HTML5一种新的协议。它实现了浏览器与服务器全双工通信(full-duplex)。一开始的握手需要借助HTTP请求完成。
MQTT（Message Queuing Telemetry Transport，消息队列遥测传输）是轻量级基于代理的发布/订阅的消息传输协议，设计思想是开放、简单、轻量、易于实现。这些特点使它适用于受限环境。例如： ①网络代价昂贵，带宽低、不可靠。②在嵌入设备中运行，处理器和内存资源有限。该协议的特点有：①使用发布/订阅消息模式，提供一对多的消息发布，解除应用程序耦合。②对负载内容屏蔽的消息传输。③使用 TCP/IP 提供网络连接。④有三种消息发布服务质量：⑤"至多一次"，消息发布完全依赖底层 TCP/IP 网络。会发生消息丢失或重复。这一级别可用于如下情况，环境传感器数据，丢失一次读记录无所谓，因为不久后还会有第二次发送。⑥"至少一次"，确保消息到达，但消息重复可能会发生。⑦"只有一次"，确保消息到达一次。这一级别可用于如下情况，在计费系统中，消息重复或丢失会导致不正确的结果。⑧小型传输，开销很小（固定长度的头部是 2 字节），协议交换最小化，以降低网络流量。⑨使用 Last Will 和 Testament 特性通知有关各方客户端异常中断的机制。WebSocket则提供使用一个TCP连接进行双向通讯的机制，包括网络协议和API，以取代网页和服务器采用HTTP轮询进行双向通讯的机制。本质上来说，WebSocket是不限于HTTP协议的，但是由于现存大量的HTTP基础设施，代理，过滤，身份认证等等，WebSocket借用HTTP和HTTPS的端口。由于使用HTTP的端口，因此TCP连接建立后的握手消息是基于HTTP的，由服务器判断这是一个HTTP协议，还是WebSocket协议。 WebSocket连接除了建立和关闭时的握手，数据传输和HTTP没丁点关系了。由此可知两者的应用场景不一样：MQTT是为了物联网场景设计的基于TCP的Pub/Sub协议，有许多为物联网优化的特性，比如适应不同网络的QoS、层级主题、遗言等等。WebSocket是为了HTML5应用方便与服务器双向通讯而设计的协议，HTTP握手然后转TCP协议，用于取代之前的Server Push、Comet、长轮询等老旧实现。 两者之所有有交集，是因为一个应用场景：如何通过HTML5应用来作为MQTT的客户端，以便接受设备消息或者向设备发送信息，那么MQTT over WebSocket自然成了最合理的途径了。

MQTT（Message Queuing Telemetry Transport，消息队列遥测传输）是轻量级基于代理的发布/订阅的消息传输协议，设计思想是开放、简单、轻量、易于实现。这些特点使它适用于受限环境。例如： ①网络代价昂贵，带宽低、不可靠。②在嵌入设备中运行，处理器和内存资源有限。该协议的特点有：①使用发布/订阅消息模式，提供一对多的消息发布，解除应用程序耦合。②对负载内容屏蔽的消息传输。③使用 TCP/IP 提供网络连接。④有三种消息发布服务质量：⑤"至多一次"，消息发布完全依赖底层 TCP/IP 网络。会发生消息丢失或重复。这一级别可用于如下情况，环境传感器数据，丢失一次读记录无所谓，因为不久后还会有第二次发送。⑥"至少一次"，确保消息到达，但消息重复可能会发生。⑦"只有一次"，确保消息到达一次。这一级别可用于如下情况，在计费系统中，消息重复或丢失会导致不正确的结果。⑧小型传输，开销很小（固定长度的头部是 2 字节），协议交换最小化，以降低网络流量。⑨使用 Last Will 和 Testament 特性通知有关各方客户端异常中断的机制。WebSocket则提供使用一个TCP连接进行双向通讯的机制，包括网络协议和API，以取代网页和服务器采用HTTP轮询进行双向通讯的机制。本质上来说，WebSocket是不限于HTTP协议的，但是由于现存大量的HTTP基础设施，代理，过滤，身份认证等等，WebSocket借用HTTP和HTTPS的端口。由于使用HTTP的端口，因此TCP连接建立后的握手消息是基于HTTP的，由服务器判断这是一个HTTP协议，还是WebSocket协议。 WebSocket连接除了建立和关闭时的握手，数据传输和HTTP没丁点关系了。由此可知两者的应用场景不一样：MQTT是为了物联网场景设计的基于TCP的Pub/Sub协议，有许多为物联网优化的特性，比如适应不同网络的QoS、层级主题、遗言等等。WebSocket是为了HTML5应用方便与服务器双向通讯而设计的协议，HTTP握手然后转TCP协议，用于取代之前的Server Push、Comet、长轮询等老旧实现。 两者之所有有交集，是因为一个应用场景：如何通过HTML5应用来作为MQTT的客户端，以便接受设备消息或者向设备发送信息，那么MQTT over WebSocket自然成了最合理的途径了。

使用一个代理服务器message broker，客户端client连接上这个服务器，然后告诉服务器，可以接收哪些类型的消息，同时client也可以发布自己的消息，这些消息根据协议的内容，可以别的client获取。这样就实现了消息推送。 消息推送是通过一定的技术标准或协议，在互联网上通过定期传送用户需要的信息来减少信息过载的一项新技术。如果想要使用消息推送，推荐使用深圳极光的消息推送系统。深圳极光是国内首个为移动应用开发者提供专业、高效的消息推送服务的产品。品牌成长的过程，就是与客户肩并肩迈向成功的过程。极光将以市场为导向，以创新为动力，以技术为支持，不断用心努力，为每一位尊贵的客户提供极致的服务。
MQTT是一项消息传递技术，由IBM再2001年发布。 总结一下，机制就是使用一个代理服务器messagebroker，客户端client连接上这个服务器，然后告诉服务器说，我可以接收哪些类型的消息，同时，client也可以发布自己的消息，这些消息根据协议的内容，可以被其他client获取。只要手机客户端，连上服务器，然后就可以接收和发布消息了，不用自己写socket什么了，低带宽，低耗电量，代码量也少，很简单吧。package com.pig.test.mqtt;import com.ibm.mqtt.MqttClient;importcom.ibm.mqtt.MqttException;import com.ibm.mqtt.MqttSimpleCallback;public class SubscribeClient {private final static StringCONNECTION_STRING = "tcp://192.168.1.60:1883";private final static booleanCLEAN_START = true;private final static short KEEP_ALIVE =30;//低耗网络，但是又需要及时获取数据，心跳30sprivate final static String CLIENT_ID ="client1";private final static String[] TOPICS ={"Test/TestTopics/Topic1","Test/TestTopics/Topic2","Test/TestTopics/Topic3","tokudu/client1"};privatefinal static int[] QOS_VALUES = {0, 0, 2,0};//////////////////private MqttClient mqttClient =null;public SubscribeClient(String i){try {mqttClient =new MqttClient(CONNECTION_STRING);SimpleCallbackHandlersimpleCallbackHandler = newSimpleCallbackHandler();mqttClient.registerSimpleHandler(simpleCallbackHandler);//注册接收消息方法mqttClient.connect(CLIENT_ID+i,CLEAN_START, KEEP_ALIVE);mqttClient.subscribe(TOPICS,QOS_VALUES);//订阅接主题/***完成订阅后，可以增加心跳，保持网络通畅，也可以发布自己的消息*/mqttClient.publish(PUBLISH_TOPICS, "keepalive".getBytes(), QOS_VALUES[0],true);} catch (MqttException e) {// TODO Auto-generatedcatch blocke.printStackTrace();}}/*** 简单回调函数，处理client接收到的主题消息* @author pig**/class SimpleCallbackHandler implements MqttSimpleCallback{/*** 当客户机和broker意外断开时触发* 可以再此处理重新订阅*/@Overridepublic void connectionLost() throws Exception {//TODO Auto-generated methodstubSystem.out.println("客户机和broker已经断开");}/*** 客户端订阅消息后，该方法负责回调接收处理消息*/@Overridepublic voidpublishArrived(String topicName, byte[] payload, int Qos, boolean retained)throws Exception {// TODO Auto-generated methodstubSystem.out.println("订阅主题: " +topicName);System.out.println("消息数据: " + newString(payload));System.out.println("消息级别(0,1,2): " +Qos);System.out.println("是否是实时发送的消息(false=实时，true=服务器上保留的最后消息): " +retained);}}/*** 高级回调* @author pig**/class AdvancedCallbackHandler implements MqttSimpleCallback{@Overridepublic void connectionLost() throws Exception {//TODO Auto-generated method stub}@Overridepublic void publishArrived(String arg0, byte[] arg1, intarg2,boolean arg3) throws Exception {// TODO Auto-generatedmethod stub}}/*** @param args*/public static void main(String[] args) {// TODO Auto-generatedmethod stubnew SubscribeClient("" + i);}}broker服务器，MQTT的jar包，记得下载啊，没有就消息我咯~到这里，如果完成IBM的MQTT协议实现push消息的实例的，都会有个问题，好像没考虑到安全问题，如果客户端连上来作乱怎么办呢？上面用的broker时rsmb的，mqtt的简单服务器。IBM已经推出了MQTT V3.1版本，已经加入了安全验证机制，不要怕啦。 转载仅供参考，版权属于原作者。祝你愉快，满意请采纳哦