<script src=\"https:\/\/unpkg.com\/mqtt\/dist\/mqtt.min.js\"><\/script><\/code><\/pre>\n\n\n\n
\n\n\n\n\u5b9a\u4e49\u57fa\u672c\u4fe1\u606f<\/h4>\n\n\n\n
Websocket \u4f7f\u7528ws\u534f\u8bae\uff0c\u6216mqtt<\/p>\n\n\n\n
Websocket TLS\/SSL\u4f7f\u7528wss\u534f\u8bae\uff0c\u5176\u4ed6\u7684\u534f\u8bae\u7c7b\u578b\u90fd\u4e0d\u884c\u3002<\/p>\n\n\n\n
\u7aef\u53e3\u9700\u8981\u5199\u5728URL\u7684\u540e\u9762<\/p>\n\n\n\n
\u6839\u636e\u5b98\u65b9\u6587\u6863\u201cMQTT-WebSocket \u7edf\u4e00\u4f7f\u7528 \/path<\/code> \u4f5c\u4e3a\u8fde\u63a5\u8def\u5f84\uff0c\u8fde\u63a5\u65f6\u9700\u6307\u660e\uff0c\u800c EMQX Broker \u4f7f\u7528\u7684\u8def\u5f84\u4e3a \/mqtt<\/code>\u3002\u201d<\/p>\n\n\n\n\u5982\u679c\u4f7f\u7528EMQX\u7684\u516c\u5171\u670d\u52a1\u5668\uff0c\u4f7f\u7528 Websocket<\/code> \u8fde\u63a5\uff0c\u670d\u52a1\u5668\u5730\u5740\u4e3abroker.emqx.io<\/code>\uff0c\u7aef\u53e3\u4e3a 8083 <\/code>\uff0c\u5373 broker.emqx.io:8083\/mqtt <\/code>\uff0c\u8fde\u63a5\u7528\u6237\u540d\u4e3a emqx<\/code> \uff0c\u5bc6\u7801\u4e3a public<\/code> \uff0c\u4e5f\u53ef\u4ee5\u4e0d\u586b\u3002 <\/p>\n\n\n\n\u5982\u679c\u4f7f\u7528\u79c1\u6709\u670d\u52a1\u5668\uff0c\u4f7f\u7528 Websocket TLS\/SSL <\/code>\u8fde\u63a5\uff0c\u670d\u52a1\u5668\u5730\u5740\u6839\u636e\u63a7\u5236\u53f0\u5177\u4f53\u4fe1\u606f\uff0c\u7aef\u53e3\u4e3a 8084 <\/code>\uff0c\u7528\u6237\u540d\u548c\u5bc6\u7801\u81ea\u5df1\u5728\u63a7\u5236\u53f0\u91cc\u5b9a\u4e49\u3002<\/p>\n\n\n\nconst connectUrl = 'ws:\/\/'\n \/\/\u6216wws:\/\/\nconst options = {\n connectTimeout: 4000,\n reconnectPeriod: 1000,\n clientId: '',\n \/\/\u8bbe\u5907ID\n username: '',\n \/\/\u8d26\u53f7,\u4e5f\u53ef\u5220\u53bb\u4e0d\u586b\n password: '',\n \/\/\u5bc6\u7801,\u4e5f\u53ef\u5220\u53bb\u4e0d\u586b\n clean: true,\n}<\/code><\/pre>\n\n\n\n\u8bbe\u5907ID\u53ef\u4ee5\u81ea\u5b9a\u4e49\uff0c\u4e5f\u53ef\u4ee5\u5728\u7ed3\u5c3e\u6dfb\u52a0\u8bbe\u5907\u7684IP\u5730\u5740\u7528\u4e8e\u533a\u5206\u8bbe\u5907\uff0c\u56e0\u4e3a\u5982\u679c\u5b58\u5728\u76f8\u540c\u7684\u8bbe\u5907ID\uff0c\u90a3\u4e48\u6240\u6709\u62e5\u6709\u76f8\u540c\u8bbe\u5907ID\u7684\u8bbe\u5907\u5c06\u4f1a\u4e0d\u65ad\u7684\u65ad\u5f00\u91cd\u8fde\u3002\u83b7\u53d6IP\u5730\u5740\u9700\u8981\u8c03\u7528\u5916\u90e8API\u3002\u4f7f\u7528\u4ee5\u4e0b\u4ee3\u7801\u5728\u5b9a\u4e49\u7684\u8bbe\u5907ID\u540e\u6dfb\u52a0\u4e0aIP\u5730\u5740\uff0c\u4e3a\u4e86\u4fdd\u9669\u8d77\u89c1\u9632\u6b62IP\u5730\u5740\u91cd\u590d\u5bfc\u81f4\u8bbe\u5907ID\u91cd\u590d\uff0c\u90a3\u4e48\u8fd8\u53ef\u4ee5\u5728IP\u5730\u5740\u540e\u518d\u52a0\u4e0a\u51e0\u4e2a\u968f\u673a\u5b57\u7b26\u3002<\/p>\n\n\n\n
function getIPAddress() \n{\n return fetch(\"https:\/\/api.ipify.org?format=json\") \n .then(response => response.json()) \n .then(data => { \n options.clientId += '-'+data.ip;\n options.clientId += '-' + Math.random().toString(16).substring(2, 8); \n }) \n .catch(error => { \n console.log(\"Error:\", error); \n }); \n}<\/code><\/pre>\n\n\n\n
\n\n\n\n\u5efa\u7acb\u8fde\u63a5<\/h4>\n\n\n\n
\u8fde\u63a5\u5230mqtt\u670d\u52a1\u5668\u7684\u8bed\u53e5\u5728 mqttConnet()<\/code> \u51fd\u6570\u5185\uff0c\u56e0\u4e3a\u5982\u679c\u5728\u8bbe\u5907ID\u540e\u6dfb\u52a0IP\u5730\u5740\uff0c\u9700\u8981\u4ece\u5916\u90e8API\u83b7\u53d6IP\u5730\u5740\uff0c\u4f46\u662f\u9700\u8981\u4e00\u5b9a\u7684\u65f6\u95f4\uff0c\u6240\u4ee5\u8fd9\u91cc\u4f7f\u7528\u4e86 async\/await <\/code>\uff0c\u5e76\u5728 mqttConnet()<\/code> \u51fd\u6570\u5185\u8c03\u7528 getIPAddress() <\/code>\u6765\u5bf9\u51fd\u6570\u8fdb\u884c\u963b\u585e\uff0c\u76f4\u5230\u83b7\u53d6\u5230IP\u5730\u5740\uff0c\u4ee5\u786e\u4fdd\u5728\u8fde\u63a5mqtt\u670d\u52a1\u5668\u65f6\u5df2\u7ecf\u83b7\u53d6\u5230IP\u5730\u5740\u5e76\u6dfb\u52a0\u5230\u8bbe\u5907ID\u540e\uff0c\u5426\u5219\u8fde\u63a5\u5230\u670d\u52a1\u5668\u65f6\u8fd8\u672a\u83b7\u5f97\u5230IP\u5730\u5740\u3002<\/p>\n\n\n\nvar client;\nconst qos=0;\n\nasync function mqttConnet() { \n await getIPAddress(); \n client = mqtt.connect(connectUrl, options);\n\n client.on('error', (error) => {\n console.log('\u8fde\u63a5\u5931\u8d25: ', error);\n client.end();\n });\n\n client.on('reconnect', () => {\n console.log('\u91cd\u8fde\u4e2d...');\n });\n\n client.on('connect', () => {\n console.log('\u8fde\u63a5\u6210\u529f:' + options.clientId);\n });\n\n client.on(\"close\", () => {\n console.log('\u5df2\u7ecf\u65ad\u5f00\u8fde\u63a5');\n });\n}\n<\/code><\/pre>\n\n\n\n
\n\n\n\n\u8ba2\u9605\u4e3b\u9898\u3001\u63a5\u6536\u53d1\u9001\u6d88\u606f\u7b49<\/h4>\n\n\n\n
\u5728 mqttConnet() <\/code>\u51fd\u6570\u7ed3\u5c3e\u6dfb\u52a0\u4ee5\u4e0b\u7a0b\u5e8f\u7528\u6765\u63a5\u6536\u6d88\u606f<\/p>\n\n\n\nclient.on('message', (topic, msg) => {\n console.log('\u6536\u5230\u6d88\u606f\uff1a');\n console.log(' \u4e3b\u9898\uff1a', topic);\n console.log(' \u6d88\u606f\uff1a', msg.toString());\n});\n<\/code><\/pre>\n\n\n\n\u8fd9\u91cc\u4f7f\u7528\u4e86 \u9ed8\u8ba4\u4e3b\u9898 \u7684\u6982\u5ff5\uff0c\u5982\u679c\u7a0b\u5e8f\u53ea\u4f7f\u7528\u4e00\u4e2a\u4e3b\u9898\u7684\u8bdd\uff0c\u53ef\u4ee5\u7528 setDefaultTopic(topic) <\/code>\u51fd\u6570\u8bbe\u7f6e\u9ed8\u8ba4\u4e3b\u9898\uff0c\u4e4b\u540e\u8c03\u7528\u8ba2\u9605\uff0c\u53d6\u6d88\u8ba2\u9605\uff0c\u53d1\u5e03\u6d88\u606f\u7684\u51fd\u6570\u65f6\u5c31\u53ef\u4ee5\u4e0d\u7528\u518d\u586b\u5199\u4e3b\u9898\u4e86\uff0c\u51fd\u6570\u9ed8\u8ba4\u53c2\u6570\u503c\u4e3a\u9ed8\u8ba4\u4e3b\u9898\u3002<\/p>\n\n\n\n\u4e5f\u53ef\u4ee5\u8ba2\u9605\u3001\u53d6\u6d88\u8ba2\u9605\u5230\u53d1\u5e03\u6d88\u606f\u5230\u591a\u4e2a\u4e0d\u540c\u7684\u4e3b\u9898\uff0c\u8fd9\u65f6\u53ea\u6709\u5176\u4e2d\u4e00\u4e2a\u4e3b\u9898\u53ef\u4ee5\u8bbe\u7f6e\u4e3a\u9ed8\u8ba4\u4e3b\u9898\uff0c\u5176\u4ed6\u4e3b\u9898\u9700\u8981\u624b\u52a8\u586b\u5199\u3002<\/p>\n\n\n\n
\nvar defaultTopic;\n\nfunction setDefaultTopic(topic){ \/\/\u8bbe\u7f6e\u9ed8\u8ba4\u4e3b\u9898\n defaultTopic = topic;\n}\n\nfunction subscribe(topic=defaultTopic){ \/\/\u8ba2\u9605\u4e3b\u9898\n client.subscribe(topic, {qos} ,(error) => {\n if (error) {\n console.log('\u8ba2\u9605\u5931\u8d25\uff1a',error);\n return;\n }\n console.log('\u8ba2\u9605\u4e3b\u9898\uff1a', topic);\n });\n}\n\nfunction unsubscribe(topic=defaultTopic){ \/\/\u53d6\u6d88\u8ba2\u9605\u4e3b\u9898\n client.unsubscribe(topic, {qos}, (error) => {\n if (error) {\n console.log('\u53d6\u6d88\u8ba2\u9605\u5931\u8d25\uff1a', error);\n return;\n }\n console.log('\u53d6\u6d88\u8ba2\u9605\u4e3b\u9898\uff1a', topic);\n });\n}\n\nfunction publish(payload, topic=defaultTopic){ \/\/\u53d1\u5e03\u6d88\u606f\n client.publish(topic, payload, { qos }, (error) => {\n if (error) {\n console.log('\u53d1\u5e03\u5931\u8d25\uff1a',error);\n return;\n }\n console.log('\u53d1\u5e03\u6210\u529f\uff1a');\n console.log(' \u4e3b\u9898\uff1a', topic);\n console.log(' \u6d88\u606f\uff1a', payload);\n });\n}\n\nfunction disconnect() \/\/\u65ad\u5f00\u8fde\u63a5\n{\n if (client.connected) {\n try {\n client.end(false, () => {\n console.log('\u65ad\u5f00\u8fde\u63a5')\n })\n } catch (error) {\n console.log('\u65ad\u5f00\u8fde\u63a5\u5931\u8d25:', error)\n }\n }\n}<\/code><\/pre>\n\n\n\n
\n\n\n\n\u5b8c\u6574\u4ee3\u7801\u793a\u4f8b<\/h4>\n\n\n\n<!DOCTYPE html>\n<html>\n <head>\n <meta charset=\"UTF-8\">\n <title>AIRCON<\/title>\n\n <script src=\"https:\/\/unpkg.com\/mqtt@5.0.3\/dist\/mqtt.min.js\"><\/script>\n <script>\n var IP='';\n const connectUrl = 'ws:\/\/broker.emqx.io:8083\/mqtt';\n const options = {\n connectTimeout: 4000,\n reconnectPeriod: 1000,\n clientIdHead: 'html',\n clean: true,\n };\n\n var client;\n var defaultTopic;\n const qos=0;\n\n function getIPAddress() \n {\n return fetch(\"https:\/\/api.ipify.org?format=json\") \n .then(response => response.json()) \n .then(data => { \n options.clientId = options.clientIdHead+'-'+data.ip;\n options.clientId += '-' + Math.random().toString(16).substring(2, 8); \n }) \n .catch(error => { \n console.log(\"Error:\", error); \n }); \n }\n \n\n mqttConnect();\n async function mqttConnect() { \n await getIPAddress(); \n client = mqtt.connect(connectUrl, options);\n\n client.on('error', (error) => {\n console.log('\u8fde\u63a5\u5931\u8d25: ', error);\n client.end();\n });\n\n client.on('reconnect', () => {\n console.log('\u91cd\u8fde\u4e2d...');\n });\n\n client.on('connect', () => {\n console.log('\u8fde\u63a5\u6210\u529f:' + options.clientId);\n });\n\n client.on(\"close\", () => {\n console.log('\u5df2\u7ecf\u65ad\u5f00\u8fde\u63a5');\n });\n\n client.on('message', (topic, msg) => {\n console.log('\u6536\u5230\u6d88\u606f\uff1a');\n console.log(' \u4e3b\u9898\uff1a', topic);\n console.log(' \u6d88\u606f\uff1a', msg.toString());\n });\n }\n\n function setDefaultTopic(topic){ \/\/\u8bbe\u7f6e\u9ed8\u8ba4\u4e3b\u9898\n defaultTopic = topic;\n console.log('\u8bbe\u7f6e\u9ed8\u8ba4\u4e3b\u9898\uff1a', topic);\n }\n\n function subscribe(topic=defaultTopic){ \/\/\u8ba2\u9605\u4e3b\u9898\n client.subscribe(topic, {qos} ,(error) => {\n if (error) {\n console.log('\u8ba2\u9605\u5931\u8d25\uff1a',error);\n return;\n }\n console.log('\u8ba2\u9605\u4e3b\u9898\uff1a', topic);\n });\n }\n\n function unsubscribe(topic=defaultTopic){ \/\/\u53d6\u6d88\u8ba2\u9605\u4e3b\u9898\n client.unsubscribe(topic, {qos}, (error) => {\n if (error) {\n console.log('\u53d6\u6d88\u8ba2\u9605\u5931\u8d25\uff1a', error);\n return;\n }\n console.log('\u53d6\u6d88\u8ba2\u9605\u4e3b\u9898\uff1a', topic);\n });\n }\n \n function publish(payload, topic=defaultTopic){ \/\/\u53d1\u5e03\u6d88\u606f\n client.publish(topic, payload, { qos }, (error) => {\n if (error) {\n console.log('\u53d1\u5e03\u5931\u8d25\uff1a',error);\n return;\n }\n console.log('\u53d1\u5e03\u6210\u529f\uff1a');\n console.log(' \u4e3b\u9898\uff1a', topic);\n console.log(' \u6d88\u606f\uff1a', payload);\n });\n }\n\n function disconnect() \/\/\u65ad\u5f00\u8fde\u63a5\n {\n if (client.connected) {\n try {\n client.end(false, () => {\n console.log('\u65ad\u5f00\u8fde\u63a5')\n })\n } catch (error) {\n console.log('\u65ad\u5f00\u8fde\u63a5\u5931\u8d25:', error)\n }\n }\n }\n <\/script>\n <\/head>\n\n <body>\n <input type=\"text\" id=\"defaultTopic\" value=\"\u8f93\u5165\u9ed8\u8ba4\u4e3b\u9898\"\/>\n <button onclick=\"setDefaultTopic(document.getElementById('defaultTopic').value)\" class=\"inputbutton\">\u8bbe\u7f6e\u9ed8\u8ba4\u4e3b\u9898<\/button>\n <button onclick=\"subscribe()\" class=\"inputbutton\">\u8ba2\u9605\u4e3b\u9898<\/button>\n <button onclick=\"publish('on')\" class=\"inputbutton\">\u5f00<\/button>\n <button onclick=\"publish('off')\" class=\"inputbutton\">\u5173<\/button>\n <button onclick=\"unsubscribe()\" class=\"inputbutton\">\u53d6\u6d88\u8ba2\u9605\u4e3b\u9898<\/button>\n <button onclick=\"disconnect()\" class=\"inputbutton\">\u65ad\u5f00\u8fde\u63a5<\/button>\n <button onclick=\"mqttConnect()\" class=\"inputbutton\">\u8fde\u63a5<\/button>\n <\/body>\n<\/html><\/code><\/pre>\n","protected":false},"excerpt":{"rendered":"\u7b80\u4ecb \u672c\u6587\u4e3b\u8981\u4ecb\u7ecd\u5982\u4f55\u5728Browser js\uff0c\u5373\u6d4f\u89c8\u5668\u73af\u5883\u4e0b\uff0c\u4f7f\u7528 HTML \u8fde\u63a5MQTT\u670d\u52a1\u5668\u3002 \u670d\u52a1\u5668\u4f7f\u7528EMQX\u4e3a\u4f8b\u3002\u90e8\u5206\u4ee3 …<\/p>","protected":false},"author":1,"featured_media":392,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[38,3],"tags":[26,25,12,22],"class_list":["post-330","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-38","category-3","tag-26","tag-25","tag-12","tag-22"],"_links":{"self":[{"href":"https:\/\/www.forillusion.com\/index.php\/wp-json\/wp\/v2\/posts\/330","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.forillusion.com\/index.php\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.forillusion.com\/index.php\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.forillusion.com\/index.php\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.forillusion.com\/index.php\/wp-json\/wp\/v2\/comments?post=330"}],"version-history":[{"count":1,"href":"https:\/\/www.forillusion.com\/index.php\/wp-json\/wp\/v2\/posts\/330\/revisions"}],"predecessor-version":[{"id":1770,"href":"https:\/\/www.forillusion.com\/index.php\/wp-json\/wp\/v2\/posts\/330\/revisions\/1770"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/www.forillusion.com\/index.php\/wp-json\/wp\/v2\/media\/392"}],"wp:attachment":[{"href":"https:\/\/www.forillusion.com\/index.php\/wp-json\/wp\/v2\/media?parent=330"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.forillusion.com\/index.php\/wp-json\/wp\/v2\/categories?post=330"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.forillusion.com\/index.php\/wp-json\/wp\/v2\/tags?post=330"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}