हाल ही में मुझे एक एपीआई से लाइव स्थान लाने के लिए एक वेब अनुप्रयोग में वेबसाकेट पर एमक्यूटीटी का उपयोग करना पड़ा। यहाँ मेरा समाधान है। मैंने MQTT मॉड्यूल को यथासंभव कार्यात्मक बनाने की कोशिश की।
एमक्यूटीटी सेवा मॉड्यूल
मैंने mqtt npm पैकेज का उपयोग किया है, जिसे आप इसके साथ स्थापित कर सकते हैं npm mqtt install स्थापित करें आदेश। यह मेरे द्वारा बनाया गया MQTT मॉड्यूल है:
import mqtt from 'mqtt'; const websocketUrl = 'wss://:443/mqtt'; const apiEndpoint = '/'; function getClient(errorHandler) { const client = mqtt.connect(websocketUrl); client.stream.on('error', (err) => { errorHandler(`Connection to ${websocketUrl} failed`); client.end(); }); return client; } function subscribe(client, topic, errorHandler) { const callBack = (err, granted) => { if (err) { errorHandler('Subscription request failed'); } }; return client.subscribe(apiEndpoint + topic, callBack); } function onMessage(client, callBack) { client.on('message', (topic, message, packet) => { callBack(JSON.parse(new TextDecoder('utf-8').decode(message))); }); } function unsubscribe(client, topic) { client.unsubscribe(apiEndpoint + topic); } function closeConnection(client) { client.end(); } const mqttService = { getClient, subscribe, onMessage, unsubscribe, closeConnection, }; export default mqttService; #प्रतिक्रिया #mqtt-ग्राहक #जावास्क्रिप्ट
levelup.gitconnected.com
एक प्रतिक्रिया ऐप में WebSocket पर MQTT
हाल ही में मुझे एक एपीआई से लाइव स्थान लाने के लिए एक वेब अनुप्रयोग में वेबसाकेट पर एमक्यूटीटी का उपयोग करना पड़ा। यहाँ मेरा समाधान है। मैंने MQTT मॉड्यूल को यथासंभव कार्यात्मक बनाने की कोशिश की। MQTT सेवा मॉड्यूल मैंने mqtt npm पैकेज का उपयोग किया है, जिसे आप npm install mqtt कमांड के साथ स्थापित कर सकते हैं। यह मेरे द्वारा बनाया गया MQTT मॉड्यूल है: