快捷搜索:  汽车  科技

mqtt为什么是物联网协议(物联网平台的基础组件之一MQTT)

mqtt为什么是物联网协议(物联网平台的基础组件之一MQTT)# 点击WEB页面上的Init按钮之后 18:11:49.183098 IP 14.150.108.187.50999 > 172.16.0.12.etlservicemgr: Flags [S] seq 3659468570 win 64240 options [mss 1360 nop wscale 8 nop nop sackOK] length 0 0x0000: 5254 00e4 a55c feee 809f 3247 0800 4568 RT...\....2G..Eh 0x0010: 0034 7b4e 4000 7206 65a0 0e96 6cbb ac10 .4{N@.r.e...l... 0x0020: 000c c737 2329 da1f 0f1a 0000 0000 8002 ...7#

开发部署在云端的设备接入网关服务就不得不提到MQTT,使用MQTT不论是从设备到设备,还是设备到云端服务的双向通讯,都可以获得较好的支持。

mqtt为什么是物联网协议(物联网平台的基础组件之一MQTT)(1)

MQTT的起源和我的理解

用tcpdump分析下MQTT的通讯时序

这里基于mosquitto,以一组实际的订阅、发布,使用tcpdump来观察MQTT的通讯。

# 使用tcpdump打印指定MQTT服务器所在端口的报文 tcpdump -n -XX -i eth0 port 1883 # 订阅指定主题的消息 mosquitto_sub -h 172.16.0.12 -t "topic/#" -u user -P password -i "client1" # 发布消息到指定主题 mosquitto_pub -h 172.16.0.12 -t "topic/" -u user -P password -i "client3" -m "1234567890123456789012345678901234567890"

tcpdump抓取的报文如下:

启动mosquitto_sub命令获得如下报文: ================================== 16:33:28.668926 IP SUB.41050 > MQTT.ibm-mqisdp: Flags [S] seq 1177792969 win 29200 options [mss 1424 sackOK TS val 530570732 ecr 0 nop wscale 7] length 0 0x0000: 5254 00e4 a55c feee 809f 3247 0800 4568 RT...\....2G..Eh 0x0010: 003c 5872 4000 3806 556b 5147 9713 ac10 .<Xr@.8.UkQG.... 0x0020: 000c a05a 075b 4633 b1c9 0000 0000 a002 ...Z.[F3........ 0x0030: 7210 a45e 0000 0204 0590 0402 080a 1f9f r..^............ 0x0040: ddec 0000 0000 0103 0307 .......... 16:33:28.669001 IP MQTT.ibm-mqisdp >SUB.41050: Flags [S.] seq 1053629863 ack 1177792970 win 28960 options [mss 1460 sackOK TS val 3885354501 ecr 530570732 nop wscale 7] length 0 0x0000: feee 809f 3247 5254 00e4 a55c 0800 4500 ....2GRT...\..E. 0x0010: 003c 0000 4000 4006 a645 ac10 000c 5147 .<..@.@..E....QG 0x0020: 9713 075b a05a 3ecd 1da7 4633 b1ca a012 ...[.Z>...F3.... 0x0030: 7120 9309 0000 0204 05b4 0402 080a e795 q............... 0x0040: ce05 1f9f ddec 0103 0307 .......... 16:33:28.672229 IP SUB.41050 > MQTT.ibm-mqisdp: Flags [.] ack 1 win 229 options [nop nop TS val 530570735 ecr 3885354501] length 0 0x0000: 5254 00e4 a55c feee 809f 3247 0800 4568 RT...\....2G..Eh 0x0010: 0034 5873 4000 3806 5572 5147 9713 ac10 .4Xs@.8.UrQG.... 0x0020: 000c a05a 075b 4633 b1ca 3ecd 1da8 8010 ...Z.[F3..>..... 0x0030: 00e5 320e 0000 0101 080a 1f9f ddef e795 ..2............. 0x0040: ce05 .. 16:33:28.672280 IP SUB.41050 > MQTT.ibm-mqisdp: Flags [P.] seq 1:42 ack 1 win 229 options [nop nop TS val 530570735 ecr 3885354501] length 41 0x0000: 5254 00e4 a55c feee 809f 3247 0800 4568 RT...\....2G..Eh 0x0010: 005d 5874 4000 3806 5548 5147 9713 ac10 .]Xt@.8.UHQG.... 0x0020: 000c a05a 075b 4633 b1ca 3ecd 1da8 8018 ...Z.[F3..>..... 0x0030: 00e5 37b7 0000 0101 080a 1f9f ddef e795 ..7............. 0x0040: ce05 1027 0006 4d51 4973 6470 03c2 003c ...'..MQIsdp...< 0x0050: 0007 636c 6965 6e74 3100 0563 636e 6574 ..client1..ccnet 0x0060: 0009 6363 6e65 7430 3930 31 ..ccnet0901 16:33:28.672313 IP MQTT.ibm-mqisdp > SUB.41050: Flags [.] ack 42 win 227 options [nop nop TS val 3885354505 ecr 530570735] length 0 0x0000: feee 809f 3247 5254 00e4 a55c 0800 4500 ....2GRT...\..E. 0x0010: 0034 d3a1 4000 4006 d2ab ac10 000c 5147 .4..@.@.......QG 0x0020: 9713 075b a05a 3ecd 1da8 4633 b1f3 8010 ...[.Z>...F3.... 0x0030: 00e3 31e3 0000 0101 080a e795 ce09 1f9f ..1............. 0x0040: ddef .. 16:33:28.672562 IP MQTT.ibm-mqisdp > SUB.41050: Flags [P.] seq 1:5 ack 42 win 227 options [nop nop TS val 3885354505 ecr 530570735] length 4 0x0000: feee 809f 3247 5254 00e4 a55c 0800 4500 ....2GRT...\..E. 0x0010: 0038 d3a2 4000 4006 d2a6 ac10 000c 5147 .8..@.@.......QG 0x0020: 9713 075b a05a 3ecd 1da8 4633 b1f3 8018 ...[.Z>...F3.... 0x0030: 00e3 11d5 0000 0101 080a e795 ce09 1f9f ................ 0x0040: ddef 2002 0000 ...... 16:33:28.675753 IP SUB.41050 > MQTT.ibm-mqisdp: Flags [.] ack 5 win 229 options [nop nop TS val 530570739 ecr 3885354505] length 0 0x0000: 5254 00e4 a55c feee 809f 3247 0800 4568 RT...\....2G..Eh 0x0010: 0034 5875 4000 3806 5570 5147 9713 ac10 .4Xu@.8.UpQG.... 0x0020: 000c a05a 075b 4633 b1f3 3ecd 1dac 8010 ...Z.[F3..>..... 0x0030: 00e5 31d9 0000 0101 080a 1f9f ddf3 e795 ..1............. 0x0040: ce09 .. 16:33:28.675772 IP SUB.41050 > MQTT.ibm-mqisdp: Flags [P.] seq 42:56 ack 5 win 229 options [nop nop TS val 530570739 ecr 3885354505] length 14 0x0000: 5254 00e4 a55c feee 809f 3247 0800 4568 RT...\....2G..Eh 0x0010: 0042 5876 4000 3806 5561 5147 9713 ac10 .BXv@.8.UaQG.... 0x0020: 000c a05a 075b 4633 b1f3 3ecd 1dac 8018 ...Z.[F3..>..... 0x0030: 00e5 46b6 0000 0101 080a 1f9f ddf3 e795 ..F............. 0x0040: ce09 820c 0001 0007 6363 6e65 742f 2300 ........ccnet/#. 16:33:28.675823 IP MQTT.ibm-mqisdp > SUB.41050: Flags [P.] seq 5:10 ack 56 win 227 options [nop nop TS val 3885354508 ecr 530570739] length 5 0x0000: feee 809f 3247 5254 00e4 a55c 0800 4500 ....2GRT...\..E. 0x0010: 0039 d3a3 4000 4006 d2a4 ac10 000c 5147 .9..@.@.......QG 0x0020: 9713 075b a05a 3ecd 1dac 4633 b201 8018 ...[.Z>...F3.... 0x0030: 00e3 a1b8 0000 0101 080a e795 ce0c 1f9f ................ 0x0040: ddf3 9003 0001 00 ....... 16:33:28.719501 IP SUB.41050 > MQTT.ibm-mqisdp: Flags [.] ack 10 win 229 options [nop nop TS val 530570783 ecr 3885354508] length 0 0x0000: 5254 00e4 a55c feee 809f 3247 0800 4568 RT...\....2G..Eh 0x0010: 0034 5877 4000 3806 556e 5147 9713 ac10 .4Xw@.8.UnQG.... 0x0020: 000c a05a 075b 4633 b201 3ecd 1db1 8010 ...Z.[F3..>..... 0x0030: 00e5 3197 0000 0101 080a 1f9f de1f e795 ..1............. 0x0040: ce0c ..

终止mosquitto_sub命令获得如下报文: ================================= 16:29:54.745664 IP 81.71.151.19.40510 > 172.16.0.12.ibm-mqisdp: Flags [F.] seq 58 ack 12 win 229 options [nop nop TS val 530356809 ecr 3885119146] length 0 0x0000: 5254 00e4 a55c feee 809f 3247 0800 4568 RT...\....2G..Eh 0x0010: 0034 e1fc 4000 3806 cbe8 5147 9713 ac10 .4..@.8...QG.... 0x0020: 000c 9e3e 075b 0e6c ea6f 989b b7f8 8011 ...>.[.l.o...... 0x0030: 00e5 1a34 0000 0101 080a 1f9c 9a49 e792 ...4.........I.. 0x0040: 36aa 6. 16:29:54.745761 IP 172.16.0.12.ibm-mqisdp > 81.71.151.19.40510: Flags [F.] seq 12 ack 59 win 227 options [nop nop TS val 3885140578 ecr 530356809] length 0 0x0000: feee 809f 3247 5254 00e4 a55c 0800 4500 ....2GRT...\..E. 0x0010: 0034 fbe4 4000 4006 aa68 ac10 000c 5147 .4..@.@..h....QG 0x0020: 9713 075b 9e3e 989b b7f8 0e6c ea70 8011 ...[.>.....l.p.. 0x0030: 00e3 c67c 0000 0101 080a e792 8a62 1f9c ...|.........b.. 0x0040: 9a49 .I 16:29:54.751445 IP 81.71.151.19.40510 > 172.16.0.12.ibm-mqisdp: Flags [.] ack 13 win 229 options [nop nop TS val 530356812 ecr 3885140578] length 0 0x0000: 5254 00e4 a55c feee 809f 3247 0800 4568 RT...\....2G..Eh 0x0010: 0034 e1fd 4000 3806 cbe7 5147 9713 ac10 .4..@.8...QG.... 0x0020: 000c 9e3e 075b 0e6c ea70 989b b7f9 8010 ...>.[.l.p...... 0x0030: 00e5 c677 0000 0101 080a 1f9c 9a4c e792 ...w.........L.. 0x0040: 8a62 .b

# 执行mosquitto_pub后得到的报文如下: 16:36:40.721513 IP 81.71.151.19.41390 > 172.16.0.12.ibm-mqisdp: Flags [S] seq 2807988728 win 29200 options [mss 1424 sackOK TS val 530762785 ecr 0 nop wscale 7] length 0 0x0000: 5254 00e4 a55c feee 809f 3247 0800 4568 RT...\....2G..Eh 0x0010: 003c 5dd0 4000 3806 500d 5147 9713 ac10 .<].@.8.P.QG.... 0x0020: 000c a1ae 075b a75e 81f8 0000 0000 a002 .....[.^........ 0x0030: 7210 8378 0000 0204 0590 0402 080a 1fa2 r..x............ 0x0040: cc21 0000 0000 0103 0307 .!........ 16:36:40.721585 IP 172.16.0.12.ibm-mqisdp > 81.71.151.19.41390: Flags [S.] seq 4236199326 ack 2807988729 win 28960 options [mss 1460 sackOK TS val 3885546554 ecr 530762785 nop wscale 7] length 0 0x0000: feee 809f 3247 5254 00e4 a55c 0800 4500 ....2GRT...\..E. 0x0010: 003c 0000 4000 4006 a645 ac10 000c 5147 .<..@.@..E....QG 0x0020: 9713 075b a1ae fc7f 459e a75e 81f9 a012 ...[....E..^.... 0x0030: 7120 9e41 0000 0204 05b4 0402 080a e798 q..A............ 0x0040: bc3a 1fa2 cc21 0103 0307 .:...!.... 16:36:40.724732 IP 81.71.151.19.41390 > 172.16.0.12.ibm-mqisdp: Flags [.] ack 1 win 229 options [nop nop TS val 530762788 ecr 3885546554] length 0 0x0000: 5254 00e4 a55c feee 809f 3247 0800 4568 RT...\....2G..Eh 0x0010: 0034 5dd1 4000 3806 5014 5147 9713 ac10 .4].@.8.P.QG.... 0x0020: 000c a1ae 075b a75e 81f9 fc7f 459f 8010 .....[.^....E... 0x0030: 00e5 3d46 0000 0101 080a 1fa2 cc24 e798 ..=F.........$.. 0x0040: bc3a .: 16:36:40.724750 IP PUB.41390 > MQTT.ibm-mqisdp: Flags [P.] seq 1:42 ack 1 win 229 options [nop nop TS val 530762788 ecr 3885546554] length 41 0x0000: 5254 00e4 a55c feee 809f 3247 0800 4568 RT...\....2G..Eh 0x0010: 005d 5dd2 4000 3806 4fea 5147 9713 ac10 .]].@.8.O.QG.... 0x0020: 000c a1ae 075b a75e 81f9 fc7f 459f 8018 .....[.^....E... 0x0030: 00e5 40ef 0000 0101 080a 1fa2 cc24 e798 ..@..........$.. 0x0040: bc3a 1027 0006 4d51 4973 6470 03c2 003c .:.'..MQIsdp...< 0x0050: 0007 636c 6965 6e74 3300 0563 636e 6574 ..client3..ccnet 0x0060: 0009 6363 6e65 7430 3930 31 ..ccnet0901 16:36:40.724787 IP 172.16.0.12.ibm-mqisdp > 81.71.151.19.41390: Flags [.] ack 42 win 227 options [nop nop TS val 3885546557 ecr 530762788] length 0 0x0000: feee 809f 3247 5254 00e4 a55c 0800 4500 ....2GRT...\..E. 0x0010: 0034 f9a2 4000 4006 acaa ac10 000c 5147 .4..@.@.......QG 0x0020: 9713 075b a1ae fc7f 459f a75e 8222 8010 ...[....E..^.".. 0x0030: 00e3 3d1c 0000 0101 080a e798 bc3d 1fa2 ..=..........=.. 0x0040: cc24 .$ 16:36:40.724978 IP 172.16.0.12.ibm-mqisdp > 81.71.151.19.41390: Flags [P.] seq 1:5 ack 42 win 227 options [nop nop TS val 3885546557 ecr 530762788] length 4 0x0000: feee 809f 3247 5254 00e4 a55c 0800 4500 ....2GRT...\..E. 0x0010: 0038 f9a3 4000 4006 aca5 ac10 000c 5147 .8..@.@.......QG 0x0020: 9713 075b a1ae fc7f 459f a75e 8222 8018 ...[....E..^.".. 0x0030: 00e3 1d0e 0000 0101 080a e798 bc3d 1fa2 .............=.. 0x0040: cc24 2002 0000 .$.... 16:36:40.728114 IP 81.71.151.19.41390 > 172.16.0.12.ibm-mqisdp: Flags [.] ack 5 win 229 options [nop nop TS val 530762791 ecr 3885546557] length 0 0x0000: 5254 00e4 a55c feee 809f 3247 0800 4568 RT...\....2G..Eh 0x0010: 0034 5dd3 4000 3806 5012 5147 9713 ac10 .4].@.8.P.QG.... 0x0020: 000c a1ae 075b a75e 8222 fc7f 45a3 8010 .....[.^."..E... 0x0030: 00e5 3d13 0000 0101 080a 1fa2 cc27 e798 ..=..........'.. 0x0040: bc3d .= 16:36:40.728144 IP PUB.41390 > MQTT.ibm-mqisdp: Flags [P.] seq 42:82 ack 5 win 229 options [nop nop TS val 530762791 ecr 3885546557] length 40 0x0000: 5254 00e4 a55c feee 809f 3247 0800 4568 RT...\....2G..Eh 0x0010: 005c 5dd4 4000 3806 4fe9 5147 9713 ac10 .\].@.8.O.QG.... 0x0020: 000c a1ae 075b a75e 8222 fc7f 45a3 8018 .....[.^."..E... 0x0030: 00e5 a8af 0000 0101 080a 1fa2 cc27 e798 .............'.. 0x0040: bc3d 3026 0006 6363 6e65 742f 3132 3334 .=0&..ccnet/1234 0x0050: 3536 3738 3930 3132 3334 3536 3738 3930 5678901234567890 0x0060: 3132 3334 3536 3738 3930 1234567890 16:36:40.728146 IP 81.71.151.19.41390 > 172.16.0.12.ibm-mqisdp: Flags [FP.] seq 82:84 ack 5 win 229 options [nop nop TS val 530762791 ecr 3885546557] length 2 0x0000: 5254 00e4 a55c feee 809f 3247 0800 4568 RT...\....2G..Eh 0x0010: 0036 5dd5 4000 3806 500e 5147 9713 ac10 .6].@.8.P.QG.... 0x0020: 000c a1ae 075b a75e 824a fc7f 45a3 8019 .....[.^.J..E... 0x0030: 00e5 5cdf 0000 0101 080a 1fa2 cc27 e798 ..\..........'.. 0x0040: bc3d e000 .=.. 16:36:40.728230 IP MQTT.ibm-mqisdp > SUB.41050: Flags [P.] seq 96:136 ack 62 win 227 options [nop nop TS val 3885546560 ecr 530753903] length 40 0x0000: feee 809f 3247 5254 00e4 a55c 0800 4500 ....2GRT...\..E. 0x0010: 005c d3a9 4000 4006 d27b ac10 000c 5147 .\..@.@..{....QG 0x0020: 9713 075b a05a 3ecd 1e07 4633 b207 8018 ...[.Z>...F3.... 0x0030: 00e3 e34f 0000 0101 080a e798 bc40 1fa2 ...O.........@.. 0x0040: a96f 3026 0006 6363 6e65 742f 3132 3334 .o0&..ccnet/1234 0x0050: 3536 3738 3930 3132 3334 3536 3738 3930 5678901234567890 0x0060: 3132 3334 3536 3738 3930 1234567890 16:36:40.728288 IP 172.16.0.12.ibm-mqisdp > 81.71.151.19.41390: Flags [.] ack 85 win 227 options [nop nop TS val 3885546561 ecr 530762791] length 0 0x0000: feee 809f 3247 5254 00e4 a55c 0800 4500 ....2GRT...\..E. 0x0010: 0034 f9a4 4000 4006 aca8 ac10 000c 5147 .4..@.@.......QG 0x0020: 9713 075b a1ae fc7f 45a3 a75e 824d 8010 ...[....E..^.M.. 0x0030: 00e3 3ce6 0000 0101 080a e798 bc41 1fa2 ..<..........A.. 0x0040: cc27 .' 16:36:40.728367 IP 172.16.0.12.ibm-mqisdp > 81.71.151.19.41390: Flags [F.] seq 5 ack 85 win 227 options [nop nop TS val 3885546561 ecr 530762791] length 0 0x0000: feee 809f 3247 5254 00e4 a55c 0800 4500 ....2GRT...\..E. 0x0010: 0034 f9a5 4000 4006 aca7 ac10 000c 5147 .4..@.@.......QG 0x0020: 9713 075b a1ae fc7f 45a3 a75e 824d 8011 ...[....E..^.M.. 0x0030: 00e3 3ce5 0000 0101 080a e798 bc41 1fa2 ..<..........A.. 0x0040: cc27 .' 16:36:40.731431 IP 81.71.151.19.41050 > 172.16.0.12.ibm-mqisdp: Flags [.] ack 136 win 229 options [nop nop TS val 530762794 ecr 3885546560] length 0 0x0000: 5254 00e4 a55c feee 809f 3247 0800 4568 RT...\....2G..Eh 0x0010: 0034 5880 4000 3806 5565 5147 9713 ac10 .4X.@.8.UeQG.... 0x0020: 000c a05a 075b 4633 b207 3ecd 1e2f 8010 ...Z.[F3..>../.. 0x0030: 00e5 54ce 0000 0101 080a 1fa2 cc2a e798 ..T..........*.. 0x0040: bc40 .@ 16:36:40.731575 IP 81.71.151.19.41390 > 172.16.0.12.ibm-mqisdp: Flags [.] ack 6 win 229 options [nop nop TS val 530762795 ecr 3885546561] length 0 0x0000: 5254 00e4 a55c feee 809f 3247 0800 4568 RT...\....2G..Eh 0x0010: 0034 0000 4000 3806 ade5 5147 9713 ac10 .4..@.8...QG.... 0x0020: 000c a1ae 075b a75e 824d fc7f 45a4 8010 .....[.^.M..E... 0x0030: 00e5 3cdf 0000 0101 080a 1fa2 cc2b e798 ..<.......... .. 0x0040: bc41 .A

去掉TCP握手和收报报文的常规交互,可知道MQTT订阅发布的完整时序如下:

mqtt为什么是物联网协议(物联网平台的基础组件之一MQTT)(2)

MQTT发布订阅的实际交互时序图

可以看到AUHT、SUB、PUB、SEND_MESSAGE的报文非常精简,基本只是对必须传送的字段增加了两个字节的长度,因此其对带宽是非常节省的。

再分析下支持websockets时的通讯时序

# 启动对9001端口的监视 tcpdump -n -XX -i eth0 port 9001 # 订阅指定主题的消息 mosquitto_sub -h 172.16.0.12 -t "topic/#" -u user -P password -i "client1"

#编写一个基于websockets访问mqtt的页面,如下亲测通过; 点击init按钮 <html> <head> <script type="text/javascript" src="https://cdnjs.cloudflare.com/ajax/libs/paho-mqtt/1.0.2/mqttws31.js"></script> </head> <body> <script> var mqtt; var host = '81.71.87.37'; var port = 9001; // onConnect 事件 function onConnect() { console.log('connected.'); /* var raw_message = 'Hello World!'; message = new Paho.MQTT.Message(raw_message); message.destinationName = 'ccnet/up/abc'; console.log('sending message: ' raw_message ); mqtt.send(message); */ // 订阅 download topic var subOptions = { qos: 1 onSuccess: onSubscribe }; mqtt.subscribe('ccnet/#' subOptions); } function onSend() { console.log('onSend.'); var raw_message = 'Hello World!'; message = new Paho.MQTT.Message(raw_message); message.destinationName = 'ccnet/up/abc'; console.log('sending message: ' raw_message ); mqtt.send(message); } // 订阅主题成功事件 function onSubscribe(context) { console.log('subscribe success'); console.log(context); } // 连接失败事件 function onFailure(message) { console.log('connect failed.'); } // onMessageArrived 事件 function onMessageArrived(message) { console.log('new message arrived...'); console.log(message.payloadString); } // 建立 MQTT websocket 连接 function MQTTconnect() { console.log('connecting to ' host ':' port); mqtt = new Paho.MQTT.Client(host port 'clientid'); var options = { timeout: 3 onSuccess: onConnect onFailure: onFailure userName: 'ccnet' password: 'ccnet0901' mqttVersion: 4 }; mqtt.onMessageArrived = onMessageArrived; mqtt.connect(options); } </script> <input type="button" value="Init" onclick="javascript:MQTTconnect();"/> <input type="button" value="Send" onclick="javascript:onSend();"/> </body> </html>

# 发布消息到指定主题 mosquitto_pub -h 172.16.0.12 -t "topic/" -u user -P password -i "client3" -m "1234567890123456789012345678901234567890"

TCPDUMP抓取的报文如下:

# 点击WEB页面上的Init按钮之后 18:11:49.183098 IP 14.150.108.187.50999 > 172.16.0.12.etlservicemgr: Flags [S] seq 3659468570 win 64240 options [mss 1360 nop wscale 8 nop nop sackOK] length 0 0x0000: 5254 00e4 a55c feee 809f 3247 0800 4568 RT...\....2G..Eh 0x0010: 0034 7b4e 4000 7206 65a0 0e96 6cbb ac10 .4{N@.r.e...l... 0x0020: 000c c737 2329 da1f 0f1a 0000 0000 8002 ...7#).......... 0x0030: faf0 797b 0000 0204 0550 0103 0308 0101 ..y{.....P...... 0x0040: 0402 .. 18:11:49.183188 IP 172.16.0.12.etlservicemgr > 14.150.108.187.50999: Flags [S.] seq 3730879023 ack 3659468571 win 29200 options [mss 1460 nop nop sackOK nop wscale 7] length 0 0x0000: feee 809f 3247 5254 00e4 a55c 0800 4500 ....2GRT...\..E. 0x0010: 0034 0000 4000 4006 1357 ac10 000c 0e96 .4..@.@..W...... 0x0020: 6cbb 2329 c737 de60 b22f da1f 0f1b 8012 l.#).7.`./...... 0x0030: 7210 7157 0000 0204 05b4 0101 0402 0103 r.qW............ 0x0040: 0307 .. 18:11:49.223085 IP 14.150.108.187.50999 > 172.16.0.12.etlservicemgr: Flags [.] ack 1 win 515 length 0 0x0000: 5254 00e4 a55c feee 809f 3247 0800 4568 RT...\....2G..Eh 0x0010: 0028 7b4f 4000 7206 65ab 0e96 6cbb ac10 .({O@.r.e...l... 0x0020: 000c c737 2329 da1f 0f1b de60 b230 5010 ...7#).....`.0P. 0x0030: 0203 2237 0000 .."7.. 18:11:49.247331 IP Browser.50999 > MQTT.etlservicemgr: Flags [P.] seq 1:511 ack 1 win 515 length 510 0x0000: 5254 00e4 a55c feee 809f 3247 0800 4568 RT...\....2G..Eh 0x0010: 0226 7b50 4000 7206 63ac 0e96 6cbb ac10 .&{P@.r.c...l... 0x0020: 000c c737 2329 da1f 0f1b de60 b230 5018 ...7#).....`.0P. 0x0030: 0203 d122 0000 4745 5420 2f6d 7174 7420 ..."..GET./mqtt. 0x0040: 4854 5450 2f31 2e31 0d0a 486f 7374 3a20 HTTP/1.1..Host:. 0x0050: 3831 2e37 312e 3837 2e33 373a 3930 3031 81.71.87.37:9001 0x0060: 0d0a 436f 6e6e 6563 7469 6f6e 3a20 5570 ..Connection:.Up 0x0070: 6772 6164 650d 0a50 7261 676d 613a 206e grade..Pragma:.n 0x0080: 6f2d 6361 6368 650d 0a43 6163 6865 2d43 o-cache..Cache-C 0x0090: 6f6e 7472 6f6c 3a20 6e6f 2d63 6163 6865 ontrol:.no-cache 0x00a0: 0d0a 5573 6572 2d41 6765 6e74 3a20 4d6f ..User-Agent:.Mo 0x00b0: 7a69 6c6c 612f 352e 3020 2857 696e 646f zilla/5.0.(Windo 0x00c0: 7773 204e 5420 3130 2e30 3b20 5769 6e36 ws.NT.10.0;.Win6 0x00d0: 343b 2078 3634 2920 4170 706c 6557 6562 4;.x64).AppleWeb 0x00e0: 4b69 742f 3533 372e 3336 2028 4b48 544d Kit/537.36.(KHTM 0x00f0: 4c2c 206c 696b 6520 4765 636b 6f29 2043 L .like.Gecko).C 0x0100: 6872 6f6d 652f 3130 312e 302e 3439 3531 hrome/101.0.4951 0x0110: 2e36 3720 5361 6661 7269 2f35 3337 2e33 .67.Safari/537.3 0x0120: 360d 0a55 7067 7261 6465 3a20 7765 6273 6..Upgrade:.webs 0x0130: 6f63 6b65 740d 0a4f 7269 6769 6e3a 206e ocket..Origin:.n 0x0140: 756c 6c0d 0a53 6563 2d57 6562 536f 636b ull..Sec-WebSock 0x0150: 6574 2d56 6572 7369 6f6e 3a20 3133 0d0a et-Version:.13.. 0x0160: 4163 6365 7074 2d45 6e63 6f64 696e 673a Accept-Encoding: 0x0170: 2067 7a69 702c 2064 6566 6c61 7465 0d0a .gzip .deflate.. 0x0180: 4163 6365 7074 2d4c 616e 6775 6167 653a Accept-Language: 0x0190: 207a 682d 434e 2c7a 683b 713d 302e 390d .zh-CN zh;q=0.9. 0x01a0: 0a53 6563 2d57 6562 536f 636b 6574 2d4b .Sec-WebSocket-K 0x01b0: 6579 3a20 7938 796a 3756 7858 624b 576f ey:.y8yj7VxXbKWo 0x01c0: 4f45 6962 3248 7176 4b51 3d3d 0d0a 5365 OEib2HqvKQ==..Se 0x01d0: 632d 5765 6253 6f63 6b65 742d 4578 7465 c-WebSocket-Exte 0x01e0: 6e73 696f 6e73 3a20 7065 726d 6573 7361 nsions:.permessa 0x01f0: 6765 2d64 6566 6c61 7465 3b20 636c 6965 ge-deflate;.clie 0x0200: 6e74 5f6d 6178 5f77 696e 646f 775f 6269 nt_max_window_bi 0x0210: 7473 0d0a 5365 632d 5765 6253 6f63 6b65 ts..Sec-WebSocke 0x0220: 742d 5072 6f74 6f63 6f6c 3a20 6d71 7474 t-Protocol:.mqtt 0x0230: 0d0a 0d0a .... 18:11:49.247360 IP 172.16.0.12.etlservicemgr > 14.150.108.187.50999: Flags [.] ack 511 win 237 length 0 0x0000: feee 809f 3247 5254 00e4 a55c 0800 4500 ....2GRT...\..E. 0x0010: 0028 653f 4000 4006 ae23 ac10 000c 0e96 .(e?@.@..#...... 0x0020: 6cbb 2329 c737 de60 b230 da1f 1119 5010 l.#).7.`.0....P. 0x0030: 00ed 214f 0000 ..!O.. 18:11:49.323395 IP 172.16.0.12.etlservicemgr > 14.150.108.187.50999: Flags [P.] seq 1:160 ack 511 win 237 length 159 0x0000: feee 809f 3247 5254 00e4 a55c 0800 4500 ....2GRT...\..E. 0x0010: 00c7 6540 4000 4006 ad83 ac10 000c 0e96 ..e@@.@......... 0x0020: 6cbb 2329 c737 de60 b230 da1f 1119 5018 l.#).7.`.0....P. 0x0030: 00ed df2c 0000 4854 5450 2f31 2e31 2031 ... ..HTTP/1.1.1 0x0040: 3031 2053 7769 7463 6869 6e67 2050 726f 01.Switching.Pro 0x0050: 746f 636f 6c73 0d0a 5570 6772 6164 653a tocols..Upgrade: 0x0060: 2057 6562 536f 636b 6574 0d0a 436f 6e6e .WebSocket..Conn 0x0070: 6563 7469 6f6e 3a20 5570 6772 6164 650d ection:.Upgrade. 0x0080: 0a53 6563 2d57 6562 536f 636b 6574 2d41 .Sec-WebSocket-A 0x0090: 6363 6570 743a 204a 6845 6544 4534 6468 ccept:.JhEeDE4dh 0x00a0: 6462 2b4b 6a47 4f52 452b 595a 7176 424b db KjGORE YZqvBK 0x00b0: 2f34 3d0d 0a53 6563 2d57 6562 536f 636b /4=..Sec-WebSock 0x00c0: 6574 2d50 726f 746f 636f 6c3a 206d 7174 et-Protocol:.mqt 0x00d0: 740d 0a0d 0a t.... 18:11:49.392070 IP 14.150.108.187.50999 > 172.16.0.12.etlservicemgr: Flags [P.] seq 511:557 ack 160 win 514 length 46 0x0000: 5254 00e4 a55c feee 809f 3247 0800 4568 RT...\....2G..Eh 0x0010: 0056 7b54 4000 7206 6578 0e96 6cbb ac10 .V{T@.r.ex..l... 0x0020: 000c c737 2329 da1f 1119 de60 b2cf 5018 ...7#).....`..P. 0x0030: 0202 7640 0000 82a8 a399 adbd b3bf adb9 ..v@............ 0x0040: eec8 f9e9 a75b ad81 a391 ced1 cafc c3c9 .....[.......... 0x0050: cafd adb8 c0fa c3d8 d799 a4de c0f7 c8c9 ................ 0x0060: 93a0 9d8c .... 18:11:49.392100 IP 172.16.0.12.etlservicemgr > 14.150.108.187.50999: Flags [.] ack 557 win 237 length 0 0x0000: feee 809f 3247 5254 00e4 a55c 0800 4500 ....2GRT...\..E. 0x0010: 0028 6541 4000 4006 ae21 ac10 000c 0e96 .(eA@.@..!...... 0x0020: 6cbb 2329 c737 de60 b2cf da1f 1147 5010 l.#).7.`.....GP. 0x0030: 00ed 2082 0000 ...... 18:11:49.392352 IP 172.16.0.12.etlservicemgr > 14.150.108.187.50999: Flags [P.] seq 160:166 ack 557 win 237 length 6 0x0000: feee 809f 3247 5254 00e4 a55c 0800 4500 ....2GRT...\..E. 0x0010: 002e 6542 4000 4006 ae1a ac10 000c 0e96 ..eB@.@......... 0x0020: 6cbb 2329 c737 de60 b2cf da1f 1147 5018 l.#).7.`.....GP. 0x0030: 00ed 7e6d 0000 8204 2002 0000 ..~m........ 18:11:49.443110 IP 14.150.108.187.50999 > 172.16.0.12.etlservicemgr: Flags [.] ack 166 win 514 length 0 0x0000: 5254 00e4 a55c feee 809f 3247 0800 4568 RT...\....2G..Eh 0x0010: 0028 7b56 4000 7206 65a4 0e96 6cbb ac10 .({V@.r.e...l... 0x0020: 000c c737 2329 da1f 1147 de60 b2d5 5010 ...7#)...G.`..P. 0x0030: 0202 1f67 0000 ...g.. 18:11:49.451571 IP 14.150.108.187.50999 > 172.16.0.12.etlservicemgr: Flags [P.] seq 557:577 ack 166 win 514 length 20 0x0000: 5254 00e4 a55c feee 809f 3247 0800 4568 RT...\....2G..Eh 0x0010: 003c 7b57 4000 7206 658f 0e96 6cbb ac10 .<{W@.r.e...l... 0x0020: 000c c737 2329 da1f 1147 de60 b2d5 5018 ...7#)...G.`..P. 0x0030: 0202 5568 0000 828e 2670 37fd a47c 37fc ..Uh....&p7..|7. 0x0040: 2677 549e 4815 43d2 0571 &wT.H.C..q 18:11:49.451667 IP 172.16.0.12.etlservicemgr > 14.150.108.187.50999: Flags [P.] seq 166:173 ack 577 win 237 length 7 0x0000: feee 809f 3247 5254 00e4 a55c 0800 4500 ....2GRT...\..E. 0x0010: 002f 6543 4000 4006 ae18 ac10 000c 0e96 ./eC@.@......... 0x0020: 6cbb 2329 c737 de60 b2d5 da1f 115b 5018 l.#).7.`.....[P. 0x0030: 00ed 0d4f 0000 8205 9003 0001 01 ...O......... 18:11:49.543376 IP 14.150.108.187.50999 > 172.16.0.12.etlservicemgr: Flags [.] ack 173 win 514 length 0 0x0000: 5254 00e4 a55c feee 809f 3247 0800 4568 RT...\....2G..Eh 0x0010: 0028 7b59 4000 7206 65a1 0e96 6cbb ac10 .({Y@.r.e...l... 0x0020: 000c c737 2329 da1f 115b de60 b2dc 5010 ...7#)...[.`..P. 0x0030: 0202 1f4c 0000 ...L.. # 点击Send按钮之后 18:16:59.642995 IP Browser.50999 > MQTT.etlservicemgr: Flags [P.] seq 677:711 ack 249 win 514 length 34 0x0000: 5254 00e4 a55c feee 809f 3247 0800 4568 RT...\....2G..Eh 0x0010: 004a 7c2e 4000 7206 64aa 0e96 6cbb ac10 .J|.@.r.d...l... 0x0020: 000c c737 2329 da1f 11bf de60 b328 5018 ...7#).....`.(P. 0x0030: 0202 736b 0000 829c 69c7 926a 59dd 9266 ..sk....i..jY..f 0x0040: 0aa4 fc0f 1de8 e71a 46a6 f009 21a2 fe06 ........F...!... 0x0050: 06e7 c505 1bab f64b .......K 18:16:59.643148 IP MQTT.etlservicemgr > Browser.50999: Flags [P.] seq 249:279 ack 711 win 237 length 30 0x0000: feee 809f 3247 5254 00e4 a55c 0800 4500 ....2GRT...\..E. 0x0010: 0046 654b 4000 4006 adf9 ac10 000c 0e96 .FeK@.@......... 0x0020: 6cbb 2329 c737 de60 b328 da1f 11e1 5018 l.#).7.`.(....P. 0x0030: 00ed ce09 0000 821c 301a 000c 6363 6e65 ........0...ccne 0x0040: 742f 7570 2f61 6263 4865 6c6c 6f20 576f t/up/abcHello.Wo 0x0050: 726c 6421 rld! 18:16:59.743220 IP 14.150.108.187.50999 > 172.16.0.12.etlservicemgr: Flags [.] ack 279 win 514 length 0 0x0000: 5254 00e4 a55c feee 809f 3247 0800 4568 RT...\....2G..Eh 0x0010: 0028 7c30 4000 7206 64ca 0e96 6cbb ac10 .(|0@.r.d...l... 0x0020: 000c c737 2329 da1f 11e1 de60 b346 5010 ...7#).....`.FP. 0x0030: 0202 1e5c 0000 ...\..

# 执行发布消息命令之后 17:56:50.992944 IP MQTT.etlservicemgr > Browser.50939: Flags [P.] seq 205:247 ack 675 win 237 length 42 0x0000: feee 809f 3247 5254 00e4 a55c 0800 4500 ....2GRT...\..E. 0x0010: 0052 e2f9 4000 4006 303f ac10 000c 0e96 .R..@.@.0?...... 0x0020: 6cbb 2329 c6fb c3b7 103a 2e40 d9e6 5018 l.#).....:.@..P. 0x0030: 00ed aaae 0000 8228 3026 0006 6363 6e65 .......(0&..ccne 0x0040: 742f 3132 3334 3536 3738 3930 3132 3334 t/12345678901234 0x0050: 3536 3738 3930 3132 3334 3536 3738 3930 5678901234567890 17:56:51.100524 IP 14.150.108.187.50939 > 172.16.0.12.etlservicemgr: Flags [.] ack 247 win 514 length 0 0x0000: 5254 00e4 a55c feee 809f 3247 0800 4568 RT...\....2G..Eh 0x0010: 0028 77db 4000 7206 691f 0e96 6cbb ac10 .(w.@.r.i...l... 0x0020: 000c c6fb 2329 2e40 d9e6 c3b7 1064 5010 ....#).@.....dP. 0x0030: 0202 bffd 0000 ......

可看到基于websockets的通讯整体协作图如下:

mqtt为什么是物联网协议(物联网平台的基础组件之一MQTT)(3)

MQTT在websockets下的工作模

可以看到除了在建立websockets时,有较大的http头信息,其余仍然很精简。而且websocket已经对Browser上送的AUTH、SUB、PUB进行了加密处理,但是对于下发到Browser的信息并没有进行加密处理

使用Mosquitto搭建支持Websockets的MQTT服务

这里使用了mosquitto-2.0.11,下载源码后,修改下config.mk文件,将WITH_WEBSOCKETS打开,如下

# Build with websockets support on the broker. WITH_WEBSOCKETS:=yes

这里是在centos下工作的,如果没有websockets库,需要安装

yum install libwebsockets* -y

然后就是一路的make,make install,之后配置下LD_LIBRARY_PATH的环境变量,就可以开始工作了。

LD_LIBRARY_PATH=:/root/setup/mosquitto-2.0.11/lib:/root/setup/cJSON-1.7.14

配置mosquitto环境,可建立一个专门的目录,将mosquitto.conf文件拷贝过来修改,目录结构如下:

<root@VM-0-12-centos:/mqtt>tree . |-- aclfile # 访问控制文件 |-- log # 日志文件目录 | `-- mosquitto.log |-- mosquitto # mqtt运行目录 | |-- mosquitto.db | `-- pid.pid |-- mosquitto.conf #配置文件!!!IMPORTANT `-- pwfile # 用户的密码文件

#cat aclfile =========================================================== # This affects access control for clients with no username. topic read $SYS/# # This only affects clients with username "roger". user roger topic foo/bar # This affects all clients. pattern write $SYS/broker/connection/%c/state # Add 20210722 user ccnet topic read ccnet/# topic write ccnet/# ========================================================= # 创建用户密码文件pwfile touch pwfile mosquitto_passwd pwfile user #cat mosquitto.conf |grep -v "#" ========================================================= pid_file /home/release/soft/mqtt/mosquitto/pid.pid user release port 1883 listener 9001 protocol websockets bind_interface eth0 persistence true persistence_location /home/release/soft/mqtt/mosquitto allow_anonymous false password_file /home/release/soft/mqtt/pwfile acl_file /home/release/soft/mqtt/aclfile

运行Mosquitto

mosquitto -c mosquitto.conf -d

MQTT有很多实现,Mosquitto的魅力在于小而美。有很多开源的实现,基于nodejs、java等,也有商业版本的,更有一些云服务商直接将之PaaS化了。

例如,阿里云将MQTT定义为这样子。一些公司直接基于mqtt搭建其上的物模型,超赞!

mqtt为什么是物联网协议(物联网平台的基础组件之一MQTT)(4)

阿里云的MQTT服务

猜您喜欢: