--<\/p>\n
\u4e4b\u524d\u4e00\u76f4\u4f7f\u7528 MQTT.js\uff0c\u5f8c\u4f86\u51fa\u73fe\u4e86\u300cWebSocket connection to 'ws:\/\/xxx\/mqtt' failed: Close received after close<\/a>\u300d\u932f\u8aa4\uff0c\u96d6\u7136\u6703\u81ea\u52d5\u91cd\u9023\uff0c\u4e0d\u904e\u5c31\u8981\u8655\u7406\u91cd\u9023\u521d\u59cb\u5316\u7684\u8a0a\u606f\u3002\u53ef\u4ee5\u8655\u7406\u4e0d\u904e\u5728 google \u8ffd\u7a76\u4e4b\u5f8c\uff0c\u5c31\u6c7a\u5b9a\u6539\u7528 Paho MQTT \u8a66\u8a66\u770b\uff0c\u7562\u7adf\u5728 Python \u4e5f\u662f\u4f7f\u7528 Paho MQTT \u7684\u7248\u672c\uff0c\u8aaa\u4e0d\u5b9a\u53ef\u4ee5\u89e3\u6c7a\u554f\u984c<\/p>\n --<\/p>\n Paho MQTT JavaScript 1.0.3<\/strong> \u7248\u672c\u622a\u81f3 2024\/07 \u53ea\u652f\u63f4 3.1.1\uff0c\u5c0d\u65bc\u7db2\u9801 WebSocket \u800c\u8a00\u4e26\u4e0d\u5f71\u97ff<\/p>\n --<\/p>\n --<\/p>\n \u5b89\u88dd\u4f7f\u7528 CDN\uff0cMQTT Broker \u4f7f\u7528\u4e86 HiveMQ \u7684<\/p>\n .connect() \u9078\u9805<\/p>\n \u5982\u679c Broker \u9700\u8981\u5e33\u865f\u3001\u5bc6\u78bc\uff0c\u5c31\u9700\u8981\u589e\u52a0 userName password \u9078\u9805<\/p>\n --<\/p>\n \u8a02\u95b1\u4e3b\u984c<\/p>\n \u53d6\u6d88\u8a02\u95b1\u4e3b\u984c<\/p>\n --<\/p>\n \u4f7f\u7528 JSON \u683c\u5f0f<\/p>\n --<\/p>\n \u63a5\u6536\u7684\u8a0a\u606f\u7d93\u904e\u8655\u7406\u8f49\u63db\u6210 JSON \u683c\u5f0f<\/p>\n messge \u53ef\u63a5\u6536\u5230<\/p>\n --<\/p>\n Paho MQTT \u51fa\u73fe\u9019\u500b\u932f\u8aa4\u7684\u8a71\u662f onMessageArrived \u63a5\u6536\u8a0a\u606f\u8655\u7406\u6642\u7a0b\u5f0f\u6709\u932f\u8aa4\uff0c\u5c0e\u81f4 WebSocket \u65b7\u7dda\uff0c\u9019\u6642 Paho \u6703\u6514\u622a\u932f\u8aa4\u52a0\u4e0a\u81ea\u5df1\u7684\u8cc7\u8a0a\u3002\u6240\u4ee5\u6703\u8b93\u4eba\u8aa4\u6703\u662f MQTT \u9023\u63a5\u554f\u984c\uff0c\u5176\u5be6\u53ea\u662f\u63a5\u53d7\u8a0a\u606f\u5167\u7684\u7a0b\u5f0f\u51fa\u932f\u3002<\/p>\n --<\/p>\n Paho MQTT \u78ba\u5be6\u89e3\u6c7a\u4e86 MQTT.js \u7684\u554f\u984c\uff0cPaho MQTT \u7684\u5fc3\u8df3\u4fdd\u6301\u529f\u80fd\u6bd4\u8f03\u6b63\u5e38\uff0c\u4e00\u5929\u7684\u6e2c\u8a66\u4e4b\u4e0b\u90fd\u662f\u7dad\u6301\u540c\u4e00\u500b\u9023\u63a5\uff0c\u4e26\u4e0d\u6703\u91cd\u65b0\u9023\u63a5\u3002\u53cd\u4e4b MQTT.js \u5247\u662f\u591a\u6b21\u91cd\u65b0\u9023\u63a5\uff0c\u4e0d\u77e5\u9053\u539f\u56e0\u70ba\u4f55\u3002<\/p>\n \u6700\u5f8c (2024\/07) Hoyo \u63a8\u85a6 JavaScript \u4f7f\u7528 Paho MQTT<\/p>\n --<\/p>\n\u53c3\u8003\u8cc7\u6e90<\/h2>\n
\n
\u7a0b\u5f0f\u78bc<\/h2>\n
<!DOCTYPE html>\r\n<html lang=\"zh-TW\">\r\n<head>\r\n <meta http-equiv=\"Content-Type\" content=\"text\/html;charset=UTF-8\">\r\n <meta charset=\"UTF-8\">\r\n <meta name=\"viewport\" content=\"width=device-width, initial-scale=1.0, maximum-scale=1.0, user-scalable=0\">\r\n <title>Paho MQTT JS Test<\/title>\r\n <link href=\"https:\/\/cdn.jsdelivr.net\/npm\/fastbootstrap@2.2.0\/dist\/css\/fastbootstrap.min.css\" rel=\"stylesheet\">\r\n <script src=\"https:\/\/cdn.jsdelivr.net\/npm\/paho-mqtt@1.0.3\/mqttws31-min.js\"><\/script>\r\n<\/head>\r\n<body>\r\n\r\n<button type=\"button\" class=\"btn btn-light\" onclick=\"send()\">Send<\/button>\r\n\r\n<script src=\"php.js?v=65cd879be1395\"><\/script>\r\n<script>\r\n let mc;\r\n let mqtt_client_id = window.localStorage.client_id + '_' + Math.random().toString(16);\r\n\r\n mc = new Paho.MQTT.Client(\"broker.hivemq.com\", 8884, mqtt_client_id);\r\n mc.connect({\r\n onSuccess: onConnect,\r\n useSSL: true\r\n });\r\n\r\n \/\/ set callback handlers\r\n mc.onConnectionLost = function (responseObject) {\r\n console.log(responseObject.errorCode);\r\n console.log(\"Connection Lost: \"+responseObject.errorMessage);\r\n }\r\n\r\n mc.onMessageArrived = function (message) {\r\n console.log(message.payloadString);\r\n }\r\n\r\n \/\/ Called when the connection is made\r\n function onConnect(){\r\n console.log(\"Connected!\");\r\n mc.subscribe(\"HootKaSelf\/lobby\", {\r\n onSuccess: function (){\r\n console.log('subscribeSuccess');\r\n },\r\n onFailure: function (){}\r\n });\r\n\r\n let message = new Paho.MQTT.Message(\"Hello\");\r\n message.destinationName = \"HootKaSelf\/lobby\";\r\n mc.send(message);\r\n }\r\n\r\n function send(){\r\n let message = new Paho.MQTT.Message(JSON.stringify({\r\n command: \"question\",\r\n room_id: window.localStorage.in_room,\r\n order: '\u5927\u5bb6\u597d',\r\n }));\r\n console.log(message);\r\n message.destinationName = \"HootKaSelf\/lobby\";\r\n mc.send(message);\r\n }\r\n<\/script>\r\n\r\n<\/body>\r\n<\/html><\/pre>\n\u5b89\u88dd\u3001\u9023\u63a5<\/h2>\n
<script src=\"https:\/\/cdn.jsdelivr.net\/npm\/paho-mqtt@1.0.3\/mqttws31-min.js\"><\/script>\r\n\r\n<script>\r\nmc = new Paho.MQTT.Client('broker.hivemq.com', 8884, 'mqtt_client_id');\r\nmc.connect({\r\n onSuccess: onConnect,\r\n useSSL: true,\r\n});\r\n\r\nfunction onConnect(){\r\n \/\/ \u9023\u63a5\u6210\u529f\u8a02\u95b1\u4e3b\u984c\r\n mc.subscribe(\"HootKaSelf\/lobby\", {\r\n onSuccess: function (){\r\n console.log('subscribeSuccess');\r\n },\r\n onFailure: function (){}\r\n });\r\n}\r\n<\/script><\/pre>\n\n
\u8a02\u95b1\u3001\u53d6\u6d88\u8a02\u95b1\u4e3b\u984c<\/h2>\n
mc.subscribe(\"HootKaSelf\/lobby\", {\r\n onSuccess: function (){\r\n console.log('subscribeSuccess');\r\n },\r\n onFailure: function (){}\r\n});<\/pre>\nmc.unsubscribe('HootKaSelf\/room\/' + j['room_id'], {\r\n onFailure: function () {},\r\n onSuccess: function () {\r\n console.log(\"subscribe success!\");\r\n }\r\n});<\/pre>\n\u50b3\u9001\u8a0a\u606f<\/h2>\n
let message = new Paho.MQTT.Message(JSON.stringify({\r\n command: \"start_game\",\r\n room_id: room_id,\r\n user_id: client_id,\r\n}));\r\nmessage.destinationName = \"HootKaSelf\/server\";\r\nmc.send(message);<\/pre>\n\u63a5\u6536\u8a0a\u606f<\/h2>\n
mc.onMessageArrived = function (message) {\r\n let json = JSON.parse(message.payloadString);\r\n}<\/pre>\n\n
AMQJS0005E Internal error.<\/h2>\n
\u7d50\u8ad6<\/h2>\n