百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 技术教程 > 正文

MQTT协议介绍及Java教程

toqiye 2024-11-27 21:10 6 浏览 0 评论

一、 概述

  MQTT(Message Queuing Telemetry Transport,消息队列遥测传输协议),是一种基于发布/订阅模式的"轻量级"通讯协议,它和 Modbus TCP 一样都是基于 TCP/IP 之上的应用层协议。

  1.1 MQTT 具备以下几个特点

  简单容易实现、支持设置消息服务质量等级(QoS)、轻量且省带宽。

  1.2 为什么是 MQTT

  物联网设备通信有一些问题需要针对性的解决:网络环境复杂而不可靠、硬件内存和闪存容量小、处理器能力有限。MQTT 协议就是为了解决遇到的这些问题而创建的。

  1.3 MQTT 与 HTTP 协议对比

  MQTT 最小报文仅为 2 个字节,比 HTTP 占用更少网络开销。

  http需要指定请求头、请求方式、请求协议版本等比MQTT请求更多的内容,也代表着它要比MQTT的网络开销要更多。

  MQTT 基于发布订阅模式,HTTP 基于请求响应。 


  MQTT 可实时推送消息,HTTP 需要通过轮询获取数据。

  MQTT 是有状态的,HTTP 是无状态的。

  MQTT客户端启动之后与Broker进行连接之后后续请求不用再带自身认证信息,而对于http来说客户端需要每次请求都带着自身认证信息表明自身身份。

  1.4 MQTT 与消息队列对比

  MQTT 和消息队列的很多行为和特性非常接近, 比如都采用发布/订阅模式,但是他们面向的场景却 有着显著的不同。消息队列主要用于服务端应用之间的消息存储与转发,这类场景往往数据量大但客户端 数量少。MQTT 是一种消息传输协议,主要用于物联网设备之间的消息传递,这类场景的特点是海量的设备接入、管理与消息传输。

  1.5 MQTT消息服务质量等级

  MQTT协议可以对消息设置三种不同的服务质量等级,分别是:

  QoS=0:最多发送一次,订阅方不会发送接收到消息的响应,发布方也不会重新发送消息,消息可能会丢失。


  QoS=1:最少发送一次,订阅方接收到消息之后发送响应给发布方,如果发布方没收到响应会重新发送消息,直到接收到响应为止,消息可能会重复。


  QoS=2:保证只有一次,订阅方不会重复接收到消息,也不会丢失消息。发布方和订阅方之间需要进行两次请求响应确认消息传输,保证相同消息只接收一次,QoS为2时消耗网络资源也最多。


  1.6 MQTT 主题通配符

  MQTT 通配符包含单层通配符 `+` 和多层通配符`#`,主要用于客户端一次订阅多个主题。在发布的时候不能用通配符下发到多个主题中。

  单层通配符适用于单个主题层级匹配的通配符,单层通配符必须占据整个层级才能生效。


  多层通配符适用于主题匹配任意层级的通配符,多层通配符表示它的父级和任意数量的子层级,多层通配符必须单独占据一个层级才能生效。


  二、 创建 MQTT 链接

  下面我们通过 Java 代码创建一个 MQTT 链接,模拟设备发送数据,通过代码模拟订阅者接收数据。


  2.1添加依赖

1.<dependency>

2. <groupId>org.eclipse.paho</groupId>

3. <artifactId>org.eclipse.paho.client.MQTTv3</artifactId>

4. <version>1.2.5</version>

5.</dependency>


  2.2编写发布者代码

1./**

2. *

3. * @param topic

4. * @param content

5. * @param qos 有3个值分别为:

6. * 0:消息最多传递一次,如果客户端没有接收到消息,那么消息会丢失

7. * 1:消息传递至少一次,发布者发送消息会等待订阅者的ACK,如果在规定时间内没有收到ACK则会重新发送,可能会出现消息重复

8. * 2:消息仅且只发送一次,保证消息到达对方并且只发送一次

9. */

10.public void sendMessage(MQTTClient client,String topic,String content,int qos){

11. MQTTMessage message = new MQTTMessage(content.getBytes());

12. message.setQos(qos);

13. try {

14. client.publish(topic,message);

15. } catch (MQTTException e) {

16. //todo publish fail

17. }

18.}

19./**

20. * 连接MQTT客户端

21. * @return

22. */

23.public MQTTClient connectMQTT() {

24. MQTTClient client = null;

25. try {

26. //broker

27. String broker = "tcp://localhost:1883";

28. //用户名

29. String username = "admin";

30. //密码

31. String password = "123456";

32. //clientId

33. String clientId = System.currentTimeMillis() + "";

34. //创建MQTT客户端(指定broker、客户端id、消息持久策略)

35. client = new MQTTClient(broker, clientId, new MemoryPersistence());

36. //创建连接参数配置

37. MQTTConnectOptions options = new MQTTConnectOptions();

38. options.setUserName(username);

39. options.setPassword(password.toCharArray());

40. //是否清除会话

41. options.setCleanSession(true);

42. //心跳间隔

43. options.setKeepAliveInterval(20);

44. //连接超时时间

45. options.setConnectionTimeout(20);

46. //是否自动重连

47. options.setAutomaticReconnect(true);

48. //连接

49. client.connect(options);

50.

51. }catch (Exception e){

52. //todo connect fail

53. }

54. return client;

55.}

56.

57./**

58. * 关闭MQTT客户端

59. * @param client

60. */

61.public void closeClient(MQTTClient client){

62. try {

63. //关闭连接

64. client.disconnect();

65. //关闭客户端

66. client.close();

67. } catch (MQTTException e) {

68. //todo close fail

69. }

70.}

  现在我们来模拟给订阅者发送一条消息,我们通过 MQTTX 客户端来模拟测试:

1.Demo demo = new Demo();

2.MQTTClient client = demo.connectMQTT();

3.String content = "{\n" +

4. " \"deviceNo\": \"x5a2aw\",\n" +

5. " \"val\": 19\n" +

6. "}";

7.//执行主题

8.String topic = "deviceUp";

9.int qos = 1;

10.if (null != client){

11. demo.sendMessage(client,topic,content,qos);

12.}

13.demo.closeClient(client);


  2.3编写订阅者代码

1.String broker = "tcp://localhost:1883";

2.String topic = "/deviceUp";

3.String username = "admin";

4.String password = "123456";

5.String clientId = System.currentTimeMillis() + "";

6.int qos = 1;

7.

8.try {

9. MQTTClient client = new MQTTClient(broker, clientId, new MemoryPersistence());

10. // 连接参数

11. MQTTConnectOptions options = new MQTTConnectOptions();

12. options.setUserName(username);

13. options.setPassword(password.toCharArray());

14. options.setConnectionTimeout(60);

15. options.setKeepAliveInterval(60);

16. // 设置回调

17. client.setCallback(new MQTTCallback() {

18. public void connectionLost(Throwable cause) {

19. }

20. public void messageArrived(String topic, MQTTMessage message) {

21. System.out.println("topic为: " + topic);

22. System.out.println("topic为: " + message.getQos());

23. System.out.println("消息内容为: " + new String(message.getPayload()));

24. }

25. public void deliveryComplete(IMQTTDeliveryToken token) {

26. }

27. });

28. client.connect(options);

29. client.subscribe(topic, qos);

30.} catch (Exception e) {

31. //todo subscribe failed

32.}


  启动订阅者之后再启动发布者代码,与此同时也可以启动自己本地的MQTTX接收消息。

  订阅者收到消息为:

  MQTTX收到消息为:


  三、 总结

  以上就是对MQTT的简单介绍和通过Java代码创建一个 MQTT 链接,模拟设备发送数据,通过代码模拟订阅者接收数据,希望可以对你有所帮助。更多关于MQTT的细节可以留言获取或者通过阅读MQTT官方文档进一步学习。

相关推荐

基于Python查找图像中最常见的颜色

如果我们能够得知道一幅图像中最多的颜色是什么的话,可以帮助我们解决很多实际问题。例如在农业领域中想确定水果的成熟度,我们可以通过检查水果的颜色是否落在特定范围内,来判断它们是否已经成熟。接下来我们将使...

出大要几次/圣彼得堡悖论

程序:fromrandomimportrandomdeffn():n=1whilerandom()<0.5:n+=1returnny=[fn()...

使用OpenCV测量图像中物体之间的距离

原文链接:https://www.pyimagesearch.com/2016/04/04/measuring-distance-between-objects-in-an-image-with-op...

让颜色更加饱满和有冲击力:图像颜色校正

大家拍照或图片时,获取会遇到图像颜色与实际颜色存在色差的现象。我们看一个标准色卡的图片:第一张图片就是有色差的图片,这种现象一般是相机或光线的原因造成的,我们可以通过标准色卡进行校正。第一张图片是有色...

Python 数据分析 : 实例

1、构建矩阵生成4x4形式的矩阵,矩阵中的数据是1~10之间的随机数random_list=np.random.random(16)random_list=np.round(...

用这些免费开源的图标库,为你的项目画龙点睛

精致好看的图标能够为你的项目增色不少,今天我就整理了一期图标库精选系列,希望你可以从中找到自己喜欢的图标库。下面就跟我来一场视觉的盛宴,我会一一介绍GitHub上品牌、流行、极小,各具特色的免费精...

ICON设计规范之图标尺寸

编辑导语:图标设计是UI设计中不可缺少的元素,它看似简单,但其实内含门道。本篇文章里,作者就对icon设计的相关知识和icon绘制方法做出经验介绍。如果你对icon设计也想要有所了解的话,那就点进来看...

PHP开发必备VSCode插件(大全)

通用chinese(simplified...):简体中文语言包liveserverhtml:实时预览prettier-codeformatter:最流行的代码格式化插件...

增强用户体验:前端开发中HTML5和CSS3表格属性的应用与优化研究

摘要:本文探讨了在前端开发中HTML5和CSS3表格属性的应用与优化。首先介绍了HTML5中常用的表格元素和CSS3中丰富的表格样式属性,旨在帮助开发人员定制表格的外观和样式。其次,研究了表格结构的优...

产品经理小技术:图片素材随手找,原型设计快又好

数十万互联网从业者的共同关注!作者:牛冰峰博客:http://uxfeng.com/画图——这项古老而精细的做法,是一代代产品狗们得以传承的立足之本。草图、线框图、思维导图、PPT插图、数据汇报图表、...

MAUI Blazor 项目实战 - 从0到1轻松构建多平台应用UI

前言最近在项目中尝鲜了MAUI,总体感受下来还是挺不错的,优缺点并存,但是瑕不掩瑜,目前随着.Net版本的迭代升级对它的支持也越来越友好,相信未来可期!感兴趣的朋友欢迎关注。文章中如有不妥的地方,也请...

webstorm常用的插件

1、AtomMaterialIcons推荐原因:这款插件不仅...

「智能家居」自动化平台nodered第三方节点dashboard的使用

自带节点库讲完了,开始说说第三方节点库dashboard,该库提供另一个可配置的UI页面,可以配置一些表单元素,以及图表。先来看一下别人使用dashboard制作的面板吧,是不是很漂亮。接下来我们一...

「炫丽」从0开始做一个WPF+Blazor对话小程序

大家好,我是沙漠尽头的狼。...

MAUI使用Masa blazor组件库

上一篇(点击阅读)我们实现了UI在Web端(BlazorServer/Wasm)和客户端(Windows/macOS/Android/iOS)共享,这篇我加上MasaBlazor组件库的引用,并...

取消回复欢迎 发表评论: