MQTT，我想问下MQTT是什么协议

本文目录一览

1，我想问下MQTT是什么协议
2，MQTT和CoAP哪个最可能成为未来物联网通信标准协议
3，工业MQTT有什么作用
4，MQTT和Websocket的区别是什么
5，JavaAndroid关于ActiveMQ与MQTT的关系是什么
6，如何采用MQTT协议实现android消息推送

1，我想问下MQTT是什么协议

MQTT就是IBM开发的一个即时通讯协议。通过这个协议，能够实现物联网中不同设备之间的互联互通。建议平时多关注一下ET-iLINK官网，上面有很详细的介绍。

我想问下MQTT是什么协议

2，MQTT和CoAP哪个最可能成为未来物联网通信标准协议

MQTT是非常流行的设备的接入协议，包括IBM、亚马逊、微软的IoT托管服务都有支持，而CoAP在这方面几乎没有露面的机会。感觉以下几点是MQTT优于CoAP的主要原因：MQTT基于TCP，在做反控设备的时候比UDP更可靠，比如CoAP走3G、4G的时候甚至需要实现CoAP over TCP，否则反控很不稳定甚至无法联通。MQTT异步Pub/Sub实现，好比发个微信，无需等待对方确认便可以继续，而不像CoAP那样必须等待对方应答才能返回的同步模式。MQTT为物联网提供了许多体贴的设计，比如QoS，比如“遗言”的设计。篇幅有限，无法完全枚举MQTT的优越性，建议参考以下文章：MQTT入门篇MQTT进阶篇MQTT安全篇MQTT实战篇当然，CoAP在功耗方面有优势，不过随着物联网设备特别是网管的计算能力加强，这点应该不是主要矛盾。

MQTT和CoAP哪个最可能成为未来物联网通信标准协议

3，工业MQTT有什么作用

多比MQTT网关可以该协议支持所有平台，几乎可以把所有联网物品和外部连接起来，可用来当做传感器和致动器的通信协议。

用途：用于制化学药品、橡胶凝固剂及纺织、印染、电镀等。甲酸是有机化工基础原料之一，广泛用于农药、皮革、医药、橡胶、印染及化工原料等行业。酸是基本有机化工原料之一，广泛用于农药、皮革、染料、医药和橡胶等工业。 (1)医药工业：咖啡因、安乃近、氨基比林、氨茶碱、可可碱冰片、维生素b1、甲硝唑、甲苯咪唑。（2）农药工业：粉锈宁、三唑酮、三环唑、三氨唑、三唑磷、多效唑、烯效唑、杀虫醚、三氯杀螨醇、写嘌呤等。（3）化学工业：甲酸钙、甲酸钠、甲酸铵、甲酸钾、甲酸乙酯、甲酸钡、二甲基甲酰胺、甲酰胺、橡胶防老剂、季戊四醇、新戊二醇、环氧大豆油、环氧大豆油酸辛酯、特戊酰氯、脱漆剂、酚醛树脂、酸洗钢板等。（4）皮革工业：皮革的鞣制集、脱灰剂和中和剂。（5）橡胶工业：天然橡胶凝聚剂。（6）其它：还可以制造印染煤染剂，纤维和纸张的染色剂、处理剂、增塑剂、食品保鲜和动物饲料添加剂等。

工业MQTT有什么作用

4，MQTT和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自然成了最合理的途径了。

根据你的描述： mqtt 跟 websocket 可以认为是不同层面的协议。mqtt 做原生设备的通信，mqtt over websocket 主要用于 mqtt 设备跟 web 端通信。

5，JavaAndroid关于ActiveMQ与MQTT的关系是什么

实在看不下去了，网上怎么竟是些胡说八道的呢。太坑人。MQTT（Message Queuing Telemetry Transport，消息队列遥测传输）是IBM开发的一个即时通讯协议，activemq只是apache下一个队列项目，不仅仅支持MQTT协议，也支持其他比如AMQP等协议。MQTT是协议，协议只是定义好的规则，比如文档也是协议。activemq只是实现了MQTT协议的一个程序

mq是队列 tt是推送 mqtt是推送队列 mq是单纯的队列推送的话不能一下子全部推送完也是需要队列一个一个来推送

2013-12-20实现点对点消息通知的关键问题activemq使用mqtt协议，加上android上的paho包，即可简单实现消息通知功能，但是mqtt协议只支持topic，而且不能用selector，使得点对点的消息投递变成问题。有两个解决思路：1、每个clientid，建一个topic...这个办法对解决消息点对点投递非常有效，但是有两个大问题:随着用户数增多，topic数量增多，对管理性要求增大，对内存的管理也有问题。消息广播操作也变得非常麻烦，只能一个个的发送了。2、另一个思路，就是在消息广播的基础上，进行点对点控制，实现某些特征的消息投递到指定的订阅者。这个的实现比较简单，而且没有上面方案的大问题。代码稍微改下即可：其实就只添加了一个新的类： clientidfilterdispatchpolicy可以git clone所在版本源码，然后加上这个类，mvn package以后使用。使用说明本修改实现mqtt协议使用单个topic，来做消息广播和点对点的投递。1、将本文件夹下的activemq-broker-5.9.0.jar、activemq-spring-5.9.0.jar换掉apache-activemq-5.9.0\lib下的jar。2、参考本文件夹下activemq.xml，在topic上配置 3、对于此配置下的所有名称以.ptp结尾的队列，如果要投递消息的properties里包含ptp_clientid，则系统只会将此消息发给clientid为此值的订阅者；如果当前没有此clientid的订阅者，消息不会被任何人接收到。如果投递消息的properties里不包含ptp_clientid，则消息广播给所有的订阅者。跟正常消息投递一致。其中后缀.ptp和键值ptp_clientid，是可以配置的：如上配置，使得此policy下的所有topic都起作用，且消息的properties里获取clientid的key变成clientid。消息发布者，如果要对所有人广播消息，直接发送消息即可。如果要对指定的消息订阅者发消息，请在消息里设置接收者的clientid： message.setstringproperty(ptp_clientid, clientid);则此消息只有指定的订阅者可以拿到。简单测试两台android设备使用mqtt协议订阅到activemq的同一个topic，clientid分别为mqtt-1001和mqtt1002；写代码发两条消息，设置消息属性中ptp_clientid分别为mqtt-1001和mqtt1002；两个设备分别接收到自己的消息通知，相互之间没有影响。还可以测试下如果消息没有ptp_clientid，两个都能收到。

6，如何采用MQTT协议实现android消息推送

MQTT是一项消息传递技术，由IBM再2001年发布。　　总结一下，机制就是使用一个代理服务器messagebroker，　　客户端client连接上这个服务器，然后告诉服务器说，我可以接收哪些类型的消息，　　同时，client也可以发布自己的消息，这些消息根据协议的内容，可以被其他client获取。　　只要手机客户端，连上服务器，然后就可以接收和发布消息了，不用自己写socket什么了，　　低带宽，低耗电量，代码量也少，很简单吧。　　package com.pig.test.mqtt;　　import com.ibm.mqtt.MqttClient;　　import　　com.ibm.mqtt.MqttException;　　import com.ibm.mqtt.MqttSimpleCallback;　　public class SubscribeClient 　　private final static String　　CONNECTION_STRING = "tcp://192.168.1.60:1883";　　private final static boolean　　CLEAN_START = true;　　private final static short KEEP_ALIVE =　　30;//低耗网络，但是又需要及时获取数据，心跳30s　　private final static String CLIENT_ID =　　"client1";　　private final static String[] TOPICS =　　　　"Test/TestTopics/Topic1",　　"Test/TestTopics/Topic2",　　"Test/TestTopics/Topic3",　　"tokudu/client1"　　};　　private　　final static int[] QOS_VALUES = 　　0};　　//////////////////　　private MqttClient mqttClient =　　null;　　public SubscribeClient(String i)　　try 　　mqttClient =　　new MqttClient(CONNECTION_STRING);　　SimpleCallbackHandler　　simpleCallbackHandler = new　　SimpleCallbackHandler();　　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-generated　　catch block　　e.printStackTrace();　　}　　}　　/**　　* 简单回调函数，处理client接收到的主题消息　　* @author pig　　*　　*/　　class SimpleCallbackHandler implements MqttSimpleCallback　　/**　　* 当客户机和broker意外断开时触发　　* 可以再此处理重新订阅　　*/　　@Override　　public void connectionLost() throws Exception 　　//　　TODO Auto-generated method　　stub　　System.out.println("客户机和broker已经断开");　　}　　/**　　* 客户端订阅消息后，该方法负责回调接收处理消息　　*/　　@Override　　public void　　publishArrived(String topicName, byte[] payload, int Qos, boolean retained)　　throws Exception 　　// TODO Auto-generated method　　stub　　System.out.println("订阅主题: " +　　topicName);　　System.out.println("消息数据: " + new　　String(payload));　　System.out.println("消息级别(0,1,2): " +　　Qos);　　System.out.println("是否是实时发送的消息(false=实时，true=服务器上保留的最后消息): " +　　retained);　　}　　}　　/**　　* 高级回调　　* @author pig　　*　　*/　　class AdvancedCallbackHandler implements MqttSimpleCallback　　@Override　　public void connectionLost() throws Exception 　　//　　TODO Auto-generated method stub　　}　　@Override　　public void publishArrived(String arg0, byte[] arg1, int　　arg2,　　boolean arg3) throws Exception 　　// TODO Auto-generated　　method stub　　}　　}　　/**　　* @param args　　*/　　public static void main(String[] args) 　　// TODO Auto-generated　　method stub　　new SubscribeClient("" + i);　　}　　}　　broker服务器，MQTT的jar包，记得下载啊，没有就消息我咯~　　到这里，如果完成IBM的MQTT协议实现push消息的实例的，　　都会有个问题，好像没考虑到安全问题，如果客户端连上来作乱怎么办呢？　　上面用的broker时rsmb的，mqtt的简单服务器。　　IBM已经推出了MQTT V3.1版本，已经加入了安全验证机制，不要怕啦。

mqtt是一项消息传递技术，由ibm再2001年发布。总结一下，机制就是使用一个代理服务器messagebroker，客户端client连接上这个服务器，然后告诉服务器说，我可以接收哪些类型的消息，同时，client也可以发布自己的消息，这些消息根据协议的内容...