{"id":144,"date":"2022-10-06T10:11:04","date_gmt":"2022-10-06T09:11:04","guid":{"rendered":"http:\/\/guillemrueda.com\/blog\/?p=144"},"modified":"2022-10-06T10:28:14","modified_gmt":"2022-10-06T09:28:14","slug":"mqtt-i-posar-en-marxa-un-servidor-mqtt","status":"publish","type":"post","link":"https:\/\/guillemrueda.com\/blog\/2022\/10\/06\/mqtt-i-posar-en-marxa-un-servidor-mqtt\/","title":{"rendered":"MQTT (I): Posar en marxa un servidor MQTT"},"content":{"rendered":"\n

Davant de varietat de servidors de MQTT triem per a l’exemple el Mosquitto.<\/p>\n\n\n\n

\n
\n

1.- Baixar Mosquitto https:\/\/mosquitto.org\/download<\/a><\/p>\n\n\n\n

2.- Anar a la carpeta d’instal\u00b7laci\u00f3 i buscar mosquitto.conf. En cas que no existeixi, crear-lo:<\/p>\n\n\n\n

3.- Posar la seg\u00fcent configuraci\u00f3: <\/p>\n<\/div><\/div>\n\n\n\n

\n
\n
listener 1883\nprotocol mqtt\nlistener 9001\nprotocol websockets\n## Authentication ##\nallow_anonymous true\n# password_file \/mosquitto\/conf\/mosquitto.conf<\/code><\/code><\/pre>\n<\/div><\/div>\n<\/div><\/div>\n<\/div><\/div>\n\n\n\n
4. Provar que funciona correctament arrancant-lo des CMD <\/p>\n\n\n\n
.\\mosquitto.exe -c .\\mosquitto.conf -v<\/code><\/pre>\n\n\n\n
\"\"<\/figure>\n\n\n\n
Per a comprovar la connexi\u00f3 i el estat del servidor de MQTT podem fer servir un client b\u00e0sic de MQTT fet amb HTML. Com per configuraci\u00f3 hem activat els websockets no ens far\u00e0 falta res m\u00e9s que executar aquesta p\u00e0gina des el navegador (les llibreries Javascript \u00e9s consulten a un CDN):<\/p>\n\n\n\n
\n<!DOCTYPE html>\n<html lang=\"en\" xmlns=\"http:\/\/www.w3.org\/1999\/xhtml\">\n<head>\n    <meta charset=\"utf-8\" \/>\n    <title>mqtt<\/title>\n    <script src=\"https:\/\/unpkg.com\/mqtt@4.0.1\/dist\/mqtt.min.js\"><\/script>\n    <script>\n        \/\/ An mqtt variable will be initialized globally\n        console.log(mqtt)\n    <\/script>\n<\/head>\n<body>\n\n    <script>\n        const options = {\n            \/\/ Clean session\n            clean: true,\n            connectTimeout: 4000,\n        }\n\n        const publishMessage = (event) => {\n            event.preventDefault();\n            let addr = document.getElementById('addrText').value;\n            let topic = document.getElementById('topicText').value;\n            let msg = document.getElementById('messageText').value;\n\n            const client = mqtt.connect(addr, options);\n\n            client.publish(topic, msg, { qos: 0, retain: false }, function (error) {\n                if (error) {\n                    console.log(error);\n                } else {\n                    console.log('Published');\n                }\n            })\n\n        }\n\n        const subscribeMessages = (event) => {\n            event.preventDefault();\n\n            let addr = document.getElementById('addrTextSub').value;\n            let topic = document.getElementById('topicTextSub').value;\n\n            const clientSub = mqtt.connect(addr, options);\n\n            clientSub.on('connect', function () {\n                console.log('Connected')\n                clientSub.subscribe(topic, function (err) {\n                    if (err) {\n                        console.log(error);\n                    } else {\n                        console.log('Subscribed');\n                    }\n                })\n            });\n\n            clientSub.on('message', function (topic, message) {\n                \/\/ message is Buffer\n                console.log();\n                var table = document.getElementById(\"messagesReceived\");\n                var row = table.insertRow();\n                var cell1 = row.insertCell(0);\n                var cell2 = row.insertCell(1);\n                cell1.innerHTML = new Date().toLocaleString();\n                cell2.innerHTML = message.toString();\n            });\n\n\n        }\n\n    <\/script>\n\n    <form onsubmit=\"return publishMessage(event)\">\n        <fieldset>\n            <legend>Send message<\/legend>\n            <label for=\"addrText\">Address:<\/label>\n            <input type=\"text\" id=\"addrText\" name=\"addrText\"><br><br>\n            <label for=\"topicText\">Topic:<\/label>\n            <input type=\"text\" id=\"topicText\" name=\"topicText\"><br><br>\n            <label for=\"messageText\">Message:<\/label>\n            <input type=\"text\" id=\"messageText\" name=\"messageText\"><br><br>\n            <input type=\"submit\" value=\"Submit\">\n        <\/fieldset>\n    <\/form>\n    <br><br>\n    <form onsubmit=\"return subscribeMessages(event)\">\n        <fieldset>\n            <legend>Subscribe<\/legend>\n            <label for=\"addrTextSub\">Address:<\/label>\n            <input type=\"text\" id=\"addrTextSub\" name=\"addrTextSub\"><br><br>\n            <label for=\"topicTextSub\">Topic:<\/label>\n            <input type=\"text\" id=\"topicTextSub\" name=\"topicTextSub\"><br><br>\n            <input type=\"submit\" value=\"Subscribe\">\n        <\/fieldset>\n    <\/form>\n    <br><br>\n    <table id=\"messagesReceived\">\n        <tr>\n            <th>\n                Timestamp\n            <\/th>\n            <th>\n                Message\n            <\/th>\n        <\/tr>\n    <\/table>\n<\/body>\n<\/html><\/code><\/pre>\n\n\n\n
Amb el codi anterior i els par\u00e0metres de connexi\u00f3 que al ser per web sockets haurem de especificar protocol (wb) i port a l’adre\u00e7a tal aix\u00ed: wb:\/\/localhost:9001. El resultat de enviar un missatge a la subscripci\u00f3 que triem hauria de ser aquesta:<\/p>\n\n\n\n
\"\"<\/figure>\n\n\n\n
5.- Feta la prova amb la configuraci\u00f3 parem el terminal, farem que sigui un servei i aix\u00ed no necessitem tenir una sessi\u00f3 activa. Per a fer-lo cal executar el mosquito.exe install<\/em>. En el cas que ja estigui instal\u00b7lat \u00e9s recomanable desinstal\u00b7lar-lo executant mosquito.exe uninstall<\/em> . Per a revisar el estat del servei ho podem fer des Control+Alt+Spr, pestanya Serveis i veure tots els serveis buscant el servei Mosquitto Broker:<\/p>\n\n\n\n
\"\"<\/figure>\n\n\n\n
Si el servei no funcion\u00e9s reviseu que a les variables de entorn el MOSQUITTO_DIR \u00e9s el de instal\u00b7laci\u00f3.<\/p>\n\n\n\n
Amb aix\u00f2 ja podem iniciar les proves de MQTT amb aquest i altres entorns, recordant que els seg\u00fcents passos amb el servidor haurien de ser dotar-lo de seguretat (autenticaci\u00f3 i encriptaci\u00f3 del canal).<\/p>\n","protected":false},"excerpt":{"rendered":"
Davant de varietat de servidors de MQTT triem per a l’exemple el Mosquitto. 1.- Baixar Mosquitto https:\/\/mosquitto.org\/download 2.- Anar a la carpeta d’instal\u00b7laci\u00f3 i buscar mosquitto.conf. En cas que no existeixi, crear-lo: 3.- Posar la seg\u00fcent configuraci\u00f3: 4. Provar que funciona correctament arrancant-lo des CMD Per a comprovar la connexi\u00f3 i el estat del servidor … Continua la lectura de MQTT (I): Posar en marxa un servidor MQTT<\/span><\/a><\/p>\n","protected":false},"author":2,"featured_media":0,"comment_status":"closed","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1,15,14,6],"tags":[],"class_list":["post-144","post","type-post","status-publish","format-standard","hentry","category-general","category-javascript","category-mqtt","category-programacio"],"_links":{"self":[{"href":"https:\/\/guillemrueda.com\/blog\/wp-json\/wp\/v2\/posts\/144","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/guillemrueda.com\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/guillemrueda.com\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/guillemrueda.com\/blog\/wp-json\/wp\/v2\/users\/2"}],"replies":[{"embeddable":true,"href":"https:\/\/guillemrueda.com\/blog\/wp-json\/wp\/v2\/comments?post=144"}],"version-history":[{"count":6,"href":"https:\/\/guillemrueda.com\/blog\/wp-json\/wp\/v2\/posts\/144\/revisions"}],"predecessor-version":[{"id":157,"href":"https:\/\/guillemrueda.com\/blog\/wp-json\/wp\/v2\/posts\/144\/revisions\/157"}],"wp:attachment":[{"href":"https:\/\/guillemrueda.com\/blog\/wp-json\/wp\/v2\/media?parent=144"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/guillemrueda.com\/blog\/wp-json\/wp\/v2\/categories?post=144"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/guillemrueda.com\/blog\/wp-json\/wp\/v2\/tags?post=144"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}